用于MQTT私有云架设的服务器端和客户端的核心代码。 稳定支持断线自动重连。 公网服务器内网内网服务器或者租赁腾讯轻服务器均可架设。 实现MQTT通信和数据存储。最近在折腾MQTT私有云的架设感觉这玩意儿挺有意思的。MQTTMessage Queuing Telemetry Transport是一种轻量级的发布/订阅消息传输协议特别适合物联网设备之间的通信。今天就来聊聊如何用核心代码搭建一个支持断线自动重连的MQTT服务器和客户端。服务器端首先我们需要一个MQTT broker。这里我选择了Eclipse Mosquitto它是一个开源的MQTT broker支持多种平台。sudo apt-get install mosquitto mosquitto-clients安装完成后启动Mosquitto服务sudo systemctl start mosquittoMosquitto默认监听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(fConnection 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中实现了断线自动重连的逻辑。用于MQTT私有云架设的服务器端和客户端的核心代码。 稳定支持断线自动重连。 公网服务器内网内网服务器或者租赁腾讯轻服务器均可架设。 实现MQTT通信和数据存储。client.connect方法用于连接到MQTT brokerclient.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数据库中。首先连接到数据库然后执行插入操作最后提交事务并关闭连接。部署你可以选择在公网服务器、内网服务器或者租赁腾讯轻服务器上部署这个MQTT系统。公网服务器适合需要远程访问的场景内网服务器则适合局域网内的设备通信。腾讯轻服务器是个不错的选择价格便宜性能也够用。总结MQTT协议在物联网领域有着广泛的应用通过简单的代码就可以实现一个支持断线自动重连的MQTT系统。希望这篇文章能帮到你如果你有任何问题欢迎留言讨论。