如何用Spring事件发布监听机制实现业务解耦

冷不防 2023-09-24 20:56 62阅读 0赞

### 1.引言 ###

> 假设一个下单场景，订单创建成功后可能有一些后续逻辑要处理，但是和创建订单本身没有关系，此时就可以在创建订单完成后，发送一个消息，有相应部分的代码进行监听处理，避免代码耦合到一起

这样的解决思路类似于MQ，但是小项目有时候又不需要MQ这样的第三方队列来实现，那么就可以使用Spring Context包的**事件发布监听的机制来进行处理**

### 2.Spring事件发布监听机制 ###

![0d517915aeeae9a44685ed7700d82a2f.png][]

1.png

**流程：** 当事件源（发布者）发布事件时，相应监听此事件的监听者接收到事件对象并且进行处理

Spring的事件发布监听机制本质上就是**发布-订阅**，即**生产者-消费者**，也体现了设计模式中的**观察者模式**

### 3.三要素 ###

*  ApplicationEvent：事件
 *  ApplicationListener：事件监听者
 *  ApplicationEventPublisher：事件发布者

#### 3.1 事件（ApplicationEvent） ####

**消息类：**

@NoArgsConstructor
    @AllArgsConstructor
    @Data
    @Builder
    public class Message {
    
        private Long messageId;
    
        private String content;
    
    }

> 事件包含的实体类

**事件类：**

@Getter
    @Setter
    public class MessageEvent extends ApplicationEvent {
    
        private static final long serialVersionUID = 4181929072911659524L;
    
        private Message message;
    
        public MessageEvent(Message message) {
            super(message);
            this.message = message;
        }
    
    }

> 事件类，继承了ApplicationEvent，并且包含了传递实体类Message

**MessageEvent的关系类图（Diagram）：**

![acfbf7eec980fad0ce84bf24ae5342db.png][]

2.png

**其中ApplicationEvent的源码：**

/**
     * Class to be extended by all application events. Abstract as it
     * doesn't make sense for generic events to be published directly.
     *
     * @author Rod Johnson
     * @author Juergen Hoeller
     * @see org.springframework.context.ApplicationListener
     * @see org.springframework.context.event.EventListener
     */
    public abstract class ApplicationEvent extends EventObject {
    
        /** use serialVersionUID from Spring 1.2 for interoperability. */
        private static final long serialVersionUID = 7099057708183571937L;
    
        /** System time when the event happened. */
        private final long timestamp;
    
    
        /**
         * Create a new {@code ApplicationEvent}.
         * @param source the object on which the event initially occurred or with
         * which the event is associated (never {@

[0d517915aeeae9a44685ed7700d82a2f.png]: https://img-blog.csdnimg.cn/img_convert/0d517915aeeae9a44685ed7700d82a2f.png
[acfbf7eec980fad0ce84bf24ae5342db.png]: https://img-blog.csdnimg.cn/img_convert/acfbf7eec980fad0ce84bf24ae5342db.png