导读：
MQTT是一种轻量级的物联网通信协议，可以快速、可靠地传递数据。MySQL是一个流行的关系型数据库管理系统。将MQTT与MySQL集成可以实现数据的持久化存储和分析。本文将介绍如何通过MQTT将数据存储到MySQL中。
1. 安装Mosquitto
首先需要安装MQTT代理服务器Mosquitto。可以在Linux或Windows上安装。安装完成后，启动Mosquitto服务。
2. 配置Mosquitto
在Mosquitto配置文件中添加以下内容：
listener 1883
protocol mqtt
allow_anonymous true
这将允许未经身份验证的客户端连接到Mosquitto代理服务器。
3. 创建MySQL数据库
使用MySQL命令行或其他工具创建一个名为“mqtt”的数据库。然后创建一个名为“messages”的表，该表将保存接收到的消息。
CREATE TABLE messages (
id INT(11) NOT NULL AUTO_INCREMENT,
topic VARCHAR(255) NOT NULL,
message TEXT NOT NULL,
created_at DATETIME NOT NULL,
PRIMARY KEY (id)
);
4. 编写Python脚本
使用Python编写一个MQTT客户端，并将接收到的消息插入到MySQL数据库中。以下是示例代码：
import paho.mqtt.client as mqtt
import MySQLdb
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("#")
def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
db = MySQLdb.connect(host="localhost", user="root", passwd="", db="mqtt")
cursor = db.cursor()
sql = "INSERT INTO messages (topic, message, created_at) VALUES (%s, %s, NOW())"
cursor.execute(sql, (msg.topic, str(msg.payload)))
db.commit()
db.close()
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("localhost", 1883, 60)
client.loop_forever()
5. 运行Python脚本
在命令行中运行Python脚本，并等待接收消息。每当收到一条消息时，它将被插入到MySQL数据库中。
总结：
通过MQTT将数据存储到MySQL中可以实现数据的持久化存储和分析。使用Mosquitto作为MQTT代理服务器，创建一个MySQL数据库来保存接收到的消息，并使用Python编写一个MQTT客户端来将消息插入到MySQL数据库中。这种集成方法可以应用于各种物联网应用场景，例如传感器数据的监控和分析。
