RocketMQ场景问题

1.消息丢失

   有这么一个场景,就是订单支付完成之后,订单系统会进行发送消息给RocketMQ集群,下游会有积分系统进行监听这个消息,进行消费然后给用户发放积分。在下面的这个场景中,通过查询日志发现了订单系统发送订单支付消息的日志。别的就没有了。

那我们进行分析

1. 发送订单支付消息给RocketMQ集群会出现消息丢失的情况的吗?

 会出现消息丢失的情况,可能出现的原因:在发送的过程中,出现了网络抖动,导致了消息没有发送的MQ的集群上;MQ集群收到了消息,但是在进行保存的时候,由于自身的一些bug或者其他原因导致数据没有存储上也是可能的等。

2.消息到达了MQ,MQ会自己导致数据丢失吗?

答案也是可能的,举个例子,我们发送消息到MQ集群上,此时消息还是在os cache中,还是没有写入到磁盘,此时Broker机器发生了宕机,那么消息就会出现丢失的情况。

3.消息到达了MQ,并且MQ将数据写入了磁盘,数据还会丢失吗?

答案还是有可能的,比方说磁盘发生了故障,导致数据的丢失。

4.消费者拿到了消息,消息就不会丢失了吗?

答案还是有可能会丢失的,假如我们的消费者拿到了消息,此时还没有进行消费,此时系统会有自动提交offset的能力,自动提交了offset,同时咱们的消息者宕机了,那么再次重启之后,这条消息就会出现丢失的情况。

解决方案:

针对情况一:我们可以采用RocketMQ的事务消息机制来保证消息发送的可靠性。

步骤一 都失败了,那就没必要进行更新订单状态可以直接返回了;

步骤二失败了 此时就会有步骤五算是一个补偿机制来进行反查状态;

步骤三失败了,会触发步骤四进行RollBack;

步骤四失败了此时就会有步骤五算是一个补偿机制来进行反查状态;

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

openwrt host方式编译ffmpeg尝试及问题分析

openwrt host方式编译ffmpeg尝试及问题分析 configure错误分析编译错误一: ERROR: gnutls not found using pkg-config编译错误2: ERROR: libdrm not found using pkg-config编译错误3: ERROR: libmp3lame >= 3.98.3 not found编译错误4: ERROR: x264 not found using pkg…

springboot优先级和ThreadLocal

什么是ThreadLocal 定义:ThreadLocal 是线程的局部变量,为每个线程提供单独一份存储空间,具有线程隔离的效果。特点:不同的线程之间不会相互干扰。 ThreadLocal的应用场景 数据共享:在同一个线程或同一个请求中进行…

cordova项目环境搭建 hello

环境准备: 1.下载nodejs并安装配置。 直接官网下载最新版本。此次我是下载的 Node.js v22.12.0。 1.1安装好后配置镜像。 输入:node -v // 显示node.js版本 npm -v // 显示npm版本 1.2环境配置 (1)找到安装的目录&am…

LE Audio 初探

LE Audio 架构 一.LE Audio profile框架 profile初识: BAP: BAP通常在手机端实现,它允许配置编解码器,配置QoS(质量服务),控制流媒体, PACS: Published Audio Capabilities Service,…

Ⅱ.INTRODUCTION TO CUDA C

前言 上一节环境配置好了,我们开始吧! 一、A First Program 1. Hello, World! 我们先写一个C语言的 Hello, World! 作为对比 int main(void){printf("Hello, World!\n");return 0; }大家应该知道这个代码运行在CPU上吧,我们CP…

CSP初赛知识学习计划(第一天)

计算机知识全解析 一、计算机的发展历程 计算机的发展堪称一部波澜壮阔的科技史诗,其源头可追溯至古老的计算工具。早期,为了满足人类在天文、历法计算以及商业贸易中对数据处理的需求,算盘、算筹等手动计算器械应运而生,它们依…

科大讯飞android面试题及参考答案

如何理解面向对象编程? 面向对象编程(Object - Oriented Programming,简称 OOP)是一种编程范式,它以对象为核心来组织程序结构。 在面向对象编程中,对象是数据和操作这些数据的方法的集合。例如,我们可以把汽车看作一个对象。汽车有自己的属性,像颜色、品牌、速度等,这…

【数据仓库】hadoop web UI 增加账号密码认证

​ 升级了hadoop版本到3.3.6,未配置任何鉴权,默认端口9870 8088开放到了公网,结果没几天就被挖矿攻击了。通过开放的端口提交了很多非法任务到yarn上,并成功在服务器执行了恶意脚本。这次是真实真切的感受了,网络环境的险恶,以前仅仅是别人的案例来提高自己的安全意识,这…

