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();