dubbo-go（dubbo工作流程）

本篇文章给大家谈谈dubbo-go，以及dubbo工作流程对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、Dubbo-发布服务执行的流程
• 2、聊聊dubbo-go的metricsFilter
• 3、Dubbo简介
• 4、2022-04-03 dubbogo 调用部署在不同zk的同一服务

Dubbo-发布服务执行的流程

我们以dubbo 的xml配置为例：

dubbo服务发布只需在spring.xml中如下配置即可：

dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" /

通过dubbo于spring的融合可以了解到dubbo:service标签是通过ServiceBean解析封装。

ServiceBean这个类继承 了ServiceConfig实现了spring的5个接口

InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener, BeanNameAware 来融入到spring的启动过程。

ServiceBean实现了 ApplicationListener 接口，当spring容器触发了ContextRefreshedEvent事件时，

就会调用 ServiceConfig 中的export()方法发布申明的dubbo服务，

ServiceConfig 中的export()方法部分源码如下，如果申明了delay（延迟多少），如敏那么延迟调用doExport()发布这个服务，如果没有设置则直接调用doExport()发布服务：

接下来看ServiceConfig的doExport()方法

1，检查中是否配置了interface, 如果为空，那么抛出异常：

if (interfaceName == null || interfaceName.length() == 0) { throw new IllegalStateException("interface not allow null!");}

2，检查接口类型必需为接口

if(! interfaceClass.isInterface()) {

throw new IllegalStateException("The interface class " + interfaceClass + " is not a interface!");

}

3，检查方法是否在接口中存在

4，检查引用不为空，并且引用必需实现接口 interface="com.alibaba.dubbo.demo.DemoService" ref="demoService"

5，检查checkApplication(); checkRegistry(); checkProtocol();有效性。

6，调用ServiceConfig.doExportUrls()发布dubbo服务

ServiceConfig.doExportUrls()如下：

通过调用loadRegistries(true)得拆喊到所有registry的url地址，例如配置了

dubbo:registry address="zookeeper://127.0.0.1:2181"

配置结果为dubbo.registry.address=zookeeper://127.0.0.1:2181；

protocols就是将要发布服务的协议集合(dubbo服务可以同时暴露多种协议)，例如配置了

dubbo:protocol name="dubbo" port="20880"

dubbo.protocol.name=dubbo ,  dubbo.protocol.port=20880

ServiceConfig.doExportUrlsFor1Protocol()

先把application、module、provider、旅橡野protocol、exporter、registries、monitor所有属性封装到Map中例如protocol=dubbo，host=10.0.0.1，port=20880，path=com.alibaba.dubbo.demo.TestService等，然后构造dubbo定义的统一数据模型URL:

URL url = new URL(name, host, port, (contextPath == null || contextPath.length() == 0 ? "" : contextPath + "/") + path, map);

这个url非常重要，贯穿整个dubbo服务的发布和调用过程，可以在服务发布后在dubbo-monitor中看到；

ServiceConfig.doExportUrlsFor1Protocol()中根据scope判断服务的发布范围：

如果配置scope = none， 那么不需要发布这个dubbo服务；

没有配置scope = none，且配置的scope != remote， 那么本地暴露 这个dubbo服务；

没有配置scope = none，且配置的scope != remote且配置的scope != local，那么远程暴露这个dubbo服务（例如远程暴露这个服务到zk上，默认情况下scope没有配置，就是在这里发布服务）；

以上如果执行成功，会把dubbo服务到zookeeper上，invoker.getUrl()的值为

registry://10.0.53.87:2188/com.alibaba.dubbo.registry.RegistryService?application=dubbo-testdubbo=2.0.0export=dubbo%3A%2F%2F10.52.16.218%3A20886%2Fcom.alibaba.dubbo.demo.DemoService%3Fanyhost%3Dtrue%26application%3Ddubbo-test%26dubbo%3D2.0.0%26interface%3Dcom.alibaba.dubbo.demo.DemoService%26loadbalance%3Droundrobin%26methods%3DsayHello%26owner%3Dafei%26pid%3D2380%26side%3Dprovider%26timestamp%3D1509953019382owner=afeipid=2380®istry=zookeeper×tamp=150995301934：

