Nacos中的事件通知NotifyCenter、DefaultPublisher、InstancesChangeNotifier

news2024/9/21 1:20:56

在 Nacos 中,NotifyCenterDefaultPublisherInstancesChangeNotifier 三者是用于事件通知机制的重要组成部分。它们相互协作来实现服务实例变更时的通知和发布。

NotifyCenter —— 事件通知中心

NotifyCenter 是 Nacos 中的事件通知中心,负责管理事件的订阅和发布。

它提供了事件的统一管理接口,并负责将事件从发布者传播到订阅者。所有的事件传递都是通过 NotifyCenter进行协调的。

它充当一个全局的事件调度中心,协调事件的发布和订阅行为。任何涉及到事件驱动的操作都需要经过 NotifyCenter

实现原理

  • NotifyCenter 维护了一个全局的事件处理器(Publisher)列表,用于处理不同类型的事件。
  • 当事件发生时,NotifyCenter 将事件传递给对应的 Publisher,而 Publisher 则将事件分发给相应的订阅者。
  • NotifyCenter 提供了事件发布、订阅、取消订阅等接口,使事件管理更加灵活。

常用方法

  • registerSubscriber(Subscriber subscriber):注册事件的订阅者
  • deregisterSubscriber(Subscriber subscriber):取消订阅者的注册
  • publishEvent(Event event):发布一个事件,将事件传给相应的订阅者

DefaultPublisher —— 事件发布者

DefaultPublisher 是 Nacos 中事件发布的具体实现类之一。它负责将事件发布给已经注册的事件监听器(订阅者),并确保事件能被正确消费。

实现原理

  • DefaultPublisher 通过内部的事件队列或线程池处理事件。当事件被推送到 DefaultPublisher 时,它会将事件放入队列中,并异步处理这些事件。
  • 它使用了基于线程池的模型,确保高并发情况下,事件发布不会阻塞调用方,并能有效处理大量的事件。
  • 当有事件监听器(订阅者)注册后,DefaultPublisher 将会将事件传递给这些监听器处理。

常用方法

  • init():初始化发布器,比如初始化线程池或资源池
  • publish(Event event):发布事件(将事件放到事件队列中,之后进行事件发布)
  • addSubscriber(Subscriber subscriber):增加事件订阅者
  • removeSubscriber(Subscriber subscriber):移除事件订阅者
  • notifySubscriber(Subscriber subscriber,Event event):通知事件订阅者具体事件

InstancesChangeNotifier —— 服务实例变更事件通知器

InstancesChangeNotifier 是专门用于通知 Nacos 中服务实例变更的类,它继承了 Subscriber,负责监听服务实例的变化事件。

每当 Nacos 的服务实例列表发生变化时,InstancesChangeNotifier 会被通知,InstancesChangeNotifier会回调具体的EventListener的onEvent方法。

实现原理

  • InstancesChangeNotifier内部维护了一个服务实例key和事件监听者的映射集合Map<String,ConcurrentHashSet<EventListener>> listenerMap,key为服务实例的key,value是该实例变更监听者集合。
  • InstancesChangeNotifier接收到实例变更事件后,会从事件中获取到服务实例key,然后在listenerMap获取到对应的监听者Listener,然后循环回调Listener的onEvent方法

常用方法

  • registerListener(String serviceName,String clusters,EventListener listener):注册服务实例变更事件监听者
  • deregisterListener(String serviceName,String clusters,EventListener listener):注销服务实例变更事件监听者
  • onEvent(Event event):当实例变更事件触发时的回调。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2150721.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

扣子智能体实战:一键生成公众号图文,AI时代文盲也能写公众号,赚钱秘籍

文章目录 一&#xff0c;需求简述二&#xff0c;智能体制作1&#xff0c;智能体人设和技能2&#xff0c;流程开发2.1 设置开始节点2.2 增加一个生成标题的大模型节点2.3 增加一个代码节点 2.4 增加一个插件节点用以生成文章配图2.4 增加一个大模型节点-根据标题和思路生成文章大…

