博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spring Boot----Dubbo
阅读量:5125 次
发布时间:2019-06-13

本文共 7524 字,大约阅读时间需要 25 分钟。

概述

治理和维护各个分系统

参考官网: (可中英文切换)

 

下载安装Zookeeper

linux

  使用docker部署

windows: 参考(),下载的zookeeper目录中需要包含lib(内置jar包,否则需要自己导入)

  1、将conf目录下的zoo_sample.cfg文件,复制粘贴一份,重命名为zoo.cfg

  2、创建data目录和log目录

  3、修改zoo.cfg 文件中的

dataDir=D:\Zookeeper\datadatalogDir=D:\Zookeeper\log

  4、启动 双击 zkServer.cmd

对zoo.cfg文件配置说明

  tickTime:这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个 tickTime 时间就会发送一个心跳。

  initLimit:这个配置项是用来配置 Zookeeper 接受客户端(这里所说的客户端不是用户连接 Zookeeper 服务器的客户端,而是 Zookeeper 服务器集群中连接到 Leader 的 Follower 服务器)初始化连接

时最长能忍受多少个心跳时间间隔数。当已经超过 10 个心跳的时间(也就是 tickTime)长度后 Zookeeper 服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。总的时间长度就是

10*2000=20 秒

  syncLimit:这个配置项标识 Leader 与 Follower 之间发送消息,请求和应答时间长度,最长不能超过多少个 tickTime 的时间长度,总的时间长度就是 5*2000=10 秒

  dataDir:顾名思义就是 Zookeeper 保存数据的目录,默认情况下,Zookeeper 将写数据的日志文件也保存在这个目录里。

  clientPort:这个端口就是客户端连接 Zookeeper 服务器的端口,Zookeeper 会监听这个端口,接受客户端的访问请求。

 

搭建Dubbo Admin

源码下载:(注意是master分支,dubbo admin好像在重构)

具体操作请看官方文档。

修改 dubbo-admin-master\dubbo-admin\src\main\resources\application.properties中的Zookeeper地cd dubbo-admin-master\dubbo-adminmvn clean package :将所有模块进行打包cd  targetjava -jar dubbo-admin-0.0.1-SNAPSHOT.jar

访问:localhost:7001  密码和用户名都是root

 

搭建Dubbo Monitor

在搭建dubbo admin是下载的文件夹中有一个dubbo-monitor-simple(一个建档的监控信息配置)

cd  dubbo-admin-master\dubbo-monitor-simplemvn clean packagecd target解压 dubbo-monitor-simple-2.0.0-assembly.tar.gz修改 \dubbo-monitor-simple-2.0.0\conf\dubbo.properties (修改zookeeper地址等)cd assembly.bin双击 start.bat

需要配置application.yml:参考  

使用是整个demo测试正常,但是monitor使用不成功,查看日志:java.lang.ClassNotFoundException: org.apache.dubbo.common.URL(未解决),后来查看日志没有报错了,但是还是不成功

 

 

1、Dubbo一些基本使用

注意问题:测试的时候,如果provider修改了,consumer服务器有时候也需要重启,不知道为什么?

1.1 Dubbo 启动配置的加载顺序

JVM -D参数 > xml > properties

参考:

1.2 超时,配置覆盖规则

参考: (不同粒度之间的覆盖关系)

1.3 Dubbo 启动时检测配置

参考;

dubbo 缺省配置:

1.4 重试次数

注意幂等请求可以设置重试,非幂等不能设置重试

参考:

1.5 关于xml

1.6 关于配置

可以使用dubbo.xml,application.properties,也可以使用注解@Service(version="xx",timeout=1)。。

1.7  多版本

一个 provider 接口被多个实现类实现

服务提供者实现多个版本的实现

@Service(version = "0.0.1")public class UserServiceImpl implements ProviderService{}

服务消费者指定版本

@Reference(version = "0.0.2")ProviderService providerService;

