pythonMQTT详解使⽤⼊门
最近开始搞mqtt，从各⽅⾯开始了解了⼀下。总结⼀下各个博客⾥得没说到位得地⽅。
⾸先，MQ 遥测传输 (MQTT) 是轻量级基于代理的发布/订阅的消息传输协议，设计思想是开放、简单、轻量、易于实现。这些特点使它适⽤于受限环境。该协议的特点有：
使⽤发布/订阅消息模式，提供⼀对多的消息发布，解除应⽤程序耦合。
对负载内容屏蔽的消息传输。
使⽤ TCP/IP 提供⽹络连接。
⼩型传输，开销很⼩（固定长度的头部是 2 字节），协议交换最⼩化，以降低⽹络流量。
使⽤ Last Will 和 Testament 特性通知有关各⽅客户端异常中断的机制。
有三种消息发布服务质量：
“⾄多⼀次”，消息发布完全依赖底层 TCP/IP ⽹络。会发⽣消息丢失或重复。这⼀级别可⽤于如下情况，环境传感器数据，丢失⼀次读记录⽆所谓，因为不久后还会有第⼆次发送。
“⾄少⼀次”，确保消息到达，但消息重复可能会发⽣。
“只有⼀次”，确保消息到达⼀次。这⼀级别可⽤于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果
寻过程
在寻MQTT服务器的过程中，我发现的Mosquitto是⼀款「An Open Source MQTT v3.1/v3.1.1 Broker」——开源的MQTT代理服务器，其下也有Windows的安装包。
搭建MQTT服务器
关于使⽤mosquitto官⽹上已经不到mosquitto的下载。参考这个博客[mosquitto使⽤]
()
这⾥是ubuntu版本的使⽤
安装好了，启动好了mqtt服务器之后开始，开始下⾯两个脚本客户端，⼀个是订阅端接收数据，⼀个publish发送数据。
这是订阅端
import paho.mqtt.client as mqtt
HOST = "192.168.10.8"
PORT = 61613
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("/+")
def on_message(client, userdata, msg):
pic+" "+msg.payload.decode("utf-8"))
def test():
client = mqtt.Client()    # 可能需要设置ClientId
client.username_pw_set("admin", "password")  # 必须设置，否则会返回「Connected with result code 4」
<_connect = on_connect
<_message = on_message
client.loop_forever()
if __name__ == '__main__':
test()
这是publish端
import paho.mqtt.client as mqtt
import json
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("chat")
client.publish("chat", json.dumps({"user": user, "say": "Hello,anyone!"}))
def on_message(client, userdata, msg):ubuntu使用入门教程
#pic+":"+str(msg.payload.decode()))
#pic+":"+msg.payload.decode())
payload = json.loads(msg.payload.decode())
("user")+":"+("say"))
if __name__ == '__main__':
client = mqtt.Client()
client.username_pw_set("admin", "password")  # 必须设置，否则会返回「Connected with result code 4」
<_connect = on_connect
<_message = on_message
HOST = "127.0.0.1"
#client.loop_forever()
user = input("请输⼊名称:")
client.user_data_set(user)
client.loop_start()
while True:
str = input()
if str:
client.publish("chat", json.dumps({"user": user, "say": str}))
运⾏两个实例，可以在MQTT服务器后台看到有两个MQTT客户端连接到服务器了，说明连接成功，尝试⽤其中⼀个客户端发送消息吧。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。