阿里云國(guó)際站經(jīng)銷(xiāo)商,主營(yíng)阿里云,騰訊云,華為云,亞馬遜aws,谷歌云gcp,微軟云az,免費(fèi)開(kāi)戶(hù),代充值優(yōu)惠大,聯(lián)系客服飛機(jī)@jkkddd
設(shè)備消息通過(guò)RocketMQ流轉(zhuǎn)到服務(wù)器
前提條件已注冊(cè)阿里云賬號(hào)。
已開(kāi)通物聯(lián)網(wǎng)平臺(tái)服務(wù)。
已開(kāi)通消息隊(duì)列RocketMQ服務(wù)。
如未開(kāi)通,請(qǐng)登錄消息隊(duì)列 RocketMQ產(chǎn)品頁(yè)面,開(kāi)通服務(wù)。
已準(zhǔn)備開(kāi)發(fā)環(huán)境。本示例使用Java SDK開(kāi)發(fā)的環(huán)境如下:
操作系統(tǒng):Windows 10 64位
JDK版本:JDK8
集成開(kāi)發(fā)環(huán)境:IntelliJ IDEA社區(qū)版
操作步驟
登錄物聯(lián)網(wǎng)平臺(tái)控制臺(tái),創(chuàng)建產(chǎn)品和設(shè)備。
在控制臺(tái)左上方,選擇地域目標(biāo)實(shí)例所在地域,然后在實(shí)例概覽頁(yè)面,找到對(duì)應(yīng)實(shí)例,單擊實(shí)例名稱(chēng)。
本示例選擇地域華東2(上海)。
在左側(cè)導(dǎo)航欄選擇設(shè)備管理 > 產(chǎn)品,單擊創(chuàng)建產(chǎn)品,配置參數(shù),單擊確認(rèn)。
本示例中,產(chǎn)品名稱(chēng)為MQ_test,節(jié)點(diǎn)類(lèi)型為直連設(shè)備,其他參數(shù)使用默認(rèn)值。
單擊查看產(chǎn)品詳情,在產(chǎn)品詳情頁(yè)面,單擊Topic類(lèi)列表 > 自定義Topic,然后單擊自定義Topic類(lèi),定義一個(gè)用于設(shè)備上報(bào)數(shù)據(jù)的Topic。
本示例中,定義的Topic類(lèi):/${YourProductKey}/${YourDeviceName}/user/data。
在左側(cè)導(dǎo)航欄選擇設(shè)備管理 > 設(shè)備,單擊添加設(shè)備,為產(chǎn)品MQ_test創(chuàng)建設(shè)備。
本示例中,創(chuàng)建了一個(gè)名稱(chēng)為MQdevice的設(shè)備。
在消息隊(duì)列RocketMQ控制臺(tái),創(chuàng)建Topic和消費(fèi)者。
登錄消息隊(duì)列RocketMQ版控制臺(tái)。
在左側(cè)導(dǎo)航欄選擇實(shí)例列表,單擊創(chuàng)建實(shí)例,創(chuàng)建一個(gè)4.0系列的標(biāo)準(zhǔn)版實(shí)例,地域選擇華東2(上海)。
具體操作,請(qǐng)參見(jiàn)創(chuàng)建實(shí)例。
在實(shí)例列表頁(yè)面,單擊實(shí)例名稱(chēng)。
在實(shí)例詳情頁(yè)面,單擊創(chuàng)建 Group,配置如下圖所示,然后單擊確定。
創(chuàng)建消息消費(fèi)者,然后在RocketMQ控制臺(tái)查看消費(fèi)者狀態(tài),確保消費(fèi)者處于在線狀態(tài),訂閱關(guān)系一致。
本文以調(diào)用TCP協(xié)議的SDK為例,進(jìn)行收發(fā)消息。SDK獲取和使用的詳細(xì)內(nèi)容,請(qǐng)參見(jiàn)調(diào)用TCP協(xié)議的SDK收發(fā)普通消息。
返回物聯(lián)網(wǎng)平臺(tái)控制臺(tái),在對(duì)應(yīng)實(shí)例下,設(shè)置數(shù)據(jù)流轉(zhuǎn)規(guī)則,將設(shè)備上報(bào)的數(shù)據(jù)轉(zhuǎn)發(fā)至消息隊(duì)列(RocketMQ)。
在左側(cè)導(dǎo)航欄選擇消息轉(zhuǎn)發(fā) > 云產(chǎn)品流轉(zhuǎn)。
在云產(chǎn)品流轉(zhuǎn)頁(yè)面,單擊創(chuàng)建規(guī)則。
輸入規(guī)則名稱(chēng)MQ流轉(zhuǎn),數(shù)據(jù)格式選擇為JSON,單擊確認(rèn)。
單擊編寫(xiě)SQL,設(shè)置數(shù)據(jù)處理SQL,如下圖所示,然后單擊確認(rèn)。
所有設(shè)置完成后,返回至云產(chǎn)品流轉(zhuǎn)頁(yè)面,單擊MQ流轉(zhuǎn)規(guī)則對(duì)應(yīng)的啟動(dòng)。
規(guī)則啟動(dòng)后,物聯(lián)網(wǎng)平臺(tái)會(huì)將規(guī)則SQL中定義的設(shè)備上報(bào)消息轉(zhuǎn)發(fā)至消息隊(duì)列(RocketMQ)的Topic中。
使用Java SDK模擬設(shè)備接入物聯(lián)網(wǎng)平臺(tái),并上報(bào)消息。
下載Java SDK Demo,然后解壓。
在IntelliJ IDEA中,導(dǎo)入Demo包中的示例工程JavaLinkKitDemo。
在文件device_id.json中輸入MQdevice的設(shè)備證書(shū)信息:productKey、deviceName和deviceSecret。
在文件srcmainjavacom.aliyun.alink.devicesdk.demoMqttSample.java中修改MQTT Topic為設(shè)備上報(bào)數(shù)據(jù)的Topic。
本示例中,使用的Topic是/{YourProductKey}/${YourDeviceName}/user/data。
心靈雞湯:
標(biāo)題:阿里云免費(fèi)開(kāi)戶(hù),阿里云服務(wù)器購(gòu)買(mǎi)
地址:http://hongyingyw.com/kfxw/64254.html