写点什么

Dubbo2.7 试用

用户头像
心平气和
关注
发布于: 2020 年 08 月 15 日

Java开发的同学相信对Dubbo都有了解,Dubbo是阿里开源的RPC/服务治理框架,以下是百度的解释:

Dubbo(读音[ˈdʌbəʊ])是阿里巴巴公司开源的一个高性能优秀的服务框架,使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和 [1]  Spring框架无缝集成。Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。



首先Dubbo是一个RPC框架,如果系统是微服务架构,服务之间可以通过Dubbo来调用,解耦调用者(Consumer)和服务提供者(Provider)的依赖问题,为了统一概念,后面都以Consumer称呼服务调用者,以Provider称呼服务提供者;



没有RPC框架,可能要在配置文件中硬编码很多服务地址,有了Dubbo之后,Consumer不用关心有多少服务提供者,打个比方我想调用用户服务,你只要把服务名告诉Dubbo,Dubbo会自动寻找相应的Provider,而不用在配置文件中写死,真正解放了运维。



http://dubbo.apache.org/zh-cn/docs/user/new-features-in-a-glance.html



二、Dubbo2.7介绍

1、Tag路由

标签路由通过将某一个或多个服务的提供者划分到同一个分组,约束流量只在指定分组中流转,从而实现流量隔离的目的,可以作为蓝绿发布、灰度发布等场景的能力基础。

这是1个实际的例子:

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、新增元数据中心



元数据中心负责存储包括服务静态化配置、服务定义(如方法签名)等数据,默认提供Zookeeper, Redis支持。



3、动态配置中心

主要承担2个功能:

    A、外部化配置。启动配置的集中式存储 (简单理解为dubbo.properties的外部化存储)。

    B、服务治理。服务治理规则的存储与通知。



启用动态配置,以Zookeeper为例


<dubbo:config-center address="zookeeper://127.0.0.1:2181"/>

实际支持Redis、Zookeeper,还有阿波罗等第三方配置中心;可以看到,这些也是方便运维的操作,以前这些操作可能需要重启应用,有了动态配置中心后只要在后台配置就可以了。



三、灰度发布

我们来看下如何通过tag路由做灰度,假设我们的应用架构是这样的:





2、商城调用订单中心保存订单接口;

3、订单调用商品中心查询接口接口;



以上面的场景来说需要做灰度首先在调用层需要将tag传递过来,通过以下代码传递tag:


RpcContext.getContext().setAttachment(TAG_KEY, "pre");



如何对应用中无侵入呢,官方建议通过Filter或SPI的方式实现,具体方式是放在动态配置中,或环境配置中,然后在过滤器初始化的时候读取这个配置,然后每次调用前将tag传递到调用链中。



对于非Java应用,比如PHP,如果通过Hessian协议调用,通过http头传递就可以了,看下Hessian的实现:


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



function getStream($url, $data, $options)
{
$curl = new Curl;
$curlOptions = [];
$curlHeader = [
'Content-Type' => 'application/binary',
'headerdubbo.tag' => 'pre',
];

即在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的标签配置:

<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的依赖:

<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-metadata-report-zookeeper</artifactId>
<version>${project.parent.version}</version>
</dependency>

provider的xml配置:

<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调用而测试的。



以下是运行结果:





往期精彩文章:

FastDFS不同步怎么破

OAuth2.0及Spring实现

Mysql中间件360 Atlas踩坑

RabbitMQ跨机房迁移数据零丢失



持续获取最新中间件等技术,请关注公众号:





发布于: 2020 年 08 月 15 日阅读数: 61
用户头像

心平气和

关注

欢迎关注公众号:程序员升级之路 2018.03.06 加入

还未添加个人简介

评论

发布
暂无评论
Dubbo2.7试用