导读：
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】通过MQTT将数据存储到MySQL中可以实现数据的持久化存储和分析 。使用Mosquitto作为MQTT代理服务器，创建一个MySQL数据库来保存接收到的消息，并使用Python编写一个MQTT客户端来将消息插入到MySQL数据库中 。这种集成方法可以应用于各种物联网应用场景，例如传感器数据的监控和分析 。
