dubbo整合spring基础配置和协议对比

比眉伴天荒 2022-05-13 23:17 155阅读 0赞

# **dubbo协议对比** #

<table> 协议特性对比 
 <tbody> 
 <tr> 
 <td style="width:85px;"> 协议 </td> 
 <td style="width:82px;"> 连接个数 </td> 
 <td style="width:73px;"> 连接方式 </td> 
 <td style="width:75px;"> 传输协议 </td> 
 <td style="width:79px;"> 传输方式 </td> 
 <td style="width:104px;"> 序列化 </td> 
 <td style="width:235px;"> 适用范围 </td> 
 <td>适用场景</td> 
 </tr> 
 <tr> 
 <td style="width:85px;"> dubbo(默认) </td> 
 <td style="width:82px;"> 单连接 </td> 
 <td style="width:73px;"> 长连接 </td> 
 <td style="width:75px;"> TCP </td> 
 <td style="width:79px;"> NIO 异步传输 </td> 
 <td style="width:104px;"> Hessian 二进制 </td> 
 <td style="width:235px;"> 传入传出参数数据包较小（建议小于100K），消费者比提供者个数多，单一消费者无法压满提供者，尽量不要用 dubbo 协议传输大文件或超大字符串。 </td> 
 <td>常规远程服务方法调用</td> 
 </tr> 
 <tr> 
 <td style="width:85px;"> rmi </td> 
 <td style="width:82px;"> 多连接 </td> 
 <td style="width:73px;"> 短连接 </td> 
 <td style="width:75px;"> TCP </td> 
 <td style="width:79px;"> 同步传输 </td> 
 <td style="width:104px;"> Java 标准二进制序列化 </td> 
 <td style="width:235px;">传入传出参数数据包大小混合，消费者与提供者个数差不多，可传文件。</td> 
 <td>常规远程服务方法调用，与原生RMI服务互操作</td> 
 </tr> 
 <tr> 
 <td style="width:85px;"> hessian </td> 
 <td style="width:82px;"> 多连接 </td> 
 <td style="width:73px;"> 短连接 </td> 
 <td style="width:75px;"> HTTP </td> 
 <td style="width:79px;"> 同步传输 </td> 
 <td style="width:104px;"> Hessian二进制序列化 </td> 
 <td style="width:235px;"> 传入传出参数数据包较大，提供者比消费者个数多，提供者压力较大，可传文件。 </td> 
 <td>页面传输，文件传输，或与原生hessian服务互操作</td> 
 </tr> 
 <tr> 
 <td style="width:85px;"> http </td> 
 <td style="width:82px;"> 多连接 </td> 
 <td style="width:73px;"> 短连接 </td> 
 <td style="width:75px;"> HTTP </td> 
 <td style="width:79px;"> 同步传输 </td> 
 <td style="width:104px;"> 表单序列化 </td> 
 <td style="width:235px;"> 传入传出参数数据包大小混合，提供者比消费者个数多，可用浏览器查看，可用表单或URL传入参数，暂不支持传文件。 </td> 
 <td>需同时给应用程序和浏览器 JS 使用的服务。</td> 
 </tr> 
 <tr> 
 <td style="width:85px;"> WebService </td> 
 <td style="width:82px;"> 多连接 </td> 
 <td style="width:73px;"> 短连接 </td> 
 <td style="width:75px;"> HTTP </td> 
 <td style="width:79px;"> 同步传输 </td> 
 <td style="width:104px;"> SOAP 文本序列化 </td> 
 <td style="width:235px;"> &nbsp; </td> 
 <td>系统集成，跨语言调用</td> 
 </tr> 
 </tbody> 
</table>

其他协议还有trifit,memcached,redis,rest，trifit是基于thrift协议的扩展，memcached是基于memcached实现rpc,redis也一样，rest是基于JAX-RS 2.0实现rest风格调用,使用http传输协议。

# 搭建基础配置 #

### *1.公共配置  (三种配置方式)* ###

***（1）整合spring通过tomcat启动如下配置***

<?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.xsd 
 http://code.alibabatech.com/schema/dubbo 
 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
 <dubbo:application name="" />
 
 <dubbo:registry address="zookeeper://host:port" />
 
 <dubbo:protocol name="dubbo" port="20880" />
 
 </beans>

***（2）整合spring通过dubbo的main方法启动则在classpath下新增一个dubbo.properties文件，配置如下***

# 指定容器 
    dubbo.container=spring
    # 指定容器名
    dubbo.application.name=
    # 指定日志类型
    dubbo.application.logger=slf4j
    # 指定注册中心地址
    dubbo.registry.address=zookeeper://127.0.0.1:2181
    # 指定端口
    dubbo.protocol.port=28030
    # 指定提供服务的超时时间
    dubbo.provider.timeout=3000
    # 指定配置文件位置
    dubbo.spring.config=classpath:*.xml

