RabbitMQ消息消费时的权衡

消息的持久化是交换器、队列、消息三者的持久化才能成为消息的持久化。

Qos 预取模式

事务模式

消息消费的拒绝

消息的拒绝方式

Reject（只能单条拒绝）

//TODO Reject方式拒绝(这里第2个参数决定是否重新投递)
// 第一个参数：nvelope.getDeliveryTag() 信封里标识每条信息的ID
// 第二个参数：true为重新投递，false为丢弃消息
channel.basicReject(envelope.getDeliveryTag(),true);

Nack(可以批次拒绝，也可以单条拒绝)

//TODO Nack方式的拒绝（）
//第一个参数同上
//第2个参数决定是否批量
//第三个参数决定是否重新投递，true代表可以重新投递,false会丢弃消息
channel.basicNack(envelope.getDeliveryTag(), false, false);

死信交换器DLX(死了的消息)

死了的消息主要有:过期、队列达到最大长度、拒绝且requeue=false
如果队列达到最大的长度,根据队列先进先出的特性，最老的那条(最先进去的)会成为为死信消息

备用交换器与死信交换器的关系

备用交换器----死信交换器

备用交换器指消息还没有进入到队列的情况，生产者往Rabbit中去发消息，备用交换器可以给消息兜底(消息会被消费)(保证生产者消息不会丢失)
死信交换器指消息到了正常的队列，消费者拒绝了该消息，同时又设置不能发生重新投递(一般情况下，保证消费者消息不会丢失)

队列的控制

临时队列(存储内存中)没有持久化的队列
- 自动删除队列(自动删除队列判断的条件：消费者断开)
- 单消费者队列（消息会被独占，不会采取轮询）
- 自动过期队列
  自动过期队列(从什么时候开始算起)
  1、队列中没有GET操作
  2、队列中没有consumer消费者连上去
持久化队列(内存中也有,数据存在磁盘)

消息消费时的权衡------总结

消费者主要关注队列
消费者一般使用推送
死信交换器结合消息过期机制一般用在“限时订单”业务场景
批量机制可以极大提升性能
事务机制一般会被遗弃
单队列一般用于顺序消息，但是也丧失了高性能
消费者遇到异常不用慌，各种机制来护航
消息重新投递、死信交换器、消息丢弃

四、RabbitMQ消息消费时的权衡相关推荐

三、RabbitMQ消息发布时的权衡
目录标题 RabbitMQ消息发布时的权衡失败通知消息发布时的权衡: 加入事务发送方确认备用交换器总结 RabbitMQ消息发布时的权衡失败通知 mandatory 消息发布时的权衡: 加 ...
如何保证消息不被重复消费啊（如何保证消息消费时的幂等性）？
1.面试题如何保证消息不被重复消费啊(如何保证消息消费时的幂等性)? 2.面试官心里分析其实这个很常见的一个问题,这俩问题基本可以连起来问.既然是消费消息,那肯定要考虑考虑会不会重复消费?能不能避 ...
rocketmq存储消息mysql_RocketMQ消息消费以及进度管理解析
最近 ONS 消息堆积的很严重,并且经常发现部分几乎没有消息消费的消费者也提示堆积,所以有必要深入了解一下 RocketMQ 的设计思路,来看看堆积量如何计算,以及如何正确的使用 Topic 以及 C ...
kafka消息消费有延迟_消息中间件选型分析---从Kafka与RabbitMQ的对比来看全局
有很多网友留言:公司要做消息中间件选型,该如何选?你觉得哪个比较好?消息选型的确是一个大论题,实则说来话长的事情又如何长话短说.对此笔者专门撰稿一篇内功心法:如何看待消息中间件的选型,不过这篇只表其意 ...
四种策略确保 RabbitMQ 消息发送可靠性！你用哪种？
微服务可以设计成消息驱动的微服务,响应式系统也可以基于消息中间件来做,从这个角度来说,在互联网应用开发中,消息中间件真的是太重要了. 今天,以 RabbitMQ 为例,松哥来和大家聊一聊消息中间消息发 ...
Rabbitmq消息可靠投递和重复消费等问题解决方案
消息的可靠性投递在一些对数据一致性要求较高的业务场景里面,如果消息在发布和消费过程中出现了问题(消息丢失,消息重复消费),就会导致数据不一致,要做到消息的可靠性投递. 在RabbitMq里面提供了很 ...
RabbitMQ消息重复消费问题
业务背景消息队列在数据传输的过程中,为了保证消息传递的可靠性,一般会对消息采用ack确认机制,如果消息传递失败,消息队列会进行重试,此时便可能存在消息重复消费的问题. 比如,用户到银行取钱后会收到扣 ...
（四）RabbitMQ消息队列-服务详细配置与日常监控管理
(四)RabbitMQ消息队列-服务详细配置与日常监控管理原文:(四)RabbitMQ消息队列-服务详细配置与日常监控管理 RabbitMQ服务管理启动服务:rabbitmq-server -de ...
RabbitMq 消息接收确认(可靠消费)
RabbitMq 消息接收确认(可靠消费) 一.消息接收确认是什么: 是RabbitMq确认消息是否成功被消费的一种机制. 有三种消息确认方式: 1.none代表不确认:该模式下,只要队列获取到了消息 ...

四、RabbitMQ消息消费时的权衡

RabbitMQ消息消费时的权衡

Qos 预取模式

事务模式

消息消费的拒绝

消息的拒绝方式

死信交换器DLX(死了的消息)

备用交换器与死信交换器的关系

队列的控制

消息消费时的权衡------总结

四、RabbitMQ消息消费时的权衡相关推荐

最新文章

热门文章