Spring Event使用

SpringEvent 自定义事件链，实用性很强的一种设计，可以利用它来做业务剥离，复杂场景解耦、代码独立等，也是事件驱动模型的核心，并且可以处理1对多，点对点，发布订阅的场景。

下面Demo是用4个Class来实现的：

1.ApplicationEventModel                     //创建上下文业务实体类，用来传递消息
2.ApplicationSendEventService               //发送事件的接口，用来传递消息
3.ApplicationListenerEventService           //监听事件，消费数据接口
4.ApplicationRunMain                        //注入spring服务 ，测试类

/**
 * 接收上下文业务对象,继承ApplicationEvent对象，而继承ApplicationEvent对象最终是继承JDK里的EventObject事件类
 * jdk中有observer观察者，java中的Event其实就是observer中的一个特例。
 */
public class ApplicationEventModel extends ApplicationEvent {

    private String businessMessage;

    /**
     * 构造一个原型事件
     *
     * @param source          来源事件最初发生的对象
     * @param businessMessage 来源事件要传递的内容
     */
    public ApplicationEventModel(Object source, String businessMessage) {
        super(source);
        this.businessMessage = businessMessage;
    }

    public String getBusinessMessage() {
        return businessMessage;
    }
}

/**
 * 具体的业务实现类，发送事件
 */
@Component
@Slf4j
public class ApplicationSendEventService {

    /**
     * 发布事件
     * 将该事件发送给对应的监听者
     */
    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;


    /**
     * A交易接口
     */
    public void tradeAtype(String message) {
        log.info("第一步：生成A交易数据:{}....", message);

        log.info("###通知交易信息....");
        applicationEventPublisher.publishEvent(new ApplicationEventModel(this, message));

    }

    /**
     * B交易接口
     */
    public void tradeBtype(String message) {
        log.info("第一步：生成B交易数据:{}....", message);

        log.info("###通知交易信息....");
        applicationEventPublisher.publishEvent(new ApplicationEventModel(this, message));

    }


}

/**
 * 监听事件类
 */
@Component
@Slf4j
public class ApplicationListenerEventService implements ApplicationListener<ApplicationEventModel> {

    @Override
    public void onApplicationEvent(ApplicationEventModel applicationEventModel) {

        log.info("监听到消息：{}", applicationEventModel.getBusinessMessage());
    }
}

@Slf4j
public class ApplicationRunMain {

    public static void main(String[] args) {
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
        applicationContext.register(ApplicationSendEventService.class, ApplicationListenerEventService.class);
        applicationContext.refresh();

        ApplicationSendEventService sendEventService = applicationContext.getBean(ApplicationSendEventService.class);
        sendEventService.tradeAtype("A交易数据信息！");
        log.info("########################################################################");
        log.info("########################################################################");
        sendEventService.tradeBtype("B交易数据信息！");

    }
}

打印日志

2019-02-27 15:54:14.717  INFO   --- [           main] c.b.m.w.c.ApplicationSendEventService    : 第一步：生成A交易数据:A交易数据信息！....
2019-02-27 15:54:14.718  INFO   --- [           main] c.b.m.w.c.ApplicationSendEventService    : ###通知交易信息....
2019-02-27 15:54:14.719  INFO   --- [           main] .b.m.w.c.ApplicationListenerEventService : 监听到消息：A交易数据信息！
2019-02-27 15:54:14.719  INFO   --- [           main] c.b.m.web.config.ApplicationRunMain      : ########################################################################
2019-02-27 15:54:14.719  INFO   --- [           main] c.b.m.web.config.ApplicationRunMain      : ########################################################################
2019-02-27 15:54:14.720  INFO   --- [           main] c.b.m.w.c.ApplicationSendEventService    : 第一步：生成B交易数据:B交易数据信息！....
2019-02-27 15:54:14.720  INFO   --- [           main] c.b.m.w.c.ApplicationSendEventService    : ###通知交易信息....
2019-02-27 15:54:14.720  INFO   --- [           main] .b.m.w.c.ApplicationListenerEventService : 监听到消息：B交易数据信息！

知识点: springboot 里面的 AnnotationConfigApplicationContext类，直接可以帮你注入对象到spring中。