天天看點

消息隊列系統 -- RabbitMQ

消息隊列系統 -- RabbitMQ

RabbitMQ是一個在AMQP基礎上完整的,可複用的企業消息系統。他遵循Mozilla Public License開源協定。

MQ全稱為Message Queue, 消息隊列(MQ)是一種應用程式對應用程式的通信方法。應用程式通過讀寫出入隊列的消息(針對應用程式的資料)來通信,而無需專用連接配接來連結它們。消 息傳遞指的是程式之間通過在消息中發送資料進行通信,而不是通過直接調用彼此來通信,直接調用通常是用于諸如遠端過程調用的技術。排隊指的是應用程式通過 隊列來通信。隊列的使用除去了接收和發送應用程式同時執行的要求。

RabbitMQ安裝

注意:service rabbitmq-server start/stop

安裝API

使用API操作RabbitMQ

基于Queue實作生産者消費者模型

對于RabbitMQ來說,生産和消費不再針對記憶體裡的一個Queue對象,而是某台伺服器上的RabbitMQ Server實作的消息隊列。

1、acknowledgment 消息不丢失

no-ack = False,如果消費者遇到情況(its channel is closed, connection is closed, or TCP connection is lost)挂掉了,那麼,RabbitMQ會重新将該任務添加到隊列中。

消費之:

2、durable   消息不丢失

生産者

消費者

3、消息擷取順序

預設消息隊列裡的資料是按照順序被消費者拿走,例如:消費者1 去隊列中擷取 奇數 序列的任務,消費者1去隊列中擷取 偶數 序列的任務。

channel.basic_qos(prefetch_count=1) 表示誰來誰取,不再按照奇偶數排列

4、釋出訂閱

消息隊列系統 -- RabbitMQ

釋出訂閱和簡單的消息隊列差別在于,釋出訂閱會将消息發送給所有的訂閱者,而消息隊列中的資料被消費一次便消失。是以,RabbitMQ實作釋出和訂閱時,會為每一個訂閱者建立一個隊列,而釋出者釋出消息時,會将消息放置在所有相關隊列中。

 exchange type = fanout

釋出者:

訂閱者:

5、關鍵字發送

消息隊列系統 -- RabbitMQ

 exchange type = direct

之前事例,發送消息時明确指定某個隊列并向其中發送消息,RabbitMQ還支援根據關鍵字發送,即:隊列綁定關鍵字,發送者将資料根據關鍵字發送到消息exchange,exchange根據 關鍵字 判定應該将資料發送至指定隊列。

消費者:

生産者:

6、模糊比對

消息隊列系統 -- RabbitMQ

 exchange type = topic

在topic類型下,可以讓隊列綁定幾個模糊的關鍵字,之後發送者将資料發送到exchange,exchange将傳入”路由值“和 ”關鍵字“進行比對,比對成功,則将資料發送到指定隊列。

# 表示可以比對 0 個 或 多個 單詞

*  表示隻能比對 一個 單詞

執行個體測試:

消息隊列系統 -- RabbitMQ

topic 執行過濾

消息隊列系統 -- RabbitMQ