NE35E MQTT協(xié)議對接阿里云

MQTT通信協(xié)議的基本介紹參考文章 NT35 MQTT通信 ，本篇給出阿里云的基本操作，NT35E通過訂閱阿里云的主題發(fā)布信息與阿里云平臺相互通信。

成都創(chuàng)新互聯(lián)公司成立于2013年，我們提供高端網(wǎng)站建設(shè)公司、網(wǎng)站制作公司、成都網(wǎng)站設(shè)計、網(wǎng)站定制、網(wǎng)絡(luò)營銷推廣、微信小程序開發(fā)、微信公眾號開發(fā)、營銷推廣服務(wù)，提供專業(yè)營銷思路、內(nèi)容策劃、視覺設(shè)計、程序開發(fā)來完成項目落地，為成都宣傳片制作企業(yè)提供源源不斷的流量和訂單咨詢。

登錄阿里云?→?工作臺?→ 物聯(lián)網(wǎng)平臺?→ 進入控制臺→ 公共實例

阿里云默認通信協(xié)議為MQTT，不需要特殊選擇，用戶按照如下步驟創(chuàng)建自己的產(chǎn)品：

創(chuàng)建產(chǎn)品 → 添加設(shè)備?

在"查看"標簽中，包含了MQTT連接的基本三元組信息，也就是后面設(shè)備要填充的基本參數(shù)

? 用戶每定義一類產(chǎn)品都會自動生成對應(yīng)的Topic列表，當然我們也可以"自定義Topic"便于自己測試。

? ?指令解析參考《Lierda NT35ENT26E-CN AT命令手冊》，這里給出使用到的AT指令對應(yīng)參數(shù)說明以便于理解。

AT+LMQTTCFG=cloud,tcpconnectID[,cloud _ type,data_type ]

tcpconnectID 。MQTT Socket 標識符。范圍：0~4。

cloud_type整型。2 alibaba，其他參數(shù)指定其他平臺

data_type整型。阿里云平臺 1 json數(shù)據(jù)?

AT+LMQTTCFG="cloud",0,2,1 ? 對應(yīng)就是對接阿里云平臺，發(fā)送json格式的數(shù)據(jù)

AT+LMQTTCFG=aliauth,tcpconnectID[,product_key,device_name,device_secret]

填充阿里云平臺中設(shè)備的三元組信息

AT+LMQTTCFG="aliauth",0,"a1JszCpjS61","NT35E_06011","390358fc595040aa73221e8393aba86c"

這部分是模組進行TCP鏈路連接(需抓包確認)

AT+LMQTTOPEN=tcpconnectID,host_name,port

host_name對應(yīng)阿里云 "設(shè)備信息"→"MQTT連接參數(shù)" 中的 "mqttHostUrl"

AT+LMQTTOPEN=0,"a1JszCpjS61.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883

模組作為客戶端，通過MQTT協(xié)議連接到服務(wù)器(需抓包確認)

AT+LMQTTCONN=tcpconnectID[,clientID[,username[,password]]]

clientID字符串型?？蛻舳藰俗R符。用戶可以隨便定義。 username,password 不需要填寫

AT+LMQTTCONN=0,"NT35E"

AT+LMQTTSUBUNSUB=tcpconnectID,subflag,msgID,topic1[,qos1[,topic2[,qos2]d…]]

subflag整型。消息類型 0 訂閱 1 取消訂閱

msgID整型。數(shù)據(jù)包消息標識符。范圍：0~65535。

topic帶雙引號的字符串型?？蛻舳擞嗛喕蛘咄擞喌闹黝}。長度范圍：0~256 字節(jié)。

qos整型?？蛻舳税l(fā)送訂閱消息(SUBSCRIBE)的 QoS 等級，此時為必選參數(shù)。2?正好一次，該主題下的消息確保接收端僅接收到一次

AT+LMQTTSUBUNSUB=0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",2

這里注意topic對應(yīng)參數(shù)的替換，里面的deviceName需要替換。

訂閱主題之后，服務(wù)器下發(fā)的數(shù)據(jù)模組就可以正常接收了。模組下發(fā)位置

? ?發(fā)布消息在對應(yīng)的設(shè)備目錄下，如果有設(shè)備"訂閱"對應(yīng)的消息，平臺"發(fā)布"相應(yīng)的數(shù)據(jù)設(shè)備就可以接收到了。

AT+LMQTTPUB=tcpconnectID,msgID,qos,retain,topic,msglen,msg

msgID整型。 0~65535。任意定義，但qos=0 時，該參數(shù)值只能為0。

qos整型。 0?最多一次 1?至少一次 2 ?正好一次

retain整型 。服務(wù)器是否保存該消息。0?不保存? 1?保存