1.8 本地存根

1、对于consumer,需要调用providerService

@Reference(version = "0.0.2")ProviderService providerService;

2、我们需要在创建ProviderService接口的实现类

public class ProviderServiceStub implements ProviderService {    @Reference    ProviderService providerService;    //必须创建一个有参构造器    //providerService 传入的远程代理对象    public ProviderServiceStub(ProviderService providerService) {        this.providerService = providerService;    }    @Override    public String providerMethod() {        if (false){            System.out.println("true");            String s = providerService.providerMethod();            return s;        }        System.out.println("false");        return "空";    }}

3 修改 @Reference

@Reference(version = "0.0.2",stub = "com.zy.dubbo.service.Impl.ProviderServiceStub")ProviderService providerService;

xml的配置可以参考官方文档:

1.8 Dubbo的 @EnableDubbo的作用

主要目的就是进行包扫描的,扫描所有的 org.apache.dubbo.config.annotation.Service;

@EnableDubbo(scanBasePackages="com.zy.dubbo.service.Impl")可以指定具体的包扫描

1.9 springboot 使用xml配置dubbo

只需要使用 @ImportResource(value = {"classpath:provider.xml"}) 加载springboot启动类上,之前的所有的注解@Service,@EnableDubbo,@Reference,全部通过xml配置。

1.10 springboot 使用API配置dubbo

单单使用注解的方式,对于Dubbo:method 不方便操作。所以我们也可以采用使用注解加API结合的模式配合dubbo

官网文档:

如果配置了 public ServiceConfig<ProviderService> serviceConfig(ProviderService providerServiceImpl){},表示往注册中心注册了一个服务,所以不需要使用@EnableDubbo和@Service

以提供者配置为例

@Configurationpublic class DubboConfig {    @Bean    public ApplicationConfig applicationConfig(){        ApplicationConfig application = new ApplicationConfig();        application.setName("provider");        return application;    }    @Bean    public RegistryConfig registryConfig(){        RegistryConfig registryConfig = new RegistryConfig();        registryConfig.setAddress("zookeeper://localhost:2181");        return registryConfig;    }    @Bean    public MonitorConfig monitorConfig(){        MonitorConfig monitorConfig = new MonitorConfig();        monitorConfig.setProtocol("registry");        return monitorConfig;    }    //暴露单个服务,对于ProviderServiceImpl,spring会自动从容器中拿,(可以是实现类,也可以是接口,测试的时候,如果有多个接口实现类且加上@Component    // 会选择其中一个实现类,所以最好使用实现类)    //注解中的 @Service    @Bean    public ServiceConfig
serviceConfig(ProviderServiceImpl02 providerServiceImpl){ ServiceConfig
serviceConfig = new ServiceConfig<>(); serviceConfig.setInterface(ProviderService.class); serviceConfig.setRef(providerServiceImpl); serviceConfig.setVersion("0.0.3"); List
methods = new ArrayList
(); MethodConfig method = new MethodConfig(); method.setName("providerMethod"); method.setTimeout(3000); method.setRetries(0); methods.add(method); serviceConfig.setMethods(methods); serviceConfig.setApplication(applicationConfig()); serviceConfig.setRegistry(registryConfig()); serviceConfig.export(); return serviceConfig; };}

但是如果使用API配置额外需要使用注解往注册中心注册服务,我们就需要@EnableDubbo和@Service来注册服务了,此时我们注册中心就会有三个服务,并且版本0.0.3的providerMethod还设置了超时

@Service(version = "0.0.1")@Componentpublic class ProviderServiceImpl implements ProviderService {    @Override    public String  providerMethod(){        System.out.println("消费者提供服务成功");        return "0.0.1";    }}------------------------------------------------------------------@Service(version = "0.0.2")@Componentpublic class ProviderServiceImpl02 implements ProviderService {    @Override    public String  providerMethod() {        System.out.println("消费者提供服务成功2");        return "0.0.2";    }}

1.11 Dubbo 高可用

如果Zookeeper宕机了,如果服务之间之前访问过,会在本地创建缓存通讯,即使zookeeper宕机了,服务之间既然能够访问,原因在于dubbo可以直连

所以即使没有注册中心,服务之间依然可以相互通讯

可以测试

@Reference(url = "localhost:20881")

1.12 dubbo负载均衡

官方文档:

随机算法(基于权重) Random LoadBalance

轮询算法   RoundRobin LoadBalance

最少活跃数算法:LeastActive LoadBalance(每次调用服务器后在本地有对应的响应时间,下次调用选择一个最少调用时间的服务器,进行请求)

一致性hash算法:ConsistentHash LoadBalance(比如请求带了一个id=1,1进行hash算法获得一个值,通过这个值,来选择服务器进行请求)

dubbo默认基于随机(基于权重)负载均衡机制,

可以默认指定 @Service(version = "0.0.1",weight = 100)

可以动态的进行权重加减

 

 

 

1.13 服务降级和容错

一个服务器需要来处理需要的服务请求,有一些请求不是很重要重要,但是依然需要服务器耗费资源来处理请求,此时的其他请求处理就很慢,此时如果大量请求来调用一些重要服务,我们就需要关闭某些不重要的服务,来减少服务器压力。

我们可以屏蔽功能:屏蔽(恢复)消费者调用服务提供者,请求不会到达服务器,服务器不会处理请求,减少服务器压力

我们可以容错功能:请求会到提供者,当提供者处理请求出错了,直接返回null,消费者不抛出异常

1.14 集群容错模式

简单实用可以参考:

实际开发需要整合hystrix

使用方法1:(测试过程中会发生容错时而容错不起作用,发送大量请求,某几次依然会报错(后来发现在fallback方法中出现的错误))

1、在提供者配置

使用@HystrixCommand注解方法,并在启动类上加上注解 @EnableHystrix,但是实际测试过程过不需要这些配置

@HystrixCommand    @Override    public String  providerMethod(){        System.out.println("提供服务成功");        return "0.0.1";    }

2、消费者配置,并在启动类上加上@EnableHystrix

@HystrixCommand(fallbackMethod = "testfallback")    @Override    public String  test() {        String s = providerService.providerMethod();        return s;    }    public String  testfallback() {        System.out.println("testfallback");        return "错误了....";    }

使用方法2:(测试过程中正常)

消费者不用任何配置

提供者配置 @HystrixCommand,并在启动类上加上@EnableHystrix

@HystrixCommand(fallbackMethod = "providerMethodFallback")    @Override    public String  providerMethod() {        System.out.println("消费者提供服务成功2");        if(Math.random()>0.5){            System.out.println(">0.5");            int a = 1/0;        }        return "0.0.2";    }    public String  providerMethodFallback(){        System.out.println("提供者出错了....");        return "提供者出错了....";    }

  

 

转载于:https://www.cnblogs.com/yanxiaoge/p/11441010.html

你可能感兴趣的文章
js和layerjs配合实现的拖拽表格列
查看>>
Spring MVC集成slf4j-logback
查看>>
java常量池
查看>>
URL类
查看>>
flask(精讲)
查看>>
Java异常处理原则与技巧总结
查看>>
springboot快速入门
查看>>
wget 命令用法详解
查看>>
方法的重写
查看>>
自定义注解
查看>>
HashMap面试题
查看>>
why I need a flow learn note.
查看>>
ASP.NET WebForm中使用WebApi
查看>>
js学习总结----编写简单的ajax方法库
查看>>
js学习总结----柯里化函数
查看>>
Knozen:新型职场社交评论匿名应用,已获多家风投投资
查看>>
第三次个人赛题目2 【多项式输出格式】
查看>>
剑指offer 重建二叉树
查看>>
排序算法之冒泡排序
查看>>
so打包进APK
查看>>