我們簡單介紹一下 HiveMQ extension for TDengine 的部署和使用方法。

TDengine 和 HiveMQ 部署方法

TDengine

安裝最新的 TDengine Database server 即可。參見官方文檔: http://www.fjzmyy.cn/getting-started/。

HiveMQ

安裝企業(yè)版（需申請(qǐng)?jiān)囉肔icense）或社區(qū)版（HiveMQ Community Edition，https://github.com/hivemq/hivemq-community-edition）都可以。參見官方文檔:?https://www.hivemq.com/docs/hivemq/4.5/user-guide/install-hivemq.html

HiveMQ TDengine 插件的編譯和部署

1. git clone https://github.com/taosdata/TDengine
2. cd TDengine && git submodule update --init --recursive
3. cd src/connector/hivemq-tdengine-extension && mvn clean && mvn package
4. 將打包好的壓縮包如: hivemq-tdengine-extension-{version}-distribution.zip 解壓到 HiveMQ 目錄的 extensions 文件夾下。如果 HiveMQ 已經(jīng)運(yùn)行需要先將 HiveMQ 后臺(tái)服務(wù)停下來，否則 HiveMQ 會(huì)禁止插件運(yùn)行，需要手動(dòng)刪除 DISABLED 文件方可使插件工作。
5. 修改插件包內(nèi)的 tdengine.xml 配置文件為實(shí)際使用的數(shù)據(jù)庫信息。
6. 不需要手動(dòng)建庫建表,插件啟動(dòng)時(shí)會(huì)自動(dòng)創(chuàng)建庫和表

演示

運(yùn)行 HivMQ

<HiveMQ>/bin/run.sh

發(fā)送 MQTT 消息

使用流行的 MQTT 軟件 mosquitto 發(fā)送 MQTT 消息進(jìn)行測(cè)試演示：

mosquitto_pub -t test -m “hello world”

驗(yàn)證 通過 taos 客戶端登陸 TDengine 查看驗(yàn)證記錄是否寫入：