Spring 事务提交成功事件监听

简介: 现在微服务做得越来越多了,头就越来月疼了。 跨系统事务和跨系统分页是最头疼的(其实头疼也没用,解决不了的问题)   现在有这么个需求(其实同样的需求见到不少了,一直没解决): 向数据库插入记录,并把数据发MQ给其他系统消费。

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

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

 

现在有这么个需求(其实同样的需求见到不少了,一直没解决):

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

 

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

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
3月前
|
安全 Java 数据库
一天十道Java面试题----第四天(线程池复用的原理------>spring事务的实现方式原理以及隔离级别)
这篇文章是关于Java面试题的笔记,涵盖了线程池复用原理、Spring框架基础、AOP和IOC概念、Bean生命周期和作用域、单例Bean的线程安全性、Spring中使用的设计模式、以及Spring事务的实现方式和隔离级别等知识点。
|
4月前
|
Java 关系型数据库 MySQL
Spring 事务失效场景总结
Spring 事务失效场景总结
60 4
|
2月前
|
Java 数据库连接 数据库
spring复习05,spring整合mybatis,声明式事务
这篇文章详细介绍了如何在Spring框架中整合MyBatis以及如何配置声明式事务。主要内容包括:在Maven项目中添加依赖、创建实体类和Mapper接口、配置MyBatis核心配置文件和映射文件、配置数据源、创建sqlSessionFactory和sqlSessionTemplate、实现Mapper接口、配置声明式事务以及测试使用。此外,还解释了声明式事务的传播行为、隔离级别、只读提示和事务超时期间等概念。
spring复习05,spring整合mybatis,声明式事务
|
2月前
|
Java 测试技术 数据库
Spring事务传播机制(最全示例)
在使用Spring框架进行开发时,`service`层的方法通常带有事务。本文详细探讨了Spring事务在多个方法间的传播机制,主要包括7种传播类型:`REQUIRED`、`SUPPORTS`、`MANDATORY`、`REQUIRES_NEW`、`NOT_SUPPORTED`、`NEVER` 和 `NESTED`。通过示例代码和数据库插入测试,逐一展示了每种类型的运作方式。例如,`REQUIRED`表示如果当前存在事务则加入该事务,否则创建新事务;`SUPPORTS`表示如果当前存在事务则加入,否则以非事务方式执行;`MANDATORY`表示必须在现有事务中运行,否则抛出异常;
115 4
Spring事务传播机制(最全示例)
|
30天前
|
Java 关系型数据库 MySQL
Spring事务失效,我总结了这7个主要原因
本文详细探讨了Spring事务在日常开发中常见的七个失效原因,包括数据库不支持事务、类不受Spring管理、事务方法非public、异常被捕获、`rollbackFor`属性配置错误、方法内部调用事务方法及事务传播属性使用不当。通过具体示例和源码分析,帮助开发者更好地理解和应用Spring事务机制,避免线上事故。适合所有使用Spring进行业务开发的工程师参考。
26 2
|
1月前
|
Java 程序员 Spring
Spring事务的1道面试题
每次聊起Spring事务,好像很熟悉,又好像很陌生。本篇通过一道面试题和一些实践,来拆解几个Spring事务的常见坑点。
Spring事务的1道面试题
|
2月前
|
Java Spring
Spring 事务传播机制是什么?
Spring 事务传播机制是什么?
22 4
|
1月前
|
监控 Java 数据库
Spring事务中的@Transactional注解剖析
通过上述分析,可以看到 `@Transactional`注解在Spring框架中扮演着关键角色,它简化了事务管理的复杂度,让开发者能够更加专注于业务逻辑本身。合理运用并理解其背后的机制,对于构建稳定、高效的Java企业应用至关重要。
41 0
|
3月前
|
Java 程序员 数据库连接
女朋友不懂Spring事务原理,今天给她讲清楚了!
该文章讲述了如何解释Spring事务管理的基本原理,特别是针对女朋友在面试中遇到的问题。文章首先通过一个简单的例子引入了传统事务处理的方式,然后详细讨论了Spring事务管理的实现机制。
女朋友不懂Spring事务原理,今天给她讲清楚了!
|
3月前
|
XML Java 数据库
Spring5入门到实战------15、事务操作---概念--场景---声明式事务管理---事务参数--注解方式---xml方式
这篇文章是Spring5框架的实战教程,详细介绍了事务的概念、ACID特性、事务操作的场景,并通过实际的银行转账示例,演示了Spring框架中声明式事务管理的实现,包括使用注解和XML配置两种方式,以及如何配置事务参数来控制事务的行为。
Spring5入门到实战------15、事务操作---概念--场景---声明式事务管理---事务参数--注解方式---xml方式