Spring 事务提交成功事件监听

现在微服务做得越来越多了，头就越来月疼了。

跨系统事务和跨系统分页是最头疼的（其实头疼也没用，解决不了的问题）

 

现在有这么个需求（其实同样的需求见到不少了，一直没解决）：

向数据库插入记录，并把数据发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（现在不用延迟了）

 

其实这个注解有其他配置的，有兴趣的可以研究一下