mosquitto python 客戶端安裝

# 安裝mosquitto python客戶端。官方文檔

# git下載源碼方式很慢
# git clone https://github.com/eclipse/paho.mqtt.python
# cd paho.mqtt.python

wget https://pypi.python.org/packages/82/d9/7064d3a0a1d62756a1a809c85b99f864c641b66de84c15458f72193b7708/paho-mqtt-1.2.tar.gz
tar -zvxf paho-mqtt-1.2.tar.gz
cd paho-mqtt-1.2

python3 setup.py install

mosquitto的啓動見mosquitto安裝

寫一個python示例，訂閱系統主題$SYS/#

#!/usr/local/bin/python3
# Filename : test_mosquitto

import paho.mqtt.client as mqtt

def on_connect(client, userData, flags, rc):
    print("Connected with result code " + str(rc));
    
    # 發佈消息測試
    payload = '123中文測試';
    client.publish('a/b/c', payload, 2, False);
    # 訂閱主題測試
    client.subscribe("$SYS/#");

# 打印接收到的信息
def on_message(client, userData, msg):
    print(msg.topic + " " + str(msg.payload));
    

client = mqtt.Client();
client.on_connect = on_connect;
client.on_message = on_message

client.connect('127.0.0.1', 1883, 60);

client.loop_forever();