一、Dubbo介绍
Java开发的同学相信对Dubbo都有了解,Dubbo是阿里开源的RPC/服务治理框架,以下是百度的解释:
Dubbo(读音[ˈdʌbəʊ])是阿里巴巴公司开源的一个高性能优秀的服务框架,使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和 [1] Spring框架无缝集成。Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。 https://baike.baidu.com/item/Dubbo/18907815?fr=aladdin
首先Dubbo是一个RPC框架,如果系统是微服务架构,服务之间可以通过Dubbo来调用,解耦调用者(Consumer)和服务提供者(Provider)的依赖问题,为了统一概念,后面都以Consumer称呼服务调用者,以Provider称呼服务提供者;
没有RPC框架,可能要在配置文件中硬编码很多服务地址,有了Dubbo之后,Consumer不用关心有多少服务提供者,打个比方我想调用用户服务,你只要把服务名告诉Dubbo,Dubbo会自动寻找相应的Provider,而不用在配置文件中写死,真正解放了运维。
Dubbo具体的功能就不在这里解释了,可以参考官方手册:
http://dubbo.apache.org/zh-cn/docs/user/new-features-in-a-glance.html
二、Dubbo2.7介绍
Dubbo最新版本为2.7.6,2.7以后有大的变化,主要特性有:
1、Tag路由
标签路由通过将某一个或多个服务的提供者划分到同一个分组,约束流量只在指定分组中流转,从而实现流量隔离的目的,可以作为蓝绿发布、灰度发布等场景的能力基础。
这是1个实际的例子:
代码语言:javascript复制 force: false
runtime: true
enabled: true
key: tradecenter
tags:
- name: pre
addresses: ["172.21.107.21:20880"]
假设当前tradecenter服务有2台机器,1台是172.21.107.21,另1台是172.21.107.22;
上面将tradecenter这个服务其中1台172.21.107.21,打了标签pre,后续Consumer调用时,只要带了pre的tag,就一定会调用到这台机;而没带tag的会调用到另1台机172.21.107.22,这样就可以实现灰度发布了。
这个下面再重点讲述。
2、新增元数据中心
这块以前是全在注册中心,之所以单独分出来,也是考虑性能、带宽的问题,因为有的配置Consumer根本不用关心,当集群调用方增多的时候,如果还按以前的方式,将大大将增加网络的消耗。
元数据中心负责存储包括服务静态化配置、服务定义(如方法签名)等数据,默认提供Zookeeper, Redis支持。
3、动态配置中心
主要承担2个功能:
A、外部化配置。启动配置的集中式存储 (简单理解为dubbo.properties的外部化存储)。
B、服务治理。服务治理规则的存储与通知。
启用动态配置,以Zookeeper为例
代码语言:javascript复制<dubbo:config-center address="zookeeper://127.0.0.1:2181"/>
实际支持Redis、Zookeeper,还有阿波罗等第三方配置中心;可以看到,这些也是方便运维的操作,以前这些操作可能需要重启应用,有了动态配置中心后只要在后台配置就可以了。
三、灰度发布
我们来看下如何通过tag路由做灰度,假设我们的应用架构是这样的:
在接入层,即用户浏览器可以访问到的是商城的接口,然后商城会依赖订单中心服务,订单又会依赖商品中心服务,举1个实际的例子,以下单接口为例:
1、用户调用接口下单接口;
2、商城调用订单中心保存订单接口;
3、订单调用商品中心查询接口接口;
以上面的场景来说需要做灰度首先在调用层需要将tag传递过来,通过以下代码传递tag:
代码语言:javascript复制RpcContext.getContext().setAttachment(TAG_KEY, "pre");
如何对应用中无侵入呢,官方建议通过Filter或SPI的方式实现,具体方式是放在动态配置中,或环境配置中,然后在过滤器初始化的时候读取这个配置,然后每次调用前将tag传递到调用链中。
对于非Java应用,比如PHP,如果通过Hessian协议调用,通过http头传递就可以了,看下Hessian的实现:
代码语言:javascript复制RpcContext.getContext().setRemoteAddress(request.getRemoteAddr(), request.getRemotePort());
Enumeration<String> enumeration = request.getHeaderNames();
while (enumeration.hasMoreElements()) {
String key = enumeration.nextElement();
if (key.startsWith(DEFAULT_EXCHANGER)) {
RpcContext.getContext().setAttachment(key.substring(DEFAULT_EXCHANGER.length()),
request.getHeader(key));
}
}
try {
skeleton.invoke(request.getInputStream(), response.getOutputStream());
} catch (Throwable e) {
throw new ServletException(e);
}
即在http头中这样传参数,Hessian Php客户端的实现,github上已经有了,原仓库地址我已经不记得了,我在github上已经clone,并做了些优化,地址:
https://github.com/programwithebay/fasthessian
代码语言:javascript复制function getStream($url, $data, $options)
{
$curl = new Curl;
$curlOptions = [];
$curlHeader = [
'Content-Type' => 'application/binary',
'headerdubbo.tag' => 'pre',
];
if (!empty($options->transportOptions)) {
即在http头中加上参数 headerdubbo.tag,上面tag内容是写死的,可以根据情况自己读取动态配置或环境配置。
四、Dubbo环境搭建
1、从github下载代码:https://github.com/apache/dubbo
2、切到相应分支,我用的是2.7.4.1的;
3、mvn编译就行了,mvn clean:compile
官方自带了一些样例代码,即demo模块,下面是demo的代码,实现方式有注解、api、xml的方式,我用xml的方式进行测试,其中dubbo-demo-xml-provider-service是我另外加的模块
这是consumer的xml配置,主要是多了 metadata-report和config-center的标签配置:
代码语言:javascript复制<dubbo:application name="demo-consumer"/>
<dubbo:metadata-report address="zookeeper://172.21.104.63:2181" />
<dubbo:registry id="zookeeper" address="zookeeper://172.21.104.63:2181" />
<dubbo:config-center address="zookeeper://172.21.104.63:2181" timeout="10000" />
记得在pom文件引用zookeeper的依赖:
代码语言:javascript复制<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-metadata-report-zookeeper</artifactId>
<version>${project.parent.version}</version>
</dependency>
provider的xml配置:
代码语言:javascript复制 <dubbo:application name="demo-provider"/>
<dubbo:consumer filter="default" timeout="5000"/>
<dubbo:registry address="zookeeper://172.21.104.63:2181" id="zookeeper" />
<dubbo:config-center address="zookeeper://172.21.104.63:2181" />
<dubbo:metadata-report address="zookeeper://172.21.104.63:2181" />
<dubbo:protocol name="hessian" port="10890" dispather="all" threadpool="fixed"
threads="10" id="hessian" server="jetty"/>
<dubbo:protocol name="dubbo" id="dubbo" port="20890" />
<bean id="demoService" class="org.apache.dubbo.demo.provider.DemoServiceImpl" />
<dubbo:service interface="org.apache.dubbo.demo.DemoService" ref="demoService" registry="zookeeper"
version="1.0.0" tag="" protocol="dubbo,hessian" />
上面加了hessian协议,是为了方便PHP调用而测试的。
以下是运行结果: