当前位置：首页 > news >正文

安装Mosquitto

news 2026/5/12 9:36:47

用于MQTT私有云架设的服务器端和客户端的核心代码。稳定支持断线自动重连。公网服务器，内网内网服务器或者租赁腾讯轻服务器均可架设。实现MQTT通信和数据存储。

最近在折腾MQTT私有云的架设，感觉这玩意儿挺有意思的。MQTT（Message Queuing Telemetry Transport）是一种轻量级的发布/订阅消息传输协议，特别适合物联网设备之间的通信。今天就来聊聊如何用核心代码搭建一个支持断线自动重连的MQTT服务器和客户端。

服务器端

首先，我们需要一个MQTT broker。这里我选择了Eclipse Mosquitto，它是一个开源的MQTT broker，支持多种平台。

sudo apt-get install mosquitto mosquitto-clients

安装完成后，启动Mosquitto服务：

sudo systemctl start mosquitto

Mosquitto默认监听1883端口，你可以通过修改配置文件/etc/mosquitto/mosquitto.conf来调整端口或其他设置。

客户端

接下来是客户端部分。这里我用Python编写了一个简单的MQTT客户端，支持断线自动重连。

import paho.mqtt.client as mqtt import time def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected successfully") else: print(f"Connection failed with code {rc}") def on_disconnect(client, userdata, rc): print("Disconnected, attempting to reconnect...") while True: try: client.reconnect() break except: time.sleep(5) client = mqtt.Client() client.on_connect = on_connect client.on_disconnect = on_disconnect client.connect("your.broker.address", 1883, 60) client.loop_start() try: while True: client.publish("test/topic", "Hello MQTT") time.sleep(10) except KeyboardInterrupt: client.loop_stop() client.disconnect()

这段代码首先定义了两个回调函数onconnect和ondisconnect，分别处理连接成功和断开连接的情况。on_disconnect中实现了断线自动重连的逻辑。

client.connect方法用于连接到MQTT broker，client.loop_start()启动一个后台线程来处理网络流量。client.publish用于发布消息到指定的主题。

数据存储

MQTT broker本身并不负责数据存储，但我们可以通过订阅主题并将消息存储到数据库或其他存储系统中来实现数据持久化。

import paho.mqtt.client as mqtt import sqlite3 def on_message(client, userdata, msg): conn = sqlite3.connect('mqtt_data.db') c = conn.cursor() c.execute("INSERT INTO messages (topic, payload) VALUES (?, ?)", (msg.topic, msg.payload.decode())) conn.commit() conn.close() client = mqtt.Client() client.on_message = on_message client.connect("your.broker.address", 1883, 60) client.subscribe("test/topic") client.loop_forever()

这段代码在on_message回调函数中将接收到的消息存储到SQLite数据库中。首先连接到数据库，然后执行插入操作，最后提交事务并关闭连接。