浅谈Dubbo

╰半橙微兮° 2022-05-08 07:33 201阅读 0赞

*  **背景**

网址：http://dubbo.io

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。

![70][]

*  **单一应用架构** 
    
     *  当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。
     *  此时，用于简化增删改查工作量的 **数据访问框架(ORM)** 是关键。
 *  **垂直应用架构** 
    
     *  当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。
     *  此时，用于加速前端页面开发的 **Web框架(MVC)** 是关键。
 *  **分布式服务架构** 
    
     *  当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求，其他系统需要调用本系统相关数据，本系统需要提供接口。
     *  此时，用于提高业务复用及整合的 **分布式服务框架(RPC)** 是关键。
 *  **流动计算架构** 
    
     *  当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。
     *  此时，用于提高机器利用率的 **资源调度和治理中心(SOA)** 是关键。

*  **du****bbo****架构**

![70 1][]

**节点角色说明：**

*  **Provider:** 暴露服务的服务提供方。
 *  **Consumer:** 调用远程服务的服务消费方。
 *  **Registry:** 服务注册与发现的注册中心。
 *  **Monitor:** 统计服务的调用次数和调用时间的监控中心。
 *  **Container:** 服务运行容器。

**调用关系说明：**

*  0. 服务容器负责启动，加载，运行服务提供者。
 *  1. 服务提供者在启动时，向注册中心注册自己提供的服务。
 *  2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
 *  3. 注册中心返回服务提供者**地址**列表给消费者，如果有变更，注册中心将基于**长连接**推送变更数据给消费者。
 *  4. 服务消费者，从提供者地址列表中，基于**软负载均衡**算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
 *  5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

*  **监控中心安装**

1.  安装环境

jdk1.7、zookeeper3.4.6、centos6.8

1.  上传监控中中心安装包至服务器

![70 2][]

![70 3][]

\-C参数用于指定tar命令解压目标的目录，可为绝对路径，也可以是相对路径。

1.  **配置，指定注册地址-重点**

vi dubbo.properties

![70 4][]

1.  启动

![70 5][]

1.  关闭防火墙，访问

service iptables stop

![70 6][]

**管理控制台安装**

1.  环境

jdk1.7、zookeeper3.4.6

1.  上传安装包至服务器

![70 7][]

1.  解压tomcat

![70 8][]

1.  将dubbo-admin解压至tomcat/webapps中

删除tomcat中ROOT目录

![70 9][]

将dubbo-admin解压至tomcat

![70 10][]

![70 11][]

\-d是directory的首字母，参数用于指定unzip命令解压的目标路径

如果没有unzip命令，可交给tomcat自动解压

1.  修改dubbo-admin中的dubbo.properties配置文件

![70 12][]

其中zk1,zk2,zk3是在hosts文件中已配置

1.  修改tomcat端口，启动

Tomcat涉及端口：8005、8080、8009

![70 13][]

启动命令

![70 14][]

1.  关闭防火墙，访问

![70 15][]

service iptables stop

访问默认用户名和密码：root/root

![70 16][]

1.duboo服务提供者（provider）-编程

*  步骤

1.  添加依赖：dubbo、zookeeper
2.  编写service（正常编写）
3.  **添加applicationContext-du****bbo-provider.xml**
4.  启动dubbo（启动spring容器）

*  实现

1.  添加依赖

<table style="margin-left:39pt;width:414.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> &lt;!-- dubbo依赖 --&gt; &lt;dependency&gt; &lt;groupId&gt;com.alibaba&lt;/groupId&gt; &lt;artifactId&gt;dubbo&lt;/artifactId&gt; &lt;version&gt;2.5.3&lt;/version&gt; &lt;exclusions&gt; &lt;!-- 排除spring 2.5.6依赖 --&gt; &lt;exclusion&gt; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &lt;artifactId&gt;spring&lt;/artifactId&gt; &lt;/exclusion&gt; &lt;/exclusions&gt; &lt;/dependency&gt; &lt;!-- zookeeper依赖 --&gt; &lt;dependency&gt; &lt;groupId&gt;org.apache.zookeeper&lt;/groupId&gt; &lt;artifactId&gt;zookeeper&lt;/artifactId&gt; &lt;version&gt;3.4.6&lt;/version&gt; &lt;/dependency&gt; &lt;dependency&gt; &lt;groupId&gt;com.101tec&lt;/groupId&gt; &lt;artifactId&gt;zkclient&lt;/artifactId&gt; &lt;version&gt;0.9&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

1.  编写service

正常编写代码即可。service的实现对象，无需要添加@Service注解。

原因：统一在applicationContext-dubbo-provider.xml中指定。

1.  applicationContext-dubbo-provider.xml

zookeeper.properties

<table style="margin-left:39pt;width:375.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:375.8pt;"> #zookeeper地址、端口 zk1.address=192.168.88.20:2181 zk2.address=192.168.88.20:2182 zk3.address=192.168.88.20:2183 </td> 
 </tr> 
 </tbody> 
