簡介&安裝
MQTT是一個基於客戶端-服務器的消息發布/訂閱傳輸協議。MQTT協議是輕量、簡單、開放和易於實現的，這些特點使它適用范圍非常廣泛.可以以極少的代碼和有限的帶寬，為連接遠程設備提供實時可靠的消息服務。作為一種低開銷、低帶寬占用的即時通訊協議，使其在物聯網、小型設備、移動應用等方面有較廣泛的應用。
MQTT 提供兩個核心功能：
- 三種級別的消息發布服務質量
- 基於訂閱/發布的消息轉發服務。
有三種消息發布服務質量：
-
"至多一次"，消息發布完全依賴底層TCP/IP網絡。會發生消息丟失或重復。這一級別可用於如下情況，環境傳感器數據，丟失一次讀記錄無所謂，因為不久后還會有第二次發送。這一種方式主要普通APP的推送，倘若你的智能設備在消息推送時未聯網，推送過去沒收到，再次聯網也就收不到了。
-
"至少一次"，確保消息到達，但消息重復可能會發生。
-
"只有一次"，確保消息到達一次。在一些要求比較嚴格的計費系統中，可以使用此級別。在計費系統中，消息重復或丟失會導致不正確的結果。這種最高質量的消息發布服務還可以用於即時通訊類的APP的推送，確保用戶收到且只會收到一次。
安裝方式見官網介紹：http://mosquitto.org/download/
Mac 安裝方式非常簡單
brew install mosquitto
安裝完成，可以見它的配置文件為地址在 /usr/local/etc/mosquitto/mosquitto.conf 下
啟動MQTT服務命令為
mosquitto -c /usr/local/etc/mosquitto/mosquitto.conf 即可開啟服務
如果提示 mosquitto 命令未找到，就添加一下環境變量
MOSQUITTO_HOME=/usr/local/Cellar/mosquitto/1.6.9/sbin
export MOSQUITTO_HOME
export PATH=$PATH:$MOSQUITTO_HOME
啟動服務 brew services start mosquitto
停止服務 brew services stop mosquitto
發送消息命令
mosquitto_pub -h 127.0.0.1 -p 1883 -t "mytopic" -m "222"
表示向 主題為 mytopic 發送一條 內容為 222的消息
添加訂閱主題命令
mosquitto_sub -h 127.0.0.1 -p 1883 -t "mytopic" -v
表示向 mqtt中添加 一個主題為 mytopic 的監聽
以上是命令的方式測試及驗證相關功能，那么在python中代碼如何調用呢
Python 使用MQTT
MqttClient.py
import datetime
import paho.mqtt.client as mqtt
# 服務器地址
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
# 設置賬號密碼
# 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
'''
發送消息
'''
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 源，具體參見這個文章