通过Ubuntu服务器部署Mqtt服务的记录#

1.设备信息#

物联网设备：ML307R，度云DTU固件
服务器：阿里云轻应用服务器
linux版本：Ubuntu 24.02

2.物联网设备部署#

1.部署方式#

使用物联网设备提供的网站进行设置修改

2.参数记录#

网络通道参数#

通道类型使用MQTT，域名使用服务器公网ip，端口号选择1883

订阅自定义为：test/topic/down，发布消息自定义为：test/topic/up

QOS等级为1，publish参数retain为0

基本参数#

心跳包开启，自定义字符串为hello，心跳间隔为600000ms

3.服务器端部署（代码问AI）#

1.EMQX#

防火墙#

设置阿里云服务器防火墙白名单，放行端口请求

图形化界面#

访问 公网ip:18083 进入图形化界面配置

调试#

通过WebSocket 客户端，调试订阅和发送

2.数据库部署#

数据库使用MySQL，读取逻辑为截取所有向服务器发送的MQTT数据，进行存储

数据处理脚本名：mqtt_to_mysql.py

自动运行脚本名：mqtt-saver.service

虚拟环境开启指令：source ~/mqtt_venv/bin/activate

数据查看：

1
##查看指令
2
mysql -u emqx_user -p123456 -D emqx_data -e "
3
SELECT '--- 当前总记录数 ---' AS '';
4
SELECT count(*) AS total_rows FROM mqtt_msg;
5
SELECT '--- 最近20条数据 (精简模式) ---' AS '';
6
SELECT id, device_id, tds, cod, ph, temp, hum, created_at FROM mqtt_msg ORDER BY id DESC LIMIT 20;"
7

8
##监控器指令
9
# 每 1 秒刷新一次
10
watch -n 1 'mysql -u emqx_user -p123456 -D emqx_data -e "SELECT count(*) AS Total FROM mqtt_msg; SELECT id, device_id, tds, cod, ph, temp, hum, created_at FROM mqtt_msg ORDER BY id DESC LIMIT 40;"'
11

12
##重启指令
13
# 1. 重新加载系统服务配置
14
sudo systemctl daemon-reload
15
# 2. 重启你的脚本服务
16
sudo systemctl restart mqtt-saver.service
17
# 3. 再次查看日志
18
sudo journalctl -u mqtt-saver -f

数据库结构：

1
CREATE TABLE IF NOT EXISTS mqtt_msg (
2
    id INT AUTO_INCREMENT PRIMARY KEY,
3
    device_id VARCHAR(50),      -- 对应 JSON 中的 id
4
    tds FLOAT,
5
    cod FLOAT,
6
    toc FLOAT,
7
    uv254 FLOAT,
8
    ph FLOAT,
9
    temp FLOAT,
10
    hum FLOAT,
11
    zhexian1 FLOAT,
12
    zhexian2 FLOAT,
13
    raw_data TEXT,              -- 保留一份原始数据备份
14
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
15
);