接下来我们分析

Protocol.export()暴露服务接口：

然后调用RegistryProtocol.export()：

核心调用registry.register(registedProviderUrl)。

调用AbstractRegistry.register(URL)，把这次需要注册的URL加到Set registered中，即本地缓存新的注册URL；

在ZookeeperRegistry.doRegister(URL)调用AbstractZookeeperClient.create()，toUrlPath将URL形式的地址转换成zookeeper路径，最终在AbstractZookeeperClient中把需要发布的服务的URL保存到zookeeper：

ZookeeperRegistry.doRegister(url)注册服务如果失败：

如果开启了启动检查check=true，那么直接抛出异常；

如果没有开启启动检查，那么将失败的注册请求记录到失败列表，定时重试;

核心调用registry.subscribe(overrideSubscribeUrl, overrideSubscribeListener):

对发布的dubbo服务的这个url进行监听， 当服务变化有时通知重新暴露服务， 以zookeeper为例，暴露服务会在zookeeper生成一个节点，当节点发生变化的时候会触发overrideSubscribeListener的notify方法重新暴露服务

注册服务失败的重试机制：

注册服务失败后，会将url加入重试url集合中，failedRegistered.add(url);重试任务在FailbackRegistry中实现：

注册的监听机制：

订阅并设置监听registry.subscribe(overrideSubscribeUrl, overrideSubscribeListener);

-- FailbackRegistry.subscribe(URL url, NotifyListener listener)

-- ZookeeperRegistry.doSubscribe(final URL url, final NotifyListener listener)，部分实现源码如下：

当服务有变化的时候:

doNotify(url, listener, urls);

AbstractRegistry.notify(URL url, NotifyListener listener, List urls)

-- RegistryDirectory.notify(List urls)

-- RegistryDirectory.refreshInvoker(List invokerUrls)，这里调用toMethodInvokers(Map invokersMap)的实现比较重要，将invokers列表转成与方法的映射关系，且每个方法对应的List需要通过Collections.sort(methodInvokers, InvokerComparator.getComparator());排序，然后，还要将其转为unmodifiable的map

其中 InvokerComparator 的定义如下，即直接根据url进行比较排序

dubbo协议发布服务会调用DubboProtocol.export()的过程：

从Invoker中获取URL： URL url = invoker.getUrl();

根据URL得到key, 由暴露的服务接口+端口组成，例如com.alibaba.dubbo.demo.DemoService:20886 ；  String key = serviceKey(url);

构造DubboExporter存到Map中local cache化：

DubboExporter exporter = new DubboExporter(invoker, key, exporterMap); exporterMap.put(key, exporter);

调用DubboProtocol.openServer()开启netty(默认)服务保持通信，并设置requestHandler处理consumer对provider的调用请求；

DubboProtocol.openServer()：

key的值就是IP:Port，例如10.52.17.167:20886，根据key从serverMap中如果取不到ExchangeServer，表示还没绑定服务端口，需要调用createServer(url)--Exchangers.bind(url, requestHandler)--Transporters.getTransporter().bind(url, handler)(dubbo支持mina，netty，grizzly，默认实现是netty) -- NettyTransporter.bind(URL, ChannelHandler) -- NettyServer.open()；

dubbo默认调用的是netty

Netty服务几个重要的地方

构造 ChannelPipeline 时指定了编码解码，其中编码为NettyCodecAdapter.getEncoder()，解码为NettyCodecAdapter.getDncoder()；

指定了handler为final NettyHandler nettyHandler = new NettyHandler(getUrl(), this);处理请求；

[img]

聊聊dubbo-go的metricsFilter

本文主要研究一下dubbo-go的metricsFilter

