[Java Framework] [Spring] Spring Event / 事件的使用 一: ApplicationEvent

Spring Event 主要是为了解耦代码使用, 对于事件弱相关业务可以添加到事件里面执行
比如: 会员购买会员卡之后会员的状态变更, 发送邮件或者站内信提醒。

JDK的Util包里抽象了事件驱动，有兴趣的朋友可以自行去看下相关类的定义。Spring事件模型ApplicationEvent是基于JDK里的事件模型，

鱗[官方文档] Additional Capabilities of the ApplicationContext

鱗[相关文章] Spring Event / 事件的使用 二: Transactional Event

• OrderPayEvent.java

public class OrderPayEvent extends ApplicationEvent {

    
    private Order order;

    public OrderPayEvent(Object source) {
        super(source);
        this.order = (Order) source;
    }

    public Order getOrder() {
        return order;
    }
}

定义监听者的方式，Spring提供了两种，一种是接口方式，一种是注解方式。

这里定义了两个监听者，实现泛型接口ApplicationListener类型为我们刚定义的OrderPayedEvent这里加上Order注解，是因为我们有多个监听者，有此业务场景中可能会有顺序的要求！

• OrderPayedPrinterListener.java

@Component
@Order(1)
public class OrderPayedPrinterListener implements ApplicationListener {

    @Override
    public void onApplicationEvent(OrderPayedEvent event) {
        System.out.printf("【线程 - %s 】订单成功成功：第一步，打印小票%n", Thread.currentThread().getName());
    }
}

• OrderPayedSendMessageListener.java

@Component
@Order(2)
public class OrderPayedSendMessageListener implements ApplicationListener {

    @Override
    public void onApplicationEvent(OrderPayedEvent event) {
        System.out.printf("【线程 - %s 】订单成功成功：第二步，发送通知商品中心添加库存%n", Thread.currentThread().getName());
    }
}

注解方式是不会有排序功能的，如果你有业务有需要排序，那么建议换成接口方式

@Component
public class OrderPayListener {

    @EventListener(classes = {OrderPayedEvent.class})
    public void sendTips(OrderPayedEvent event) {
        System.out.printf("【线程 - %s 】订单成功成功：发送用户订单支付消息%n", Thread.currentThread().getName());
    }

    @EventListener(classes = {OrderPayedEvent.class})
    public void reward(OrderPayedEvent event) {
        System.out.printf("【线程 - %s 】订单成功成功：奖励业务%n", Thread.currentThread().getName());
    }
}

•  ShoppingMallConsumerApplication.java

@SpringBootApplication
public class ShoppingMallConsumerApplication implements CommandLineRunner {
    public static void main(String[] args) {
        SpringApplication.run(ShoppingMallConsumerApplication.class);
    }

    //这里注入 应用上下文，可以注入 applicationEventPublisher
    @Resource
    ApplicationContext context;
//    @Resource
//    ApplicationEventPublisher applicationEventPublisher;
    @Override
    public void run(String... args) throws Exception {
        context.publishEvent(new OrderPayEvent(new Order(100L,"酸菜鱼")));
    }
}

• 打印结果

【线程 - main 】订单成功成功：第一步，打印小票
【线程 - main 】订单成功成功：第二步，发送通知商品中心添加库存

ApplicationEvent对异步支持是怎么样的呢？

只要在启动类上加上@EnableAsync,在监听器类加上@Async

•  ShoppingMallConsumerApplication.java

@EnableAsync
@SpringBootApplication
public class ShoppingMallConsumerApplication implements CommandLineRunner {
    public static void main(String[] args) {
        SpringApplication.run(ShoppingMallConsumerApplication.class);
    }

    //这里注入 应用上下文，可以注入 applicationEventPublisher
    @Resource
    ApplicationContext context;
//    @Resource
//    ApplicationEventPublisher applicationEventPublisher;
    @Override
    public void run(String... args) throws Exception {
        context.publishEvent(new OrderPayEvent(new Order(100L,"酸菜鱼")));
    }
}

• 打印结果

【线程 - task-2 】订单成功成功：第二步，发送通知商品中心添加库存
【线程 - task-1 】订单成功成功：第一步，打印小票

[1] Spring事件,ApplicationEvent在业务中的应用