目錄 什么是中間件 消息隊列協議 AMQP協議 MQTT協議 OpenMessage協議 Kafka協議 消息隊列持久化 ...
目錄 過期時間TTL 設置隊列TTL 消息確認機制的配置 死信隊列 內存磁盤的監控 RabbitMQ的內存控制 命令的方式 配置文件方式 rabbitmq.conf RabbitMQ的內存換頁 RabbitMQ的磁盤預警 集群 RabbitMQ 集群 集群搭建 分布式事務 分布式事務的方式 兩階段提交 PC 需要數據庫產商的支持,java組件有atomikos等 補償事務 TCC 嚴選,阿里,螞 ...
2021-09-05 18:57 5 340 推薦指數:
目錄 什么是中間件 消息隊列協議 AMQP協議 MQTT協議 OpenMessage協議 Kafka協議 消息隊列持久化 ...
1. 簡介 MQ(Message Queue)消息隊列,是基礎數據結構中“FIFO(先進先出)”的一種數據結構。 一般用來解決應用解耦,異步消息,流量削峰等問題,實現高性能,高可用,可伸縮和最終一 ...
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)。 ...