Spring4 版 eventbus 事件通信 事件驱动 介绍

开始使用

1. 事件发送器

1    @Autowired
2    ApplicationEventPublisher eventPublisher;

2. 发送事件

1    //订单准备工作完成 ， 使订单生效
2    eventPublisher.publishEvent(new OrderEffectEvent(order.getId()));

例子 OrderEffectEvent类的定义(其实就是一个普通的java bean)

1public final class OrderEffectEvent implements IOrderEvent {
2
3
4   @Getter
5   private final String orderId;
6
7
8   public OrderEffectEvent(String orderId) {
9       this.orderId = orderId;
10
11
12   }
13}

3 在需要处理的地方接收发送的事件,使用@EventListener 注解

1   /**
2    * 使订单生效
3    *
4    * @param event 订单生效事件
5    * @return
6    */
7   @EventListener
8   public void handlerEffectOrder(OrderEffectEvent event) {
9      
10      // do some thing
11   }
12
13

@EventListener 还支持事件过滤，例如 下面这个例子只想接收到 订单业务类型为 MONTHLY 的事件

注意 condition 内容为sqEl 表达式 需要返回类型为 boolean

1  /**
2    * 订单未支付，取消业务状态
3    *
4    * @param event 订单事件
5    */
6   @EventListener(condition = "T(com.xxx.Order.BizType).MONTHLY eq #event.orderType")
7   public void handlerEvent(OrderPayExpireEvent event) {
8
9
10   }

注意 泛型也是支持的

1  /**
2    *
3    * @param event 新增事件
4    */
5   @EventListener
6   public void handlerEvent(ICreateEvent event) {
7       
8      // switch (event)
9      // if(event instanceof OrderCreateEvent )
10
11   }

4 扩展阅读

• spring4.2更好的应用事件
• Spring表达式语言 SpEL语法
• 详解Spring事件驱动模型