消息隊列系統 -- 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實作釋出和訂閱時,會為每一個訂閱者建立一個隊列,而釋出者釋出消息時,會将消息放置在所有相關隊列中。
exchange type = fanout
釋出者:
訂閱者:
5、關鍵字發送
exchange type = direct
之前事例,發送消息時明确指定某個隊列并向其中發送消息,RabbitMQ還支援根據關鍵字發送,即:隊列綁定關鍵字,發送者将資料根據關鍵字發送到消息exchange,exchange根據 關鍵字 判定應該将資料發送至指定隊列。
消費者:
生産者:
6、模糊比對
exchange type = topic
在topic類型下,可以讓隊列綁定幾個模糊的關鍵字,之後發送者将資料發送到exchange,exchange将傳入”路由值“和 ”關鍵字“進行比對,比對成功,則将資料發送到指定隊列。
# 表示可以比對 0 個 或 多個 單詞
* 表示隻能比對 一個 單詞
執行個體測試:
topic 執行過濾