dubbo的应用场景与高级特性之高级用法篇腾讯云开发者社区

关闭某个服务的启动时检查(没有提供者时报错)：

关闭所有服务的启动时检查(没有提供者时报错)：

关闭注册中心启动时检查(注册订阅失败时报错)：

通过dubbo.properties

dubbo.reference.com.foo.BarService.check=falsedubbo.consumer.check=falsedubbo.registry.check=false通过-D参数

java-Ddubbo.reference.com.foo.BarService.check=falsejava-Ddubbo.consumer.check=falsejava-Ddubbo.registry.check=false6.2直连提供者Dubbo中点对点的直连方式

在开发及测试环境下，经常需要绕过注册中心，只测试指定服务提供者，这时候可能需要点对点直连，点对点直连方式，将以服务接口为单位，忽略注册中心的提供者列表，A接口配置点对点，不影响B接口从注册中心获取列表。

配置：

6.3集群容错集群调用失败时，Dubbo提供的容错方案

在集群调用失败时，Dubbo提供了多种容错方案，缺省为failover重试。

各节点关系：

FailoverCluster

失败自动切换，当出现失败，重试其它服务器。通常用于读操作，但重试会带来更长延迟。可通过retries="2"来设置重试次数(不含第一次)。该配置为缺省配置

FailfastCluster

快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。

FailsafeCluster

失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。

FailbackCluster

失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。

ForkingCluster

并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过forks="2"来设置最大并行数。

BroadcastCluster

广播调用所有提供者，逐个调用，任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

AvailableCluster

调用目前可用的实例（只调用一个），如果当前没有可用的实例，则抛出异常。通常用于不需要负载均衡的场景。

@reference(cluster="broadcast",parameters={"broadcast.fail.percent","20"})6.4负载均衡Dubbo提供的集群负载均衡策略

在集群负载均衡时，Dubbo提供了多种均衡策略，缺省为random随机调用。

具体实现上，Dubbo提供的是客户端负载均衡，即由Consumer通过负载均衡算法得出需要将请求提交到哪个Provider实例。

负载均衡策略

目前Dubbo内置了如下负载均衡算法，用户可直接配置使用：

算法

特性

备注

RandomLoadBalance

加权随机

默认算法，默认权重相同

RoundRobinLoadBalance

加权轮询

借鉴于Nginx的平滑加权轮询算法，默认权重相同

LeastActiveLoadBalance

最少活跃优先+加权随机

背后是能者多劳的思想，最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差;使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。

ShortestResponseLoadBalance

最短响应优先+加权随机

ConsistentHashLoadBalance

一致性Hash

一致性Hash，相同参数的请求总是发到同一提供者。当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动。

6.5服务分组使用服务分组区分服务接口的不同实现

当一个接口有多种实现时，可以用group区分。

服务端

@DubboService(group="groupImpl1")publicclassGroupImpl1implementsGroup{@OverridepublicStringdoSomething(Strings){System.out.println("===========GroupImpl1.doSomething");return"GroupImpl1.doSomething";}}代码语言：javascript复制@DubboService(group="groupImpl2")publicclassGroupImpl2implementsGroup{@OverridepublicStringdoSomething(Strings){System.out.println("===========GroupImpl2.doSomething");return"GroupImpl2.doSomething";}}消费端

@DubboReference(check=false,group="groupImpl1"/*,parameters={"merger","true"}*/)Groupgroup;6.6分组聚合通过分组对结果进行聚合并返回聚合后的结果

通过分组对结果进行聚合并返回聚合后的结果，比如菜单服务，用group区分同一接口的多种实现，现在消费方需从每种group中调用一次并返回结果，对结果进行合并之后返回，这样就可以实现聚合菜单项。

生产者配置：

@DubboService(group="groupImpl1")publicclassGroupImpl1implementsGroup{@OverridepublicStringdoSomething(Strings){System.out.println("===========GroupImpl1.doSomething");return"GroupImpl1.doSomething";}}@DubboService(group="groupImpl2")publicclassGroupImpl2implementsGroup{@OverridepublicStringdoSomething(Strings){System.out.println("===========GroupImpl2.doSomething");return"GroupImpl2.doSomething";}}消费者配置：

