本文共 895 字,大约阅读时间需要 2 分钟。
环境:python3.6+
#!/usr/bin/python3 # -*- coding: utf-8 -*-
import paho.mqtt.client as mqttimport jsondef on_connect(client, userdata, flags, rc): client.subscribe("chat") client.publish('chat', json.dumps('hello,everyone.....'))def on_message(client, userdata, msg): info = json.loads(msg.payload.decode()) say_user = info.get("user") print("info:" + str(info)) if say_user != client.user: print(info.get('say') + '\n')if __name__ == '__main__': HOST = 'IP' #you mqtt server ip PORT = 1883 client = mqtt.Client(client_id='1008001', clean_session=False) client.on_connect = on_connect client.on_message = on_message client.connect(HOST, PORT) client.loop_start() while True: say_str = input('') print(say_str) if say_str: info = { 'say': say_str} print(str(info)) client.publish('chat', json.dumps(info))客户端登录的用户名密码:
User Name: admin
password: public
0也行
转载地址:http://mwagi.baihongyu.com/