【RocketMQ每日一问】rocketmq事务消息原理?

rocketmq事务消息原理?

RocketMQ的事务消息主要由三部分组成:半消息(Half Message)、执行本地事务和事务补偿机制。下面详细介绍这三部分:

  1. 半消息(Half Message)用户向RocketMQ发送半消息,这是一个预处理消息,也就是说它不会被消费者所消费。半消息主要存储在Commit Log中。
  2. 执行本地事务在用户的业务服务中执行本地事务。本地事务的执行结果可能成功或失败,根据本地事务的执行结果,用户会向RocketMQ提交事务或者回滚事务。
  3. 提交或回滚消息如果本地事务执行成功,用户会向RocketMQ提交事务,这将会使得之前的半消息变为可消费的消息;如果本地事务执行失败,那么用户可以回滚事务,这将会删除之前存储的半消息。
  4. 事务补偿机制如果在上述过程中产生了某些故障,例如网络问题或者应用崩溃导致RocketMQ没有收到事务提交或回滚指令,RocketMQ提供了一种事务检查机制。RocketMQ会定期扫描哪些处于"半消息"状态的消息,然后询问用户这些消息对应的本地事务执行结果。然后根据用户的反馈决定是提交还是回滚。

       
注:回查请求内容:   CHECK_TRANSACTION_STATE 请求码

"CHECK_TRANSACTION_STATE":这是一种命令类型,表示需要检查事务状态。
"producerGroup":生产者所在的组。
"tranStateTableOffset":事务状态表中的偏移值。
"commitLogOffset":提交日志中的偏移值。
"msgId":消息ID。


RocketMQ在事务消息的处理过程中,Broker和生产者端使用了特定的请求码进行通信。

请求码: Broker向生产者发送回查事务状态的请求时,会通过"CHECK_TRANSACTION_STATE"请求码来标识该操作。

当生产者客户端收到这个请求码后,它会进一步执行以下操作:

  1. RocketMQ客户端对每个生产者实例注册一个TransactionListener,这个监听器包含两个方法:executeLocalTransaction 和 checkLocalTransaction。前者用于执行本地事务,后者用于检查本地事务的状态。
  2. 当生产者客户端收到"CHECK_TRANSACTION_STATE"请求时,然后找到生产组,客户端会将生产组缓存起来,找到   MQProducerInner producer = this.mqClientFactory.selectProducer(group);,然后调用对应的producer中的TransactionListener中的checkLocalTransaction方法。
  3. checkLocalTransaction方法会根据业务逻辑判断事务执行结果,并返回一个枚举值:COMMIT_MESSAGE、ROLLBACK_MESSAGE或者UNKNOW。COMMIT_MESSAGE表示事务提交,ROLLBACK_MESSAGE表示事务回滚,UNKNOW表示未知状态。
  4. 客户端将这个结果响应给Broker,Broker根据响应结果更新消息的状态。

通过以上的步骤,RocketMQ可以确保消息的发送和本地事务的执行具有原子性,即要么都成功,要么都失败。

此外,RocketMQ内部通过一个CheckTransactionStateService服务线程来定期扫描消息,判断其是否需要检查。RocketMQ不会对每一条消息进行事务状态检查,只有当一条消息第一次被发出并且已经等待了一段时间(默认超过6s),RocketMQ才会触发事务状态的检查。

对于消息的发送方来说,如果收到RocketMQ的事务状态回查请求,需要重新检查本地事务的执行状态,然后再次向RocketMQ确认消息提交或回滚。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/263728.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

基于ssm的星巴克咖啡店管理系统论文

基于ssm的星巴克咖啡店管理系统 摘要 当下,正处于信息化的时代,许多行业顺应时代的变化,结合使用计算机技术向数字化、信息化建设迈进。以前星巴克咖啡店对于咖啡信息的管理和控制,采用人工登记的方式保存相关数据,这…

【AI提示词艺术】第11期 家居几种类型图处理和人像生成的技巧

家居处理和人像生成的技巧 AI处理家居图像具有以下优势: 自动化处理:AI可以自动处理大量的家居图像,无需人工干预。这大大提高了处理效率,节省了时间和人力成本。 快速识别和分类:AI可以快速准确地识别和分类家居图…

LSTM和GRU vs 普通的循环神经网络RNN

1、考虑下列三种情况下,对比一下普通RNN的表现和LSTM和GRU表现: (1)早期观测值对预测未来观测者具有非常重要的意义。 考虑一个极端情况,其中第一个观测值包含一个校验和, 目标是在序列的末尾辨别校验和是…

常见的弧形导轨有哪些

弧形导轨又叫圆弧导轨、滚轮圆弧导轨,是通过v形滚轮在圆弧v型导轨表面滚动,作圆周运动,运用广泛:数控机床、包装机械、输送设备、医疗器械、航空航天等设备;弧形导轨也分几种,常见的弧形导轨有以下几种&…

关于时区处理策略

