MQTT学习笔记——树莓派MQTT客户端 使用Mosquitto和paho-python

[python] view plaincopy

1. # -*- coding: utf-8 -*-    
2. import paho.mqtt.client as mqtt  
3. import RPi.GPIO as GPIO  
4. import json  
5.   
6. # BCM GPIO编号  
7. pins = [17,18,27,22,23,24,25,4]  
8. def gpio_setup():  
9.     # 采用BCM编号  
10.     GPIO.setmode(GPIO.BCM)  
11.     # 设置所有GPIO为输出状态，且输出低电平  
12.     for pin in pins:  
13.         GPIO.setup(pin, GPIO.OUT)  
14.         GPIO.output(pin, GPIO.LOW)  
15.           
16. def gpio_destroy():  
17.     for pin in pins:  
18.         GPIO.output(pin, GPIO.LOW)  
19.         GPIO.setup(pin, GPIO.IN)  
20.           
21. # 连接成功回调函数  
22. def on_connect(client, userdata, flags, rc):  
23.     print("Connected with result code " + str(rc))  
24.     # 连接完成之后订阅gpio主题  
25.     client.subscribe("gpio")  
26.   
27. # 消息推送回调函数  
28. def on_message(client, userdata, msg):  
29.     print(msg.topic+" "+str(msg.payload))  
30.     # 获得负载中的pin 和 value  
31.     gpio = json.loads(str(msg.payload))  
32.   
33.     if gpio['pin'] in pins:  
34.         if gpio['value'] == 0:  
35.             GPIO.output(gpio['pin'], GPIO.LOW)  
36.         else:  
37.             GPIO.output(gpio['pin'], GPIO.HIGH)  
38.   
39. if __name__ == '__main__':  
40.     client = mqtt.Client()  
41.     client.on_connect = on_connect  
42.     client.on_message = on_message  
43.     gpio_setup()  
44.       
45.     try:  
46.         # 请根据实际情况改变MQTT代理服务器的IP地址  
47.         client.connect("192.168.1.110", 1883, 60)  
48.         client.loop_forever()  
49.     except KeyboardInterrupt:  
50.         client.disconnect()  
51.         gpio_destroy()