原文:生產環境中,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