物聯網平臺thingsboard搭建學習記錄

概述：在thingsboard官網下載安裝包，根據官網提供的檔案進行安裝配置thingsboard服務，通過esp32模擬智能節點，使用mqtt協議將資料上報至平臺，進行動態的可視化展示，并通過wereshark抓取上報程序中的mqtt報文，進行安全性分析，任務內容做要是做一個安全分析的demo，

搭建所涉及的技術堆疊：

PostgreSQL+Rabbitmq+MQTTBox-win

產生的相關代碼：

esp32運行microPy代碼模擬終端產生溫度資料：

import network
import time
import random
import machine
import json
import ubinascii
from simple import MQTTClient

SSID="dpls4"
PASSWORD="dplslab123"

CLIENT_ID = ubinascii.hexlify(machine.unique_id())

CONFIG = {
"server": "192.168.31.11", # ThingsBoard地址
"port":1883, # MQTT埠（默認1883）
"mqtt_user": "TCCWopryNcNCSl8iSo3Q", # 設備的訪問令牌
"mqtt_password": "TCCWopryNcNCSl8iSo3Q", # 設備的訪問令牌
"mqtt_topic": "v1/devices/me/telemetry", # MQTT主題
}

#連接WiFi函式
def connectWifi(ssid,passwd):
global wlan
wlan=network.WLAN(network.STA_IF)
wlan.active(True)
wlan.disconnect()
wlan.connect(ssid,passwd)
while(wlan.ifconfig()[0]=='0.0.0.0'):
time.sleep(1)

#獲取溫濕度函式
def get_humiture():
d = random.randint(0,100)

return d

#上傳溫濕度到ThingsBoard函式
def pub_humiture(temperature):
global c
data={'hello':temperature}
c.publish(CONFIG["mqtt_topic"], json.dumps(data))
print(json.dumps(data))

def main():
connectWifi(SSID,PASSWORD)
global c
c = MQTTClient(CLIENT_ID, CONFIG["server"],CONFIG["port"], CONFIG["mqtt_user"], CONFIG["mqtt_password"])
c.connect()
print("Connected to %s, publish to %s topic" % (CONFIG["server"], CONFIG["mqtt_topic"]))
print("即將進入回圈！")
while True:
tem=get_humiture()
pub_humiture(tem)
time.sleep(5)

if __name__ == "__main__":
main()

Java 中間版本：

package org.jmqtt.java;

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class ThingsboardClient {

public void toTB(String content){
System.out.println("開始執行DHT方法*************************");
String HOST = "tcp://127.0.0.1:1883"; //TBip地址和mqtt埠
String TOPIC = "v1/devices/me/telemetry";//TB遙測資料API介面
String clientid = "jmqttThingsBoardClient";
MqttClient client=null;
MqttConnectOptions options;
MqttTopic topic;
String username="TCCWopryNcNCSl8iSo3Q";//設備秘鑰
try {
// host為主機名，clientid即連接MQTT的客戶端ID，一般以唯一識別符號表示，MemoryPersistence設定clientid的保存形式，默認為以記憶體保存
client = new MqttClient(HOST, clientid, new MemoryPersistence());
// MQTT的連接設定
options = new MqttConnectOptions();
// 設定是否清空session,這里如果設定為false表示服務器會保留客戶端的連接記錄，這里設定為true表示每次連接到服務器都以新的身份連接
options.setCleanSession(true);
// 設定連接的用戶名

options.setUserName(username);//設備秘鑰
// 設定連接的密碼
//options.setPassword(passWord.toCharArray());
// 設定超時時間 單位為秒
options.setConnectionTimeout(10);
// 設定會話心跳時間 單位為秒 服務器會每隔1.5*20秒的時間向客戶端發送個訊息判斷客戶端是否在線，但這個方法并沒有重連的機制
options.setKeepAliveInterval(20);
// 設定回
client.setCallback(new MqttCallbackExtended() {
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
String context = new String(message.getPayload());
}

@Override
public void deliveryComplete(IMqttDeliveryToken token) {
// TODO Auto-generated method stub

}

@Override
public void connectionLost(Throwable cause) {
// TODO Auto-generated method stub
}

@Override
public void connectComplete(boolean reconnect, String serverURI) {
// TODO Auto-generated method stub
}

});
topic = client.getTopic(TOPIC);
//setWill方法，如果專案中需要知道客戶端是否掉線可以呼叫該方法，設定最終埠的通知訊息
options.setWill(topic, "close".getBytes(), 2, true);
client.connect(options);
// sendCon = "{\"temperature\":\"25\",\"humidity\":\"12\",\"light\":\"255\"}";//json格式
client.publish(TOPIC, content.getBytes(), 0, false);//推送資料到tb上
} catch (MqttException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} finally {

}
}
}