M5mqttモジュール内のAPIを使用して、mqttサーバーとサブスクリプション配信メッセージコンテンツを接続します。
from m5mqtt import M5mqtt
# 创建连接实例
m5mqtt = M5mqtt(
client_id,
server,
port=0,
user=None,
password=None,
keepalive=0,
ssl=False,
ssl_params=None
)
# 开始连接
m5mqtt.start()
while True:
# 订阅消息
def callback(topic_data):
print(topic_data)
m5mqtt.subscribe(topic, callback)
# 发布消息
m5mqtt.publish(topic, data)
# 配置客户端遗嘱消息
m5mqtt.set_last_will(topic, msg)
# 断开连接
m5mqtt.deinit()