RocketMQ事务消息是如何实现的？
大家好，我是锋哥。今天分享关于【RocketMQ事务消息是如何实现的？】面试题。希望对大家有帮助；
RocketMQ事务消息是如何实现的？
1000道 互联网大厂Java工程师 精选面试题-Java资源分享网
RocketMQ 事务消息的实现是通过 分布式事务 的机制来保证消息的可靠性和一致性，主要通过 三阶段提交（Three-Phase Commit）来实现。下面详细介绍 RocketMQ 事务消息的实现过程：
1. 事务消息的概述
RocketMQ 提供了事务消息的功能，用于处理消息的 最终一致性，保证消息在发送和消费过程中的原子性。如果消息发送成功但消费者无法正常处理，可以通过重试机制和事务补偿来确保最终一致性。
2. 事务消息的实现机制
RocketMQ 事务消息的实现分为三个阶段：
阶段 1：消息发送（事务消息的发送阶段）
- 在发送消息时，生产者会先发送一条 半消息（Half Message） 到消息队列，这条消息处于 暂挂状态，此时消息并未真正被消费者消费。
- 在这一步中，消息会附带上一个事务标识，以便后续处理。
阶段 2：执行本地事务（事务执行阶段）
- 消息发送到 Broker 后，生产者会执行本地事务逻辑，比如数据库操作、调用外部接口等。
- 在执行本地事务时，生产者会返回一个 事务状态（COMMIT、ROLLBACK、UNKNOWN）来告知 Broker 事务的执行结果：
- COMMIT：本地事务成功，消息可以提交给消费者。
- ROLLBACK：本地事务失败，消息会被回滚，消费者无法消费。
- UNKNOWN：事务未完成，需要进一步检查。
阶段 3：消息提交或回滚（事务消息的补偿检查阶段）
- 在事务执行完成后，生产者会向 RocketMQ Broker 发送事务状态的反馈：
- 如果生产者执行了本地事务，并返回了
COMMIT，Broker 会将半消息变为正常消息，并允许消费者消费。 - 如果返回了
ROLLBACK，Broker 会丢弃该消息，确保消费者无法消费。 - 如果生产者返回
UNKNOWN，Broker 会在一定时间后发起 事务状态检查请求，这时 Broker 会询问生产者该消息的事务状态。如果生产者在事务状态检查时依然没有给出明确结果，Broker 会重试这个检查操作直到得到结果。
- 如果生产者执行了本地事务，并返回了
3. 事务状态检查
RocketMQ 为了确保事务的最终一致性，设计了一个 事务状态回查机制：
- 当生产者未能返回明确的事务状态（例如，因网络问题等）时，Broker 会定期向生产者发起 事务状态回查。
- 生产者需要在回查接口中提供事务状态（COMMIT 或 ROLLBACK），并根据业务逻辑返回当前事务的最终处理结果。
4. 事务消息的发送过程
- 生产者通过
sendMessageInTransaction()方法发送事务消息。 - 在
sendMessageInTransaction()调用中，消息被发送到 Broker 后，生产者会执行本地事务（例如，数据库更新、调用外部接口等）。 - 如果本地事务执行成功，则返回
COMMIT事务状态，消息就会正常提交。 - 如果本地事务失败，则返回
ROLLBACK，消息会被回滚。 - 如果状态未知，则返回
UNKNOWN，并等待事务状态回查。
5. 事务回查接口
生产者需要实现一个 事务回查接口 (TransactionCheckListener)，当消息处于未知状态时，Broker 会调用该接口来确认事务的最终状态。接口方法通常如下：
public interface TransactionCheckListener {// 用于回查事务状态public TransactionStatus checkLocalTransaction(Message msg);
}
6. 事务消息的总结
- 事务消息通过半消息 + 本地事务 + 事务回查的机制，确保了消息在发送与消费过程中能够达到最终一致性。
- RocketMQ 事务消息的优势在于它能够保证 异步消息传递过程中的一致性，特别适用于需要保证数据一致性和可靠性的场景。
- 这种机制对于实现金融、电商等场景中的分布式事务非常有用。
7. 使用 RocketMQ 事务消息时需要注意
- 事务消息的性能开销较大，因为涉及到消息发送、事务执行、状态回查等步骤。它适合用于那些必须保证一致性的场景，不建议用于高吞吐量的消息场景。
- 回查逻辑可能会导致事务的不确定性，因此需要确保回查的实现逻辑能够正确判断事务状态。
总体来说，RocketMQ 事务消息通过三阶段提交机制，确保了消息在高并发、分布式系统中的一致性和可靠性。
相关文章：
RocketMQ事务消息是如何实现的？
大家好，我是锋哥。今天分享关于【RocketMQ事务消息是如何实现的？】面试题。希望对大家有帮助； RocketMQ事务消息是如何实现的？ 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 RocketMQ 事务消息的实现是通过 分布式事…...
16届蓝桥杯寒假刷题营】第2期DAY5IOI赛
3.小蓝小彬的代码挑战 - 蓝桥云课 问题描述 在蓝桥杯大赛中，小蓝和小彤是一对好朋友。他们在比赛中遇到了一个有趣的挑战。这个挑战是给定一个由大写字母组成的代码，他们需要找出这串代码中有多少个子序列LQB。小蓝和小彬都很聪明，他们想到…...
【云安全】云原生-K8S-搭建/安装/部署
一、准备3台虚拟机 务必保证3台是同样的操作系统！ 1、我这里原有1台centos7，为了节省资源和效率，打算通过“创建链接克隆”2台出来 2、克隆之前，先看一下是否存在k8s相关组件，或者docker相关组件 3、卸载原有的docker …...
)
[A-29]ARMv8/v9-GIC-中断子系统的安全架构设计(Security/FIQ/IRQ)
ver0.1 前言 打开这篇文章的时候，我们已经为每一个中断信号规划一条路径，在外设和PE-Core之间建立了消息通道，外设有紧急的情况下可以给SOC中的大哥打报告了。下面就把接力棒就交到了CPU手里了，但是PE-Core要交给那个Exception Level以及Security下运行的软件处理呢？本文…...
12 款开源OCR发 PDF 识别框架
2024 年 12 款开源文档解析框架的选型对比评测：PDF解析、OCR识别功能解读、应用场景分析及优缺点比较 这是该系列的第二篇文章，聚焦于智能文档处理（特别是 PDF 解析）。无论是在模型预训练的数据收集阶段，还是基于 RAG…...
使用 lock4j-redis-template-spring-boot-starter 实现 Redis 分布式锁
在分布式系统中，多个服务实例可能同时访问和修改共享资源，从而导致数据不一致的问题。为了解决这个问题，分布式锁成为了关键技术之一。本文将介绍如何使用 lock4j-redis-template-spring-boot-starter 来实现 Redis 分布式锁，从而…...
css-background-color（transparent）
1.前言 在 CSS 中，background-color 属性用于设置元素的背景颜色。除了基本的颜色值（如 red、blue 等）和十六进制颜色值（如 #FF0000、#0000FF 等），还有一些特殊的属性值可以用来设置背景颜色。 2.backgrou…...
MySQL 9.2.0 的功能
MySQL 9.2.0 的功能 MySQL 9.2.0 的功能新增、弃用和删除内容如下： 新增功能 权限新增12：引入了CREATE_SPATIAL_REFERENCE_SYSTEM权限，拥有该权限的用户可执行CREATE SPATIAL REFERENCE SYSTEM、CREATE OR REPLACE SPATIAL REFERENCE SYSTEM…...
编程题-最长的回文子串（中等）
题目： 给你一个字符串 s，找到 s 中最长的回文子串。 示例 1： 输入：s "babad" 输出："bab" 解释："aba" 同样是符合题意的答案。示例 2： 输入：s &…...
打破传统束缚：领略 Web3 独特魅力
在互联网发展的历程中，我们见证了Web1和Web2的变迁。Web1是静态信息的展示平台，Web2则引领了社交互动和内容创作的繁荣，而如今，Web3作为新时代的互联网架构，正逐渐展现出其独特的魅力，带领我们走向一个更加…...
linux系统中的 scp的使用方法
SCP（Secure Copy Protocol）是一种通过加密的方式在本地主机和远程主机之间安全地传输文件的协议。 它是基于SSH协议的扩展，允许用户在不同主机之间进行文件复制和传输，是Linux和Unix系统中常用的工具之一。 在嵌入式Linux软件的…...
RAG技术：通过向量检索增强模型理解与生成能力
网罗开发 （小红书、快手、视频号同名） 大家好，我是 展菲，目前在上市企业从事人工智能项目研发管理工作，平时热衷于分享各种编程领域的软硬技能知识以及前沿技术，包括iOS、前端、Harmony OS、Java、Python等…...
【现代深度学习技术】深度学习计算 | 参数管理
【作者主页】Francek Chen 【专栏介绍】 ⌈ ⌈ ⌈PyTorch深度学习 ⌋ ⌋ ⌋ 深度学习 (DL, Deep Learning) 特指基于深层神经网络模型和方法的机器学习。它是在统计机器学习、人工神经网络等算法模型基础上，结合当代大数据和大算力的发展而发展出来的。深度学习最重…...
【Linux基础指令】第三期
近期更新的基础指令链接： 【Linux基础指令】第一期-CSDN博客 【Linux基础指令】第二期-CSDN博客 本期博客的主题依旧是 "基础指令" ；话不多说，正文开始。 一、Linux的指令 1.zip / unzip 功能：打包压缩 命令格式&…...
WPS数据分析000005
目录 一、数据录入技巧 二、一维表 三、填充柄 向下自动填充 自动填充选项 日期填充 星期自定义 自定义序列 1-10000序列 四、智能填充 五、数据有效性 出错警告 输入信息 下拉列表 六、记录单 七、导入数据 编辑 八、查找录入 会员功能 Xlookup函数 VL…...
UiAutomator的详细介绍
UIAutomator作为一种高效的测试框架，通过自动化手段显著提升了用户界面（UI）测试的效率与准确性。它不仅支持自动生成功能测试用例，还允许开发者在不同设备上执行这些测试，确保了应用程序的一致性和稳定性。 以下是对 …...
在虚拟机里运行frida-server以实现对虚拟机目标软件的监测和修改参数（一）
frida-server下载路径 我这里选择frida-server-16.6.6-android-x86_64 以root身份启动adb 或 直接在android studio中打开 adb root 如果使用android studio打开的话，最好选择google api的虚拟机，默认以root模式开启 跳转到下载的frida-server文件位…...
Ubuntu二进制部署K8S 1.29.2
本机说明 本版本非高可用，单Master，以及一个Node 新装的 ubuntu 22.04k8s 1.29.3使用该文档请使用批量替换 192.168.44.141这个IP，其余照着复制粘贴就可以成功需要手动 设置一个 固定DNS，我这里设置的是 8.8.8.8不然coredns无法…...
机器学习周报-文献阅读
文章目录 摘要Abstract 1 相关知识1.1 WDN建模1.2 掩码操作（Masking Operation） 2 论文内容2.1 WDN信息的数据处理2.2 使用所收集的数据构造模型2.2.1 Gated graph neural network2.2.2 Masking operation2.2.3 Training loss2.2.4 Evaluation metrics 2…...
TensorFlow实现逻辑回归模型
逻辑回归是一种经典的分类算法，广泛应用于二分类问题。本文将介绍如何使用TensorFlow框架实现逻辑回归模型，并通过动态绘制决策边界和损失曲线来直观地观察模型的训练过程。 数据准备 首先，我们准备两类数据点，分别表示两个不同…...
)
06-AD向导自动创建P封装(以STM32-LQFP48格式为例)
自动向导创建封装 自动向导创建封装STM32-LQFP48Pin封装1.选则4排-LCC或者QUAD格式2.计算焊盘相定位长度3.设置默认引脚位置(芯片逆时针)4.特殊情况下:加额外的标记 其他问题测量距离:Ctrl M测量 && Ctrl C清除如何区分一脚和其他脚?芯片引脚是逆时针看的? 自动向导…...
《 C++ 点滴漫谈： 二十四 》深入 C++ 变量与类型的世界：高性能编程的根基
摘要 本文深入探讨了 C 中变量与类型的方方面面，包括变量的基本概念、基本与复合数据类型、动态类型与内存管理、类型推导与模板支持，以及类型系统的高级特性。通过全面的理论讲解与实际案例分析，展示了 C 类型系统的强大灵活性与实践价值。…...
)
Ceph：关于Ceph 中 RADOS 块设备快照克隆管理的一些笔记整理(12)
写在前面 准备考试，整理 ceph 相关笔记博文内容涉及使用 RADOS 块设备提供 RDB 的快照和克隆如何操作理解不足小伙伴帮忙指正对每个人而言，真正的职责只有一个：找到自我。然后在心中坚守其一生，全心全意，永不停息。所有其它的路都是不完整的，是人的逃避方式，是对大众理想…...
C语言连接Mysql
目录 C语言连接Mysql下载 mysql 开发库 方法介绍mysql_init()mysql_real_connect()mysql_query()mysql_store_result()mysql_num_fields()mysql_fetch_fields()mysql_fetch_row()mysql_free_result()mysql_close() 完整代码 C语言连接Mysql 下载 mysql 开发库 方法一…...
2023CISCN初赛unzip
2023CISCN初赛unzip 随便上传一个文件，会自动跳转到uplaod.php目录下,源码如下： <?php error_reporting(0); highlight_file(__FILE__);$finfo finfo_open(FILEINFO_MIME_TYPE); if (finfo_file($finfo, $_FILES["file"]["tmp_name…...
Elasticsearch的索引生命周期管理
目录 零、参考一、ILM的基本概念二、ILM的实践步骤Elasticsearch ILM策略中的“最小年龄”是如何计算的？如何监控和调整Elasticsearch ILM策略的性能？ 1. **监控性能**使用/_cat/thread_pool API基本请求格式请求特定线程池的信息响应内容 2. **调整ILM策…...
检测到联想鼠标自动调出运行窗口，鼠标自己作为键盘操作
联想鼠标会自动时不时的调用“运行”窗口 然后鼠标自己作为键盘输入 然后打开这个网页 （不是点击了什么鼠标外加按键，这个鼠标除了左右和中间滚轮，没有其他按键了）...
2024年记 | 凛冬将至
放弃幻想，准备斗争！ 考研or就业？ 上大学以来，考研上名校在我的心里一直是一颗种子，2024年初，当时的想法是考研和就业两手抓。买了张宇的高数现代，想要死磕！ 也记了挺多笔记... 如果…...
【Java-数据结构】Java 链表面试题下 “最后一公里”：解决复杂链表问题的致胜法宝
我的个人主页 我的专栏：Java-数据结构，希望能帮助到大家！！！点赞❤ 收藏❤ 引言： Java链表，看似简单的链式结构，却蕴含着诸多有趣的特性与奥秘，等待我们去挖掘。它就像一…...
vim如何解决‘’文件非法关闭后,遗留交换文件‘’的问题
过程描述： 由于我修改文件时（一定得修改了文件，不做任何修改不会产生这个问题）的非法关闭，比如直接关闭虚拟机，或者直接断开远程工具的远程连接，产生了以下遗留交换文件的问题： 点击…...
国内优秀的FPGA设计公司主要分布在哪些城市？
近年来，国内FPGA行业发展迅速，随着5G通信、人工智能、大数据等新兴技术的崛起，FPGA设计企业的需求也迎来了爆发式增长。很多技术人才在求职时都会考虑城市的行业分布和发展潜力。因此，国内优秀的FPGA设计公司主要分布在哪些城市&a…...
运用python爬虫爬取汽车网站图片并下载，几个汽车网站的示例参考
当然，以下是一些常见的汽车网站及其爬虫示例代码，展示如何爬取汽车图片并下载。请注意，爬取网站内容时应遵守网站的使用协议和法律法规，避免对网站造成不必要的负担。 示例1：爬取汽车之家图片 网站地址 汽车之家 爬…...
IO进程寒假作业DAY6
请使用互斥锁 和 信号量分别实现5个线程之间的同步 使用互斥锁 #include <stdio.h> #include <string.h> #include <stdlib.h> #include <stdio.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include &…...
C++ 中用于控制输出格式的操纵符——setw 、setfill、setprecision、fixed
目录 四种操纵符简要介绍 setprecision基本用法 setfill的基本用法 fixed的基本用法 setw基本用法 以下是一些常见的用法和示例： 1. 设置字段宽度和填充字符 2. 设置字段宽度和对齐方式 3. 设置字段宽度和精度 4. 设置字段宽度和填充字符，结合…...
solidity高阶 -- 线性继承
Solidity是一种面向合约的高级编程语言，用于编写智能合约。在Solidity中，多线继承是一个强大的特性，允许合约从多个父合约继承属性和方法。本文将详细介绍Solidity中的多线继承，并通过不同的实例展示其使用方法和注意事项。 在Sol…...
PydanticAI应用实战
PydanticAI 是一个 Python Agent 框架，旨在简化使用生成式 AI 构建生产级应用程序的过程。 它由 Pydantic 团队构建，该团队也开发了 Pydantic —— 一个在许多 Python LLM 生态系统中广泛使用的验证库。PydanticAI 的目标是为生成式 AI 应用开发带来类似 FastAPI 的体验，它基…...
Leecode刷题C语言之跳跃游戏②
执行结果:通过 执行用时和内存消耗如下： int jump(int* nums, int numsSize) {int position numsSize - 1;int steps 0;while (position > 0) {for (int i 0; i < position; i) {if (i nums[i] > position) {position i;steps;break;}}}return steps…...
fpga学习入门 串口rs232回环
奇偶检验位这里是省略了 做好回环后可以使用上位机做回环测试，top文件写的方式就是将rx（fpga端）接受到的模块（pc端）tx发送出去，这两个端口用杜邦线连接，同理模块的rx连接fpga的tx，…...
单片机基础模块学习——DS18B20温度传感器芯片
不知道该往哪走的时候，就往前走。 一、DS18B20芯片原理图 该芯片共有三个引脚，分别为 GND——接地引脚DQ——数据通信引脚VDD——正电源 数据通信用到的是1-Wier协议 优点：占用端口少，电路设计方便 同时该协议要求通过上拉电阻…...
)
C基础寒假练习(4)
输入带空格的字符串，求单词个数、 #include <stdio.h> // 计算字符串长度的函数 size_t my_strlen(const char *str) {size_t len 0;while (str[len] ! \0) {len;}return len; }int main() {char str[100];printf("请输入一个字符串: ");fgets(…...
es6.7.1分词器ik插件安装-和head插件连接es特殊配置
es6.7.1分词器ik插件安装-和head插件连接es特殊配置 如果对运维课程感兴趣，可以在b站上、A站或csdn上搜索我的账号： 运维实战课程，可以关注我，学习更多免费的运维实战技术视频 1.查看es6.7.1和es-head安装位置和es插件路径 [ro…...
Luzmo 专为SaaS公司设计的嵌入式数据分析平台
Luzmo 是一款嵌入式数据分析平台，专为 SaaS 公司设计，旨在通过直观的可视化和快速开发流程简化数据驱动决策。以下是关于 Luzmo 的详细介绍： 1. 背景与定位 Luzmo 前身为 Cumul.io ，专注于为 SaaS 公司提供嵌入式分析解决方案。…...
菜鸟之路Day10一一集合进阶（三）
菜鸟之路Day10一一集合进阶（三） 作者：blue 时间：2025.1.28 文章目录 菜鸟之路Day10一一集合进阶（三）0.概述1.双列集合概述2.Map2.1Map的常见API2.2Map的遍历方式 3.HashMap4.LinkedHashMap5.TreeMap 0.概…...
编译讯为3568开发板安卓)
Android车机DIY开发之学习篇(六)编译讯为3568开发板安卓
Android车机DIY开发之学习篇(六)编译讯为3568开发板安卓 1.SDK解压到家目录下的 rk3588_android_sdk 目录 一. 全部编译 ###执行 sudo apt-get update sudo apt-get install git-core gnupg flex bison gperf build-essential zip curl zlib1g-dev gcc-multilib gmultilib…...
Workerman和Swoole有什么区别
Workerman和Swoole都是PHP的socket服务器框架，它们之间存在一些显著的区别，主要体现在以下几个方面： 一、实现语言与性能 Workerman：使用纯PHP实现。由于PHP本身的性能限制，Workerman在某些方面可能不如C语言实现的框…...
MySQL（1）
数据库 基础篇 MYSQL概述 SQL 函数 约束 多表查询 事务 进阶篇 存储索引 索引 SQL优化 试图/存储过程/触发器 锁 InnoDB核心 MySQL管理 运维篇 日志 主从复制 分库本表 读写分离 基础篇 MySQL 数据库概念：存储数据的仓库，数据是有…...
DeepseekMath：超强开源数学模型（论文详解）
摘要 近日，中国团队Deepseek推出了一款名为DeepSeekMath的7B开源数学模型，这个模型在数学方面的表现令人惊叹。DeepSeekMath 7 B在不依赖外部工具包和投票技术的情况下，在竞赛级MATH基准测试中获得了51.7%的分数，接近Gemini-Ultr…...
OpenCSG月度更新2025.1
1月的OpenCSG取得了一些亮眼的成绩 在2025年1月，OpenCSG在产品和社区方面继续取得了显著进展。产品方面，推出了AutoHub浏览器自动化助手，帮助用户提升浏览体验；CSGHub企业版功能全面升级，现已开放试用申请，…...
简易CPU设计入门：控制总线的剩余信号（四）
项目代码下载 请大家首先准备好本项目所用的源代码。如果已经下载了，那就不用重复下载了。如果还没有下载，那么，请大家点击下方链接，来了解下载本项目的CPU源代码的方法。 CSDN文章：下载本项目代码 上述链接为本项目…...
scrol家族 offset家族 client家族学习
Scroll 系列属性 scrollTop & scrollLeft scrollTop: 返回元素的内容已向上滚动的部分的高度。scrollLeft: 返回元素的内容已向左滚动的部分的宽度。 scrollHeight & scrollWidth scrollHeight: 返回元素的实际高度，包括由于溢出而在屏幕上不可见的内容…...