概念

        关于发布订阅这个词，其实不仅仅出现在Spring框架当中，其实在Redis中也有存在（其对应的是convertAndSend()方法），还有在MQ消息队列里也是有的，但这里就主要介绍的是关于Spring框架的ApplicationEventPublisher如何做到消息的发布与订阅。随着现在的业务量和需求量越来越大，其实基本都是分布式微服务集群的使用了，所以基本都是用到Redis与MQ。但是对于单体Spring Boot应用时，用Spring自带的发布订阅就已经绰绰有余了。

        需要知道的是发布订阅需要有三个对象：事件、事件发布源、事件接收源（监听器）。

事件

        对于事件来说，需要去继承ApplicationEvent。至于为什么需要继承ApplicationEvent就需要研究源码，等我后续看完再回来更新笔记。

public class LogEvent extends ApplicationEvent {

    public LogEvent(Object message) {
        super(message);
    }
}

事件发布源

        这个基本上都是业务层的代码，但是作为学习阶段，我将其直接放在控制层。关于如何去发布，就需要用到Spring中的ApplicationEventPublisher。

@Slf4j
@RestController
@RequestMapping("/log")
public class LogController {

    @Autowired
    private ApplicationEventPublisher publisher;

    @GetMapping("/publisher")
    public void log() {
        log.info("进入到log方法,开始发送事件");
        publisher.publishEvent(new LogEvent("log方法生成事件信息"));
        log.info("log方法发送事件完毕");
    }

}

监听器

/**
 * 管理员日志监听器
 */
@Slf4j
@Component
public class AdminListener {

    @EventListener(LogEvent.class)
    public void adminListen(LogEvent logEvent) {
        try {
            log.info("管理员监听到的日志信息为,{}", logEvent);
            Thread.sleep(5000); // 睡眠5s
            log.info("管理员监听完毕");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 用户日志事件监听器
 */
@Slf4j
@Component
public class UserListener {

    @EventListener(LogEvent.class)
    public void userListen(LogEvent logEvent) {
        try {
            log.info("用户监听到的日志信息为,{}", logEvent);
            Thread.sleep(10000); // 睡眠10s
            log.info("用户监听完毕");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

执行结果

        从执行结果可以发现管理员线程睡眠了5s后执行完毕才会执行用户的代码块。所以表明是同步执行的。

        于是为了将同步执行变为异步执行，又在两个监听器的方法上添加了@Async注解，并且一定要在启动类上添加@EnableAsync注解。再次执行会发现两次的执行结果并不一致。两个监听器是异步执行的。甚至在监听器上放置@Order注解可以实现先后顺序，但这里就不演示了。

源码追踪

        这里只进行粗略的源码查看，因为作者功力有限无法解释得完全仔细，以后看懂了再回来更新笔记。可以发现其已经使用了JDK8新特性了。从ApplicationEventPublisher的publisher(Application event)方法就会进入到其子类AbstartApplicationContext中。

protected void publishEvent(Object event, @Nullable ResolvableType eventType) {
        Assert.notNull(event, "Event must not be null");
        Object applicationEvent;
        if (event instanceof ApplicationEvent) {
            applicationEvent = (ApplicationEvent)event;
        } else {
            applicationEvent = new PayloadApplicationEvent(this, event);
            if (eventType == null) {
                eventType = ((PayloadApplicationEvent)applicationEvent).getResolvableType();
            }
        }

        if (this.earlyApplicationEvents != null) {
            this.earlyApplicationEvents.add(applicationEvent);
        } else {
            // 在这步完成真正的发布订阅 只有监听完才会向下继续执行
            this.getApplicationEventMulticaster().multicastEvent((ApplicationEvent)applicationEvent, eventType);
        }

        if (this.parent != null) {
            if (this.parent instanceof AbstractApplicationContext) {
                ((AbstractApplicationContext)this.parent).publishEvent(event, eventType);
            } else {
                this.parent.publishEvent(event);
            }
        }