dubbo系列--dubbo中的高级配置(一)

迷南。 2023-07-01 10:56 17阅读 0赞

在上一篇中我们介绍了dubbo中的概念以及框架的搭建，介绍了直连方式与注册中心方式两种方式注册服务。在本篇中，我们将基于注册中心的方式继续介绍dubbo中的高级配置。在本篇中我们依然主要主要关注服务提供者与服务消费者的配置文件，Java实现部分不作为重点。

### 多版本控制 ###

在实际工作过程中，我们的服务可能需要经常迭代，进行功能升级。在软件工程的开闭原则中，我们不能直接修改代码，使用新服务替换旧服务，我们无法保证新服务的100%可用，所以需要进行灰度发布(金丝雀发布)。在灰度发布中，我们就需要使用版本控制来使一部分消费者依然调用老服务，这时就需要应用到多版本控制。

在多版本控制中，服务提供者中使用version进行版本控制，新服务与旧服务使用不同的版本号，示例如下所示(为了便于读者学习，我们这里展示了整个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://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="04-provider-version"/>
    
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        <bean id="oldService" class="com.abc.provider.OldServiceImpl"/>
        <bean id="newService" class="com.abc.provider.NewServiceImpl"/>
    
        
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="oldService" version="0.0.1"/>
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="newService" version="0.0.2"/>
    
    </beans>

通过上面的示例我们可以看到，新老服务实现的接口(interface)是相同的，而暴露时引用的实现是不同的，同时对应的version也是不同的。服务消费者通过引用不同版本provider实现新老版本服务的调用。服务消费者配置文件如下所示。

<?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://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="04-consumer-version"/>
    
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        
        
    
        
        <dubbo:reference id="someService" version="0.0.2"
                         interface="com.abc.service.SomeService"/>
    
    </beans>

通过消费者配置文件，在<dubbo:reference>中指定要消费的版本即可。启动服务提供者完成服务注册，通过zookeeper客户端查看注册中心provider信息，具体信息如下所示。  
![版本控制注册zookeeper][zookeeper]  
从图中可以看到，zookeeper中的com.abc.service.SomeService提供者有0.0.1和0.0.2两个版本，可以证明在配置文件中声明的两个版本均已注册到注册中心。

### 服务分组 ###

在实际开发过程中，对于同一个interface可能会提供不同实现。比如支付接口，可以为微信支付，也可以为支付宝支付，此时就需要对服务进行分组。

注意：虽然对同一个interface存在不同的实现，但是并不存在服务之间的替代关系，只是服务实现不同，需要与上面
         介绍的version区分开来。

在服务分组中，通过group来指定分组信息。以支付接口为例，实现为支付宝服务和微信服务，服务提供者配置文件如下所示。

<?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://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="05-provider-group"/>
    
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        <bean id="weixinService" class="com.abc.provider.WeixinServiceImpl"/>
        <bean id="zhifubaoService" class="com.abc.provider.ZhifubaoServiceImpl"/>
    
        
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="weixinService" group="pay.weixin"/>
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="zhifubaoService" group="pay.zhifubao"/>
    </beans>

可以看到实例化bean时，初始化了支付宝服务和微信服务两个实现，在暴露服务时通过group来区分不同的服务。下面附上两种实现的Java代码。

public class WeixinServiceImpl implements SomeService {
        @Override
        public String hello(String name) {
            System.out.println("使用【微信】付款");
            return "WeixinServiceImpl";
        }
    }
    
    public class ZhifubaoServiceImpl implements SomeService {
        @Override
        public String hello(String name) {
            System.out.println("使用【支付宝】付款");
            return "ZhifubaoServiceImpl";
        }
    }

启动服务提供者服务，通过zookeeper客户端查看支付宝服务和微信服务已注册到注册中心中，详情如下所示。  
![服务分组注册zookeeper][zookeeper 1]  
下面来看服务消费者如何通过group来消费服务，配置文件如下所示。

从配置文件中看到，服务消费者同时消费了支付宝服务和微信服务，通过group来区分不同的服务。服务消费者实现如下所示。

public class ConsumerRun {
        public static void main(String[] args) {
            ApplicationContext ac = new ClassPathXmlApplicationContext("spring-consumer.xml");
    
            // 使用微信支付
            SomeService weixinService = (SomeService) ac.getBean("weixin");
            String weixin = weixinService.hello("China");
            System.out.println(weixin);
    
            // 使用支付宝支付
            SomeService zhifubaoService = (SomeService) ac.getBean("zhifubao");
            String zhifubao = zhifubaoService.hello("China");
            System.out.println(zhifubao);
        }
    }

### 多协议支持 ###

#### 服务暴露协议 ####

在前面的演示中，服务提供者与服务消费者都是通过zookeeper连接协议连接到zookeeper注册中心。这里的zookeeper协议，是消费者/提供者连接注册中心的连接协议，而不是消费者与提供者之间的链接协议。

当消费者连接上注册中心后，在消费服务之前，需要连接上这个服务提供者。虽然消费者可以通过注册中心获取到服务提供者，但是服务提供者对服务消费者来说是透明的，消费者并不知道真正的服务提供者是谁。不过，无论提供者是谁，消费者都必须连接上提供者才可以获取真正的服务，而这个连接也有专门的连接协议，即服务暴露协议。

在dubbo中，默认的服务暴露协议为dubbo服务暴露协议，除了默认的协议，dubbo还支持8中服务暴露协议：RMI协议、Hessian协议、HTTP协议、WebService协议、Thrift协议、Memcached协议、Redis协议、Rest协议。在实际生产环境中使用最多的为Dubbo服务暴露协议。

#### 各个协议的特点 ####

##### dubbo协议 #####

*  dubbo协议是默认的服务暴露协议
 *  连接方式：长连接
 *  连接个数：単连接
 *  传输协议：TCP
 *  传输方式：NIO异步传输
 *  适用范围：传入传出参数数据包较小(100K)，消费者的数量比提供者多，单一消费者无法压满提供者，尽量不要使用dubbo协议传输大文件或者超大字符串。

##### RMI协议 #####

*  采用JDK标准的java.rmi.\*实现
 *  连接方式：短连接
 *  连接个数：多连接
 *  传输协议：TCP
 *  传输方式：BIO同步传输
 *  适用范围：传入传出参数数据包大小混合，消费者与提供者数量差不多，可以传输文件。

##### Hessian协议 #####

*  连接方式：短连接
 *  连接个数：多连接
 *  传输协议：HTTP
 *  传输方式：BIO同步传输
 *  适用范围：传入传出参数数据包较大，提供者的数量比消费者多，提供者抗压能力较大。

##### HTTP协议 #####

*  连接方式：短连接
 *  连接个数：多连接
 *  传输协议：HTTP
 *  传输方式：BIO同步传输
 *  适用范围：传入传出参数数据包大小混合，提供者比消费者个数多，支持浏览器查看，可用表单或URL传递参数，暂时不支持传输文件。

##### WebService协议 #####

*  连接方式：短连接
 *  连接个数：多连接
 *  传输协议：HTTP
 *  传输方式：BIO同步传输
 *  适用范围：系统集成，支持跨语言之间的调用。

##### Thrift协议 #####

目前dubbo支持的thrift协议是基于原生thrift协议的扩展，thrift协议暂不支持null值的传递。

##### memcached协议与redis协议 #####

二者都是高效的key-value缓存服务，会对传输的数据进行缓存。

##### rest协议 #####

如果需要开发具有restful风格的服务，需要使用该协议。

#### 多协议的使用 ####

上面介绍了dubbo中的服务暴露协议，在dubbo中多协议的使用方法有两种：第一种是同一个服务支持多种协议，第二种是不同的服务使用不同的协议。

消费者如果需要连接当前的服务，就需要通过这里指定的协议以及端口号访问提供者。这里的端口号可以使任意的，不一定适用默认的端口号(dubbo默认的端口号为20880，rmi默认的端口号是1099)。指定的协议名称以及端口号，在当前服务注册到注册中心时会一并写入到服务映射表中，当消费者根据服务名称查找对应的主机时，会同时查询出消费此服务的协议、端口号等信息。其底层是一个socket变成，通过主机名与端口号进行连接。

##### 同一服务支持多种协议 #####

对于一个服务，可能需要通过多个协议进行暴露，则在<dubbo:service>中指定协议名称。若不指定，则默认为dubbo协议。在配置文件中声明多个协议，配置文件如下所示。

<?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://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="04-provider-version"/>
    
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        <dubbo:protocol name="dubbo" port="20880"/>
        <dubbo:protocol name="rmi" port="1099"/>
    
        
        <bean id="oldService" class="com.abc.provider.OldServiceImpl"/>
        <bean id="newService" class="com.abc.provider.NewServiceImpl"/>
    
        
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="oldService" version="0.0.1"/>
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="newService" version="0.0.2" protocol="dubbo,rmi"/>
    
    </beans>

在配置文件中使用<dubbo:protocol>指定暴露协议，在<dubbo:service>中使用protocol属性来指定当前暴露服务所使用的暴露协议，如不指定，则使用默认暴露协议。启动服务提供者，我们从debug日志中可以看到以下信息，可以发现服务通过我们指定的dubbo和rmi协议进行暴露。

[INFO ]  [DUBBO] Register: dubbo://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Subscribe: provider://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Notify urls for subscribe url provider://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1, urls: [empty://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138
    [DEBUG]  [DUBBO] original override urls: [empty://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138
    [DEBUG]  [DUBBO] subscribe url: provider://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1, override urls: [empty://10.2.62.138:20880/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=20880&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160200293&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Export dubbo service com.abc.service.SomeService to local registry, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Export dubbo service com.abc.service.SomeService to url rmi://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Register dubbo service com.abc.service.SomeService url rmi://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1 to registry registry://localhost:2181/org.apache.dubbo.registry.RegistryService?application=04-provider-version&dubbo=2.0.2&pid=11944&registry=zookeeper&release=2.7.0&timestamp=1579160195285, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Register: rmi://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Subscribe: provider://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1, dubbo version: 2.7.0, current host: 10.2.62.138
    [INFO ]  [DUBBO] Notify urls for subscribe url provider://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1, urls: [empty://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138
    [DEBUG]  [DUBBO] original override urls: [empty://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138
    [DEBUG]  [DUBBO] subscribe url: provider://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1, override urls: [empty://10.2.62.138:1099/com.abc.service.SomeService?anyhost=true&application=04-provider-version&bean.name=com.abc.service.SomeService&bind.ip=10.2.62.138&bind.port=1099&category=configurators&check=false&dubbo=2.0.2&generic=false&interface=com.abc.service.SomeService&methods=hello&pid=11944&release=2.7.0&revision=0.0.1&side=provider&timestamp=1579160210738&version=0.0.1], dubbo version: 2.7.0, current host: 10.2.62.138

在消费者端的<dubbo:reference>中也可以指定所使用的协议。

##### 不同服务使用不同协议 #####

对于不同的服务，可能在不同的暴露协议下表现的性能不一致，所以对于不同的服务可能需要不同的暴露协议，配置文件如下所示。

<dubbo:service interface="com.abc.service.SomeService"
                       ref="oldService" version="0.0.1" protocol="dubbo"/>
        <dubbo:service interface="com.abc.service.SomeService"
                       ref="newService" version="0.0.2" protocol="rmi"/>

### 小节 ###

本篇介绍了dubbo中的常见高级配置，很多在生产环境中使用频繁，希望对初学者有一定的帮助。其余的高级配置，将在下一篇中继续为大家介绍。

[zookeeper]: https://img-blog.csdnimg.cn/20200121141430351.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3MTM1NDIx,size_16,color_FFFFFF,t_70
[zookeeper 1]: https://img-blog.csdnimg.cn/20200121141520128.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM3MTM1NDIx,size_16,color_FFFFFF,t_70