1. # -*- coding: utf-8 -*- 
    2. import paho.mqtt.client as mqtt
    4. # The callback for when the client receives a CONNACK response from the server.
    5. def on_connect(client, userdata, flags, rc):
    6.     print("Connected with result code "+str(rc))
    9. # The callback for when a PUBLISH message is received from the server.
    10. def on_message(client, userdata, msg):
    11.     #在这里处理业务逻辑
    12.     print(msg.topic+" "+str(msg.payload))
    14. client = mqtt.Client()
    15. client.on_connect = on_connect
    16. client.on_message = on_message
    18. client.connect("106.14.142.242", 1883, 60)
    19. client.subscribe("junjietest")
    21. # Blocking call that processes network traffic, dispatches callbacks and
    22. # handles reconnecting.
    23. # Other loop*() functions are available that give a threaded interface and a
    24. # manual interface.
    25. client.loop_forever()