topic帶雙引號的字符串型。 客戶端發(fā)布消息的主題。長度范圍：0~256 字節(jié)

msglen整型 。指定的消息數(shù)據(jù)長度。范圍：0~1460。

msg字符串型。 需要發(fā)布的消息數(shù)據(jù)。

AT+LMQTTPUB=0,0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",10,"1122334455"

?注意剛剛自己創(chuàng)建的主題屬性是" 發(fā)布和訂閱 "，所以模組發(fā)送該主題的信息，阿里云也是可以收到的

注意這里模組發(fā)送數(shù)據(jù)的時候，也推送了自己發(fā)送的數(shù)據(jù)，因為剛剛訂閱了這個主題，所以模組訂閱(收)到了對應(yīng)的數(shù)據(jù)

? ?前面我們通過NT35E與平臺進行信息交互，那么為什么是這樣填寫對應(yīng)的參數(shù)呢，每個參數(shù)對應(yīng)的說明在阿里云上是什么樣的呢，用戶可以查看阿里云的幫助文檔進行確認。

? ?上面我們使用三元組的方式( 一機一密 )實現(xiàn)NT35E與阿里云平臺通信，但實際生產(chǎn)過程中該方式不好實現(xiàn)，比如工廠有1000個設(shè)備生產(chǎn)，如果每個設(shè)備都復制不同的三元組，很難實現(xiàn)工廠批量化生產(chǎn)，此時可以通過 一型一密 的通信方式解決該問題。

一型一密模組端實現(xiàn)方式后續(xù)更新。

在云服務(wù)器上搭建了mqtt，為什么手機連接不上mqtt，要怎么做才能連接上？求求大神幫忙

MQTT協(xié)議是廣泛應(yīng)用的物聯(lián)網(wǎng)協(xié)議，使用測試MQTT協(xié)議需要MQTT的代理。有兩種方法使用MQTT服務(wù)，一是租用現(xiàn)成的MQTT服務(wù)器，如阿里云，百度云，華為云等公用的云平臺提供的MQTT服務(wù)，使用公用的MQTT服務(wù)器的好處是省事，但如果僅僅用于測試學習還需要注冊帳號，靈活性差些，有的平臺還需要付費。另一方法是自己使用開源的MQTT組件來搭建。

MQTT服務(wù)器非常多，如apache的ActiveMQ，emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。

這里介紹的是用輕量級的mosquitto開源項目來搭建一個屬于自己的MQTT服務(wù)器。

第一步：需要安裝一臺linux主機，這不多介紹，可以使用真機安裝也可以使用虛擬機安裝。如果僅僅是自己測試使用都可以。

第二步：下載mosquitto需要的依賴

sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake

第三步：下載mosquitto并解壓，現(xiàn)在mosquitto官網(wǎng)最新的版本是1.5.1

tar xzvf mosquitto-1.5.1.tar.gz

第四步：編譯

cd mosquitto-1.5.1/

make

make install

第五步：啟動mosquitto

./mosquitto -v

1535473957: mosquitto version 1.5.1 starting

1535473957: Using default config.

1535473957: Opening ipv4 listen socket on port 1883.

1535473957: Opening ipv6 listen socket on port 1883.

這時候mosquitto就會以默認的參數(shù)啟動。如果需要帶配置文件可以修改配置文件mosquitto.conf，

啟動時候加上參數(shù) -c，

./mosquitto -c mosquitto.conf

可以看到，mosquitto監(jiān)聽的端口為1883.

這時候我們的MQTT服務(wù)器就搭建好了。可找一個mqtt客戶端來測試一下。

先發(fā)布一個主題“home/garden/fountain/2”

內(nèi)容是“hello world”

這時候在mosquitto會打印出下面的log

535474247: New connection from 192.168.1.105 on port 1883.

1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).

1535474247: No will message specified.

1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)

1535474307: Received PINGREQ from MQTT_FX_Client

1535474307: Sending PINGRESP to MQTT_FX_Client

1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))

1535474367: Received PINGREQ from MQTT_FX_Client

1535474367: Sending PINGRESP to MQTT_FX_Client

訂閱主題“home/garden/fountain/2”

可以看到收到了自己發(fā)布的消息。

用wireshark抓包

可以看到抓到了一個MQTT的publish的報文。

黑群暉怎樣搭建MQTT服務(wù)器

1、打開群暉Docker，注冊表搜索：mqtt；

2、點擊下載好的鏡像文件創(chuàng)建容器，輸入容器名字，點擊高級設(shè)置

3、勾選啟用自動重新啟動

4、點擊網(wǎng)絡(luò)—-勾選與docker host相同的網(wǎng)絡(luò)，點擊應(yīng)用，一直下一步直到創(chuàng)建完成