纯净、安全、绿色的下载网站

首页|软件分类|下载排行|最新软件|IT学院

当前位置:首页IT学院IT技术

Dubbo暴露服务过程详解 java开发分布式服务框架Dubbo暴露服务过程详解

又蠢又笨的懒羊羊程序猿   2021-11-20 我要评论
想了解java开发分布式服务框架Dubbo暴露服务过程详解的相关内容吗又蠢又笨的懒羊羊程序猿在本文为您仔细讲解Dubbo暴露服务过程详解的相关知识和一些Code实例欢迎阅读和指正我们先划重点:java开发,分布式服务框架,Dubbo暴露服务过程下面大家一起来学习吧。

Dubbo服务暴露机制

前言

在进行服务暴露机制的分析之前必须谈谈什么是URL在Dubbo服务暴露过程中URL是无处不在的贯穿了整个过程。

一般情况下URL指的是统一资源定位符标准格式如下:

protocol://host:port/path?key1=value1&key2=value2

Dubbo就是用这种URL的方式来作为约定的参数类型服务之间也是用URL来进行交互。

Dubbo用URL作为配置总线贯穿整个源码体系。

URL的具体参数如下:

protocol:dubbo中的各种协议如:dubbo、http、thrift

host/port:主机/端口号

path:接口名称

parameters:参数键值对

服务暴露流程

大体流程分为三个步骤:

检测配置有些配置为空值会有默认值自动填充并自动组装为URL暴露服务包括暴露到本地和远程的服务注册为服务到服务注册中心

源码解析

先来到ServiceBean

在这里插入图片描述

可以看到这个类实现了ApplicationListener<ContextRefreshedEvent>这样就会在Spring IOC容器刷新之后调用onApplicationEvent方法这个方法中做的就是服务暴露。

在这里插入图片描述

if判断条件中我们可以看到如果配置中没有设置延迟暴露、并且没有暴露过、并且支持暴露的情况下就会执行this.export()最终会调用父类ServiceConfig中的export方法。

请添加图片描述

上述方法中主要就是进行配置检查然后进入this.doExport()进行服务暴露这个方法前面的部分都是一些配置检查重点放在最后的this.doExportUrls()

请添加图片描述

从上述源码中可以看到Dubbo是支持多注册中心的并且支持多种协议一个服务如果有多个协议那么都需要暴露。this.loadRegistries()是根据配置组装成注册中心相关的URL如下:

registry://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?application=user-service-provider-one&dubbo=2.6.2&pid=29056&registry=zookeeper&timestamp=1632309180780

接下来进入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中塞入invokerkey是服务接口全类名value是一个setset中存储包装过的invoker。

在这里插入图片描述

然后进入 doLocalExport 方法内部

在这里插入图片描述

箭头指向的方法最终会调用DubboProtocol中的export()

在这里插入图片描述

在这里插入图片描述

需要创建server

在这里插入图片描述

上述代码中主要就是根据URL创建出key然后将key和invoker存入exporterMap中关联起来如果是初次服务暴露则需要创建监听服务器默认是NettyServer并且初始化各种Handler比如心跳检测解码等。

至此服务暴露流程结束。

在这里插入图片描述

此处引用博主敖丙的文章中的本地暴露流程图:

在这里插入图片描述

如果不足或错误欢迎评论指正。


相关文章

猜您喜欢

  • js深拷贝 带你搞懂js的深拷贝

    想了解带你搞懂js的深拷贝的相关内容吗浪漫主义码农在本文为您仔细讲解js深拷贝的相关知识和一些Code实例欢迎阅读和指正我们先划重点:搞懂js,js深拷贝下面大家一起来学习吧。..
  • VUE的数据代理与事件 VUE的数据代理与事件详解

    想了解VUE的数据代理与事件详解的相关内容吗LuckyLazyPig在本文为您仔细讲解VUE的数据代理与事件的相关知识和一些Code实例欢迎阅读和指正我们先划重点:VUE数据代理,VUE事件下面大家一起来学习吧。..

网友评论

Copyright 2020 www.tdogsoftware.com 【零度软件园】 版权所有 软件发布

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 点此查看联系方式