Excel--WPS 函数与公式技巧(轻松搞定各类排名)

一、直接按成绩或数值的排序&#xff08;rank函数轻松搞定&#xff09; 以上函数非常简单&#xff0c;记住两点&#xff1a; 1.rank排名同分作为同一名次&#xff0c;后面的名次需要占位&#xff0c;如&#xff0c;以上两个70分&#xff0c;同为第8名&#xff0c;那么第9名将被…

Shader 中的光源

1、Shader 开发中常用的光源属性 Unity当中一共支持四种光源类型&#xff1a; 平行光&#xff08;Directional&#xff09;点光源&#xff08;Point&#xff09;聚光灯&#xff08;Spot&#xff09;面光源&#xff08;Area&#xff09;— 面光源仅在烘焙时有用 不管光源类型到…

可视化工具箱-Visualization Toolkit(VTK)

一、Visualization Toolkit&#xff08;VTK&#xff09;简概 可视化工具箱&#xff08;VTK&#xff09;&#xff0c;是一个用于3D计算机图形、图像处理和科学可视化的开源软件系统&#xff0c;其包含C类库和Tcl/Tk、Java与python的解释型接口层。VTK支持各种可视化算法&#xf…

软设9.20

1 已知一个文件中出现的各字符及其对应的频率如下表所示。若采用定长编码&#xff0c;则该文件中字符的码长应为()。若采用Hufman编码&#xff0c;则字符序列“face”的编码应为()。 1.&#xff08;&#xff09; A.2 B.3 C.4 D.5 2.&#xff08;&#xff09; A.110001001101…

小程序构建npm失败

小程序构建npm失败 项目工程结构说明解决方法引入依赖导致的其他问题 今天在初始化后的小程序中引入TDesign组件库&#xff0c;构建npm时报错。 项目工程结构说明 初始化后的项目中&#xff0c;包含miniprogram文件夹和一些项目配置文件&#xff0c;在project.config.json文件中…

VS运行程序时报错--无法定位程序输入点

发现问题&#xff1a; VS 在运行程序时&#xff0c;报错&#xff1a; 找到原因&#xff1a; 因为我在替换动态库的时候&#xff0c;只替换了lib库&#xff0c;没有替换运行目录下的dll库&#xff0c;运行时候的dll与程序中的lib库不对应。 替换库后就能解决这个问题。

秋意渐浓,温暖筹备——铁路职工御寒劳保鞋,寒冬无阻!

随着秋意渐浓&#xff0c;气温逐渐走低&#xff0c;冬日的寒风已在不远处蓄势待发。对于坚守在铁路一线的工友们来说&#xff0c;这不仅是季节的变换&#xff0c;更是工作装备升级换代的信号。意味着需要更加注重防寒保暖&#xff0c;以确保在寒冷的天气中能够安全、高效地工作…

前端大数据渲染:虚拟列表、触底加载与分堆渲染方案

前言 针对表格展示数据&#xff0c;用户提出要求前端在表格下面有一展示多少条数据的选项&#xff0c;如果要求一次性展示10000条数据&#xff0c;如果直接染会造成页面的卡顿&#xff0c;渲染速度下降&#xff0c;内容展示慢,如果有操作&#xff0c;操作会卡顿 下面总结常见…

工程师 - PFM介绍

在电子电路设计中&#xff0c;PFM&#xff08;Pulse Frequency Modulation&#xff0c;脉冲频率调制&#xff09;是一种调制技术&#xff0c;其主要特点是在负载变化时调整脉冲的频率&#xff0c;而保持脉冲的宽度&#xff08;时间长度&#xff09;相对恒定。与PWM&#xff08;…

lambda 自调用递归

