python flask模块写http和mqtt服务

下面是一个使用Flask编写HTTP和MQTT服务的示例代码：

from flask import Flask, request
from flask_mqtt import Mqtt

# 创建Flask应用
app = Flask(__name__)

# 配置MQTT连接信息
app.config['MQTT_BROKER_URL'] = 'broker.mqtt-dashboard.com'
app.config['MQTT_BROKER_PORT'] = 1883
app.config['MQTT_KEEPALIVE'] = 60
app.config['MQTT_USERNAME'] = ''
app.config['MQTT_PASSWORD'] = ''
app.config['MQTT_CLIENT_ID'] = ''

# 创建MQTT客户端对象
mqtt = Mqtt(app)

# 定义HTTP路由和视图函数
@app.route('/')
def hello():
    return 'Hello, World!'

# 定义MQTT订阅处理函数
@mqtt.on_connect()
def on_connect(client, userdata, flags, rc):
    mqtt.subscribe('test/topic')

@mqtt.on_message()
def on_message(client, userdata, message):
    print(message.topic + ' ' + message.payload.decode())

# 启动Flask应用
if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000, debug=True)

上述代码中，我们首先创建了一个Flask应用对象`app`。接着，我们通过配置`app.config`来设置MQTT连接信息，并在应用中创建了一个MQTT客户端对象`mqtt`。我们还定义了一个HTTP路由`'/'`，并为该路由定义了一个简单的视图函数`hello`，该函数向客户端返回一个字符串“Hello, World!”。

在MQTT部分，我们使用`@mqtt.on_connect()`和`@mqtt.on_message()`装饰器来定义MQTT订阅处理函数。在订阅处理函数中，我们订阅了主题`'test/topic'`，并打印出收到的消息。

最后，我们通过`app.run()`方法启动了Flask应用，并指定了HTTP服务的监听地址和端口号。当您运行上述代码后，在浏览器中访问`http://localhost:5000`时，应该会看到一个显示“Hello, World!”的页面。同时，可以使用MQTT客户端向主题`'test/topic'`发送消息，程序会打印出收到的消息。