零工订单的消息通知怎么发？站内信 + 短信，我用事件异步把链路解耦了

零工订单的消息通知怎么发站内信 短信我用事件异步把链路解耦了导读xllg 里订单状态一变用户就要收到通知“老板已确认”“工人已开工”“工资已结算”。一开始我在业务代码里同步发通知订单接口越写越重偶尔发短信失败还影响主流程。后来改成事件驱动 异步消费业务只管发事件通知中心负责投递。这篇讲这套怎么落地的。业务只发事件不直接发通知核心设计业务代码里不再出现发短信写站内信这种代码只发一个领域事件// 订单状态变更时业务里只发事件ServicepublicclassOrderService{AutowiredprivateApplicationEventPublisherpublisher;TransactionalpublicvoidconfirmOrder(LongorderId){orderMapper.updateStatus(orderId,WAIT_WORK);// 发事件通知中心异步处理publisher.publishEvent(newOrderStatusEvent(orderId,WAIT_WORK));}}事件对象很简单只带必要信息publicclassOrderStatusEvent{privatefinalLongorderId;privatefinalIntegerstatus;// 构造、getter 略}通知中心监听事件异步投递监听器负责查详情、组文案、写站内信、发短信全部异步ComponentpublicclassOrderNotifyListener{AutowiredprivateNotifyServicenotifyService;EventListenerAsync(notifyExecutor)publicvoidonOrderStatusChange(OrderStatusEventevent){// 1. 查订单和用户信息事件里只带 id避免事件对象臃肿OrderDetaildetailnotifyService.getOrderDetail(event.getOrderId());// 2. 按状态组装不同文案StringcontentbuildContent(event.getStatus(),detail);// 3. 写站内信notifyService.saveInboxMessage(detail.getUserId(),content);// 4. 发短信失败不影响主流程try{notifyService.sendSms(detail.getPhone(),content);}catch(Exceptione){log.error(短信发送失败: orderId{},event.getOrderId(),e);}}privateStringbuildContent(Integerstatus,OrderDetaildetail){switch(status){case1:return您发布的岗位「detail.getJobTitle()」已确认开工;case2:return您报名的零工「detail.getJobTitle()」已开始记得按时打卡;// 其他状态略default:return您的零工订单状态已更新;}}}短信失败只记日志不影响主流程——站内信是必达的短信是增强两者分开处理。短信通道别只接一家短信这块我多提一句零工场景对到达率的要求比普通业务高工人干活前要靠短信提醒打卡收不到就误工。所以短信服务我接了两家一家主通道一家备用主通道连续失败自动切备用ComponentpublicclassSmsGateway{privatefinalListprovidersList.of(newAliSmsProvider(),// 主通道newYunpianProvider()// 备用通道);publicvoidsend(Stringphone,Stringcontent){Exceptionlastnull;for(SmsProviderp:providers){try{p.send(phone,content);return;}catch(Exceptione){laste;log.warn(短信通道[{}]发送失败切换备用,p.name(),e);}}// 全部失败抛出去由监听器兜底记录thrownewSmsException(所有短信通道均失败,last);}}另外提醒频率也要控——同一用户 1 小时内同类短信最多发 2 条用 Redis 计数不然活动期间容易被投诉骚扰。这个我踩过坑后面详细说。踩坑异步监听在事务提交前执行通知内容读到旧数据现象订单确认后用户收到的短信内容是待确认但页面上订单已经是待开工了。短信内容滞后一个状态。排查事件是在事务方法里发的publishEvent在Transactional方法内部Spring 默认同步调用监听器——监听器在事务提交前就执行了。此时getOrderDetail查到的还是旧状态事务还没提交或者查的是未提交前的老数据文案自然错了。定位问题本质是事件发布时机和事务边界的关系。同步事件在事务内执行读不到事务里刚改的数据。解决用 Spring 的TransactionalEventListener(phase TransactionPhase.AFTER_COMMIT)让监听器在事务提交后再执行ComponentpublicclassOrderNotifyListener{EventListenerAsync(notifyExecutor)TransactionalEventListener(phaseTransactionPhase.AFTER_COMMIT)publicvoidonOrderStatusChange(OrderStatusEventevent){// 事务已提交这里读到的数据一定是最新的// ...}}注意TransactionalEventListener默认不生效时需要配合EnableAsync 事件发布处配置另外事务提交后监听器若抛异常不会回滚主事务——正好符合通知尽力而为的定位。可直接复用的清单业务代码只发事件不直接调通知服务解耦核心链路通知监听用AFTER_COMMIT 阶段避免事务内读到旧数据站内信和短信分离站内信必达短信失败只记日志事件对象只带 ID别塞完整实体监听器自己去查最新数据短信、推送这种外部依赖统一放异步线程池别占业务线程短信接双通道主备自动切换单通道故障不阻塞通知同一用户同类短信用 Redis 做频率限制防投诉防骚扰这套事件通知在 xllg 里跑着订单状态相关通知再没乱过。记住一句话事务提交前发的通知内容永远可能过期。项目源码https://gitee.com/gzqkl/xllg