转MQTT--Python进行发布、订阅测试

前言

 使用python编写程序进行测试MQTT的发布和订阅功能。首先要安装:pip install paho-mqtt

测试发布（pub）

 个人MQTT部署在阿里云的服务器上面，因此我在本机上编写了python程序进行测试。

而后在shell里面从新打开一个终端，订阅一个主题为“chat” mosquitto_sub -t chat

 在本机上测试远程的MQTT的发布功能就是把本身做为一个发送信息的人，当本身发送信息的时候，全部订阅过该主题（topic）的对象都将收到本身发送的信息。 
mqtt_client.py

# encoding: utf-8

import paho.mqtt.client as mqtt

HOST = "101.200.46.138"
PORT = 1883

def test():
    client = mqtt.Client()
    client.connect(HOST, PORT, 60)
    client.publish("chat","hello liefyuan",2) # 发布一个主题为'chat',内容为‘hello liefyuan’的信息
    client.loop_forever()

if __name__ == '__main__':
    test()

　　

 

注解函数：

client.connect(self, host, port, keepalive, bind_address)

client.publish(self, topic, payload, qos, retain) ---保留（retain）

client.subscribe(self, topic, qos)

 

注： MQTT传输的消息分为：主题（Topic）和负载（payload）两部分：

（1）Topic，能够理解为消息的类型，订阅者订阅（Subscribe）后，就会收到该主题的消息内容（payload）；

（2）payload，能够理解为消息的内容，是指订阅者具体要使用的内容。

（3）当应用数据经过MQTT网络发送时，MQTT会把与之相关的服务质量（QoS）和主题名（Topic）相关连。

测试订阅（sub）

 在本机上编写程序测试订阅功能，就是让本身的程序做为一个接收者，同一个主题没有发布（pub）信息的时候，就本身一直等候。

# encoding: utf-8


import paho.mqtt.client as mqtt


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


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("www.liefyuan.top", 1883, 60)
client.loop_forever()