小编给大家分享一下java开发分布式服务框架Dubbo暴露服务的示例分析,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!在进免费云主机域名行服务暴露机制的分析之前,必须谈谈什么是URL
,在Dubbo服务暴露过程中URL
是无处不在的,贯穿了整个过程。一般情况下,URL
指的是统一资源定位符,标准格式如下:Dubbo就是用这种URL
的方式来作为约定的参数类型,服务之间也是用URL
来进行交互。Dubbo用URL
作为配置总线,贯穿整个源码体系。URL
的具体参数如下:protocol
:dubbo中的各种协议,如:dubbo、http、thrifthost/port
:主机/端口号path
:接口名称parameters
:参数键值对大体流程分为三个步骤:检测配置,有些配置为空值会有默认值自动填充并自动组装为URL
暴露服务,包括暴露到本地和远程的服务注册为服务到服务注册中心先来到ServiceBean
中可以看到这个类实现了ApplicationListener
,这样就会在Spring IOC容器刷新之后调用onApplicationEvent
方法,这个方法中做的就是服务暴露。从if
判断条件中,我们可以看到如果配置中没有设置延迟暴露、并且没有暴露过、并且支持暴露的情况下就会执行this.export()
,最终会调用父类ServiceConfig
中的export
方法。上述方法中主要就是进行配置检查,然后进入this.doExport()
进行服务暴露,这个方法前面的部分都是一些配置检查,重点放在最后的this.doExportUrls()
。从上述源码中可以看到Dubbo是支持多注册中心的,并且支持多种协议,一个服务如果有多个协议那么都需要暴露。this.loadRegistries()
是根据配置组装成注册中心相关的URL,如下:接下来进入this.doExportUrlsFor1Protocol()
,构建完成之后的URL如下图所示:使用的是dubbo协议,接下来要做的就是根据URL来进行服务暴露进入exportLocal()
看一下,这个方法做的事就是进行本地暴露,使用的是injvm
协议,这个方法中对URL进行修改,将协议改为injvm
。此处的protocol.export()
是标注了@Adaptive
注解的,设计自适应拓展,调用该方法之后会生成代理类,代理类通过URL中的参数得知所使用的协议,然后通过Dubbo SPI机制实现拓展,选择对应的实现类进行export()
方法,此处的方法会选择InjvmProtocol
中的export()
进行暴露。经过转化后得到的export
如下所示:如图所示,具体实现类被层层包装。为什么要封装成invoker呢?封装成invoker是为了屏蔽调用的细节,统一暴露出一个可执行体,使得调用者调用时变得便捷简易。为什么要使用本地暴露呢?因为可能存在本地不同服务之间相互调用的情况,因此本地暴露后,内部可以直接进行调用,而省去了不必要的网络通信。此处引用一下博主敖丙的文章中的本地暴露流程图:此时本地暴露已经完成了,现在开始远程暴露。流程与本地暴露相似,都需要先封装为invoker然后再进一步生成exporter,以下是registryURL.addParameterAndEncoded()
方法将URL进行拼接后的结果:可以看到先是走registry
协议,然后参数中有一个export=dubbo://
,此时会走dubbo
协议,所以我们得知SPI会先通过registry
协议找到RegistryPotocol
然后执行export()
,然后再执行DubboPotocol
中的export()
。现在我们进入RegistryPotocol
中的export()
方法。上述操作主要是讲export转化为exporter,获取注册中心的相关配置,如果需要注册则向注册中心进行注册,并且在ProviderConsumerRegTable
中记录服务提供者信息,进入源码中,我们发现实质就是往一个ConcurrentHashMap
中塞入invoker,key是服务接口全类名,value是一个set,set中存储包装过的invoker。然后进入 doLocalExport
方法内部箭头指向的方法最终会调用DubboProtocol
中的export()
需要创建server上述代码中,主要就是根据URL创建出key,然后将key和invoker存入exporterMap中关联起来,如果是初次服务暴露则需要创建监听服务器,默认是NettyServer,并且初始化各种Handler,比如心跳检测,解码等。至此服务暴露流程结束。此处引用博主敖丙的文章中的本地暴露流程图:看完了这篇文章,相信你对“java开发分布式服务框架Dubbo暴露服务的示例分析”有了一定的了解,如果想了解更多相关知识,欢迎关注百云主机行业资讯频道,感谢各位的阅读!
相关推荐: springcloud怎么使用Feign后台内部传递MultipartFile
这篇文章主要介绍了springcloud怎么使用Feign后台内部传递MultipartFile,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。若SpringFormEncoder 引入报错,加上…
免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。