监听器是基于事件驱动的,用于对操作事件进行监听,当监听到有操作事件的时候进行的逻辑处理,是观察者设计模式的应用。
2、监听器三元素事件源:事件发生的源头。比如Zookeeper事件:对事件进行抽象、封装监听器:用于监听事件源,当事件发生时进行处理 3、监听器本质
首先:监听器像服务端的事件源注册一个对某种事件源的监听
然后:生产者通过事件源产生一个事件
再然后:服务端事件源根据本地注册的监听器逐个去调用监听器,这个监听器可以是远程,也可以是本地,远程监听器一般是需要注册Ip地址
最后:监听器收到事件源的调用之后开始进行自己的逻辑处理。
伪代码如下:
//事件源对象一般是服务端维护,联动生产者和监听者 EventSource eventSource=new EventSource();//事件源一般是单例,生产者(产生事件的端)和消费者(监听器,即监听产生的事件)共用 //消费者像服务端注册一个监听器 EventListenerHandler addEventListenerHandler=new AddEventListenerHandler(); eventSource.registryEventListenerHandler(addEventListenerHandler); //生产者生产一个事件 eventSource.addCar(); eventSource.addCar();二、观察者模式应用场景
观察者模式最典型的应用就是消息的发布订阅模式,生产者与消费者模式,监听的应用等。
应用案例:
1、各种消息队列。如Kafka,ActiveMQ,RocketMQ等
2、Zookeeper的watcher等,这个场景有很多,下面列举一些:
分布式锁。如多个操作操作排序等待操作某条数据。观察者模式表现在:
事件监听器:等待操作的客户端,会注册一个watcher事件源:前面的临时Znode的操作事件,比如删除事件:即删除事件分布式系统选主过程Hbase的Master节点通过zookeeper监听各个regionserver的健康状况
3、服务注册与发现。客户端监听注册中心是否有服务变更,如果有变更需要实时的更新到本地。
参考:
Java监听器原理及实例



