当前位置: 首页 > article >正文

如何保证RabbitMQ消息的可靠传输?

丢失分为:生产者丢失消息、消息列表丢失消息、消费者丢失消息;

1.生产者丢失消息

从生产者弄丢数据这个角度来看,RabbitMQ提供transaction和confirm模式来确保生产者不丢消息;transaction机制就是说:发送消息前,开启事务(channel.txSelect()),然后发送消息,如果发送过程中出现什么异常,事务就会回滚(channel.txRollback()),如果发送成功则提交事务(channel.txCommit())。然而,这种方式有个缺点:吞吐量下降;

confirm模式用的居多:一旦channel进入confirm模式,所有在该信道上发布的消息都将会被指派一个唯一的ID(从1开始),一旦消息被投递到所有匹配的队列之后;rabbitMQ就会发送一个ACK给生产者(包含消息的唯一ID),这就使得生产者知道消息已经正确到达目的队列了;

如果rabbitMQ没能处理该消息,则会发送一个Nack消息给你,你可以进行重试操作。

2.消息队列丢数据:消息持久化。

处理消息队列丢数据的情况,一般是开启持久化磁盘的配置。

这个持久化配置可以和confirm机制配合使用,你可以在消息持久化磁盘后,再给生产者发送一个Ack信号。

这样,如果消息持久化磁盘之前,rabbitMQ阵亡了,那么生产者收不到Ack信号,生产者会自动重发。

那么如何持久化呢?这里顺便说一下吧,其实也很容易,就下面两步

将queue的持久化标识durable设置为true,则代表是一个持久的队列

发送消息的时候将deliveryMode=2,这样设置以后,即使rabbitMQ挂了,重启后也能恢复数据

3.消费者丢失消息:

消费者丢数据一般是因为采用了自动确认消息模式,改为手动确认消息即可!

消费者在收到消息之后,处理消息之前,会自动回复RabbitMQ已收到消息;如果这时处理消息失败,就会丢失该消息;

解决方案:处理消息成功后,手动回复确认消息。


http://www.kler.cn/a/378324.html

相关文章:

  • Vehicle OS软件平台解决方案
  • 操作系统(10) (并发(2)------基于软件/硬件/操作系统层面解决两个进程之间的临界区问题/抢占式/非抢占式内核)
  • Postgresql源码(137)执行器参数传递与使用
  • RestTemplate 常用方法(提供了多种方法来发送 HTTP 请求)
  • 使用DJL和PaddlePaddle的口罩检测详细指南
  • HTML 块级元素和内联(行内)元素详解
  • linux驱动-输入子系统框架讲解
  • ERC论文阅读(04)--DialogueCRN论文阅读笔记(2024-11-03)
  • Apache POI(java操作Miscrosoft Office)
  • 江协科技STM32学习- P31 I2C通信协议
  • 多臂老虎机——入门强化学习
  • linux-环境变量
  • 心法利器[121] | 读源码:用mT5训练一个自动摘要模型(含代码)
  • 计算机毕业设计Python+大模型新闻自动分类 新闻舆情预测 新闻语料情感分析 新闻推荐系统 朴素贝叶斯分类算法 机器学习 深度学习
  • 【多模态读论文系列】LLaVA论文笔记
  • list与iterator的之间的区别,如何用斐波那契数列探索yield
  • Java后端面试内容总结
  • fetch 与 xmlHttpRequest 请求总结
  • IT运维的365天--018 如何在内网布置一个和外网同域名的网站,并开启SSL(https访问),即外网证书如何在内网使用
  • 【机器学习】回归树
  • 【大语言模型】ACL2024论文-06 探索思维链COT在多模态隐喻检测中的应用
  • Logback 常用配置详解
  • 第十九章 Vue组件之data函数
  • Python Matplotlib 如何处理大数据集的绘制,提高绘图效率
  • lc 73 矩阵置0 ACM模式
  • webpack5