DubboDubbo 源码学习

Dubbo 服务暴露 总结(五)

2018-05-08  本文已影响81人  jwfy

笔记简述
Dubbo服务暴露之前分为了两小节Dubbo 服务暴露 源码学习(上)(三)Dubbo 服务暴露 源码学习(下)(四) 从源码的角度去分析去学习dubbo服务暴露的细节,现在站在更高的一个角度去回顾整个服务暴露整个的流程和操作,我们能从其中学习到什么。
更多内容可看[目录]Dubbo 源码学习

目录

Dubbo 服务暴露 总结(五)
1、Spring
2、SPI
3、服务暴露流程

  1. 获取注册中心
  2. 服务信息的组装
  3. 服务IO端口提供
  4. 服务的注册

1、Spring

基于spring开发,做到无缝对接spring,在使用上只有极少数的xml配置学习成本,在Dubbo内部继承了若干个类,自定义实现的xsd和配套的解析方法等。如果以后需要接入自定义的NameSpaceContext,同样需要类似的处理

获取Spring IOC容器之后,在自定义实现dubbo的服务bean时,就可以获取到系统配置的注册中心、使用的协议、均衡负责等内容(对注册中心、协议等对Spring而言只是个普通的bean而言),这样就可以完成对ServiceBean的属性输入。

2、SPI

虽然之前介绍过了SPI的整个的处理细节,详情可看Dubbo SPI 源码学习 & admin安装(二),在整个的dubbo中也确实大量使用中。可是真正的在调试服务暴露中还是有不少细节被忽略掉了。

3、服务暴露流程

如果是我们去完成这个任务会怎么去做呢?有两点肯定是要实现的

服务调用方感知到服务的存在,然后获取其服务的套接字信息,然后直接通过网络IO完成信息交换

Dubbo其实也基本上按照这种思路来实现的,只是支持了多种协议,并且还有监控、统计等功能,层次分明。

1. 获取注册中心

注册中心的基本配置就是在xml配置的dubbo:registry,生成的URL也是注册协议的URL,例如
registry://127.0.0.1:2182/com.alibaba.dubbo.registry.RegistryService?application=dubbo-demo&client=zkclient&dubbo=2.5.3&group=dubbo-demo&owner=jwfy&pid=2772&registry=zookeeper&timestamp=1525276569763
会把一个dubbo的xml配置的基本信息给提取出去

2. 服务信息的组装

既然注册中心已经准备好了,那现在就需要处理我们对外暴露的service信息
对外暴露服务也需要配置的,这个配置就是从dubbo:protocol来的
这个配置会告诉系统,所有对外暴露的IO读取协议是什么,默认的是dubbo,其实也支持redis、http等
是处理IO数据流方式的协议
不过,如果没有IP、端口等数据,则从dubbo:provider提取
再配置其他属性数据,生成的URL,例如
dubbo://172.16.109.110:20880/com.jwfy.dubbo.product.ProductService?anyhost=true&application=dubbo-demo&default.loadbalance=random&
dubbo=2.5.3&interface=com.jwfy.dubbo.product.ProductService&methods=print,getStr&owner=jwfy
&pid=2772&side=provider&timestamp=1525313423899
这个对外的服务使用的那种均衡负责、暴露的接口、具体可以被调用的函数等,而且是属于提供方

3. 服务IO端口提供

既然网络IO端的协议数据已经准备好了,那就可以开启,等待服务方的调用
这点可以直接跳到DubboProtocol类的export操作了(以Dubbo协议为例子)
针对每一个URL都提取出一个key,然后存储对应的invoker、url等信息
真正操作中取的是服务名+协议端口为key,DubboExporter为value的一个map,后续就可以通过key反取出invoke对象
接下来就是使用哪种Transporter操作了,默认是使用了netty的NettyTransporter(netty是一种基于java开发的异步的、事件驱动的高效的网络IO框架),如果需要使用其他的IO框架,则需要在dubbo:provider设置service字段
现在网络对外的协议Netty已经准备好了,服务信息也已经准备好了,那接下来就按照特定的格式decode操作,把数据转变为字节流,由netty向外开放出来即可
由此服务调用方就可以通过网络IO 链接到服务提供方上

4. 服务的注册

服务的注册是另一个操作,也就是把当前提供的服务告诉给注册中心,后续服务调用方就可以订阅注册中心,从而知道有哪些服务了,当前例子是使用了zookeeper作为注册中心
现在我们知道的是对外暴露服务的url信息(也就是invoke对象中的url)
所以操作也就很明显了,先获取到注册中心的配置信息,然后把服务url信息转为zk协议的url信息,最后连接到注册中心,注册保存即可
这里面就有使用zookeeper的jar包功能,需要和注册中心交互的操作
此外还有些附属的功能,例如超时重试、连接信息的保存和读取(如果注册中心突然出现问题,服务端和客户端还可以利用本地文件缓存继续工作,只是不能再实时获取最新的订阅信息罢了)
一般本地的连接信息存储在/Users/XXX/.dubbo中,如果出现了无法注册无法调用的情况,可以考虑删除该文件重启服务

上一篇下一篇

猜你喜欢

热点阅读