如何保证RabbitMQ的消息不会丢失？怎么保证RabbitMQ的可靠性？
- 生产者：
原因：
由于网络原因导致消息发送失败，消息队列没有接收到生产者发送的消息，但生产者认为消息发送成功。
解决办法：
- transaction模式：事务模式：开启事务，发送消息，成功提交事务，失败回滚事务。
- confirm模式：确认模式，不管成功与否，消息队列都给生产者一个成功或失败的回执，然后生产者根据成功或失败做处理。
- 消息队列：
正常：
消息队列接收消息，消费者监听消息并消费。
丢失：
消息队列接收消息，在消费者还没有消费之前就宕机了。这时在消息队列中的消息就丢失了。
解决：
可以对消息进行持久化操作，设置消息为持久化消息，那么持久化的消息会被保存到磁盘中，即使RabbitMQ宕机了。但是在重启
之后的时候依然可以将持久化的消息重新加载到消息队列中。在持久化消息的同时还可以结合生产的confirm模式来使用。
通过这种方式最大程度的解决消息丢失问题
- 消费者：
原因：
消费者之所以会发生消息丢失是因为消费者采用了自动确认消息模式。
丢失：在消费者采用自动确认消息模式时，在接收到消息后，会自动给消息队列发送确认信息，他是不关注这条消息在消费过程中是否
出现问题导致没有成功消费的情况的，这时消息队列已经接收到确认消费回执，并把此消息移除了，这就导致消息丢失，
解决办法：
将自动确认模式改成手动确认消息模式。接收到消息后，只有代码执行成功，消息被真正消费掉了，才发送确认消息如果执行失败就
不发送确认消息信息。
如何保证RabbitMQ的消息不会丢失？怎么保证RabbitMQ的可靠性？的更多相关文章
- rabbitmq学习（二）：rabbitmq（消息队列）的作用以及rabbitmq之直连交换机
前言 上篇介绍了AMQP的基本概念,组成及其与rabbitmq的关系.了解了这些东西后,下面我们开始学习rabbitmq(消息队列)的作用以及用java代码和rabbitmq通讯进行消息发布和接收.因 ...
- RabbitMq如何确保消息不丢失
上篇写了掌握Rabbitmq几个重要概念,从一条消息说起,这篇来总结关于消息丢失让人头痛的事情.网络故障.服务器重启.硬盘损坏等都会导致消息的丢失.消息从生产到消费主要结果以下几个阶段如下图. ①生产 ...
- 四种途径提高RabbitMQ传输消息数据的可靠性（一）
前言 RabbitMQ虽然有对队列及消息等的一些持久化设置,但其实光光只是这一个是不能够保障数据的可靠性的,下面我们提出这样的质疑: (1)RabbitMQ生产者是不知道自己发布的消息是否已经正确达到 ...
- 如何保证RabbitMQ的消息不丢失及其背后的原理
一.消息为什么丢失 RabbitMQ默认情况下的交换机和队列以及消息是非持久化的,也就是说在服务器重启或者宕机恢复后,之前创建的交换机和队列都将不复存在,之前未消费的消息也就消失不见了.原因在于每个队 ...
- RabbitMQ防止消息丢失
转载请注明出处 0.目录 RabbitMQ-从基础到实战(1)— Hello RabbitMQ RabbitMQ-从基础到实战(3)— 消息的交换 1.简介 RabbitMQ中,消息丢失可以简单的分为 ...
- RabbitMQ如何保证发送端消息的可靠投递
消息发布者向RabbitMQ进行消息投递时默认情况下是不返回发布者该条消息在broker中的状态的,也就是说发布者不知道这条消息是否真的抵达RabbitMQ的broker之上,也因此会发生消息丢失的情 ...
- RabbitMQ使用教程（三）如何保证消息99.99%被发送成功？
1. 前情回顾 RabbitMQ使用教程(一)RabbitMQ环境安装配置及Hello World示例 RabbitMQ使用教程(二)RabbitMQ用户管理,角色管理及权限设置 在以上两篇博客发布后 ...
- RabbitMQ使用教程（五）如何保证队列里的消息99.99%被消费？
1. 前情回顾 RabbitMQ使用教程(一)RabbitMQ环境安装配置及Hello World示例 RabbitMQ使用教程(二)RabbitMQ用户管理,角色管理及权限设置 RabbitMQ使用 ...
- RabbitMQ：消息丢失 | 消息重复 | 消息积压的原因+解决方案+网上学不到的使用心得
前言 首先说一点,企业中最常用的实际上既不是RocketMQ,也不是Kafka,而是RabbitMQ. RocketMQ很强大,但主要是阿里推广自己的云产品而开源出来的一款消息队列,其实中小企业用Ro ...
- RabbitMQ如何保证发送端消息的可靠投递-发生镜像队列发生故障转移时
上一篇最后提到了mandatory这个参数,对于设置mandatory参数个人感觉还是很重要的,尤其在RabbitMQ镜像队列发生故障转移时. 模拟个测试环境如下: 首先在集群队列中增加两个镜像队列的 ...
随机推荐
- jemter 分布式压测
1.测试机搭建 首选 压力机A,压力机B,压力机C, 压力机A作为控制台 压力机B,压力机C作为分布式的测试机 压力机Aip:172.16.23.69, 压力机Bip:192.168.184.128 ...
- uniapp自定义组件的使用--记录
在 pages.json同级目录下 创建目录和文件: components: videoComp: VideoPlaySelf.vue VideoPlaySelf.vue 内容 <templat ...
- efk部署
转载: https://www.cnblogs.com/liweiboy/p/16100002.html
- uniapp组件监听onShow
在uniapp开发中,组件中需要监听页面onShow的方法 index.vue onShow() { uni.$emit('onShow', 1); //用于子组件监听onShow }, 子组件 be ...
- NLP学习日记
数据读取 下载csv文件后使用excel进行转存,然后用pandas读取,再把读取后转为numpy,numpy的tensor里.-1代表数组的最大维度,将原始数据集的标签和特征集分开,便于下一步的处理 ...
- day11 事件相关笔记
day11 事件上 事件的概述 事件是指代一个东西的操作被另外一个东西监听以后的一个过程(事件),这个过程可以完成对应的操作(处理函数)事件监听器是一个标准的观察者模式(observer)也被称为订阅 ...
- Raid磁盘阵列更换磁盘时另一块盘离线恢复案例（v7000存储数据恢复）
Raid磁盘阵列更换磁盘时另一块盘离线恢复案例(v7000存储数据恢复) [故障描述]客户设备型号为IBM V7000存储,架构为AIX+oracle+V7000存储阵列柜,需要恢复的数据主要存放在阵 ...
- 第二周day7
第二周day7,星期天 所用时间:0 代码量:0 博客量:0 所学知识:提高社交能力,多锻炼.
- 基于Sobel算子的图像边缘检测
索贝尔算子(Sobeloperator)主要用于获得数字图像的一阶梯度,是一种离散性差分算子.它是prewitt算子的改进形式,改进之处在于sobel算子认为,邻域的像素对当前像素产生的影响不是等价的 ...
- ubuntu20.04系统中扩展swap分区
1.首先停止/swapfile #swapon /swapfile 2.删除以前的/swapfile #rm -rf swapfile 3.创建新的/swapfile(以2G为例) #dd if=/d ...