【JAVA秒会技术之Dubbo入门】Dubbo在电商开发中的应用

Dubbo在电商开发中的应用

一、Dubbo背景

所谓背景介绍，就是“我们在什么情况下，基于什么原因开发了这样一个中间件？”就博主来看，简而言之，总结如下:

(1) 随着服务的不断增多，服务的URL配置管理变得非常困难。此时，我们需要找一个中介替我们管理。

(2) 服务间的依赖关系变得错踪复杂，相互调用混乱。此时，我们需要厘清谁是服务提供方，谁是服务的消费方。

(3) 服务间的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？此时，我们需要有一个自动监控系统，帮助我们监控管理这一切。

基于以上三点，我们再做一个进一步提取：

我们需要一个管理众多服务URL的中介 ——注册中心；

我们需要搞清服务间复杂的依赖关系 ——服务提供方和服务消费方；

我们需要有一个自动监控系统，监管一切 ——监控中心。

如此，我们Dubbo的模型就自然而然的出来了。

二、Dubbo简介

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合），比如表现层和业务层就需要解耦合。

从面向服务的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。

除了以上两个角色，它还有注册中心和监控中心。它可以通过注册中心对服务进行注册和订阅，实现了软负载均衡和Failover（故障切换），降低对F5硬件负载均衡器的依赖，也能减少部分成本。同事，还可以通过监控中心对服务进行监控，这样的话，就可以知道哪些服务使用率高、哪些服务使用率低。对使用率高的服务增加机器，对使用率低的服务减少机器，达到合理分配资源的目的。

调用关系说明：

[0] 服务容器负责启动，加载，运行服务提供者。

[1] 服务提供者在启动时，向注册中心注册自己提供的服务。

[2] 服务消费者在启动时，向注册中心订阅自己所需的服务。

[3] 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

[4] 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

[5] 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

三、注册中心

注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小。Dubbo目前支持4种注册中心,（multicast、zookeeper、Redis、simple），但是对于dubbo-2.3.3以上版本，建议使用Zookeeper注册中心。

（1）Zookeeper简介

Zookeeper是Apacahe Hadoop的子项目，是一个树型的目录服务，支持变更推送，适合作为Dubbo服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。

流程说明：

①服务提供者启动时：
    向/dubbo/com.foo.BarService/providers目录下写入自己的URL地址。
②服务消费者启动时：
    订阅/dubbo/com.foo.BarService/providers目录下的提供者URL地址。
    并向/dubbo/com.foo.BarService/consumers目录下写入自己的URL地址。
③监控中心启动时：
    订阅/dubbo/com.foo.BarService目录下的所有提供者和消费者URL地址。

支持以下功能：

①当提供者出现断电等异常停机时，注册中心能自动删除提供者信息。
②当注册中心重启时，能自动恢复注册数据，以及订阅请求。
③当会话过期时，能自动恢复注册数据，以及订阅请求。
④当设置<dubbo:registry check="false" />时，记录失败注册和订阅请求，后台定时重试。
⑤可通过<dubbo:registry username="admin" password="1234" />设置zookeeper登录信息。
⑥可通过<dubbo:registry group="dubbo" />设置zookeeper的根节点，不设置将使用无根树。
⑦支持*号通配符<dubbo:reference group="*" version="*" />，可订阅服务的所有分组和所有版本的提供者

（2）Zookeeper单机安装

安装环境：Linux centOS、JDK环境（Zookeeper是由Java开发的）

第一步：下载zookeeper的压缩包，上传到linux系统

[plain] view plain copy

1. 下载Zookeeper-3.4.5.tar.gz 地址http://www./dist/zookeeper/  

第二步：解压缩

[plain] view plain copy

1. tar -zxf zookeeper-3.4.5.tar.gz  

第三步：创建zoo.cfg文件，进入zookeeper-3.4.5/conf/目录，修改zoo_sample.cfg 为zoo.cfg

[plain] view plain copy

1. cp zoo_sample.cfg zoo.cfg  

第四步：配置zoo.cfg

[plain] view plain copy

1. 主要配置dataDir和clientPort参数。例如：dataDir = /usr/local/zookeeper/data; clientPort = 2181。  
2. 注意：datadir目录中的data末级目录如果不存在，也会自动生成。  

第五步：启动zookeeper

[plain] view plain copy

1. 启动命令：./zkServer.sh start  
2. 关闭命令：./zkServer.sh stop  
3. 查看状态命令：./zkServer.sh status  

第六步：关闭防火墙（可选）

[plain] view plain copy

1. 暂时关闭：service iptables stop  
2. 永久关闭：chkconfig iptables off</strong>  

四、Dubbo的配置

Dubbo采用全spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

在Maven的pom.xml中配置如下

[plain] view plain copy