dubbo-go-v1.4.2/filter/filter_impl/metrics_filter.go

dubbo-go-v1.4.2/穗备filter/filter_impl/metrics_filter.go

dubbo-go-v1.4.2/filter/filter_impl/metrics_filter.go

dubbo-go-v1.4.2/filter/filter_impl/metrics_filter.go

metricsFilter的Invoke方法在invoker.Invoke(ctx, invocation)前后知族友记录时间搭槐，最后算出duration，然异步遍历p.reporters，执行reporter.Report

Dubbo简介

Dubbo是Alibaba开源的分布式服务框架，它按照分层的方式来架构，使用这种方式可以使各层解耦。

Dubbo在调用远程的服务的时候再本地有一个接口，就想调用本地方法一样去调用，底层实现好参数传输和远程服务运行结果传回之后的返回。

Dubbo的特点：

（1）它主要使用高效的网络框架和序列化框架，让分布式服务之间调用效率更高。

（2）采用注册中心管理众多的服务接口地址，当你想调用服务的时候只需要跟注册中心询问谈歼瞎即可，不像使用WebService一样每个服务都得记录好接口调用方式。

（3）监控中心时实现服务方和调用方之间运行状态的监控，还能控制服务的优先级、权限、权重、上下线等，让整个庞大的分布式服务系统的维护和治理比较方便。

（4）高可用，如果有服务挂了，注册中心就会从服务列表去掉该节点，客户端会像注册中心请求另一台可用的服务节点重新调用。同时注册中心也能实现高可用（ZooKeeper）。

（5）负载均衡，采用软负载均衡算法实现对多个相同服务的节点的请求负载均衡。

Dubbo需要四大基本组件：Rigistry,Monitor,Provider,Consumer。

1、含空监控中心的配置文件-dubbo.properties文件

（1）容器改改，监控中心是在jetty和spring环境下运行，依赖于注册中心，日志系统是log4j

    dubbo.container = log4j,spring,registry,jetty

（2）监控服务的名称，监控系统对整个Dubbo服务系统来说也是一个服务

    dubbo.application.name = simple-monitor

（3）服务的所有者，这是Dubbbo的服务的功能，可以指定服务的负责人

    dubbo.application.owner = coselding

（4）注册中心的地址，配置后监控中心就能通过注册中心获取当前可用的服务列表及其状态，在页面向你汇报Dubbo中的服务运行情况。

    dubbo.registr.address = multicast://{ip}:{port} //广播

    dubbo.registr.address = zookeeper://{ip}:{port} //zookeper

    dubbo.registr.address = redis://{ip}:{port} //redis

    dubbo.registr.address = dubbo://{ip}:{port} //dubbo

（5）dubbo协议端口号

    dubbo.protocol.port = 7070

（6）jetty工作端口号

    dubbo.jetty.port = 8082

（7）工作目录，用于存放监控中心的数据

    dubbo.jetty.directory = ${user.home}/monitor

（8）监控中心报表存放目录

    dubbo.charts.directory=${dubbo.jetty.directory}/charts

（9）监控中心数据资料目录

    dubbo.statistics.directory=${user.home}/monitor/statistics

（10）监控中心日志文件路径

    dubbo.log4j.file=logs/dubbo-monitor-simple.log

（11）监控中心日志记录级别

    dubbo.log4j.level=WARN

2、Dubbo提供负载均衡方式

（1）Random，随机，按权重配置随机概率，调用量越大分布越均匀，默认方式。

（2）RounRobin，轮询，按权重设置轮询比例，如果存在比较慢的机器容易在这台机器上请求阻塞较多。

（3）LeastActive，最少活跃调用数，不支持权重，只能根据自动识别的活跃数分配，不能灵活调配。

（4）ConsistenHash，一致性hash，对相同参数的请求路由到一个服务提供者上，如果有类似灰度发布需求可采用。

3、Dubbo过滤器

