首页 > 其他分享> 文章详细

MQTT服务搭建和简单使用

2021-12-04 01:34:50 阅读：227 来源： 互联网

标签：publisher retained subscriber MQTT 消息简单服务端搭建

本文通过MetaWeblog自动发布，原文及更新链接：https://extendswind.top/posts/technical/mqtt_simple_use

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…

标签：publisher,retained,subscriber,MQTT,消息,简单,服务端,搭建
来源： https://www.cnblogs.com/fly2wind/p/15640722.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9