物聯網平台支援通過消費組訂閱需要的Topic訊息到AMQP服務端。本文介紹在物聯網平台控制台設定和管理AMQP服務端訂閱的操作步驟。
前提條件
已建立待訂閱訊息的消費組。您可使用物聯網平台預設消費組(DEFAULT_GROUP)或建立消費組。具體操作,請參見管理AMQP消費組。
設定訂閱
在物聯網平台控制台設定服務端訂閱的訊息類型。
登入物聯網平台控制台。
在執行個體概覽頁簽的全部環境下,找到對應的執行個體,單擊執行個體卡片。
在左側導覽列,選擇 。
在服務端訂閱頁面,單擊建立訂閱。
在建立訂閱對話方塊中,完成配置,單擊確認。
參數
說明
產品
選擇訂閱訊息源裝置所屬的產品。
訂閱類型
選擇AMQP。
消費組
選擇訊息的消費組。 一個產品可選擇多個消費組,且一個消費組下可建立多個產品的訂閱。
物聯網平台已提供一個預設消費組,用於消費訊息。如果您需要對消費端進行分組,可單擊選擇目標消費組對話方塊右下角的建立消費組,建立消費組。消費組相關說明,請參見管理AMQP消費組。
推送訊息類型
服務端要訂閱的訊息類型。目前,服務端可訂閱的裝置訊息類型如下,對應原始通訊的Topic、訊息轉寄的Topic及對應資料格式說明,請參見資料格式。
重要對於雲網關下產品和裝置,僅支援推送裝置上報訊息、裝置狀態變化通知和裝置生命週期變更的資料。訊息轉寄Topic和資料格式的詳情說明,請參見開源MQTT協議的訊息通訊說明、JT/T 808協議的訊息轉寄說明、GB/T 32960協議的訊息轉寄說明。
裝置上報訊息:產品下所有裝置Topic列表中,操作許可權為發布的Topic中的訊息。更多資訊,請參見什麼是Topic。
裝置上報訊息,包括裝置上報的自訂資料和物模型資料(屬性上報、事件上報、屬性設定響應和服務調用響應)。推送到服務端的物模型資料是經物聯網平台系統處理過後的資料,資料格式請參見資料格式。
例如,一個產品有3個Topic類,分別是:
/${YourProductKey}/${YourDeviceName}/user/get
,具有訂閱許可權。/${YourProductKey}/${YourDeviceName}/user/update
,具有發布許可權。/${YourProductKey}/${YourDeviceName}/thing/event/property/post
,具有發布許可權。
那麼,服務端訂閱會推送具有發布許可權的Topic類中的訊息,即
/${YourProductKey}/${YourDeviceName}/user/update
和/${YourProductKey}/${YourDeviceName}/thing/event/property/post
中的訊息。重要若訂閱非同步服務調用響應資料,裝置端返回的響應訊息Id必須與物聯網平台下發訊息的Id相同,才可實現資料正常訂閱。
裝置狀態變化通知:該產品下的裝置上下線狀態變化時通知的訊息。
網關子裝置發現上報:網關將發現的子裝置資訊上報給物聯網平台。需要網關上的應用程式支援。網關產品特有訊息類型。
裝置拓撲關係變更:子裝置和網關之間的拓撲關係建立和解除訊息。網關產品特有訊息類型。
裝置生命週期變更:裝置建立、刪除、禁用、啟用等訊息。
物模型歷史資料上報:裝置上報的屬性和事件歷史資料。
OTA升級裝置狀態通知:包括升級包驗證和批量升級時,裝置升級成功、失敗、取消和進度的事件通知。
裝置標籤變更:裝置上報的標籤變更訊息。
OTA模組版本號碼上報:裝置上報的OTA模組版本號碼變更訊息。
OTA升級批次狀態通知:裝置OTA升級批次狀態變化通知。
說明如果您需要對監聽的裝置訊息進行過濾或處理,可先通過雲產品流轉規則將資料轉寄到AMQP服務端訂閱消費組,再通過AMQP用戶端,監聽相關訊息。更多資訊,請參見雲產品流轉。
傳遞訊息至AMQP服務端與對應訂閱的裝置Topic說明,請參見訊息轉寄與裝置原始通訊的Topic說明。
管理產品的訂閱
設定服務端訂閱成功後,在服務端訂閱頁面的訂閱列表下,找到已訂閱的產品名稱,可執行以下操作。
操作 | 步驟 |
編輯 | 您可修改訂閱的消費組和訊息類型。
|
刪除 | 警告 如果使用者在其他業務中使用了該產品訂閱的裝置資料,可能導致服務不可用或影響使用者的業務。請謹慎操作。
|
後續步驟
配置AMQP用戶端:建議您使用阿里雲物聯網平台提供的AMQP SDK接入樣本。對於您自研的AMQP SDK,阿里雲不提供後續支援人員服務。
所有配置完成,且裝置上報訂閱資料,並被AMQP用戶端接收後,您可以登入物聯網平台控制台,在對應執行個體的 頁簽,查看裝置上報資料、物聯網平台轉寄資料到AMQP用戶端和AMQP用戶端返回ACK的日誌記錄。