概述
治理和维护各个分系统
参考官网: (可中英文切换)
下载安装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 ServiceConfigserviceConfig(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 "提供者出错了...."; }