【Nacos源码篇(六)】Event源码分析

先贴Event抽象类的源码

public abstract class Event implements Serializable {
private static final AtomicLong SEQUENCE = new AtomicLong(0);
private final long sequence = SEQUENCE.getAndIncrement();
public long sequence() {
return sequence;
}
}

⚡️ 其实这个类没什么具体的功能，仅仅起到一个标记作用，用来标记其子类是一个事件类，而这个事件的具体属性也都在其子类里面

拿一个具体的实现来瞅瞅

/**
* 操作客户端事件
* Operation client event.
*/
public class ClientOperationEvent extends Event {
private static final long serialVersionUID = -4582413232902517619L;
private final String clientId;
private final Service service;
public ClientOperationEvent(String clientId, Service service) {
this.clientId = clientId;
this.service = service;
}
public String getClientId() {
return clientId;
}
public Service getService() {
return service;
}
/**
* 客户端服务注册事件
* Client register service event.
*/
public static class ClientRegisterServiceEvent extends ClientOperationEvent {
private static final long serialVersionUID = 3412396514440368087L;
public ClientRegisterServiceEvent(Service service, String clientId) {
super(clientId, service);
}
}
/**
* 客户端注销服务事件
* Client deregister service event.
*/
public static class ClientDeregisterServiceEvent extends ClientOperationEvent {
private static final long serialVersionUID = -4518919987813223120L;
public ClientDeregisterServiceEvent(Service service, String clientId) {
super(clientId, service);
}
}
/**
* 客户端订阅服务事件
* Client subscribe service event.
*/
public static class ClientSubscribeServiceEvent extends ClientOperationEvent {
private static final long serialVersionUID = -4518919987813223120L;
public ClientSubscribeServiceEvent(Service service, String clientId) {
super(clientId, service);
}
}
/**
* 客户端取消订阅服务事件
* Client unsubscribe service event.
*/
public static class ClientUnsubscribeServiceEvent extends ClientOperationEvent {
private static final long serialVersionUID = -4518919987813223120L;
public ClientUnsubscribeServiceEvent(Service service, String clientId) {
super(clientId, service);
}
}
}

⚡️ 我们可以看到的是，这个ClientOperationEvent客户端操作事件里面具体定义了一些其他的事件，如客户端服务注册事件，客户端注销服务事件，客户端订阅服务事件，客户端取消订阅服务事件
⚡️ 均继承自ClientOperationEvent和Event，所以这里的每一个事件均含有sequence，clientId，service这些属性
⚡️ 既然这里每个事件类都携带有本身这个事件所带有的含义（属性），如客户端注册，自然就应该有客户端id以及客户端所包含的信息，如namespace，group等，所以不同的订阅者只需要按需来对这个事件进行相应的处理
⚡️ 当然每次新生成一个事件，sequence都会原子自增1次，因为private static final AtomicLong SEQUENCE = new AtomicLong(0)这段代码，SEQUENCE 是static定义的，并且每次new一个Enent事件出来的时候，sequence = SEQUENCE.getAndIncrement();即模板SEQUENCE就会原子增加，可以看下面这段代码

public static void main(String[] args) {
for(int i=0;i<10;i++){
ClientOperationEvent clientOperationEvent = new ClientOperationEvent(null, null);
System.out.print(clientOperationEvent.sequence());
}
}
=================================================
0123456789

不过有个小问题，如果达到long的最大值的话（9223372036854775807）会不会直接事件通知就down了？

当然，既然唠嗑的是一个事件，如果看了之前的几篇文章自然就会想到，订阅者Subscriber，毕竟事件的落地还是订阅者
这里还是贴上上篇订阅者Subscriber里比较熟悉的代码

可以看到，在subscribeTypes()方法里，这个订阅者订阅了我们的ClientOperationEvent事件以及其子类们（该方法调用处获取的是订阅的类型），当事件发布者调用了订阅者的onEvent方法的时候，假设当前事件是 ClientRegisterServiceEvent 那么就会去执行handleClientOperation 方法来做客户端注册操作

当然，顺便贴一下发布这个注册事件的代码：

NotifyCenter.publishEvent(new ClientOperationEvent.ClientRegisterServiceEvent(singleton, clientId));

至此，Event的细节已经剖析的差不多了

Nacos源码篇

• 【Nacos源码篇(一)】Nacos源码本地环境搭建
• 【Nacos源码篇(二)】Nacos的事件通知机制
• 【Nacos源码篇(三)】NotifyCenter源码剖析
• 【Nacos源码篇(四)】EventPublisher源码分析
• 【Nacos源码篇(五)】Subscriber源码分析

语雀版文档

• 事件通知
  • 事件通知核心流程
  • NotifyCenter源码分析
  • EventPublisher源码分析
  • Subscriber源码分析
  • Event源码分析
  • 消息通知总结
  • 扣一扣服务注册的流程

Nacos源码注释

最后

以上就是开心钢铁侠为你收集整理的【Nacos源码篇(六)】Event源码分析的全部内容，希望文章能够帮你解决【Nacos源码篇(六)】Event源码分析所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。