Dubbo初始化过程加载ClassPath下的META-INF/dubbo/internal/，META-INF/dubbo/，META-INF/services/三个路径下的com.alibaba.dubbo.rpc.Filter文件。文件内容：

    Name = FullClassName,这些类必须实现Filter接口。

自定义Filter类：

配置文件在配置过滤器，consumer.xml中：

Dubbo对过滤器的加载过程：

    先加载三个路径下的com.alibaba.dubbo.rpc.Filter文件里面的键值对，key为过滤器名称，value为过滤器的类的全限定名(这个类必须实现Dubbo中的Filter接口)。

    自定义的类中@Active注解是过滤器设定的全局基本属性。

    Spring在加载consumer.xml文件时，通过 dubbo:consumer filter="xxx" id = "xxx" retrries = "0"这个配置指定消费者端要加载的过滤器，通过filter属性指定过滤器名称。

@Activate注解-自动激活，group属性是表示匹配了对应的角色才被加载，value表示表明过滤条件，不写则表示所有条件都会被加载，写了则只有dubbo URL中包含该参数名且参数值不为空才被加载，这个参数会以dubbo协议的一个参数K-V对传到Provider。

4、Dubbo的Provider配置

5、Dubbo的Consumer配置

1、Dubbo是什么？

Dubbo是阿里巴巴开源的基于Java的高性能RPC分布式框架。

2、为什么使用Dubbo？

很多公司都在使用，经过很多线上的考验，内部使用了Netty，Zookeeper，保证了高性能可用性。

使用Dubbo可以将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，可以提高业务复用灵活性扩展，使前端应用能快速的响应对边的市场需求。分布式架构可以承受更大规模的并发流量。

Dubbo的服务治理图：

3、Dubbo和Spring Cloud的区别

两个没有关联，但是非要说区别，有如下几点：

（1）通信方式不同，Dubbo使用RPC通信，Spring Cloud使用HTTP Restful方式

（2）组成部分不同

4、Dubbo支持的协议

dubbo://  （推荐）；rmi:// ；hessian:// ；http:// ；webservice:// ；thrift:// ；memcached:// ；redis:// ；rest:// 。

5、Dubbo需要容器吗？

不需要，如果硬要容器的话，会增加复杂性，同时也浪费资源。

6、Dubbo内置的服务容器

Spring Container；Jetty Container；Log4j Container。

7、Dubbo中节点角色

Register，Monitor，Provider，Consumer，Container(服务运行的容器)。

8、Dubbo的服务注册和发现的流程图

9、Dubbo的注册中心

默认使用Zookeper作为注册中心，还有Redis，Multicast，dubbo注册中心。

10、Dubbo的配置方式

Spring配置方式和Java API配置方式

11、Dubbo的核心配置

（1）dubbo:service 服务配置

（2）dubbo:referece 引用配置

（3）dubbo:protocol 协议配置

（4）dubbo:application 应用配置

（5）dubbo:registry 注册中心配置

（6）dubbo:monitor 监控中心配置

（7）dubbo:provider 提供方配置

（8）dubbo:consumer 消费方配置

（9）dubbo:method 方法配置

（10）dubbo:argument 参数配置

12、在Provider 节点上可以配置Consumer端的属性有哪些？

（1）timeout：方法调用超时

（2）retries：失败重试次数，默认是2次

（3）loadbalance：负载均衡算法，默认随机

（4）actives消费者端，最大并发调用控制

13、Dubbo启动时如果依赖的服务不可用会怎样

Dubbo缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止Spring初始化完成。默认check ="true"。

14、Dubbo序列化框架

推荐使用Hessian序列化，还有Dubbo，FastJson，Java自带序列化。

15、Dubbo的通信框架

默认使用Netty框架，另外也提供了Mina，Grizzly。

16、Dubbo集群容错方案

（1）Failover Cluster，失败自动切换，自动重试其他服务器。

（2）Failfast Cluster，快速失败，立即报错，只发起一次调用。

