场景1 启动时
dubbo服务提供端在Zookeeper上注册的节点目录:假设接口名称是:com.bob.dubbo.service.CityDubboService
zk节点结构
dubbo服务提供端连接到注册中心,注册自身到/providers
目录下,其节点信息参考如下。
其中第4个节点是临时节点。心跳检测超时zk会删除临时节点。
dubbo服务消费端连接到注册中心,注册自身到/consumers
目录下,同时还会订阅/providers
目录,实时获取其上Provider的URL字符串信息。同时订阅获得的Provider信息持久化到本地文件。
/providers
下的临时节点变动时,dubbo服务消费端会拉取最新的/providers
目录。
5s定时任务
dubbo服务提供端(Provider)或dubbo服务消费端(Consumer)启动成功后,会创建一个5s定时任务,内容如下:
Provider向zookeeper注册自身的url,生成一个临时的znode
Provider从Dubbo容器中退出,停止提供RPC调用。也就是移除zookeeper内自身url对应的znode
Consumer订阅 `/dubbo/Service/providers` 目录的子节点,生成ChildListener
Consumer从Dubbo容器中退出,移除之前创建的ChildListener
场景2 zk服务器挂掉
dubbo服务提供端(Provider)或dubbo服务提供端(Consumer)内部的zkClient会不停地尝试连接Server。
连接成功后重新注册和订阅。
连接不成功,不影响dubbo服务提供端(Consumer)调用。加载本地文件的Provider信息进行调用。
如果一个dubbo客户端出现异常,原因在以下过程中
5s定时请求zk获取服务节点更新本地缓存。
- 新增节点
- 移除节点
- 更新节点信息
一个接口的标识需要dubbo url+group+version
zk挂了,使用本地缓存。再20s定时连接zk。
重连上之后,获取服务节点更新本地缓存。
服务节点连接不上,直接报错。
参考:
https://blog.csdn.net/qq_27529917/article/details/80632078
https://juejin.im/post/5cd29c1c6fb9a031f0381306
网友评论