天天看点

如何将dubbo封装成http协议

很多小伙伴在测试的时候发现使用现成的工具无法对dubbo协议进行调用,我们现在就来看一下如何通过封装,将dubbo封装成一个http协议,然后再使用现成的http测试工具即可实现dubbo的直接调用。

首先,我们来看dubbo是啥

Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。关于注册中心、协议支持、服务监控等内容,详见后面描述。

总体架构

Dubbo的总体架构,如图所示:

Paste_Image.png

Dubbo框架设计一共划分了10个层,而最上面的Service层是留给实际想要使用Dubbo开发分布式服务的开发者实现业务逻辑的接口层。图中左边淡蓝背景的为服务消费方使用的接口,右边淡绿色背景的为服务提供方使用的接口, 位于中轴线上的为双方都用到的接口。

下面,结合Dubbo官方文档,我们分别理解一下框架分层架构中,各个层次的设计要点:

服务接口层(Service):该层是与实际业务逻辑相关的,根据服务提供方和服务消费方的业务设计对应的接口和实现。

配置层(Config):对外配置接口,以ServiceConfig和ReferenceConfig为中心,可以直接new配置类,也可以通过spring解析配置生成配置类。

服务代理层(Proxy):服务接口透明代理,生成服务的客户端Stub和服务器端Skeleton,以ServiceProxy为中心,扩展接口为ProxyFactory。

服务注册层(Registry):封装服务地址的注册与发现,以服务URL为中心,扩展接口为RegistryFactory、Registry和RegistryService。可能没有服务注册中心,此时服务提供方直接暴露服务。

集群层(Cluster):封装多个提供者的路由及负载均衡,并桥接注册中心,以Invoker为中心,扩展接口为Cluster、Directory、Router和LoadBalance。将多个服务提供方组合为一个服务提供方,实现对服务消费方来透明,只需要与一个服务提供方进行交互。

监控层(Monitor):RPC调用次数和调用时间监控,以Statistics为中心,扩展接口为MonitorFactory、Monitor和MonitorService。

远程调用层(Protocol):封将RPC调用,以Invocation和Result为中心,扩展接口为Protocol、Invoker和Exporter。Protocol是服务域,它是Invoker暴露和引用的主功能入口,它负责Invoker的生命周期管理。Invoker是实体域,它是Dubbo的核心模型,其它模型都向它靠扰,或转换成它,它代表一个可执行体,可向它发起invoke调用,它有可能是一个本地的实现,也可能是一个远程的实现,也可能一个集群实现。

信息交换层(Exchange):封装请求响应模式,同步转异步,以Request和Response为中心,扩展接口为Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。

网络传输层(Transport):抽象mina和netty为统一接口,以Message为中心,扩展接口为Channel、Transporter、Client、Server和Codec。

数据序列化层(Serialize):可复用的一些工具,扩展接口为Serialization、 ObjectInput、ObjectOutput和ThreadPool。

上面的介绍看不懂?没关系,我也是从别人的论坛抄的,它就是一个分布式的协议架构,解决企业级应用问题,学dubbo之路很漫长,涉及到多种协议、网络知识、zookeeper、spring,我们统统先不管它们,直接开始将它封装成我们熟悉的http协议。

预警:以下的代码不是dubbo的常规用法,是小编从dubbo的spring架构里拆出来的函数,做做工具还可以,不要拿来学做企业级应用,否则你会越走越远。为了工具更轻量级,我们只好将它从spring里抽离出来(小编搞了好久才完成抽离,是不是应该给个红包)

啥?你想学常规版本的dubbo应用,建议你还是去网上看dubbo教程吧,出门左拐。

<a href="https://link.jianshu.com?t=http://maven.pingan.work/nexus/service/local/repositories/central/content/com/alibaba/dubbo/2.0.10/dubbo-2.0.10.jar" target="_blank">http://maven.pingan.work/nexus/service/local/repositories/central/content/com/alibaba/dubbo/2.0.10/dubbo-2.0.10.jar</a>

maven依赖是(如果在spring里整合出现jar冲突,请使用exclusion规避):

&lt;dependency&gt;

&lt;groupId&gt;com.alibaba&lt;/groupId&gt;

&lt;artifactId&gt;dubbo&lt;/artifactId&gt;

&lt;version&gt;2.4.10&lt;/version&gt;

&lt;exclusions&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;

接下来直接上代码:

http传入的form如下:

下面来封装dubbo,我们采用直接点对点rpc调用,不走dubbo注册中心:

ok了,dubbo就封装成http了。

附件:ResponseUtil的封装