SpringCloudAlibaba集成RocketMQ实现分布式事务事例(一)

9月前作者：懒羊羊--搞点小技术分类：Toy博客阅读(106) 违法举报

这篇具有很好参考价值的文章主要介绍了SpringCloudAlibaba集成RocketMQ实现分布式事务事例(一)。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

SpringCloudAlibaba集成RocketMQ实现分布式事务事例(一)

业务需求

用户请求订单微服务 order-service 接口删除订单（退货），删除订单时需要调用 account-service的方法给账户增加余额，一个典型的分布式事务问题。

SpringCloudAlibaba集成RocketMQ实现分布式事务事例(一),SpringCloudAlibaba,rocketmq,分布式
代码实现

事务消息有三种状态：

TransactionStatus.CommitTransaction：提交事务消息，消费者可以消费此消息
TransactionStatus.RollbackTransaction：回滚事务，它代表该消息将被删除，不允许被消费。
TransactionStatus.Unknown ：中间状态，它代表需要检查消息队列来确定状态。

基础配置

在开始代码之前首先需要搭建好的RocketMQ环境文章来源地址https://www.toymoban.com/news/detail-541044.html

在Order-Service和Account-Service中引入Rocket消息组件

<dependency>

到了这里，关于SpringCloudAlibaba集成RocketMQ实现分布式事务事例(一)的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

【分布式技术专题】RocketMQ延迟消息实现原理和源码分析

痛点背景业务场景假设有这么一个需求，用户下单后如果30分钟未支付，则该订单需要被关闭。你会怎么做？之前方案最简单的做法，可以服务端启动个定时器，隔个几秒扫描数据库中待支付的订单，如果(当前时间-订单创建时间)30分钟，则关闭订单。方案评估优点：是实

2024年02月13日
浏览(53)
基于SpringCloudAlibaba+Sentinel的分布式限流设计

胡弦，视频号2023年度优秀创作者，互联网大厂P8技术专家，Spring Cloud Alibaba微服务架构实战派(上下册)和RocketMQ消息中间件实战派(上下册)的作者，资深架构师，技术负责人，极客时间训练营讲师，四维口袋KVP最具价值技术专家，技术领域专家团成员，2021电子工业出版社年度优

2024年04月22日
浏览(34)
SpringBoot集成Skywalking实现分布式链路追踪

官方网址： Apache SkyWalking 官方文档： SkyWalking 极简入门 | Apache SkyWalking 下载地址：Downloads | Apache SkyWalking Agent ：以探针的方式进行请求链路的数据采集，并向管理服务上报； OAP-Service ：接收数据，完成数据的存储和展示； Storage ：数据的存储层，支持ElasticSearch、Mysql、

2024年02月03日
浏览(45)
Spring Boot 集成 Redisson 实现分布式锁

Redisson 是一种基于 Redis 的 Java 驻留集群的分布式对象和服务库，可以为我们提供丰富的分布式锁和线程安全集合的实现。在 Spring Boot 应用程序中使用 Redisson 可以方便地实现分布式应用程序的某些方面，例如分布式锁、分布式集合、分布式事件发布和订阅等。本篇

2024年02月08日
浏览(40)
2.Zookeeper集成springboot操作节点，事件监听，分布式锁实现

1.Springboot项目中添加zookeeper 已经对应的客户端依赖，pom.xml文件如下 2.application.yml 文件中配置zookeeper连接的相关配置信息 3.java配置的方式添加zookeeper相关的配置 4.Zookeeper基础操作服务和分布式锁服务编码 5.watcher机制事件处理抽象封装 6.基本操作的单元测试代码

2024年03月10日
浏览(49)
springboot dubbo seata nacos集成分布式事务seata实现

官网：http://seata.io/zh-cn/docs/overview/what-is-seata.html Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案。官网；https://cn.dubbo.apache.org/zh-cn/overview/what/

2024年02月13日
浏览(47)
分布式消息队列RocketMQ概念详解

目录 1.MQ概述 1.1 RocketMQ简介 1.2 MQ用途 1.3 常见MQ产品 2.RocketMQ 基本概念 2.1 消息 2.2 主题 2.3 标签 2.4 队列 2.5 Producer 2.6 Consumer 2.7 NameServer 2.8 Broker 2.9 RocketMQ 工作流程 RocketMQ 是阿里开源的分布式消息中间件，跟其它中间件相比，RocketMQ 的特点是纯JAVA实现，是一套提供了消息

2024年02月03日
浏览(64)
分布式事务，zookeeper，dubbo，rocketmq

CAP理论是分布式领域中非常重要的一个指导理论，C（Consistency）表示强一致性，A（Availability）表示可用性，P（Partition Tolerance）表示分区容错性，CAP理论指出在目前的硬件条件下，一个分布式系统是必须要保证分区容错性的，而在这个前提下，分布式系统要么保证CP，要么保

2024年04月12日
浏览(46)
分布式消息中间件RocketMQ的应用

所有代码同步至GitCode：https://gitcode.net/ruozhuliufeng/test-rocketmq.git 普通消息消息发送分类 Producer对于消息的发送方式也有多种选择，不同的方式会产生不同的系统效果。同步发送消息同步发送消息是指，Producer发出一条消息后，会在收到MQ返回的ACK之后才发下一条消息。

2024年02月05日
浏览(87)
【SpringBoot应用篇】SpringBoot集成atomikos实现多数据源配置和分布式事务管理

讨论分布式事务之前我们分清两个概念：本地事务、分布式事务；本地事务是解决单个数据源上的数据操作的一致性问题的话，而分布式事务则是为了解决跨越多个数据源上数据操作的一致性问题。百度官方对分布式事务的定义是指事务的参与者、支持事务的服务

2024年02月16日
浏览(50)