基于Spring的发布订阅模式 EventListener( 三 ) _生活百科

好了，通过这3步，我们就可以在spring中愉快的实现事件-监听机制了。在我们需要发送事件时，只要调用 EventService的发送方法即可
@Slf4j@Builder@Data@AllArgsConstructor@NoArgsConstructorpublic class Order extends BaseDO implements OrderPublisher {private Long orderId;private String bizType;private String tradeOrderNo;private Long totalFee;private Long actualPaidFee;private Long discountFee;private Long refundFee;private Date payTime;private Date refundTime;private Integer status;private Long userId;private String tradeChannel;private String attributes;private Long deliveryFee;private List<SubOrder> subOrders;private List<Promotion> promotions;public void create() {this.publish(new OrderCreateEvent(this, this.tradeOrderNo, this.userId));}public void confirm() {this.publish(new OrderConfirmEvent(this, this.tradeOrderNo, this.userId));}public void paid() {this.publish(new OrderPaidEvent(this, this.tradeOrderNo, this.userId));}public void refund(RefundOrderDTO subOrderId) {this.publish(new OrderRefundEvent(this, this.tradeOrderNo, this.userId,subOrderId));}public void canceled() {this.publish(new OrderCancelEvent(this, this.tradeOrderNo, this.userId));}public void finishPaid() {if (this.status == OrderPayStatusEnum.PAID_DONE.getValue() || this.status == OrderPayStatusEnum.PAID_DONE_SHIPPED.getValue()) {return;}if (this.status != OrderPayStatusEnum.UN_PAID.getValue()) {throw new BusinessException(OrderErrorCode.ORDER_STATUS_IS_ERROR);}this.status = OrderPayStatusEnum.PAID_DONE.getValue();this.payTime = new Date();}public void confirmOrder() {if (this.status == OrderPayStatusEnum.PAID_DONE_SHIPPED.getValue()) {return;}if (this.status == OrderPayStatusEnum.CLOSED.getValue()) {return;}if (this.status != OrderPayStatusEnum.PAID_DONE.getValue()) {throw new BusinessException(OrderErrorCode.ORDER_STATUS_IS_ERROR);}this.status = OrderPayStatusEnum.PAID_DONE_SHIPPED.getValue();subOrders.forEach(subOrder -> {if (subOrder.getStatus() != SubOrderStatusEnum.INIT.getValue()) {throw new BusinessException(OrderErrorCode.ORDER_STATUS_IS_ERROR);}subOrder.setStatus(SubOrderStatusEnum.WAIT.getValue());});}public void cancel() {if (this.status != OrderPayStatusEnum.UN_PAID.getValue()) {return;}if (this.status == OrderPayStatusEnum.PAID_OUTTIME.getValue()) {return;}this.status = OrderPayStatusEnum.PAID_OUTTIME.getValue();}public void complete(Long subOrderId) {subOrders.stream().filter(e -> e.getSubOrderId().equals(subOrderId)).forEach(subOrder -> {subOrder.setStatus(SubOrderStatusEnum.END.getValue());});if (subOrders.stream().allMatch(subOrder ->SubOrderStatusEnum.END.getValue().equals(subOrder.getStatus()) ||SubOrderStatusEnum.TXP_CLOSE.getValue().equals(subOrder.getStatus()))) {this.status = OrderPayStatusEnum.SUCCESS.getValue();}}public void refundOrder(Long refundFee, Date refundDate) {if (this.status == OrderPayStatusEnum.UN_PAID.getValue()) {throw new BusinessException(OrderErrorCode.ORDER_STATUS_IS_ERROR);}if (this.status == OrderPayStatusEnum.CLOSED.getValue()) {throw new BusinessException(RefundErrorCode.ORDER_IS_REFUND);}refundOrder(refundFee, refundDate, null, null);}}
使用@EventListener还支持SPEL表达式
@EventListener(condition = "#jkRecordConfirmEvent.jkRecordConfirmEventDTO.cwConfirmAndReturnFlag")@Async("asyncListenerExecutor")
我们可以看到在监听器中，实现的方法使用了@Async注解。在spring3提供了@Aync注解来完成异步调用。我们可以使用这个新特性来完成异步调用。在实际项目中，我们一般也是把这两者结合来使用的，特别是监听事件是一件耗时过程时，这种方式降低了代码的耦合性，非常好用。【基于Spring的发布订阅模式 EventListener】

基于Spring的发布订阅模式 EventListener( 三 )

推荐阅读

依维柯宝迪edc灯消不掉怎么回事依维柯宝迪提示灯

白城到长春白城到长春客车时间表

绝地求生怎么跑绝地求生快速跑动按键详解

人生自古谁无死出自哪首诗人生自古谁无死

汽车用品买什么是必备的买车以后有哪些重要的车用品

炒猪肚用什么配菜好吃炒猪肚用什么配菜

请评教是什么意思网上评教是什么意思

西梅可以冷冻保存吗怎么吃西梅可以冷冻保存吗

十二星座专属配套服装

关于感恩节的作文600字

好听的双胞胎男孩名字

狮子座生日狮子座是几月份

三国程普怎么死的

机动车检验去哪里办理

快手小店上传商品审核多久快手商品审核多长时间

护士节的来历

怎么自制减肥营养餐

冰箱里放三天的饭菜还可以吃吗饭菜放冰箱三天能吃吗

立秋后的第一杯奶茶是什么意思?

2020年07月14日双子座事业爱情运势