本文共 1904 字，大约阅读时间需要 6 分钟。

---

前言

Spring中提供一种类似发布订阅功能的实现方式，我们可以利用该特性，在需要通知其他组件的地方发布消息，订阅方收到消息后，就能 做相应逻辑处理。

下面是个简单demo演示

一、项目结构

一：MyController

简单的路口

@RestController@RequestMapping(value = "/demo")public class MyController {
       @Autowired    private MyRegister myRegister;    @RequestMapping(value = "",method = RequestMethod.GET)    public void test(){
           myRegister.register();    }    @RequestMapping(value = "/test2",method = RequestMethod.GET)    public void test2(){
           myRegister.registerEvent();    }}

二：UserDto

简单实体类

@Datapublic class UserDto {
       private String name;    private int age;}

三：MyApplicationEvent

spring的源码中通过对ApplicationEventPublisher可以知道，支持两种发布格式，这是其中一种

需要继承这个类：org.springframework.context.ApplicationEvent;

public class MyApplicationEvent extends ApplicationEvent {
       public MyApplicationEvent(Object source) {
           super(source);    }}

四：MyListener

订阅者组件

@EventListener支持SPEL表达式，如果是true，订阅到消息才执行 如果没有配置condition属性，默认接收到订阅消息就执行

@Componentpublic class MyListener {
       @EventListener(condition = "#userDto.name != null")    public void handler(UserDto userDto) {
           System.out.println(userDto);    }    @EventListener    public void handler(MyApplicationEvent myApplicationEvent) {
           System.out.println(myApplicationEvent.getSource().toString());    }}

五：MyRegister

发布者

这里可以看到ApplicationEventPublisher 支持两种方式的发布 第一种是直接发布Object对象 第二种是经过封装的ApplicationEvent 的对象，其实这个对象里面只有两个属性，一个时间戳，一个Object对象

@Servicepublic class MyRegister {
       @Autowired    private ApplicationEventPublisher publisher;    public void register() {
           UserDto userDto = new UserDto();        userDto.setAge(18);        userDto.setName("张三");        publisher.publishEvent(userDto);    }    public void registerEvent() {
           ApplicationEvent event = new MyApplicationEvent("哈哈哈哈哈哈");        publisher.publishEvent(event);    }}

六：启动测试

测试发布订阅第一种方式，测试成功

测试发布订阅第二种方式，测试成功

转载地址：http://wurii.baihongyu.com/