簡介&安裝

MQTT是一個基于客戶端-服務(wù)器的消息發(fā)布/訂閱傳輸協(xié)議。MQTT協(xié)議是輕量、簡單、開放和易于實現(xiàn)的，這些特點使它適用范圍非常廣泛.可以以極少的代碼和有限的帶寬，為連接遠程設(shè)備提供實時可靠的消息服務(wù)。作為一種低開銷、低帶寬占用的即時通訊協(xié)議，使其在物聯(lián)網(wǎng)、小型設(shè)備、移動應(yīng)用等方面有較廣泛的應(yīng)用。

MQTT 提供兩個核心功能：

三種級別的消息發(fā)布服務(wù)質(zhì)量

基于訂閱/發(fā)布的消息轉(zhuǎn)發(fā)服務(wù)。

有三種消息發(fā)布服務(wù)質(zhì)量：

"至多一次"，消息發(fā)布完全依賴底層TCP/IP網(wǎng)絡(luò)。會發(fā)生消息丟失或重復(fù)。這一級別可用于如下情況，環(huán)境傳感器數(shù)據(jù)，丟失一次讀記錄無所謂，因為不久后還會有第二次發(fā)送。這一種方式主要普通APP的推送，倘若你的智能設(shè)備在消息推送時未聯(lián)網(wǎng)，推送過去沒收到，再次聯(lián)網(wǎng)也就收不到了。

"至少一次"，確保消息到達，但消息重復(fù)可能會發(fā)生。

"只有一次"，確保消息到達一次。在一些要求比較嚴格的計費系統(tǒng)中，可以使用此級別。在計費系統(tǒng)中，消息重復(fù)或丟失會導致不正確的結(jié)果。這種最高質(zhì)量的消息發(fā)布服務(wù)還可以用于即時通訊類的APP的推送，確保用戶收到且只會收到一次。

安裝方式見官網(wǎng)介紹：http://mosquitto.org/download/

Mac 安裝方式非常簡單

brew install mosquitto

安裝完成，可以見它的配置文件為地址在 /usr/local/etc/mosquitto/mosquitto.conf 下

啟動MQTT服務(wù)命令為

mosquitto -c /usr/local/etc/mosquitto/mosquitto.conf 即可開啟服務(wù)

如果提示 mosquitto 命令未找到，就添加一下環(huán)境變量

MOSQUITTO_HOME=/usr/local/Cellar/mosquitto/1.6.9/sbin

export MOSQUITTO_HOME

export PATH=$PATH:$MOSQUITTO_HOME

啟動服務(wù) brew services start mosquitto

停止服務(wù) brew services stop mosquitto

發(fā)送消息命令

mosquitto_pub -h 127.0.0.1 -p 1883 -t "mytopic" -m "222"

表示向 主題為 mytopic 發(fā)送一條 內(nèi)容為 222的消息

添加訂閱主題命令

mosquitto_sub -h 127.0.0.1 -p 1883 -t "mytopic" -v

表示向 mqtt中添加 一個主題為 mytopic 的監(jiān)聽

以上是命令的方式測試及驗證相關(guān)功能，那么在python中代碼如何調(diào)用呢

Python 使用MQTT

MqttClient.py

import datetime

import paho.mqtt.client as mqtt

# 服務(wù)器地址

strBroker = "localhost"

# 通信端口

port = 1883

# 用戶名

username = 'username'

# 密碼

password = 'password'

# 訂閱主題名

topic = 'topic'

def on_connect(mqttc, obj, rc):

print("OnConnetc, rc: " + str(rc))

def on_publish(mqttc, obj, mid):

print("OnPublish, mid: " + str(mid))

def on_subscribe(mqttc, obj, mid, granted_qos):

print("Subscribed: " + str(mid) + " " + str(granted_qos))

def on_log(mqttc, obj, level, string):

print("Log:" + string)

def on_message(mqttc, obj, msg):

curtime = datetime.datetime.now()

strcurtime = curtime.strftime("%Y-%m-%d %H:%M:%S")

print(strcurtime + ": " + msg.topic + " " + str(msg.qos) + " " + str(msg.payload))

on_exec(str(msg.payload))

def on_exec(strcmd):

print

"Exec:", strcmd

# =====================================================

if __name__ == '__main__':

mqttc = mqtt.Client("test")

mqttc.on_message = on_message

mqttc.on_connect = on_connect

mqttc.on_publish = on_publish

mqttc.on_subscribe = on_subscribe

mqttc.on_log = on_log

# 設(shè)置賬號密碼

# mqttc.username_pw_set(username, password=password)

mqttc.connect(strBroker, port, 60)

mqttc.subscribe(topic, 0)

mqttc.loop_forever()

MqttServer.py

import sys

import datetime

import socket, sys

import paho.mqtt.publish as publish

'''

發(fā)送消息

'''

def transmitMQTT(strMsg):

strMqttBroker = "localhost"

strMqttTopic = "topic"

publish.single(strMqttTopic, strMsg, hostname=strMqttBroker)

if __name__ == '__main__':

msg = "Hello,MQTT 2020!"

transmitMQTT("msg")

print("Send msg = [", msg, "] ok.")

ps :如果Homebrew 更新太慢，可以替換Homebrew 源，具體參見這個文章

總結(jié)

以上是生活随笔為你收集整理的python mqtt broker_python Mqtt 的安装及使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。