使用Python庫paho.mqtt.client 模擬mqtt client 連接broker，publish topic。

#-*-coding:utf-8-*-
import paho.mqtt.client as mqtt

class mqttHandle(object):

    def __init__(self,mqtt_info):
        self.mqtt_info=mqtt_info

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

    def on_message(client, userdata, msg):
        print("topic:" + msg.topic + " payload:" + str(msg.payload))

    def publish(self):
        client = mqtt.Client()
        client.on_connect = mqttHandle.on_connect
        client.on_message = mqttHandle.on_message
        client.username_pw_set(self.mqtt_info[
 
‘username‘], self.mqtt_info[‘password‘])
        client.connect(self.mqtt_info[‘host‘], self.mqtt_info[‘port‘], 60)
        client.publish(self.mqtt_info[‘topic‘], str(self.mqtt_info[‘payload‘]))
        #client.loop_forever()
        client.disconnect()
        print(‘publish topic over‘)

if __name__
 
=="__main__":
    mqtt_info={
    ‘username‘:‘username‘,
    ‘password‘:‘password‘,
    ‘host‘:‘10.10.10.10‘,
    ‘port‘:1833,
    ‘topic‘:‘test‘,
    ‘payload‘:‘hello world‘,
}
    mqttc=mqttHandle(mqtt_info)
    mqttc.publish()

python mqtt client publish操作