管理AMQP消費(fèi)組
本文中含有需要您注意的重要提示信息，忽略該信息可能對(duì)您的業(yè)務(wù)造成影響，請(qǐng)務(wù)必仔細(xì)閱讀。
消費(fèi)組是消息消費(fèi)端的身份標(biāo)識(shí)，多個(gè)消費(fèi)者組成消息消費(fèi)組接入物聯(lián)網(wǎng)平臺(tái)。設(shè)置AMQP服務(wù)端訂閱后，物聯(lián)網(wǎng)平臺(tái)會(huì)將收到的設(shè)備消息轉(zhuǎn)發(fā)到相應(yīng)消費(fèi)組，每條被流轉(zhuǎn)到消費(fèi)組的消息會(huì)被其中一個(gè)消費(fèi)者接收。本文介紹如何在物聯(lián)網(wǎng)平臺(tái)創(chuàng)建、查看和刪除消費(fèi)組。
工作原理
AMQP服務(wù)端訂閱會(huì)將同一產(chǎn)品所有設(shè)備的指定類型消息，轉(zhuǎn)發(fā)到一個(gè)或多個(gè)消費(fèi)組中，每個(gè)消費(fèi)組中隨機(jī)一個(gè)消費(fèi)者收到消息。不同消費(fèi)組通過(guò)消費(fèi)組ID區(qū)分，每個(gè)AMQP客戶端只能配置一個(gè)消費(fèi)組ID，每個(gè)消費(fèi)組最多包括64個(gè)AMQP客戶端。您需要先創(chuàng)建消費(fèi)組，然后將消費(fèi)組ID配置到AMQP客戶端，最后配置AMQP服務(wù)端訂閱。
訂閱關(guān)系1：將產(chǎn)品1的消息轉(zhuǎn)發(fā)到消費(fèi)組1和消費(fèi)組2。
訂閱關(guān)系2：將產(chǎn)品2的消息轉(zhuǎn)發(fā)到消費(fèi)組2。
AMQP服務(wù)端訂閱只能流轉(zhuǎn)同一產(chǎn)品所有設(shè)備的指定類型消息，如果需要更靈活的流轉(zhuǎn)設(shè)備消息。例如轉(zhuǎn)發(fā)部分設(shè)備消息到AMQP客戶端進(jìn)行消費(fèi)，可以使用物聯(lián)網(wǎng)平臺(tái)提供的云產(chǎn)品流轉(zhuǎn)功能，先指定設(shè)備Topic消息轉(zhuǎn)發(fā)至AMQP服務(wù)端訂閱的消費(fèi)組，進(jìn)而流轉(zhuǎn)到消費(fèi)對(duì)應(yīng)消費(fèi)組的AMQP客戶端，操作步驟請(qǐng)參見云產(chǎn)品流轉(zhuǎn)。
創(chuàng)建消費(fèi)組
在實(shí)例概覽頁(yè)簽的全部環(huán)境下，找到對(duì)應(yīng)的實(shí)例，單擊實(shí)例卡片。
在左側(cè)導(dǎo)航欄，選擇，單擊消費(fèi)組列表頁(yè)簽。
單擊創(chuàng)建消費(fèi)組。
在創(chuàng)建消費(fèi)組對(duì)話框中，輸入組名，單擊確認(rèn)。
消費(fèi)組名稱支持中文、英文字母、日文、數(shù)字和下劃線（_），長(zhǎng)度范圍為4~30個(gè)字符。一個(gè)中文或日文占2個(gè)字符。
查看和監(jiān)控消費(fèi)組
您可以查看消費(fèi)組內(nèi)的消息消費(fèi)速率、消息堆積量，也可以設(shè)置云監(jiān)控報(bào)警規(guī)則來(lái)監(jiān)控消費(fèi)組。
在消費(fèi)組列表中，找到要查看的消費(fèi)組，并單擊對(duì)應(yīng)的查看。
在消費(fèi)組狀態(tài)頁(yè)簽，查看訂閱消息的實(shí)時(shí)消息消費(fèi)速率、堆積消息消費(fèi)速率、消息堆積量、最近消費(fèi)時(shí)間和在線客戶端列表。
當(dāng)消息堆積量大于等于（≥）1時(shí)，消息堆積量右側(cè)會(huì)顯示清空按鈕，您可清除堆積消息。
說(shuō)明消息組創(chuàng)建后：
若未上線過(guò)，此時(shí)消費(fèi)組處于離線狀態(tài)，向消費(fèi)組發(fā)送消息時(shí)，不會(huì)有消息堆積。
若已上線，然后離線，此時(shí)消費(fèi)組處于離線狀態(tài)，向消費(fèi)組發(fā)送消息時(shí)，會(huì)有消息堆積。
在消費(fèi)組狀態(tài)頁(yè)簽，單擊報(bào)警配置，然后在創(chuàng)建報(bào)警規(guī)則頁(yè)面，配置云監(jiān)控閾值報(bào)警規(guī)則，監(jiān)控消費(fèi)組消息堆積數(shù)、消費(fèi)組消息消費(fèi)速率，并接收?qǐng)?bào)警消息。
您需選擇產(chǎn)品為物聯(lián)網(wǎng)平臺(tái)-服務(wù)端訂閱，其他參數(shù)根據(jù)您的需求設(shè)置。具體操作，請(qǐng)參見創(chuàng)建閾值報(bào)警規(guī)則。
在消費(fèi)組詳情頁(yè)面，單擊消費(fèi)日志頁(yè)簽，可查看具體的消費(fèi)記錄。
刪除消費(fèi)組
刪除消費(fèi)組后，消費(fèi)組內(nèi)的所有消費(fèi)端會(huì)停止接收消息，消費(fèi)組相關(guān)的服務(wù)端訂閱服務(wù)不可用，可能導(dǎo)致用戶業(yè)務(wù)中斷，請(qǐng)謹(jǐn)慎操作。
用戶創(chuàng)建的消費(fèi)組可以刪除，物聯(lián)網(wǎng)平臺(tái)的默認(rèn)消費(fèi)組不可刪除。
解除訂閱。如果消費(fèi)組已關(guān)聯(lián)訂閱關(guān)系，則需先解除訂閱；如果消費(fèi)組無(wú)訂閱關(guān)系，請(qǐng)忽略此步驟。
在消費(fèi)組列表中，單擊消費(fèi)組對(duì)應(yīng)的查看。
在消費(fèi)組詳情頁(yè)面的訂閱產(chǎn)品頁(yè)簽下，單擊產(chǎn)品名對(duì)應(yīng)的解除訂閱，再單擊確認(rèn)。
說(shuō)明如果該產(chǎn)品的服務(wù)端訂閱只有一個(gè)消費(fèi)組，則不能在消費(fèi)組詳情頁(yè)面解除訂閱。您可返回服務(wù)端訂閱頁(yè)面的訂閱列表頁(yè)簽，編輯或刪除訂閱。
在服務(wù)端訂閱頁(yè)面的消費(fèi)組列表頁(yè)簽下，單擊消費(fèi)組對(duì)應(yīng)的刪除，然后單擊確認(rèn)。
相關(guān)文檔
將消費(fèi)組ID配置到AMQP客戶端上，以接收消息，請(qǐng)參見：
相關(guān)API
API | 描述 |
創(chuàng)建一個(gè)消費(fèi)組，用于創(chuàng)建AMQP服務(wù)端訂閱。 | |
修改消費(fèi)組名稱。 | |
根據(jù)消費(fèi)組ID查詢消費(fèi)組詳情。 | |
查詢用戶所有消費(fèi)組列表，或按消費(fèi)組名稱進(jìn)行模糊查詢。 | |
使用AMQP服務(wù)端訂閱時(shí)，查詢某個(gè)消費(fèi)組的狀態(tài)，包括在線客戶端信息、消息消費(fèi)速率、消息堆積數(shù)、最近消息消費(fèi)時(shí)間。 | |
使用AMQP服務(wù)端訂閱時(shí)，清空某個(gè)消費(fèi)組的堆積消息。 | |
刪除消費(fèi)組。 |