消息隊列MQ可作為規則引擎對接的擴展增值服務使用，配合物聯網套件，可形成具備設備接入、設備管理、消息分發、應用承載能力的高性能服務組合

消息隊列MQ具有如下特點：

• 消息緩存

  MQ服務支持消息緩存，可以有效的緩存由于網絡或者應用服務器異常等原因導致的未能被即時消費的消息

  隊列緩存具有一定的容量上限，當隊列容量達到上限后，服務將回收隊列頭部的數據

• 削峰去谷

  MQ服務可以有效的緩沖前向突發的大并發量設備消息，以較低的較為平均的速率推送給消費客戶端，從而減輕消費端壓力

• 最多一次與至少一次

  用戶可以通過配置消息鎖定時間來實現最多消費一次以及至少消費一次的消息模式，若啟用消息鎖定時間，在該時間內，若客戶端無應答確認，則認為消費失敗，鎖定時間段之后，客戶端可以再次消費到該未被確認的消息

• 消息過期時間

  用戶可以自定義消息過期時間，進入隊列時長達到消息過期時間的消息將會被刪除，即服務會刪除進入隊列超過一定時間的消息

• 順序消息

  對于同一個topic，所有消息按照先入先出（FIFO）的順序進行發布和消費，保證嚴格的消息順序性

• 消息回溯

  支持用戶自定義消費位置，重新消費隊列中消息，例如設置為從頭部消費，完成設置后，客戶端將消費到來自隊列中自定義位置之后的消息

  只要消息沒有因為超時或者緩存區已滿而被刪除，用戶均可以通過指定消費位置重新消費到該消息

• 多方獨立消費

  服務支持用戶為一個隊列創建多個消費代理(sub)，消費代理之間相互獨立，可以分別采用不同的配置消費同一隊列中的數據

• 單點消費與集群消費

  MQ服務支持一個或者多個client同時與同一個sub（訂閱 subscription）建立訂閱關系

  當多個client同時與同一個topic中的同一個sub建立訂閱關系時，MQ服務會認為客戶端處于集群消費模式，消息將被均衡的發送至每個client，且每條消息僅能夠被一個客戶端消費

1、添加服務實例

服務實例是消息隊列MQ獨立服務與計費的實體，目前支持用戶創建最多10個實例。

在Onenet平臺找到消息隊列MQ

首次開通消息隊列MQ有15天的免費體驗期，同意開通后添加實例

添加完成后如圖所示：

2、添加topic

一個topic可以理解為一個實際的隊列實體，服務實例中可以創建多個topic。

直接點擊新建的yuyun-mq-test實例，進去后在topic管理頁直接添加topic

添加成功后，如圖：

3、添加訂閱

點擊查看新建的topic詳情，進入topic詳情頁，在最下方點擊“添加訂閱”，訂閱名稱為yuyun-topic-data

總結

以上是生活随笔為你收集整理的OneNET物联网平台06 消息队列MQ服务开启与配置的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。