阿里云國際站經銷商,主營阿里云,騰訊云,華為云,亞馬遜aws,谷歌云gcp,微軟云az,免費開戶,代充值優惠大,聯系客服飛機@jkkddd
前提條件已注冊阿里云賬號。
已開通物聯網平臺服務。
已開通消息隊列RocketMQ服務。
如未開通,請登錄消息隊列 RocketMQ產品頁面,開通服務。
已準備開發環境。本示例使用Java SDK開發的環境如下:
操作系統:Windows 10 64位
JDK版本:JDK8
集成開發環境:IntelliJ IDEA社區版
操作步驟
登錄物聯網平臺控制臺,創建產品和設備。
在控制臺左上方,選擇地域目標實例所在地域,然后在實例概覽頁面,找到對應實例,單擊實例名稱。
本示例選擇地域華東2(上海)。
在左側導航欄選擇設備管理 > 產品,單擊創建產品,配置參數,單擊確認。
本示例中,產品名稱為MQ_test,節點類型為直連設備,其他參數使用默認值。
單擊查看產品詳情,在產品詳情頁面,單擊Topic類列表 > 自定義Topic,然后單擊自定義Topic類,定義一個用于設備上報數據的Topic。
本示例中,定義的Topic類:/${YourProductKey}/${YourDeviceName}/user/data。
在左側導航欄選擇設備管理 > 設備,單擊添加設備,為產品MQ_test創建設備。
本示例中,創建了一個名稱為MQdevice的設備。
在消息隊列RocketMQ控制臺,創建Topic和消費者。
登錄消息隊列RocketMQ版控制臺。
在左側導航欄選擇實例列表,單擊創建實例,創建一個4.0系列的標準版實例,地域選擇華東2(上海)。
具體操作,請參見創建實例。
在實例列表頁面,單擊實例名稱。
在實例詳情頁面,單擊創建 Group,配置如下圖所示,然后單擊確定。
創建消息消費者,然后在RocketMQ控制臺查看消費者狀態,確保消費者處于在線狀態,訂閱關系一致。
本文以調用TCP協議的SDK為例,進行收發消息。SDK獲取和使用的詳細內容,請參見調用TCP協議的SDK收發普通消息。
返回物聯網平臺控制臺,在對應實例下,設置數據流轉規則,將設備上報的數據轉發至消息隊列(RocketMQ)。
在左側導航欄選擇消息轉發 > 云產品流轉。
在云產品流轉頁面,單擊創建規則。
輸入規則名稱MQ流轉,數據格式選擇為JSON,單擊確認。
單擊編寫SQL,設置數據處理SQL,如下圖所示,然后單擊確認。
所有設置完成后,返回至云產品流轉頁面,單擊MQ流轉規則對應的啟動。
規則啟動后,物聯網平臺會將規則SQL中定義的設備上報消息轉發至消息隊列(RocketMQ)的Topic中。
使用Java SDK模擬設備接入物聯網平臺,并上報消息。
下載Java SDK Demo,然后解壓。
在IntelliJ IDEA中,導入Demo包中的示例工程JavaLinkKitDemo。
在文件device_id.json中輸入MQdevice的設備證書信息:productKey、deviceName和deviceSecret。
在文件srcmainjavacom.aliyun.alink.devicesdk.demoMqttSample.java中修改MQTT Topic為設備上報數據的Topic。
本示例中,使用的Topic是/{YourProductKey}/${YourDeviceName}/user/data。
相關查詢
溫馨提示:尊敬的[]站點管理員,將本頁鏈接加入您的網站友情鏈接,下次可以快速來到這里更新您的站點信息哦!每天更新您的[阿里云免費開戶,阿里云服務器購買]站點信息,可以排到首頁最前端的位置,讓更多人看到您站點的信息哦。