前端会通过 App-Id 请求头附带 客户端时区 信息 前端传入的如果是 字符串,会自动根据 请求的客户端时区 解析为对应的 日期 如果前端传入的是时间戳,则无需额外解析转换 如果是 商户后台、管理后台 都统一基于 商户所在国家的时区(总台目前…

机器视觉:AI赋能缺陷检测,铸就芯片产品的大算力与高能效

导言:近年来,国内芯片行业快速发展,市场对芯片需求的不断增大,芯片的缺陷检测压力也越来越大。芯片产品在生产制造过程中,需要经历数道工序,每个生产环节的材料、环境、工艺参数等都有可能造成产品缺陷。不…

2023最新版JavaSE教程——第13天:泛型

目录 一、泛型概述1.1 生活中的例子1.2 泛型的引入 二、使用泛型举例2.1 集合中使用泛型2.1.1 举例2.1.2 练习 2.2 比较器中使用泛型2.2.1 举例2.2.2 练习 2.3 相关使用说明 三、自定义泛型结构3.1 泛型的基础说明3.2 自定义泛型类或泛型接口3.2.1 说明3.2.2 注意3.2.2 举例3.2…

react 2

1.快速搭建开发环境 2.react渲染流程 3.1 jsx基础 概念 3.2 jsx基础 本质 3.3 jsx基础 jsx表达式 3.4 jsx基础 实现列表渲染 3.5 jsx基础 实现条件渲染 3.5 jsx基础 实现复杂的条件渲染 4. react中事件绑定 5.react组建基础使用 6.1 useState 6.2 useState修改状态的规则 7.基础…

海外媒体发稿:雅虎全球发稿推广脱颖而出的10种方法-华媒舍

雅虎全球发稿是一项重要的推广手段,能够帮助企业和个人提升品牌知名度和曝光率。在众多的发稿中脱颖而出并不容易。本文将为您介绍10种让您的雅虎全球发稿在众多文章中脱颖而出的方法,帮助您取得更好的效果。 1. 深入研究目标受众 在撰写雅虎全球发稿前…

【排序算法】C语言实现选择排序与冒泡排序

文章目录 🚀前言🚀冒泡排序✈️冒泡排序的逻辑✈️冒泡排序coding 🚀选择排序✈️选择排序的逻辑✈️选择排序coding 🚀前言 这里是阿辉算法与数据结构专栏的第一篇文章,咱们就从排序算法开始讲起,排序算法…

优化企业员工管理的利器——ADManager Plus

在当今数字化的商业环境中,企业员工管理是组织成功运营的关键组成部分。为了提高效率、确保安全性和满足法规合规性要求,企业需要一种强大的工具来简化和集中管理其活跃目录(Active Directory)环境。ADManager Plus作为一款功能丰…

Ubuntu 常用命令之 zip 命令用法介绍

📑Linux/Ubuntu 常用命令归类整理 Ubuntu系统下的zip命令是用来压缩文件的。这个命令可以将一个或多个文件或者目录压缩成一个.zip文件,也可以将整个目录树压缩成一个.zip文件。 zip命令的基本格式 zip [选项] [压缩文件名] [要压缩的文件或目录...]z…

10、基于LunarLander登陆器的Dueling DDQN强化学习(含PYTHON工程)

10、基于LunarLander登陆器的Dueling DDQN强化学习(含PYTHON工程) LunarLander复现: 07、基于LunarLander登陆器的DQN强化学习案例(含PYTHON工程) 08、基于LunarLander登陆器的DDQN强化学习(含PYTHON工程…

Mybatis的关联查询(association和collection)

关联查询 实体间的关系(拥有 has、属于 belong) OneToOne:一对一关系(account ←→ user) OneToMany:一对多关系(user ←→ account) ManyToMany:多对多关系&#xff0…

测试框架|Burp Suite几个基本工具的使用

前阵子项目上想通过测试工具在网页上模拟返回错误代码 500 来查看页面的错误处理,然后去调查了下 burp suite,看了些基本工具的使用文档。虽然最后证实 burp suite 只能用来处理页面测试应用程序的实际行为和响应,而不是尝试模拟不存在的问题…

python脚本传参

sys.argvargparse 第一种:argparse 简单使用: import argparse # 创建一个参数解析实例 parser argparse.ArgumentParser(descriptionParameters) # 添加参数解析 parser.add_argument(--training_epoch, typeint, default3000) parser.add_argument(…

flutter + firebase 云消息通知教程 (android-安卓、ios-苹果)

如果能看到这篇文章的 一定已经对手机端的 消息推送通知 有了一定了解。 国内安卓厂商这里不提都有自己的FCM 可自行查找。(国内因无法科学原因 ,不能使用谷歌服务)只说海外的。 目前 adnroid 和 ios 推送消息分别叫 FCM 和 APNs。这里通过…

flutter开发windows应用的库

一、window_manager 这个插件允许 Flutter 桌面应用调整窗口的大小和位置 地址:https://github.com/leanflutter/window_manager二、win32 一个包,它使用FFI包装了一些最常见的Win32 API调用,使Dart代码可以访问这些调用,而不需…

华为交换机配置BGP的基本示例

BGP简介 定义 边界网关协议BGP(Border Gateway Protocol)是一种实现自治系统AS(Autonomous System)之间的路由可达,并选择最佳路由的距离矢量路由协议。早期发布的三个版本分别是BGP-1(RFC1105&#xff0…

Python+Playwright自动化测试--playwright处理浏览器多窗口切换

1.简介 浏览器多窗口的切换问题相比大家不会陌生吧,之前小编在javaselenium系列文章中就有介绍过。大致步骤就是:使用selenium进行浏览器的多个窗口切换测试,如果我们打开了多个网页,进行网页切换时,我们需要先获取各…
最新文章