域上的多项式环,整除,相通,互质

例1.已知 (R,,x)为域,请选出正确的说法:(A)(R,,x)也是整区; ABCD (B)R中无零因子; C)R在x运算上满足第一、二、三指数律; (D)R只有平凡理想; (E)R只有平凡子环。 域的特征: 域中,非0元素的加法周期 思考、在模7整数环R,中,…

【0x0014】HCI_Read_Local_Name命令详解

目录 一、命令概述 二、命令格式 三、返回事件及参数说明 3.1. HCI_Command_Complete 事件 3.2. Status 3.3. Local_Name 四、命令执行流程 4.1. 命令发送 4.2. 控制器接收并处理命令 4.3. 控制器返回结果 4.4. 主机接收并解析事件包 4.5. 示例代码 五、应用场景 …

【AI日记】25.01.04 kaggle 比赛 3-3 | 王慧玲与基层女性

【AI论文解读】【AI知识点】【AI小项目】【AI战略思考】【AI日记】 工作 参加:kaggle 比赛 Forecasting Sticker Sales时间:6 小时 读书 书名:基层女性时间:3 小时原因:虽然我之前就知道这个作者,因为我…

【从零开始入门unity游戏开发之——C#篇40】C#特性(Attributes)和自定义特性

文章目录 前言一、特性(Attributes)基本概念二、自定义特性1、自定义特性代码示例:2、应用自定义特性:3、解释3.1 **AttributeUsage 特性**3.2 特性的命名3.3 **构造函数**:3.4 **属性**: 4、使用反射获取特…

PG起库逻辑和spill导致起库慢问题分析

问题现象-起库缓慢 版本pg13.2 数据库启动缓慢,startup进程在读取spill文件,文件名在变化。查看spill文件也很慢,ls -l最后跑出来有800w个文件spill文件。 为什么有上千万个spill文件 wal段和LSN的含义 LSN LSN总体是一个64位的bigint&…

【Python学习(六)——While、for、循环控制、指数爆炸】

Python学习(六)——While、for、循环控制、指数爆炸 本文介绍了While、for、循环控制、指数爆炸,仅作为本人学习时记录,感兴趣的初学者可以一起看看,欢迎评论区讨论,一起加油鸭~~~ 心中默念:Py…

【JS】期约的Promise.all()和 Promise.race()区别

概述 Promise.all() 和 Promise.race() 都是 JavaScript 中处理多个异步操作的 Promise 方法,但它们的行为和返回结果有所不同。 Promise.all()和Promise.race() 1. Promise.all() Promise.all() 接受一个由多个 Promise 实例组成的可迭代对象(例如数…

5 Linux 网络编程基础 API

5 Linux 网络编程基础 API 主机字节序和网络字节序 主机&#xff08;小端&#xff09;字节序&#xff1a;0x0201网络&#xff08;大端&#xff09;字节序&#xff1a;0x0102&#xff0c;利于人看 #include <netinet/in.h> unsigned long int htonl(unsigned long int …

基于PyQt5的UI界面开发——图像与视频的加载与显示

介绍 这里我们的主要目标是实现一个基于PyQt5和OpenCV的图像浏览和视频播放应用。用户可以选择本地的图像或视频文件夹&#xff0c;进行图像自动播放和图像切换以及视频播放和调用摄像头等操作&#xff0c;并且支持图像保存功能。项目的核心设计包括文件路径选择、图像或视频的…

JAVA类和对象练习

设计一个矩形类Rectangle&#xff0c;包含私有的数据成员宽度(Width)和高度(Height)&#xff1b;公有的方法double getArea()返回矩形的面积&#xff0c;公有的方法double getPerimeter()返回矩形的周长。 例如: 测试Result Rectangle rectnew Rectangle(8,5); System.out.pr…

云手机+Facebook:让科技与娱乐完美结合

移动互联网时代&#xff0c;Facebook作为全球最大的社交媒体平台之一&#xff0c;早已成为企业、品牌和组织竞相角逐的营销阵地。而云手机的出现&#xff0c;则为Facebook营销注入了新的活力&#xff0c;其独特的优势让营销活动更加高效、精准且灵活。本文将深入探讨云手机在Fa…

全新免押租赁系统打造便捷安全的租赁体验

内容概要 全新免押租赁系统的推出&#xff0c;标志着租赁行业的一次重大变革。这个系统的最大特点就是“免押金”&#xff0c;大大减轻了用户在租赁过程中的经济负担。从此&#xff0c;不再需要为一部手机或其他商品支付高昂的押金&#xff0c;用户只需通过简单的信用评估&…