flas监听mqtt

Flask是一个轻量级的Web应用框架，而MQTT（Message Queuing Telemetry Transport）是一种发布订阅式的、轻量级的通讯协议，常用于物联网(IoT)和实时数据传输场景。要在Flask应用中监听MQTT消息，你可以使用第三方库如`paho-mqtt`。

以下是简单的步骤：

1. **安装依赖**:
使用pip安装`flask`和`paho-mqtt`库：

   pip install flask paho-mqtt

2. **设置Flask应用**:
创建一个基本的Flask应用实例：

   from flask import Flask
   app = Flask(__name__)

3. **创建MQTT连接**:
使用`paho-mqtt`库建立到MQTT broker的连接：

   from paho.mqtt.client import Client

   mqtt_client = Client()
   mqtt_client.connect("your_broker_address", port=1883)

4. **处理消息回调**:
定义一个函数来接收并处理接收到的MQTT消息：

   def on_message(client, userdata, message):
       print(f"Received MQTT message: {message.payload.decode()}")
   
   mqtt_client.on_message = on_message

5. **开始监听**:
启动Flask应用并在适当的时候启动MQTT客户端监听消息：

   @app.route('/')
   def handle_requests():
       # 这里可以添加其他路由，当浏览器访问时处理请求
       return "MQTT listener running"

   if __name__ == '__main__':
       mqtt_client.loop_start()
       app.run(host="0.0.0.0", port=5000)  # 运行Flask应用

6. **关闭连接**:
在程序结束时记得关闭MQTT连接：

   def shutdown_server():
       mqtt_client.disconnect()
       sys.exit(0)

   # 添加一个信号处理器来优雅退出
   import signal
   signal.signal(signal.SIGINT, shutdown_server)