【Message Queue】關於Message Queue的幾個常見傳輸協定

AMQP協議

• Producer: 生產者, 負責生產訊息並送到交換機。
• Broker: Message Queue的服務器(RabbitMQ…之類的產品)
• Exchange: 交換器, 它指定訊息按照什麼樣的規則送到哪個Queue。
• Binding: 綁定規則, 後面會介紹幾種常用的MQ模式。
• Queue: 消息隊列, 每條訊息都會被送到一個或多個Queue。
• Consumer: 消費者, 負責接收與處理訊息。

特點

• 金融業發展出來用於交易所訊息交換的協定。
• 發布者、交換機、隊列、消費者都可以有多個。因為AMQP是一種網路協議, 所以過程中的發布者、消費者、代理都能分佈在不同的設備上。
• 發布消息時可以帶上消息屬性(Message Meta), 有些屬性可以被消息代理(Brokers)使用, 有些則為不透明的, 只能被消費者使用。
• 由於必須假設網路是不可靠的, 因此可能某個消費者處理訊息的過程中可能掛掉, 基於此原因AMQP協議就包含了消息確認(Message Acknowledgements)機制, 確保收到來自消費者的訊息後才將該筆訊息從Queue中刪除。

Exchange交換機

STOMP協議

COMMAND
header1:value1
header2:value2
Body^@
SEND
destination:/broker/roomId/1
content-length:57
{“type”:”ENTER”,”content”:”o7jD64gNifq-wq-C13Q5CRisJx5E”}

MQTT協議

1. 取得所有房間的溫濕度: Sensor/#
2. 取得Room1的溫度與濕度: Sensor/+/Room1