@DubboReference(check=false,group="*",parameters={"merger","true"})Groupgroup;SPI文件配置在resources下创建META-INF文件夹并在其下面创建dubbo文件夹，然后在dubbo文件夹下面创建org.apache.dubbo.rpc.cluster.Merger文件，在该文件下写好Merger的实现类，如：

publicclassStringMergerimplementsMerger{//定义了所有group实现类的返回值的合并规则@OverridepublicStringmerge(String...strings){if(strings.length==0){returnnull;}StringBuilderbuilder=newStringBuilder();for(Stringstring:strings){if(string!=null){builder.append(string).append("-");}}returnbuilder.toString();}}6.7多版本在Dubbo中为同一个服务配置多个版本

当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。

可以按照以下的步骤进行版本迁移：

@DubboService(version="1.0.0")publicclassVersionServiceImplimplementsVersionService{@OverridepublicStringversion(Strings){System.out.println("========VersionServiceImpl.1.0.0");return"========VersionServiceImpl.1.0.0";}}@DubboService(version="1.0.1")publicclassVersionServiceImpl1implementsVersionService{@OverridepublicStringversion(Strings){System.out.println("========VersionServiceImpl1.1.0.1");return"========VersionServiceImpl1.1.0.1";}}消费者配置：

@DubboReference(check=false,version="1.0.0")VersionServiceversionService;6.8参数验证在Dubbo中进行参数验证

Maven依赖

javax.validationvalidation-api1.0.0.GAorg.hibernatehibernate-validator4.2.0.Final参数验证类：

publicclassValidationParamterimplementsSerializable{privatestaticfinallongserialVersionUID=32544321432L;@NotNull@Size(min=2,max=20)privateStringname;@Min(18L)@Max(100L)privateintage;@PastprivateDateloginDate;@FutureprivateDateexpiryDate;}生产者：

@DubboServicepublicclassValidationServiceImplimplementsValidationService{@Overridepublicvoidsave(ValidationParamtervalidationParamter){System.out.println("========ValidationServiceImpl.save");}@Overridepublicvoidupdate(ValidationParamtervalidationParamter){System.out.println("========ValidationServiceImpl.update");}@Overridepublicvoiddelete(longl,Strings){System.out.println("========ValidationServiceImpl.delete");}}消费者：

@DubboReference(check=false,validation="true")ValidationServicevalidationService;@Testpublicvoidvalidation(){ValidationParamterparamter=newValidationParamter();paramter.setName("Jack");paramter.setAge(98);paramter.setLoginDate(newDate(System.currentTimeMillis()-10000000));paramter.setExpiryDate(newDate(System.currentTimeMillis()+10000000));validationService.save(paramter);}6.9使用泛化调用选讲做测试的，没有使用场景

实现一个通用的服务测试框架，可通过GenericService调用所有服务实现

泛化接口调用方式主要用于客户端没有API接口及模型类元的情况，参数及返回值中的所有POJO均用Map表示，通常用于框架集成，比如：实现一个通用的服务测试框架，可通过GenericService调用所有服务实现。

消费者：

@Testpublicvoidusegeneric(){ApplicationConfigapplicationConfig=newApplicationConfig();applicationConfig.setName("dubbo_consumer");RegistryConfigregistryConfig=newRegistryConfig();registryConfig.setAddress("zookeeper://192.168.67.139:2184");ReferenceConfigreferenceConfig=newReferenceConfig<>();referenceConfig.setApplication(applicationConfig);referenceConfig.setInterface("com.xiangxue.jack.service.UserService");//这个是使用泛化调用referenceConfig.setGeneric(true);GenericServicegenericService=referenceConfig.get();Objectresult=genericService.$invoke("queryUser",newString[]{"java.lang.String"},newObject[]{"Jack"});System.out.println(result);}6.10参数回调通过参数回调从服务器端调用客户端逻辑

服务接口示例：

publicinterfaceCallbackService{voidaddListener(Stringvar1,CallbackListenervar2);}CallbackListener.java

publicinterfaceCallbackListener{voidchanged(Stringmsg);}生产者：

@DubboService(methods={@Method(name="addListener",arguments={@Argument(index=1,callback=true)})})publicclassCallbackServiceImplimplementsCallbackService{@OverridepublicvoidaddListener(Strings,CallbackListenercallbackListener){//这里就是回调客户端的方法callbackListener.changed(getChanged(s));}privateStringgetChanged(Stringkey){return"Changed:"+newSimpleDateFormat("yyyy-MM-dd:mm:ss").format(newDate());}}消费者：

@DubboReference(check=false)CallbackServicecallbackService;callbackService.addListener("jack",newCallbackListener(){publicvoidchanged(Stringarg0){System.out.println("=====================callbackresult:"+arg0);}});6.11本地存根在Dubbo中利用本地存根在客户端执行部分逻辑

远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑，比如：做ThreadLocal缓存，提前验证参数，调用失败后伪造容错数据等等，此时就需要在API中带上Stub，客户端生成Proxy实例，会把Proxy通过构造函数传给Stub1，然后把Stub暴露给用户，Stub可以决定要不要去调Proxy。

生产者：

@DubboServicepublicclassStubServiceImplimplementsStubService{@OverridepublicStringstub(Strings){System.out.println("==========本地存根业务逻辑=========");returns;}}消费者：

@DubboReference(check=false,stub="cn.enjoy.stub.LocalStubProxy")StubServicestubService;@Testpublicvoidstub(){System.out.println(stubService.stub("jingtian"));}代理层：

如何在Dubbo中利用本地伪装实现服务降级

生成者：

@DubboServicepublicclassMockServiceImplimplementsMockService{@OverridepublicStringmock(Strings){System.out.println("=======mockservice的业务处理=======");try{Thread.sleep(1000000);}catch(InterruptedExceptione){e.printStackTrace();}System.out.println("=======mockservice的业务处理完成=======");return"MockServiceImpl.mock";}@OverridepublicStringqueryArea(Strings){returns;}@OverridepublicStringqueryUser(Strings){returns;}}消费者：

//这两种方式会走rpc远程调用fail--会走远程服务@DubboReference(check=false,mock="true")//@DubboReference(check=false,mock="cn.enjoy.mock.LocalMockService")//不走服务直接降级force--是不会走远程服务的，强制降级..这种方式是用dubbo-admin去配置它，服务治理的方式//@DubboReference(check=false,mock="force:returnjack")MockServicemockService;@Testpublicvoidmock(){System.out.println(mockService.mock("wy"));}代码语言：javascript复制/**MockServiceMock**1、接口名+"Mock"*2、mock逻辑必须定义在接口的包下面*/publicclassMockServiceMockimplementsMockService{@OverridepublicStringmock(Strings){System.out.println(this.getClass().getName()+"--mock");returns;}@OverridepublicStringqueryArea(Strings){System.out.println(this.getClass().getName()+"--queryArea");returns;}@OverridepublicStringqueryUser(Strings){System.out.println(this.getClass().getName()+"--queryUser");returns;}}6.13异步调用在Dubbo中发起异步调用

从2.7.0开始，Dubbo的所有异步编程接口开始以CompletableFuture为基础

基于NIO的非阻塞实现并行调用，客户端不需要启动多线程即可完成并行调用多个远程服务，相对多线程开销较小。

代码案例

publicinterfaceAsyncService{StringasynctoDo(Stringvar1);}@DubboServicepublicclassAsyncServiceImplimplementsAsyncService{@OverridepublicStringasynctoDo(Strings){for(inti=0;i<10;i++){System.out.println("===============AsyncServiceImpl.asynctoDo");try{Thread.sleep(100);}catch(InterruptedExceptione){//TODOAuto-generatedcatchblocke.printStackTrace();}}return"hello,"+s;}}消费者：

@DubboReference(check=false,timeout=1000000000,methods={@Method(name="asynctoDo",async=true)})AsyncServiceasyncService;@Testpublicvoidasync()throwsInterruptedException{Stringaa=asyncService.asynctoDo("aa");System.out.println("main=="+aa);System.out.println("并行调用其他接口====");try{Thread.sleep(2000);}catch(InterruptedExceptione){e.printStackTrace();}//需要拿到异步调用的返回结果CompletableFuture