Python MQTT 实验

Two client:

  • Pub_1.py
    import paho.mqtt.client as mqtt
    import time
    import sys
    import random
    
    
    def on_connect(client, userdata, flags, rc):
        print("connected with result code "+str(rc))
    
    
    def on_publish(client, userdata, mid):
        print("Publish au/csie/5/9/5912/temperture", )
    
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_publish = on_publish
    
    
    client.connect("iot.eclipse.org", 1883, 60)
    
    
    while True:
        try:
            with open("C:\Users\86390\Desktop\test_s.txt", "r") as f:
                data = f.readlines()
            # data = random.randint(24, 28)
            # client.publish("au/csie/5/9/5912/tempeture", str(data)+"C")
            print(len(str(data)))
            time.sleep(2)
        except KeyboardInterrupt:
            print("EXIT")
            client.disconnect()
            sys.exit(0)
  • Sub_1.py
    import paho.mqtt.client as mqtt
    import time
    import sys
    import random
    
    
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code"+str(rc))
        client.subscribe("/inode/mychannel")
    
    
    def on_message(client, userdata, msg):
        print(len(str(msg.payload))/1024/1024)
    
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    
    client.connect("127.0.0.1", 1883, 60)
    client.loop_forever()

Publisher and Client:

  • Pub_2.py
    import paho.mqtt.publish as publish
    import time
    
    def transmitMQTT(strMsg):
        strMqttBroker = "localhost"
        # strBroker = "127.0.0.1"
        strMqttChannel = "/inode/mychannel"
        print(len(str(strMsg)))
        publish.single(strMqttChannel, strMsg, hostname=strMqttBroker)
    
    if __name__ == '__main__':
        while True:
            transmitMQTT("a"*1024*1024*40)
            time.sleep(0.1)
    
            print (time.time())
  • Sub_2.py
    import paho.mqtt.client as mqtt
    import time
    import sys
    import random
    
    
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code"+str(rc))
        client.subscribe("/inode/mychannel")
    
    
    def on_message(client, userdata, msg):
        print(len(str(msg.payload))/1024/1024)
    
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    
    client.connect("127.0.0.1", 1883, 60)
    client.loop_forever()

坑:

  • 在Windows上正常通信的两个Client, 在虚拟机上sub端接收不到,可能是DNS网管问题。
  • 两个Client通信,必须搭建中间的broker, 但是如果是一个pub, 一个sub,则直接通过本地主机作为broker即可。
原文地址:https://www.cnblogs.com/ryu-manager/p/9347867.html