从前序与中序遍历序列构造二叉树 官方解析实在是记不住&#xff0c;翻别人的题解发现了一个有意思的写法 class Solution { public:TreeNode* buildTree(vector<int>& preorder, vector<int>& inorder) {auto dfs [](auto&& dfs, auto&&…

深度学习-图像处理篇1.1-1.2神经网络

1.1卷积神经网络基础 卷积层 对彩色RGB图像进行卷积 1.卷积核的通道数与输入特征层的通道数相同 2.卷积输出的特征矩阵通道数与卷积核个数相同 池化层 池化中一般池化核大小和步长大小一样 思考 加上偏移量bias该如何计算? 卷积计算时加上偏移量即可 加上激活函数该如何计…

Nomad Web服务终于成熟了!

大家好&#xff0c;才是真的好。 9月份HCL Notes/Domino相关产品发布的还真不少&#xff0c;前脚刚发布了HCL Notes Domino 14.5 EA1&#xff0c;后脚就迎来了Notes Domino 14.0FP2IF1&#xff0c;还有Nomad 1.0.13版本。 在我的记忆中&#xff0c;他们不喜欢数字13&#xff…

分布式消息中间件kafka

文章目录 什么是kafka?整体架构 kafka核心概念1. 生产者 (Producer)2. 消费者 (Consumer)3. 主题 (Topic)4. 分区 (Partition)5. 经纪人 (Broker)6. 复制 (Replication)7. 消费者组 (Consumer Group)8. 日志段 (Log Segment) 主要功能1. 高吞吐量2. 可靠的消息传递3. 发布/订阅…

打印菱形(图像打印)

//打印菱形 // ---* // *** // ***** // ******* // ***** // *** // * //一共需要line行&#xff0c;分成两边&#xff0c;上半部分需要line/21行 //下半部分需要line/2行 #include<stdio.h> #define L 11 //行 #define R 11 //列 int main() {int …

十三 系统架构设计(考点篇)试题

A 对&#xff0c;B对&#xff0c;C好像是分布式中间件吧&#xff0c;D对。选C 第一题&#xff0c;感觉肯定有交互支持&#xff0c;选B;第二B。实际答案&#xff1a;D和B。 在一个分布式系统中&#xff0c;中间件通常提供两种不同类型的支持&#xff1a; &#xff08;1&#xff…

【读书笔记-《30天自制操作系统》-23】Day24

本篇内容依然比较简单&#xff0c;主要是优化窗口功能以及开发定时器应用程序。首先是优化窗口的切换功能&#xff0c;实现通过键盘和鼠标切换窗口&#xff0c;然后是实现通过鼠标关闭窗口。接着实现不同窗口输入状态的切换&#xff0c;最后是实现定时器的API与应用程序。 1.…

mybatisplus乐观锁

使用方法&#xff1a; 1.添加version锁标记字段 2.实体类添加对应字段&#xff0c;并加上Version注解 3.添加配置类 Configuration public class MpComfig {Beanpublic MybatisPlusInterceptor mpInterceptor(){MybatisPlusInterceptor mpInterceptor new MybatisPlusIntercep…

VuePress搭建文档网站/个人博客(详细配置)主题配置-侧边栏配置

天行健&#xff0c;君子以自强不息&#xff1b;地势坤&#xff0c;君子以厚德载物。 每个人都有惰性&#xff0c;但不断学习是好好生活的根本&#xff0c;共勉&#xff01; 文章均为学习整理笔记&#xff0c;分享记录为主&#xff0c;如有错误请指正&#xff0c;共同学习进步。…

沟通更高效:微信群转移至企业微信操作攻略!

微信群转移到企业微信并不难&#xff0c;具体操作如下&#xff1a; 打开移动端企业微信主页&#xff0c;找到微信聊天栏中的【接收微信中的工作消息】&#xff1b; 点击【前往微信选择群聊】&#xff0c; 跳转到微信&#xff1b; 选择微信上的工作群聊&#xff0c;只能选择作…