欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

使用python實現mqtt的發(fā)布和訂閱

 更新時間:2019年05月05日 11:17:47   作者:xxt_  
這篇文章主要介紹了使用python實現mqtt的發(fā)布和訂閱,本文通過實例代碼給大家介紹的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下

需要安裝的python庫

使用python編寫程序進行測試MQTT的發(fā)布和訂閱功能。首先要安裝:pip install paho-mqtt

測試發(fā)布(pub)

我的MQTT部署在阿里云的服務器上面,所以我在本機上編寫了python程序進行測試。

然后在shell里面重新打開一個終端,訂閱一個主題為“chat” mosquitto_sub -t chat

在本機上測試遠程的MQTT的發(fā)布功能就是把自己作為一個發(fā)送信息的人,當自己發(fā)送信息的時候,所有訂閱過該主題(topic)的對象都將收到自己發(fā)送的信息。

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) # 發(fā)布一個主題為'chat',內容為‘hello liefyuan'的信息
  client.loop_forever()
if __name__ == '__main__':
  test()

發(fā)布/訂閱測試

# -*- coding: utf-8 -*-
import paho.mqtt.client as mqtt
MQTTHOST = "101.200.46.138"
MQTTPORT = 1883
mqttClient = mqtt.Client()
# 連接MQTT服務器
def on_mqtt_connect():
  mqttClient.connect(MQTTHOST, MQTTPORT, 60)
  mqttClient.loop_start()
# publish 消息
def on_publish(topic, payload, qos):
  mqttClient.publish(topic, payload, qos)
# 消息處理函數
def on_message_come(lient, userdata, msg):
  print(msg.topic + " " + ":" + str(msg.payload))
# subscribe 消息
def on_subscribe():
  mqttClient.subscribe("/server", 1)
  mqttClient.on_message = on_message_come # 消息到來處理函數
def main():
  on_mqtt_connect()
  on_publish("/test/server", "Hello Python!", 1)
  on_subscribe()
  while True:
    pass
if __name__ == '__main__':
  main()

注解函數:

client.connect(self, host, port, keepalive, bind_address)
client.publish(self, topic, payload, qos, retain)
client.subscribe(self, topic, qos)

測試訂閱(sub)

在本機上編寫程序測試訂閱功能,就是讓自己的程序作為一個接收者,同一個主題沒有發(fā)布(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()

總結

以上所述是小編給大家介紹的使用python實現mqtt的發(fā)布和訂閱,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!

相關文章

  • Django 按組控制權限類及定義方法詳解

    Django 按組控制權限類及定義方法詳解

    這篇文章主要為大家介紹了Django 按組控制權限類及定義方法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-06-06
  • python登錄pop3郵件服務器接收郵件的方法

    python登錄pop3郵件服務器接收郵件的方法

    這篇文章主要介紹了python登錄pop3郵件服務器接收郵件的方法,涉及Python操作郵件的相關技巧,需要的朋友可以參考下
    2015-04-04
  • 在Python中用has_key()方法查找鍵是否存在的教程

    在Python中用has_key()方法查找鍵是否存在的教程

    這篇文章主要介紹了在Python中用has_key()方法查找鍵是否存在的教程,是Python入門學習中的基礎知識,需要的朋友可以參考下
    2015-05-05
  • Opencv圖像處理方法最全總結

    Opencv圖像處理方法最全總結

    這篇文章主要給大家介紹了關于Opencv圖像處理方法的相關資料,OpenCV是一個開源的計算機視覺庫,提供了很多圖像處理、計算機視覺和機器學習等方面的函數和工具,被廣泛應用于各種計算機視覺領域的研究和應用中,需要的朋友可以參考下
    2024-06-06
  • python使用SMTP發(fā)送qq或sina郵件

    python使用SMTP發(fā)送qq或sina郵件

    這篇文章主要為大家詳細介紹了python使用SMTP發(fā)送qq或sina郵件,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-10-10
  • Python字符串格式化之使用format()方法

    Python字符串格式化之使用format()方法

    這篇文章主要介紹了Python字符串格式化之使用format()方法,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-08-08
  • 獲取python運行輸出的數據并解析存為dataFrame實例

    獲取python運行輸出的數據并解析存為dataFrame實例

    這篇文章主要介紹了獲取python運行輸出的數據并解析存為dataFrame實例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-07-07
  • json-server?如何快速搭建REST?API?服務器

    json-server?如何快速搭建REST?API?服務器

    json-server 是一個非常流行的開源工具,用于快速搭建一個完整的 REST API 服務器,它使用 JSON 文件作為數據源,通過簡單的配置即可模擬復雜的服務器功能,這篇文章主要介紹了json-server如何快速搭建REST API服務器,需要的朋友可以參考下
    2017-10-10
  • Python基本文件操作實用指南

    Python基本文件操作實用指南

    文件操作是我們開發(fā)中必不可少的一項需求,下面這篇文章主要給大家介紹了關于Python基本文件操作的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-06-06
  • 使用Flask-Cache緩存實現給Flask提速的方法詳解

    使用Flask-Cache緩存實現給Flask提速的方法詳解

    這篇文章主要介紹了使用Flask-Cache緩存實現給Flask提速的方法,結合實例形式詳細分析了Flask-Cache的安裝、配置及緩存使用相關操作技巧,需要的朋友可以參考下
    2019-06-06

最新評論