</table>

applicationContext-dubbo-provider.xml

<table style="margin-left:39pt;width:375.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:375.8pt;"> &lt;?xml&nbsp;version="1.0"&nbsp;encoding="UTF-8"?&gt; &lt;beans&nbsp;xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"&nbsp;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"&gt; &lt;!-- 1.配置application 指定名称 用于计算依赖 此名称不能consumer配置application名称相同 --&gt; &lt;dubbo:application&nbsp;name="ego-manager-dubbo-provider"/&gt; &lt;!-- 2.指定注册 中心地址 --&gt; &lt;dubbo:registry&nbsp;address="${zk1.address},${zk2.address},${zk3.address}"&nbsp;protocol="zookeeper"/&gt; &lt;!-- 3.暴露服务接口端口号 并指定协议 --&gt; &lt;dubbo:protocol&nbsp;name="dubbo"&nbsp;port="20880"&nbsp;/&gt; &nbsp; &lt;!-- 4.与spring一样，配置service bean --&gt; &lt;bean&nbsp;id="fileUploadService"&nbsp;class="com.lk.service.impl.FileUploadServiceImpl"/&gt; &lt;bean&nbsp;id="goodsCategoryService"&nbsp;class="com.lk.service.impl.GoodsCategoryServiceImpl"/&gt; &lt;bean&nbsp;id="goodsService"&nbsp;class="com.lk.service.impl.GoodsServiceImpl"/&gt; &nbsp; &lt;!-- 5.dubbo暴露服务接口与service bean进行关联 --&gt; &lt;dubbo:service&nbsp;interface="com.lk.service.FileUploadService" ref="fileUploadService"/&gt; &lt;dubbo:service&nbsp;interface="com.lk.service.GoodsCategoryService" ref="goodsCategoryService"/&gt; &lt;dubbo:service&nbsp;interface="com.lk.service.GoodsService"&nbsp;ref="goodsService"/&gt; &lt;/beans&gt; </td> 
 </tr> 
 </tbody> 
</table>

1.  启动dubbo

ProviderRun.java

<table style="margin-left:39pt;width:414.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> public&nbsp;class&nbsp;ProviderRun { &nbsp; private&nbsp;static&nbsp;final&nbsp;Logger logger&nbsp;= LoggerFactory.getLogger(ProviderRun.class); &nbsp; public&nbsp;static&nbsp;void&nbsp;main(String[] args) { //1.加载配置文件 ClassPathXmlApplicationContext ctx&nbsp;= new&nbsp;ClassPathXmlApplicationContext("spring/applicationContext-*.xml"); //2.启动 ctx.start(); &nbsp; while(true){ try&nbsp;{ System.out.println("ego-manager-dubbo-provider正在运行"); Thread.sleep(60*1000); } catch&nbsp;(InterruptedException e) { //记录日志 logger.error("ego-manager-dubbo-provider服务出错了："+e.getMessage()); } } } } </td> 
 </tr> 
 </tbody> 
</table>

*  查看注册的服务

![70 17][]

*  关于元素 'constructor-arg' 中不允许出现属性 'name'问题

根本原因：旧版本spring不支持在constructor-arg添加name属性。

解决办法：将dubbo自动关联的spring排除

![70 18][]

2.dubbo服务消费者（consumer）-编程

1.  依赖

<table style="margin-left:18pt;width:396.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:396.8pt;"> &lt;!-- dubbo依赖 --&gt; &lt;dependency&gt; &lt;groupId&gt;com.alibaba&lt;/groupId&gt; &lt;artifactId&gt;dubbo&lt;/artifactId&gt; &lt;version&gt;2.5.3&lt;/version&gt; &lt;exclusions&gt; &lt;!-- 排除spring 2.5.6依赖 --&gt; &lt;exclusion&gt; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &lt;artifactId&gt;spring&lt;/artifactId&gt; &lt;/exclusion&gt; &lt;/exclusions&gt; &lt;/dependency&gt; &lt;!-- zookeeper依赖 --&gt; &lt;dependency&gt; &lt;groupId&gt;org.apache.zookeeper&lt;/groupId&gt; &lt;artifactId&gt;zookeeper&lt;/artifactId&gt; &lt;version&gt;3.4.6&lt;/version&gt; &lt;/dependency&gt; &lt;dependency&gt; &lt;groupId&gt;com.101tec&lt;/groupId&gt; &lt;artifactId&gt;zkclient&lt;/artifactId&gt; &lt;version&gt;0.9&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

2.配置applicationContext-dubbo-consumer.xml

