Lung-Yu,Tsai 的部落格

1

pip install paho-mqtt

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

import paho.mqtt.client as mqtt

MQTT_DOMAIN_NAME = '192.168.50.182'
MQTT_PORT = 1883

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("Flow")

def on_message(client, userdata, msg):
	print (str(msg.payload,encoding='utf-8'))


def main():
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect(MQTT_DOMAIN_NAME, MQTT_PORT, 60)
    client.loop_forever()

if __name__ == "__main__":
    main()
    pass