訊息中介軟體之 rabbitmq總結

2021-10-24 19:07:14 字數 1259 閱讀 8451

**1. 生產者

生產者:投遞訊息的一方,生產者建立訊息、發布到rabbitmq中,訊息一般包括兩個部分、訊息體和標籤

消費者
消費者連線到rabbitmq伺服器、訂閱訊息

佇列

rabbitmq的內部物件、用於儲存訊息,kafka訊息是儲存在topic中、rabbitmq則是儲存在佇列中

交換器

exchange-x:生產者將訊息傳送到交換機、由交換器將訊息路由到乙個或者多個佇列中、如果路由不到、則返回給生產者或直接丟棄。

fanout 會傳送到該交換器的訊息路由到所有佇列中

direct 會把訊息路由到routingkey和bingingkey完全匹配的佇列中

topic

[外鏈轉存失敗,源站可能有防盜煉機制,建議將儲存下來直接上傳(img-hvxktjns-1602730272384)( 「標題」)]

[外鏈轉存失敗,源站可能有防盜煉機制,建議將儲存下來直接上傳(img-o3q5fdv9-1602730272390)( 「標題」)]

[外鏈轉存失敗,源站可能有防盜煉機制,建議將儲存下來直接上傳(img-qsq7faon-1602730272394)( 「標題」)]

路由鍵

routingkey 指定路由規則、需要與交換器型別和繫結鍵一起使用

繫結

bindingkey

連線通道

channel 是不能進行執行緒共享的、所有如果多執行緒實現、則需要在乙個連線上建立多個通道

broker

訊息中介軟體的服務節點

10.exchangedeclare方法詳解

exchange 交換機名稱

type交換機型別

durable 設定是否持久化,持久化就是可以將資訊儲存在磁碟中,重啟的時候不會丟失

autodelete 設定是否自動刪除、

11.queuedeclare方法詳解

queue 佇列名稱

durable 設定是否持久化,持久化就是可以將資訊儲存在磁碟中,重啟的時候不會丟失

訊息中介軟體RabbitMQ

rabbitmq 是用erlang實現的乙個高併發高可靠amqp訊息佇列伺服器。rabbitmq 依賴於erlang環境,所以先要安裝erlang 執行 otp win32 r16b03.exe 再安裝rabbitmq 執行 rabbitmq server 3.2.3.exe 新增環境變數 rabb...

訊息中介軟體RabbitMQ

1非同步 不等待 2解耦 任務的序列變並行 3流量削峰 大任務量負載均衡 rabbitmq,kafka,flume amqp advanced message queue protocol 0 訊息 分為訊息頭和訊息體,訊息頭包含 路由鍵 routing key,優先順序priority,deliv...

訊息中介軟體RabbitMQ

1.1.為什麼使用訊息佇列 應用場景 常見的訊息中介軟體有?用於實現分布式系統模組與模組之間的訊息通訊。原理 原理就是生產者生產訊息,把訊息傳送給activemq。activemq接收到訊息,然後檢視有多少個消費者,然後把訊息 給消費者,此過程中生產者無需參與。消費者接收到訊息後做相應的處理和生產者...