dubbo-常用配置

Posted 2021-01-19 我俩绝配

一、启动时检查

官网说明：

Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题，默认 check="true"。

可以通过 check="false" 关闭检查，比如，测试时，有些服务不关心，或者出现了循环依赖，必须有一方先启动。

另外，如果你的 Spring 容器是懒加载的，或者通过 API 编程延迟引用服务，请关闭 check，否则服务临时不可用时，会抛出异常，拿到 null 引用，如果 check="false"，总是会返回引用，当服务恢复时，能自动连上。

在消费者一方的 dubbo-consumer.xml 配置里：

<!--生成远程服务代理，可以和本地bean一样使用demoService
     ***** 启动时检查：
     check="true"，Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题，默认 check="true"
    -->
    <dubbo:reference id="userFacade" interface="com.lhy.service.user.UserFacade" check="true" />

只启动消费者，不启动生产者

会报如下的错：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name \'userController\': 
Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: 
Could not autowire field: private com.lhy.service.user.UserFacade com.lhy.consumer.controller.UserController.userFacade; 
nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name \'userFacade\': 
FactoryBean threw exception on object creation; nested exception is java.lang.IllegalStateException: 
Failed to check the status of the service com.lhy.service.user.UserFacade. 
No provider available for the service com.lhy.service.user.UserFacade 
from the url zookeeper://192.168.85.3:2181/com.alibaba.dubbo.registry.RegistryService?application=lhy-consumer&check=true&dubbo=2.5.4&interface=com.lhy.service.user.UserFacade&methods=getById,getUsers,addUser&pid=13664&revision=1.0&side=consumer&timestamp=1541645721420 to the consumer 192.168.0.105 use dubbo version 2.5.4

设置  check="fase" 则可以正常启动消费者，在调用该服务的时候，则会报错

二、集群容错

当服务提供者部署到多个机器的时候，此时可以配置集群容错，一般配置为Failover （缺省配置） 或者Failfast 即可。可以配置到提供者上，也可以配置到消费者上

<!-- 声明需要暴露的服务接口 ,写操作可设置retries="0"避免重复调用SOA服务
         集群容错：
         cluster="failover"：失败自动切换，当出现失败，重试其它服务器 [1]。通常用于读操作，但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)。
         cluster="failfast" :快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。
         cluster="failsafe" :失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。
         cluster="failback":失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
         cluster="forking":广播调用所有提供者，逐个调用，任意一台报错则报错 。通常用于通知所有提供者更新缓存或日志等本地资源信息。
         一般配置为failover，重试0次/或者failfast
    -->
    <dubbo:service retries="0" interface="com.lhy.service.user.UserFacade" ref="userFacade" cluster="failover"/>

 三、负载均衡

dubbo的负载均衡可以通过xml配置，也可以在dubbo-admin管控台动态配置。一般使用管控台配置，更加灵活。

一般配置为随机模式

管控台配置负载均衡，可以对每个服务的每个方法设置负载均衡策略。（但是管控台的策略 没有一致性hash）

xml配置，可以配在提供者，也可以配置在消费者：

<dubbo:service"interface="...""loadbalance="roundrobin""/>
或者
<dubbo:reference"interface="...""loadbalance="roundrobin""/>

 四、直连提供者

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

通过 XML 配置（消费者）

<dubbo:reference id="accountFacade" interface="com.lhy.service.user.AccountFacade" url="dubbo://localhost:20880" />

五、只订阅

官方解释：为方便开发测试，经常会在线下共用一个所有服务可用的注册中心，这时，如果一个正在开发中的服务提供者注册，可能会影响消费者不能正常运行。

可以让服务提供者开发方，只订阅服务(开发的服务可能依赖其它服务)，而不注册正在开发的服务，通过直连测试正在开发的服务。

 

只订阅 provider.xml配置：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">


    <!--提供方应用信息，用户计算依赖关系-->
    <dubbo:application name="lhy-service"/>

    <!--使用zookeeper注册中心暴露服务地址-->
    <!--只订阅，不注册： register="false"
    开发阶段，只订阅zk中已有的服务(开发中的服务可能用到)，而不向zk注册服务，配合直连使用，此时消费者通过直连来调用
    -->
    <dubbo:registry address="zookeeper://192.168.85.3:2181?backup=192.168.85.4:2181,192.168.85.5:2181" register="false"/>
    <!--<dubbo:registry"protocol="zookeeper""address="10.20.153.10:2181,10.20.153.11:2181,10.20.153.12:2181""/>-->

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <!-- 声明需要暴露的服务接口 ,写操作可设置retries="0"避免重复调用SOA服务
         集群容错：
         cluster="failover"：失败自动切换，当出现失败，重试其它服务器 [1]。通常用于读操作，但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)。
         cluster="failfast" :快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。
         cluster="failsafe" :失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。
         cluster="failback":失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
         cluster="forking":广播调用所有提供者，逐个调用，任意一台报错则报错 。通常用于通知所有提供者更新缓存或日志等本地资源信息。
         一般配置为failover，重试0次/或者failfast
    -->
    <dubbo:service retries="0" interface="com.lhy.service.user.UserFacade" ref="userFacade" cluster="failover"/>

    <dubbo:service retries="0" interface="com.lhy.service.user.ProductFacade" ref="productFacade" cluster="failover"/>

    <dubbo:service retries="0" interface="com.lhy.service.user.AccountFacade" ref="accountFacade" cluster="failover"/>


</beans>

消费者一方，consumer.xml ，通过直连来访问：

 <dubbo:reference id="accountFacade" interface="com.lhy.service.user.AccountFacade" url="dubbo://localhost:20880" />

说白了就是，开发测试阶段，不让服务提供方往注册中心注册，但是能从注册中心订阅已有的服务（如果正开发的服务依赖某个服务的话，可以调用）。如果配置了只订阅，那么本 provider中所有的服务，只能通过 直连来访问。

 

欢迎关注个人公众号一起交流学习：