MQTT服务搭建和简单使用
Table of Contents
MQTT为了物联网的消息传递而设计,业余时间弄了个报警器,之前用长轮询的实现感觉略麻烦,测试了一下MQTT的实现。
个人感觉使用比较简单,对网络问题的处理也比较完善,但是某些方面的灵活性略微不足,而且中文资料相对较少。
简单使用
服务端用mosquitto,客户端用python-paho-mqtt。
服务端
安装mosquitto,然后systemctl start mosquitto启动对应的服务。
公网环境下建议将配置文件中的默认端口1883改为其它端口,避免被直接扫描。
一些安全方面的设置也建议加上。
客户端
subscriber
#!/bin/python
import paho.mqtt.subscribe as subscribe
# 当调用这个函数时,程序会堵塞在这里,直到有一条消息发送到 topics/topic1 主题
msg = subscribe.simple("topics/topic1", hostname="your ip", port=yourport,
retained=False, client_id="youid", clean_session=False, qos=1)
print(f"{msg.topic} {msg.payload}")
hostname和port需要改为正确的参数。
其中,网络环境好并且不需要离线接收消息时,可以不设置clean_session
、client_id
、qos
三个参数。
publisher
发送一条消息
#!/bin/python
import paho.mqtt.publish as publish
publish.single("topics/topic1", "a message", hostname="your ip", port=yourport, qos=1)
其它
MQTT 几个基本概念
通常由3部分构成:subscriber订阅客户端、publisher发布消息客户端、Server服务器。
主题topic,类似一连串消息的标识符。
Message,具体的消息,对应于每个topic。
publisher向服务器指定主题发送消息。
subscriber连接服务器并且指定主题,当publisher向订阅的主题推送消息后,服务器会推送到对应的subscriber。
retained消息
MQTT使用了一个retained消息机制,用于保存主题的状态。publisher可以向主题发送retained消息,在subscriber获取retained消息时(获取参数中retained=True)服务端会返回最后一条retained消息,每一次都会返回而非普通消息的那种只读取一次。ratained消息更像是一种保存消息的状态,用在主题状态的设置,如开门的感应器,ratained消息用于标记门是否打开。
在python的paho库中,publisher的retained参数默认是False,而subscriber的retained参数默认为True,这个有点小坑。
QoS(Quality of Service)与离线消息
在subscriber和publisher中都可以指定,定义消息的可靠性级别,服务器会取两个客户端中较低的级别作为主题消息对应的处理级别。
QoS0,At most once,至多一次; QoS1,At least once,至少一次; QoS2,Exactly once,确保只有一次。
使用默认参数时,如果subscriber掉线,publisher发送的消息会丢失。
要想subscriber在离线后重新连接,还能收到publisher的消息,需要下面的设置:
- publisher与subscriber的QoS级别都设置为0以上;
- subscriber的
clean_session
设置为False; - subscriber设置固定的
client_id
.
存储消息历史记录
这个翻了一下网上的资料,感觉略不靠谱。MQTT的设计中没有考虑消息在服务端的存储,通常采用下面的几个方案:
- 使用另一个subscriber获取消息并存储;
- 使用EMQ等支持插件的服务端,通过插件处理消息。
- 换kafka…