Spring源码之事件监听机制（下）

文章目次

• 前言
  
• 一、手写事件监听机制框架
  
• 
  
  
  
  • 1.准备
    
  • 2.事件监听接口
    
  • 3.事件管理器
    
  • 4.事件发布器
    
  • 5.需求
    
  • 6.编码
    
    
  
• 二、观察者模式
  
• 
  
  
  
  • 1.概述
    
  • 2.UML图
    
  • 3.Coding验证
    
    
  
• 小结
  

  一、手写事件监听机制框架

1.准备

JDK为我们提供了事件监听的支持，在java.util包的下面提供了事件监听接口以及事件类。

2.事件监听接口

1. public interface IEventListener extends EventListener {    void onApplicationEvent(E event);}

复制代码

界说一个事件监听接口供事件监听类实现
3.事件管理器

1. public class EventMulticaster {    private Set set = new LinkedHashSet();    public void registerListener(IEventListener listener) {        if (!set.contains(listener)) {            set.add(listener);        }    }    public void removeListener(IEventListener listener) {        if (!set.contains(listener)) {            set.remove(listener);        }    }    public Set getEventListeners() {        return set;    }}

复制代码

界说一个事件管理器，存储事件监听以及对事件监听的增删操纵
4.事件发布器

1. public class EventPublisher {    private EventMulticaster eventMulticaster;    public void initEventMulticaster() {        if (eventMulticaster == null) {            eventMulticaster = new EventMulticaster();        }    }    public void registerListener(IEventListener listener) {        if (eventMulticaster != null) {            eventMulticaster.registerListener(listener);        }    }    public void removeListener(IEventListener listener) {        if (eventMulticaster != null) {            eventMulticaster.removeListener(listener);        }    }    public void publishEvent(EventObject eventObject) {        if (eventMulticaster != null) {            Set set = eventMulticaster.getEventListeners();            for (IEventListener listener : set) {                listener.onApplicationEvent(eventObject);            }        }    }}

复制代码

5.需求

和上一篇一样：在订单服务中，用户下单乐成后，需要物流服务和库存服务举行相应的处理处罚，采取异步解耦的方式。
6.编码

• 订单事件
  

1. public class OrderEvent extends EventObject {    public OrderEvent(Object source) {        super(source);    }}

复制代码

• 库存监听
  

1. public class StoreListener implements IEventListener{    @Override    public void onApplicationEvent(OrderEvent event) {        System.out.println("库存服务运行中……");    }}

复制代码

• 物流监听
  

1. public class LogisticsListener implements IEventListener {    @Override    public void onApplicationEvent(OrderEvent event) {        System.out.println("物流服务运行中……");    }}

复制代码

• 订单服务
  

1. System.out.println("订单服务开始运行");System.out.println("创建订单完成，通知物流、库存……");// 初始化事件管理器EventPublisher eventPublisher = new EventPublisher();eventPublisher.initEventMulticaster();// 添加事件监听eventPublisher.registerListener(new LogisticsListener());eventPublisher.registerListener(new StoreListener());// 发布事件eventPublisher.publishEvent(new OrderEvent(this));

复制代码

• 效果
  

  订单服务开始运行
创建订单完成，通知物流、库存……
物流服务运行中……
库存服务运行中……

二、观察者模式

1.概述

  观察者模式（有时又被称为模子（Model）-视图（View）模式、源-收听者(Listener)模式或附属者模式）是软件设计模式的一种。在此种模式中，一个目的物件管理所有相依于它的观察者物件，而且在它本身的状态改变时主动发出通知。这通常透过召唤各观察者所提供的方法来实现。此种模式通常被用来实现事件处理处罚系统。（百度百科）

事件监听机制举行建模分析，当不思量事件发布器之后，可以简朴的理解为：一个事件对应着多个监听者，当事件发布的时候，监听者收到消息，是不是就是典范的观察者模式。
2.UML图

其实JDK已经为我们提供了对观察者模式的支持，下面是我根据JDK中提供的观察者与被观察者绘制的UML图：

从UML图中可以看出：被观察者也被称为主题，与观察者之间是一对多的关系，主题存储着所有观察者，当主题状态变动的时候，通知观察者举行更新。
3.Coding验证

• 主题
  

1. public class Subject extends Observable {    public void setChanged() {        super.setChanged();    }}

复制代码

• 观察者
  

1. public class ConcreteObserver1 implements Observer {    private String name;    public ConcreteObserver1(String name) {        this.name = name;    }    @Override    public void update(Observable o, Object arg) {        System.out.println(name + "：当前状态：" + o.hasChanged() + "，内容：" + arg.toString());    }}

复制代码

• 客户端验证
  

1. public class Client {    public static void main(String[] args) {        Subject subject = new Subject();        subject.addObserver(new ConcreteObserver1("观察者1"));        subject.addObserver(new ConcreteObserver2("观察者2"));        subject.setChanged();        subject.notifyObservers("我已经不是当初你认识的我自己……");    }}

复制代码

• 效果
  

  观察者2：当前状态：false，内容：我已经不是当初你认识的我自己……
观察者1：当前状态：false，内容：我已经不是当初你认识的我自己……

  小结

  从Spring的事件监听机制，到自界说监听框架，再到观察者模式，一路走来，从繁入简，相信各人对Spring的监听机制已经有了清晰的认知。
  那我们从设计模式，到Sping的事件监听再回顾一下。当对象之间存在着一对多的关系，一个对象改变，依赖于它的所有对象都会收到通知，这就是我们的观察者模式。但被观察者与观察者之间依然存在着很强的耦合关系，所以为了降低这种耦合关系，我们在被观察者和观察者之间放置一个消息通道，也就是事件发布器，这就是事件监听机制，Spring的事件监听机制就是依托于此，只不外它更加的完善。
  好了，这篇文章到这里就竣事了，相信到这里再转头看Spring的事件监听机制源码一定会有不一样的收获。

来源：https://blog.csdn.net/qq_27023083/article/details/111938356
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！