（3）Failsafe Cluster，失败安全，出现异常时，直接忽略。

（4）Failback Cluster，失败自动恢复，记录失败请求，定时重发。

（5）Forking Cluster，并行调用多个服务器，只要一个返回成功即可。

（6）Broadcast Cluster，广播逐个调用所有提供者，任意一个报错则报错。

17、Dubbo的负载均衡策略

（1）Random LoadBalance，随机，按权重设置随机概率，默认。

（2）RoundRobin LoadBalace，轮询，按公约后的权重设置轮训比例。

（3）LeastActive LoadBalace，最少活跃调用数，相同活跃数的随机。

（4）ConsistenHash LoadBalance，一致性hash，相同参数的请求总是发到用一个服务器。

18、指定某一个服务

可以配置环境点对点直连，绕过注册中心，将以服务接口为单位，忽略注册中心的提供者列表。

dubbo:reference interface="com.weidian.dubbo.IMyDemo" version="1.0" id="myDemo" url="dubbo://127.0.0.1:20880/"/dubbo:reference

19、Dubbo多协议

Dubbo允许配置多协议，在不同服务器上支持不同协议，或者同一服务支持多种协议。

20、当一个服务有多种实现时怎么做？

当一个接口有多种是现实，可以用group属性来分组，服务提供方和消费方都指定同一个group即可。

21、兼容旧版本

使用版本号过度，多个不同版本的服务注册到注册中心，版本号不同的服务相互间不引用。

22、Dubbo可以缓存吗？

Dubbo提供声明式缓存，用于加速热门数据的访问速度，以减少用户加缓存的工作量。

23、Dubbo服务之间的调用时阻塞的吗？

默认是同步等待结果阻塞的，支持异步调用。Dubbo是基于NIO的非阻塞实现并行调用的，客户端不需要启动多线程即可完成并行调用多个远程服务，相对多线程开销较小，异步调用会返回一个Future对象。

24、Dubbo不支持分布式事务

25、Dubbo必须依赖的包

Dubbo必须依赖JDK，其他为可选。

26、Dubbo使用过程中的问题

Dubbo的设计目的是为了满足高并发小数据量的rpc请求，在大数据量下性能表现不是很好，建议使用rmi或http协议。

27、Dubbo的管理控制台的作用

路由规则，动态配置，服务降级，访问控制，权重调整，负载均衡。

28、Spring boot整合Dubbo

（1）添加依赖

        !-- --

        dependency

            groupIdcom.alibaba.boot/groupId

            artifactIddubbo-spring-boot-starter/artifactId

            version0.1.0/version

        /dependency

        !-- --

        dependency

            groupIdcom.101tec/groupId

            artifactIdzkclient/artifactId

            version0.10/version

        /dependency

（2）配置dubbo

    ## Dubbo 服务提供者配置

    spring.dubbo.application.name=provider

    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181

    spring.dubbo.protocol.name=dubbo

    spring.dubbo.protocol.port=20880

    spring.dubbo.scan=org.spring.springboot.dubbo

    ## Dubbo 服务消费者配置

    spring.dubbo.application.name=consumer

    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181

    spring.dubbo.scan=org.spring.springboot.dubbo

2022-04-03 dubbogo 调用部署在不同zk的同一服务

在 2021-10-17 dubbogo 基础使用 中，介绍了如何用 go 写一个部署到 zookeeper 的 dubbo 服务，这次编写一个 go 语言的 dubbo 调用端。并且支持同时连接到多个 zookeeper ，根据需要调用不同 zk 上的同一个服务

这里我们部署两个 zookeeper ，端口号分别是 2181 和 2182

这里我们配置了两个 UserService 的引用，并且设置了不同罩誉的别名。指定了每个引用连接各自的 zk .

注慧宽意，这里 service.UserService 为服务提供方的接口，我们直接继承他

服务1 的日志如下：

服务2 的物碧段日志如下：

github-dubbogodemo

关于dubbo-go和dubbo工作流程的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。