<table style="margin-left:18pt;width:396.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:396.8pt;"> &lt;?xml&nbsp;version="1.0"&nbsp;encoding="UTF-8"?&gt; &lt;beans&nbsp;xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"&nbsp;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"&gt; &lt;!-- 1.配置application 指定名称 用于计算依赖 此名称不能provider配置application名称相同 --&gt; &lt;dubbo:application&nbsp;name="ego-manager-dubbo-consumer"/&gt; &lt;!-- 2.指定注册 中心地址 --&gt; &lt;dubbo:registry&nbsp;address="${zk1.address},${zk2.address},${zk3.address}"&nbsp;protocol="zookeeper"/&gt; &lt;!-- 3.引用服务 --&gt; &lt;dubbo:reference&nbsp;interface="com.lk.service.FileUploadService"&nbsp;id="fileUploadService"&nbsp;timeout="60000"/&gt; &lt;dubbo:reference&nbsp;interface="com.lk.service.GoodsCategoryService"&nbsp;id="goodsCategoryService"&nbsp;timeout="60000"/&gt; &lt;dubbo:reference&nbsp;interface="com.lk.service.GoodsService"&nbsp;id="goodsService"&nbsp;timeout="60000"/&gt; &lt;/beans&gt; </td> 
 </tr> 
 </tbody> 
</table>

3.直接启动web项目即可。

**解决dubbo上传文件失败问题**

原因：dubbo协议不支持InputStream、File对象。

*  **方式****1****-使用hess****ian****协议**

1.  在消费者（consumer）添加hessian依赖

<table style="margin-left:39pt;width:375.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:375.8pt;"> &lt;dependency&gt; &lt;groupId&gt;com.caucho&lt;/groupId&gt; &lt;artifactId&gt;hessian&lt;/artifactId&gt; &lt;version&gt;4.0.7&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

1.  在服务提供者（provider）端添加hessian、jetty依赖、添加hessian协议

<table style="margin-left:39pt;width:375.8pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:375.8pt;"> &lt;dependency&gt; &lt;groupId&gt;com.caucho&lt;/groupId&gt; &lt;artifactId&gt;hessian&lt;/artifactId&gt; &lt;version&gt;4.0.7&lt;/version&gt; &lt;/dependency&gt; &lt;dependency&gt; &lt;groupId&gt;org.mortbay.jetty&lt;/groupId&gt; &lt;artifactId&gt;jetty&lt;/artifactId&gt; &lt;version&gt;6.1.26&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

修改applicationContext-dubbo-provider.xml

![70 19][]

默认容器使用jetty,如果指定为serlvet，产生问题：由于当前项目是java project，不是web项目，如果是servlet，当前项目启动会报错。

*  方式3-交inputStream转换为byte\[\]

1.  工具

![70 20][]

1.  修改消费者（consumer）端

FileUploadController.java

![70 21][]

1.  修改服务提供者（provider）端

FileUploadServiceImpl.java

![70 22][]

[70]: /images/20220508/728748df7f6145f898427ae94408527a.png
[70 1]: /images/20220508/c05ada515cb14202995c81d0844b4452.png
[70 2]: /images/20220508/cd65ab861161447fb8a420029eefa35f.png
[70 3]: /images/20220508/32de2dbd1817436687c7084f6ba568dd.png
[70 4]: /images/20220508/edae8830e84e466c9c905d8c24ad4264.png
[70 5]: /images/20220508/4a6b95a0e0c249ba8f8af1977ff095e0.png
[70 6]: /images/20220508/50d6d93c6b4449bebc9bb3d7bbc8e5c7.png
[70 7]: /images/20220508/9b4206ccb42147ec945dfe3b5440e163.png
[70 8]: /images/20220508/f0c2e0df916340fb92d292d00395607c.png
[70 9]: /images/20220508/ce14988be7164a0a814ce8c66ca3084f.png
[70 10]: /images/20220508/830f51b833734ace90929469ddc186bb.png
[70 11]: /images/20220508/a662afd0dd254f07922cd54aa4ab3872.png
[70 12]: /images/20220508/86d67e1519ff42a6a48c90c43a98abee.png
[70 13]: /images/20220508/4108679a85b24881b11c3ab68757701a.png
[70 14]: /images/20220508/98f7b7aa704746e7a16b3a01250f383b.png
[70 15]: /images/20220508/69295ab4b6de47e4aa84d1c855f8d4e3.png
[70 16]: /images/20220508/41410bfa38fc4fc48723e1114cae80bb.png
[70 17]: /images/20220508/87694a98a9f7442bbf323e51a9a7a26d.png
[70 18]: /images/20220508/9b73aaae5e6245b3a1f5b484c495a0fd.png
[70 19]: /images/20220508/178af256484c489fa06c25d532539328.png
[70 20]: /images/20220508/4173e7d534ee4604bc600b98bbab2fc7.png
[70 21]: /images/20220508/e077f8ce4c1f4b1bb270458cb4a17c23.png
[70 22]: /images/20220508/4e13c4516ba1401fbb8ed13a27ad4b0b.png