Spring中的发布订阅

• 事件类

ApplicationEvent 继承 java.util.EventObject， 
我们需要继承ApplicationEvent，必要时候为事件添加一些属性

• 事件发布类

ApplicationContext 继承了org.springframework.context.ApplicationEventPublisher，
我们需要通过ApplicationContext.publisEvent(event)发布事件

• 事件处理类

ApplicationListener 继承了java.util.EventListener，
我们需要实现ApplicationListener接口，并覆写处理事件的方法，完成事件处理逻辑

如果在应用中发生了某些事件，事件会被拦截和处理就好了，这样就有了很大的灵活性，至少代码不会紧密的耦合在一起，

代码的解耦就是业务的解耦，业务A的代码不用手动的调用业务B的代码，业务B只需要监听相关事件，根据事件处理业务就可以了。

• 事件定义

public class SendEmailEvent extends ApplicationEvent {
    private String message;
 
    public SendEmailEvent(Object source, String message) {
        super(source);
        this.message = message;
    }
 
    public String sendEmail(){
        return message;
    }
 
}

• 事件发布

@Component
@Slf4j
public class SendEmailEventPublisher {
    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;
 
    public void publish(final String message) {
        log.info("publis a SendEmailEvent,message:{}", message + " time: " + LocalTime.now());
        SendEmailEvent sendEmailEvent = new SendEmailEvent(this, message);
        applicationEventPublisher.publishEvent(sendEmailEvent);
    }
 
}

• 事件监听(a)

@Component
@Slf4j
public class SendEmailListener implements ApplicationListener {
    @Override
    public void onApplicationEvent(SendEmailEvent sendEmailEvent) {
        String s = sendEmailEvent.sendEmail();
        log.info("SendRegisterEmailListener message: " + s+" time: "+ LocalTime.now());
    }
}

• 事件监听(b)

@Component
@Slf4j
public class SendEmailListener2 {
    @EventListener
    public void sendEmmail(SendEmailEvent sendEmailEvent){
        String s = sendEmailEvent.sendEmail();
        log.info("SendRegisterEmailListener message: " + s+" time: "+ LocalTime.now());
    }
 
}

分析

• 监听如何确定对应的事件？

根据发布与订阅接口的参数类型进行匹配

• 默认是同步执行还是异步执行?

Spring事件默认是同步的，通过在启动类Application上加上@EnableAsync开启异步。
使用方法注解@Async可以作用在监听器的执行方法上，异步执行。
@Async不带参数默认使用SpringBoot默认的线程池。推荐使用自定义的线程池.

@Configuration
public class ThreadPoolConfig {
 
    @Bean("executor")
    public Executor getExecutor() {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(10,
                20,
                60,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue(10000));
        return executor;
    }
}