1. <dependency>  
2. <!-- 配置zookeeper的客户端Curator支持Fluent风格的操作API -->  
3.     <groupId>com.netflix.curator</groupId>  
4.     <artifactId>curator-framework</artifactId>  
5.     <version>${com.netflix.curator.version}</version>  
6. </dependency>  
7. <dependency>  
8. <!-- 配置zookeeper的客户端ZkClient -->  
9. <!-- 可以解决常见问题：重复注册watcher、session失效重连、异常处理。 -->  
10.     <groupId>com.101tec</groupId>  
11.     <artifactId>zkclient</artifactId>  
12.     <version>${com.101tec.version}</version>  
13.     <exclusions>  
14.         <exclusion>  
15.             <!-- 添加日志 -->  
16.                 <groupId>org.slf4j</groupId>  
17.                 <artifactId>slf4j-log4j12</artifactId>  
18.         </exclusion>  
19.     </exclusions>  
20. </dependency>  
21. <dependency>  
22. <!-- 配置Zookeeper -->  
23.     <groupId>org.apache.zookeeper</groupId>  
24.     <artifactId>zookeeper</artifactId>  
25.     <version>${org.apache.zookeeper.version}</version>  
26.         <exclusions>  
27.             <exclusion>  
28.                 <!-- 添加日志 -->  
29.                 <groupId>org.slf4j</groupId>  
30.                 <artifactId>slf4j-log4j12</artifactId>  
31.             </exclusion>  
32.         </exclusions>  
33. </dependency>  
34. <dependency>  
35. <!-- 配置Dubbo -->  
36.     <groupId>com.alibaba</groupId>  
37.     <artifactId>dubbo</artifactId>  
38.     <version>${com.alibaba.version}</version>  
39.         <exclusions>  
40.             <exclusion>  
41.                 <artifactId>spring</artifactId>  
42.                 <groupId>org.springframework</groupId>  
43.             </exclusion>  
44.         </exclusions>  
45. </dependency>  

在applicationContext.xml中添加如下配置

[plain] view plain copy

1. <!-- 引入Dubbo相关的配置文件 -->  
2.     <import resource="applicationContext-dubbo.xml"/>  
3.     <import resource="service-provider.xml"/>  
4.     <import resource="service-consumer.xml"/>  

在applicationContext-dubbo.xml中添加如下配置

[plain] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <beans xmlns:xsi="http://www./2001/XMLSchema-instance"  
3.     xmlns:dubbo="http://code./schema/dubbo"  
4.     xmlns="http://www./schema/beans"  
5.     xsi:schemaLocation="  
6.     http://www./schema/beans   
7.     http://www./schema/beans/spring-beans-2.5.xsd  
8.     http://code./schema/dubbo   
9.     http://code./schema/dubbo/dubbo.xsd">  
10.     <!-- 注册中心地址 -->  
11.     <dubbo:registry protocol="zookeeper" address="${dubbo.protocol.zookeeper}"  
12.         client="curator" file="docservice-query.properties" />   
13.     <!-- 本地缓存文件（保留已注册的服务） -->  
14.     <!--<dubbo:registry address="multicast://224.5.96.10:1234" /> -->  
15.     <!-- 提供方应用信息：application-计算依赖关系。name-应用名，owner-负责人 -->  
16.     <dubbo:application name="${dubbo.application.name}"  
17.         owner="${dubbo.application.owner}" logger="slf4j" />  
18.     <!-- 注册端口名字（接收器）-->  
19.     <dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}" />  
20.     <!-- 当前提供组名 -->  
21.     <dubbo:provider group="${dubbo.registry.group}" />  
22.     <!-- 需要消费的消费组名 -->  
23.     <dubbo:consumer group="${dubbo.registry.group}" />  
24. </beans>  

服务提供方service-provider.xml配置如下

[plain] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <beans xmlns:xsi="http://www./2001/XMLSchema-instance"  
3.        xmlns:dubbo="http://code./schema/dubbo"  
4.        xmlns="http://www./schema/beans"  
5.        xsi:schemaLocation="  
6.    http://www./schema/beans  
7.    http://www./schema/beans/spring-beans-2.5.xsd  
8.    http://code./schema/dubbo  
9.    http://code./schema/dubbo/dubbo.xsd">  
10. <!-- 需要暴露的服务地址以及服务名 ，protocol接收器标识-->  
11. <dubbo:service interface="com.xxx.XxxService" ref="xxxService"  
12.     protocol="dubbo"  timeout="1000"/>  
13. </beans>  

服务消费方service-consumer.xml配置如下

[plain] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <beans xmlns:xsi="http://www./2001/XMLSchema-instance"  
3.        xmlns:dubbo="http://code./schema/dubbo"  
4.        xmlns="http://www./schema/beans"  
5.        xsi:schemaLocation="  
6.    http://www./schema/beans  
7.    http://www./schema/beans/spring-beans-2.5.xsd  
8.    http://code./schema/dubbo  
9.    http://code./schema/dubbo/dubbo.xsd">  
10. <!-- 需要暴露的服务地址以及服务名 ，protocol接收器标识-->  
11. <dubbo:reference interface="com.xxx.XxxService" id="xxxService" protocol="dubbo"  
12.      timeout="10000" init="true" group="${dubbo.registry.group}" check="false"/>  

dubbo.properties配置如下

[plain] view plain copy

1. <strong>#注册端口名字（接收器）  
2. dubbo.application.name=service-query  
3. dubbo.protocol.name=dubbo  
4. dubbo.protocol.port=20020  
5. #contarin conf  
6. dubbo.container=logback,spring  
7. dubbo.shutdown.hook=true  
8. #log  
9. dubbo.application.logger=slf4j  
10. #spring container  
11. dubbo.spring.config=classpath*:*spring/applicationContext.xml  
12. dubbo.logback.level=debug  
13. dubbo.logback.maxhistory=30</strong>