***（3）整合springboot的配置方式  如上新建一个dubbo.properties，main方法上使用@PropertySource引入该配置***

*新建一个配置类，注入spring容器*

import com.alibaba.dubbo.config.ApplicationConfig;
    import com.alibaba.dubbo.config.ConsumerConfig;
    import com.alibaba.dubbo.config.ProtocolConfig;
    import com.alibaba.dubbo.config.RegistryConfig;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class DubboConfig {
    
    	@Value("${dubbo.application.name}")
        private String applicationName;
    	
    	@Value("${dubbo.registry.address}")
        private String registryAddress;
    	
    	@Value("${dubbo.protocol.port}")
    	private int port;
    	
        @Bean
        public ApplicationConfig applicationConfig() {
            ApplicationConfig applicationConfig = new ApplicationConfig();
            applicationConfig.setName(appName);
            return applicationConfig;
        }
        
        @Bean
        public RegistryConfig registryConfig() {
            RegistryConfig registryConfig = new RegistryConfig();
            registryConfig.setAddress(registryAddress);
            return registryConfig;
        }
        
        @Bean
        public ProtocolConfig protocolConfig(){
        	ProtocolConfig protocolConfig = new ProtocolConfig();
        	protocolConfig.setPort(port);
        	return protocolConfig;
        }
    
        @Bean
        public ConsumerConfig consumerConfig() {
            ConsumerConfig consumerConfig = new ConsumerConfig();
            consumerConfig.setCheck(false);
            return consumerConfig;
        }
        
    }

### *2.注册配置（建议新建一个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.xsd 
 http://code.alibabatech.com/schema/dubbo 
 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
 <dubbo:service interface="me.lance.service.TestService" ref="testServiceImpl" />
 </beans>

### *3.消费配置（建议新建一个consumer 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.xsd 
 http://code.alibabatech.com/schema/dubbo 
 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
 <dubbo:reference interface="me.lance.testService" id="testService" />
 </beans>

### 4.pom文件 ###

<dependency>
 <groupId>org.apache.zookeeper</groupId>
 <artifactId>zookeeper</artifactId>
 <version>3.4.9</version>
 </dependency>
 <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>dubbo</artifactId>
 <version>2.8.4</version>
 </dependency>
 <dependency>
 	<groupId>com.github.sgroschupf</groupId>
 	<artifactId>zkclient</artifactId>
 	<version>0.1</version>
 	<exclusions>
 	 <exclusion>
 		<groupId>org.apache.zookeeper</groupId>
 		<artifactId>zookeeper</artifactId>
 		</exclusion>
 	</exclusions>
 </dependency>

### *5.启动方式* ###

***(1)通过tomcat启动***

***(2)通过配置maven启动  如图***

exec:java -Dexec.mainClass=com.alibaba.dubbo.container.Main

![70][]

***（3）springboot通过main方法启动即可***。

# 集群容错模式 #

配置方式

<dubbo:service cluster="failsafe" />

或

<dubbo:reference cluster="failsafe" />

**Failover Cluster（默认）**

失败自动切换，当出现失败，重试其它服务器 。通常用于读操作，但重试会带来更长延迟。可通过 `retries="2"` 来设置重试次数。

**Failfast Cluster**

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

**Failsafe Cluster**

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

**Failback Cluster**

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

**Forking Cluster**

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

**Broadcast Cluster**

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

# 负载均衡 #

**Random LoadBalance（默认）**

*  随机，按权重设置随机概率。
 *  在一个截面上碰撞的概率高，但调用量越大分布越均匀，而且按概率使用权重后也比较均匀，有利于动态调整提供者权重。

**RoundRobin LoadBalance**

*  轮循，按公约后的权重设置轮循比率。
 *  存在慢的提供者累积请求的问题，比如：第二台机器很慢，但没挂，当请求调到第二台时就卡在那，久而久之，所有请求都卡在调到第二台上。

**LeastActive LoadBalance**

*  最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。
 *  使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。

**ConsistentHash LoadBalance**

* 一致性 Hash，相同参数的请求总是发到同一提供者。
 * 当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动。
 * 缺省只对第一个参数 Hash，如果要修改，请配置 `<dubbo:parameter key="hash.arguments" value="0,1" />`
 * 缺省用 160 份虚拟节点，如果要修改，请配置 `<dubbo:parameter key="hash.nodes" value="320" />`

**实例**

<dubbo:service interface="..." loadbalance="roundrobin" weight="2" />

本文章参考自[dubbo文档][dubbo]。

[70]: /images/20220514/6545a7c9efa040738fc1c5b6bcc7b522.png
[dubbo]: https://dubbo.incubator.apache.org/zh-cn/docs/user/quick-start.html