第一步, 在pc上, 用MQTT.fx與抓包軟件WireShark, 查看MQTT的整個通訊過程
https://www.cnblogs.com/xiaohanlin/p/8683503.html
具體文章參考上面這個;
我抓到的包如下:
我的MQTT在阿里IoT的配置如下:
broker address: a1kk9wvkNzl.iot-as-mqtt.cn-shanghai.aliyuncs.com (這個broker應該就是RockerMQ里面的broker)
broker port: 1883
client id: 12345|securemode=3,signmethod=hmacsha1|
其實真正的client id就前面那個, 12345, 后面是加密方法, 在用來算后面的密碼的時候, 直用填12345即可, 在這兒我繞了半天
securemode是3, 代表直連, 不做tls加密,
username 是 stm32&a1kk9wvkNzl, 就是devicename加productname, password就是根據它指定的hmacsha1算法進行加密算出來的.
臉上之后, 往 /a1kk9wvkNzl/stm32/user/location 主題, public一個消息:
{"lon":12.32324,"did":"fdsafd","la":232.23232}
在IoT的控制台上的日志里面可以看到:
主題 Topic:
/a1kk9wvkNzl/stm32/user/location
消息:
{"lon":12.32324,"did":"fdsafd","la":232.23232}
也就是這個時候, IoT的broker是能收到這個topic的消息的.
說到底, 這個topic的模式有點兒像ROS里面的主題消息部分.
接着配置規則引擎
SELECT did as device_id,lon as longitude,la as latitude FROM "/a1kk9wvkNzl/stm32/user/location"
將lon, la轉成數據庫需要的鍵名, 其實這里也不用怎么轉, 放后面轉也行
貧窮限制了我的想象力, 本來想用超時空數據庫的(時間序列數據庫TSDB), 后來發現窮, 真的要命, 直接用普通的rds吧.
中間發現, 消息雖然能進broker, 但是卻並未被消費, 沒有轉存到我的mysql, 提了個工單, 修改了一下配置規則, 終於搞通了.
接下來是用usb轉串口, 手動發送mqtt的數據包, 看能否成功進行消息的發布(public).