1. 簡介 MQ（Message Queue）消息隊列，是基礎數據結構中“FIFO（先進先出）”的一種數據結構。 一般用來解決應用解耦，異步消息，流量削峰等問題，實現高性能，高可用，可伸縮和最終一 ...

目錄 過期時間TTL 設置隊列TTL 消息確認機制的配置 死信隊列 內存磁盤的監控 RabbitMQ的內存控制 命令的方式 配置文件方式 rabbitmq ...

1.簡介 為什么要對消費端進行限流？ 其實很好理解，比如我們常能接觸到的消費場景：春運期間12306火車票的搶購，雙11期間的下單等。這些場景都有一個共同點就是都會導致短暫時間內請求數激增，如果我 ...

一、現網問題描述 1.理想情況 現網mq倒換演練，即關閉rabbitmq主，此時keepalived的檢測腳本檢查到rabbitmq服務異常，觸發腳本關閉主服務的keepalived，那么keepalived的虛擬ip就會綁定到從服務器上，繼續使用rabbitmq從節點。 2.實際情況 ...

概述 fanout扇出也稱之為廣播 在廣播模式下，消息發送的流程是這樣的，如下所示： 可以有多個消費者。 每個消費者有自己的 queue（隊列） 每個隊列都要綁定到 Excha ...

1. 簡介 我們在上一篇博文中遺留了一個小問題，就是雖然TTL + DLX能實現延遲隊列的功能，但是有兩個問題。 首先業務場景為：比如海底撈預約，每個人預約的時間段不一致，有個可能一個小時后，有的 ...

Overview Overview 概覽 connections：無論生產者還是消費者，都需要與 RabbitMQ 建立連接后才可以完成消息的生產和消費，在這里可以查看連接情況 channels：通道，建立連接后，會形成通道，消息的投遞獲取依賴 ...

對於有異常的消息我們可以有如下做法： 記錄下來再ack。 nack或者reject，同時將requeue設為false。 在第2條的基礎上增加死信（Dead Letter）。 ...