原文:生产环境中,RabbitMQ 持续积压消息不进行ack,发生什么了?

问题:生产环境 rabbitmq 部分客户端 channel 持续积压消息不进行ack。 . 服务配置rabbitmq 集群 普通集群模式 消费者 三台 消费线程各消费者 消费者配置 使用 spring amqp auto ack 模式 . 故障发现 近日有同学发现一个业务队列存在上千个 unacked 消息,并且有持续上涨的趋势。 . 故障表现 队列下其中两个客户端的各一个 channel 分 ...

2021-12-25 14:17 0 752 推荐指数:

查看详情

RabbitMQ消息队列里积压很多消息

1、场景:上千万条消息在mq里积压了几个小时了还没解决 2、解决: 1)先修复consumer的问题,确保其恢复消费速度,然后将现有cnosumer都停掉 ...

Thu Feb 21 18:53:00 CST 2019 2 5698
RabbitMQ消息积压的几种解决思路

在日常工作中使用RabbitMQ偶尔会遇不可预料的情况导致的消息积压,一般出现消息积压基本上分为几种情况: 消费者消费消息的速度赶不上生产速度,这总问题主要是业务逻辑没设计好消费者和生产者之间的平衡,需要改业务流程或逻辑已保证消费度跟上生产消息的速,譬如增加消费者的数量 ...

Thu Sep 17 06:31:00 CST 2020 2 13254
消息持续积压几小时怎么办

大量消息在mq里积压了几个小时了还没解决   几千万条数据在MQ里积压了七八个小时,最简单的方法可以让他恢复消费速度,然后等待几个小时消费完毕。   一个消费者一秒是1000条,一秒3个消费者是3000条,一分钟是18万条,1000多万条 ,所以如果你积压了几百万到上 ...

Tue Nov 27 18:57:00 CST 2018 1 2050
RabbitMQ---4、消息确认Ack

一:消费者确认 消费者确认或者说消费者应答指的是RabbitMQ需要确认消息到底有没有被收到 - 自动应答 boolean autoAck = true; channel.basicConsume(QUEUE_NAME, autoAck, consumer); 在订阅消息的时候可以指定应答 ...

Tue Sep 04 18:50:00 CST 2018 0 811
RabbitMQ消息确认ACK机制

1、什么是消息确认ACK。   答:如果在处理消息的过程,消费者的服务器在处理消息的时候出现异常,那么可能这条正在处理的消息就没有完成消息消费,数据就会丢失。为了确保数据不会丢失,RabbitMQ支持消息确定-ACK。 2、ACK消息确认机制。   答:ACK机制是消费者 ...

Mon Nov 04 05:56:00 CST 2019 0 9872
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM