Dubbo-聊聊注册中心的设计( 六 ) _生活百科

注册/订阅AbstractRegistry 实现了 Registry 接口，当新节点注册进来时候registry() 方法，会将当前节点要注册的 URL缓存到 registered集合，当节点下线时候，unregistry() 方法会从 registered 集合删除指定的 URL 。当消费者新增加一个订阅的时候，subscribe() 方法会将当前节点作为 Consumer 的 URL 以及相关的 NotifyListener 记录到 subscribed 集合，当消费者取消一个订阅的时候，unsubscribe() 方法会将当前节点的 URL 以及关联的 NotifyListener 从 subscribed 集合删除。这四个方法相对比较简单，这里不做展示，此处设计为抽象类，当子类重写的时候可以对其进行增强。
恢复/销毁当因为网络问题与注册中心断开连接之后，会进行重连，重新连接成功之后，会调用 recover() 方法将 registered 集合中的全部 URL 重新执行register() 方法，恢复注册数据。同样，recover() 方法也会将 subscribed 集合中的 URL 重新执行subscribe() 方法，恢复订阅监听器。当前节点下线的时候，destroy() 方法会调用 unregister() 方法和 unsubscribe() 方法将当前节点注册的 URL 以及订阅的监听全部清理掉，此外还会销毁本实例。
public void destroy() { if (logger.isInfoEnabled()) { logger.info("Destroy registry:" + getUrl()); } Set<URL> destroyRegistered = new HashSet<>(getRegistered()); if (!destroyRegistered.isEmpty()) { for (URL url : new HashSet<>(destroyRegistered)) { if (url.getParameter(DYNAMIC_KEY, true)) { try { //取消注册 unregister(url); if (logger.isInfoEnabled()) { logger.info("Destroy unregister url " + url); } } catch (Throwable t) { logger.warn("Failed to unregister url " + url + " to registry " + getUrl() + " on destroy, cause: " + t.getMessage(), t); } } } } Map<URL, Set<NotifyListener>> destroySubscribed = new HashMap<>(getSubscribed()); if (!destroySubscribed.isEmpty()) { for (Map.Entry<URL, Set<NotifyListener>> entry : destroySubscribed.entrySet()) { URL url = entry.getKey(); for (NotifyListener listener : entry.getValue()) { try { //取消订阅 unsubscribe(url, listener); if (logger.isInfoEnabled()) { logger.info("Destroy unsubscribe url " + url); } } catch (Throwable t) { logger.warn("Failed to unsubscribe url " + url + " to registry " + getUrl() + " on destroy, cause: " + t.getMessage(), t); } } } } //移除注册中心 AbstractRegistryFactory.removeDestroyedRegistry(this); }

Dubbo-聊聊注册中心的设计( 六 )

经验总结扩展阅读

在恋爱关系中|男人不会珍惜的两种女人，你是其中之一吗？

2022年10月12日走亲访友黄道吉日 2022年农历九月十七宜走亲访友吗

固态硬盘格式化选什么格式比较好固态硬盘格式化选哪种格式比较好

浅谈是什么意思

创造与魔法魔法深海旧日遗蜕技能介绍

一千多的女表什么牌子好点,能推荐一些适合女生的手表品牌吗？价格不超过1千的

英雄联盟手游绑定端游账号

要跟着美容生物钟来护肤

这四种体质的女性，很容易怀孕，看看你是不是？

发型昆明正规美容美发学校带你了解美容美发的作用

女士高档手表品牌推荐,女士手表排行榜10强女士手表推荐

三无车辆是哪三无,三无车辆交警怎么处理

深零设计师姚工|合肥夫妇家中的高级场面，130平坚决沙发不靠墙，效果不是一般的实用

2022年属鸡农历九月提车黄道吉日

涂一层素颜也能美翻天，谁用谁爱上......这个防晒隔离太绝了

芋圆是开水下锅还是冷水下锅

hosts文件位置?

诗经多少篇

广东珠海中考时间2022年具体时间广东珠海中考时间及科目安排

什么样的鸡蛋是坏的鸡蛋是坏的能吃吗