现在微服务做得越来越多了,头就越来月疼了。
跨系统事务和跨系统分页是最头疼的(其实头疼也没用,解决不了的问题)
现在有这么个需求(其实同样的需求见到不少了,一直没解决):
向数据库插入记录,并把数据发MQ给其他系统消费。
其他系统接收到消息后会调用查询接口回来查询更多信息。
可是这个时候可能插入记录的事务都还没提交,所以根本查询不到。
通常的做法是延迟消费(或者延迟发送):
比如假设事务在几分钟内一定会提交,那就延后10分钟后再过去查询。
查询到了就可以了。
查询不到就任务之前的事务回滚了。。
其实这个场景如果在spring环境下,有两种解决方案:
一种是使用JMS,spring在其中提供了事务支持。
但是如果你本来没用jms,这样改造会比较重。
另一种方法是事件监听。
我们说一下这种方法。
假设老式的延迟发送代码如下:
@Transactional(rollbackFor = Exception.class) public boolean insertSelectiveHeader(SupplierBillPO header) { .... int i = billPOMapper.insertSelective(header); //延迟发送mq消息 service.delaySendMQ(header); return i > 0; }
改造后我们不再使用发送mq的service服务,而是用
org.springframework.context.ApplicationEventPublisher; @Autowired private ApplicationEventPublisher publisher;
发送代码改成发送事件:
@Transactional(rollbackFor = Exception.class) public int insertSelectiveHeader(SupplierBillPO header) { .... int i = billPOMapper.insertSelective(header); publisher.publishEvent(header); return i; }
publishEvent的入参可以是任何自定义对象。
然后去建一个Bean类:
@Component public class TransactionalMessageListener { @TransactionalEventListener(fallbackExecution = true) public void handleSupplierBillPush(SupplierBillPO data){ service.sendImmediately(data); } }
这个类首先要是一个bean,不然没有人去监听我们的事件啊。
然后里面的方法要用
import org.springframework.transaction.event.TransactionalEventListener;
做注解。
方法不要有返回值
方法的入参和上面发布事件的入参要一样。
这样spring在事务成功提交后就会调用这个方法了。
我们可以在里面注入其他服务,比如立即发送MQ(现在不用延迟了)
其实这个注解有其他配置的,有兴趣的可以研究一下