接收离线消息mqtt

2023-12-14

我使用 mosquitto 作为代理,使用 paho(python) 作为客户端。我正在尝试让订阅者接收离线消息。

为此我做了以下更改:

  • 固定客户端 ID
  • 服务质量级别 2

但是,订阅者仍然无法接收消息。

有什么帮助吗?

谢谢, 拉胡尔


为了让您的客户端成为持久客户端并在离线时接收发送到主题的消息,您需要满足以下条件:

  1. 固定客户端 ID(正如您所做的那样)
  2. 始终使用 clean_session=False 连接
  3. 订阅必须以 QoS>0 进行
  4. 发布的消息必须具有 QoS>0

我最常犯的错误是忘记了第 3 点和第 4 点之一,因此我使用 QoS=0 进行发布或使用 QoS=0 进行订阅,这两种情况都会导致消息不被存储。

您还可以查看queue_qos0_messages选项告诉代理也存储 QoS=0 消息。请注意,这是可能特定于 mosquitto 的实现细节。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

接收离线消息mqtt 的相关文章

  • Paho MQTT 客户端在设备锁定后断开连接

    我目前正在开发一个小型 紧急按钮 应用程序 该应用程序应该在医疗机构中运行 由于该项目的假设之一是独立于 Internet 因此我决定采用 MQTT 并在本地 WLAN 中设置服务器 我已经实现了 Paho Android 服务 效果非常好
  • python paho mqtt无法使用用户名和密码连接到mqtts

    我的 raspberrypi 上的以下 python 代码无法连接到我的 mqtt 代理 它只是在打印后挂起Connecting import paho mqtt client as mqtt def on connect client u
  • 无法接收已发布的消息以在 mqtt paho 上订阅主题

    我正在使用 paho 发送和接收 mqtt 消息 到目前为止 发送消息没有任何问题 我在接收它们时遇到问题 我的代码是 package BenchMQTT import org eclipse paho client mqttv3 IMqt
  • Paho MqttClient 的发布方法永远阻塞

    这非常适合启动连接并发布第一条消息 MemoryPersistence persistence new MemoryPersistence client new MqttClient tcp IrisProperties MQTT SERV
  • 用于测试的 MQTT 代理

    尝试创建一个订阅 MQTT 代理并处理数据的 Python 脚本 然而 MQTT 代理到目前为止还没有收到任何数据 这使得测试变得困难 我发现以下脚本可以订阅主题并打印出有效负载 但我似乎无法连接到测试代理 import paho mqtt
  • Paho MqttAndroidClient.connect 总是失败

    我想从 Android 发布消息service到本地服务器 这是我的代码的一部分 以最简单的形式基于片段here https stackoverflow com questions 24791118 android paho mqtt se
  • golang mqtt 发布和订阅

    有谁知道我可以在哪里获得一些在无限循环中发布和订阅的示例 MQTT 客户端 Go golang 代码 我正在与在 MacO 上运行的 Mosquitto 代理进行消息传递 更详细地 从网络获取消息 主题 根据该消息计算一些内容 将计算结果发
  • 如何在 RSMB 中配置 MQTT-SN 主题 ID

    我的问题是关于通过 MQTT SN 网关使用 MQTT 主题名称和 MQTT SN 主题 ID 来配置 RSMB 使用 Really Small Message Broker 入门 信息对于了解在将两个 Very Small Message
  • 通过安全 Websockets 的 MQTT 套接字一分钟后关闭 - RabbitMQ

    我正在通过安全 Websockets 连接到 MQTT RabbitMQ 实例 Angular 6 使用此模块 import Paho from ng2 mqtt mqttws31 它连接成功 但套接字连接似乎在一分钟后关闭 无论 Keep
  • 在 Android 中使用 MQTT 的基本步骤

    我是 Android 新手 希望使用 MQTT 作为来自服务器的 Android 推送通知程序 我读过有关 MQTT 的内容 但不太了解 如果有人使用过这个库 请告诉我我必须做什么才能开始使用它 我有一个 Java 服务器 在 Window
  • 使用 TLS 的 node.js mqtt 客户端

    我正在尝试使用下面的包来实现带有 TLS 的 node js mqtt 客户端 https www npmjs com package mqtt client https www npmjs com package mqtt client
  • Cumulocity smarREST 响应模板

    我正在尝试设置 Cumulocity smartREST 响应模板以提供应用程序存储的设备对象的信息 我认为这是不可能的 但我想确认一下 因为文档很简短而且不清楚 我之前已经成功实现了测量发布模板 但我现在正在尝试执行库存获取 我已经在设备
  • 最大 MQTT 连接数

    我需要创建一个服务器场 可以处理 5 100 万个连接 5 00000 个主题 每个客户端一个 每秒处理 300k 消息 我尝试了解各种消息代理的功能 因此我目前使用两个 RHEL EC2 实例 r3 4xlarge 来获取大量可用资源 所
  • 在 mqtt.js 中发布无法访问的主题时如何捕获“访问错误”?

    我正在使用带有 mqtt js 的 node js 和 mosquitto 代理创建一个项目 在 mosquitto 配置文件中 我设置了 pwfile aclfile 来控制哪个用户可以访问哪个主题 如果用户名 密码 发布主题和订阅主题正
  • AWS-IoT 核心代理的最大消息负载大小是多少?

    在文档中AWS 服务限制 https docs aws amazon com general latest gr aws service limits htmlIoT Core 服务的有效负载大小限制尚不清楚 既然我们可以将本地 mosqu
  • Mosquitto 1.4.2 Websocket 支持

    我正在尝试利用 Mosquittos 最近的更新来支持代理中的 websocket 我正在运行 Mosquitto v1 4 2 并将以下几行添加到 mosquitto 配置文件 mosquitto conf 中 listener 1000
  • Spring集成MQTT发布订阅多个主题

    我正在尝试构建一个订阅多个 mqtt 主题的应用程序 获取信息 处理它并形成 xml 并在处理时触发一个事件 以便这些可以发送到某个云服务器 并将成功的响应从那里发送回MQTT 通道
  • AWS IOT 连接超时异常

    AWSIoTPythonSDK exception AWSIoTExceptions connectTimeoutException 在我的机器上运行示例 python 代码后 我收到此异常 参考了github的例子 https githu
  • 以编程方式设置 mosquitto 中的访问控制限制

    我正在开发一个将使用 mqtt 的应用程序 我将使用 python 库 我一直倾向于使用 mosquitto 但找不到以编程方式为其设置访问控制限制的方法 我正在编写的应用程序需要能够区分用户 并且只允许他们订阅某些主题 当前的解决方案看起
  • 请求/响应的 MQTT 主题名称

    我正在设计一个包含许多设备的系统 使用 MQTT 连接到中央代理 有些主设备可以向某些从设备发送请求 来自一台主机的请求通常会发送给一台从机 请求的主题可以是 mysystem slaveId req 因此从站可以订阅该主题 并且主站可以发

随机推荐

  • 如何清理和重新编码 R 调查数据中的检查所有适用的响应?

    我有一些调查数据 其中包含一些多重响应问题 如下所示 HS18 为什么在南非看病难 选择所有符合条件的 1 Too expensive 2 No transportation to the hospital clinic 3 Hospita
  • 如何构建采用资源 id 数组的 REST API

    我正在为我的项目构建 REST API 用于获取给定用户的 INFO 的 API 是 api com users USER ID 我还想允许客户端传递用户 ID 列表 如何构建 API 使其成为 RESTful 并接收用户 ID 列表 如果
  • HTML5 是否允许您在浏览器中与本地客户端文件交互

    我看过一些关于通过网页访问客户端计算机上的文件的帖子 即这个question 我正在尝试为我正在编写的某些算法采用 在云中持续更新 范例 以便我的用户只需访问网页即可访问最新版本 这要求程序 网页可以从一个目录开始 递归地检查其中的文件 并
  • ptTimeSelect JQuery TimePicker 插件问题

    我正在尝试使用 jQuery ptTimeSelect 插件http pttimeselect sourceforge net example index html 这是来自 aspx 的代码
  • 如何使用 DirectShow.NET C# 访问音频流

    我想做的是将任意音频文件传递到 DirectShow 过滤器 并最终使用 NET 3 5 C 和 DirectShow NET 接收 PCM 音频 流对象 我想说的是 Stream OpenFile string filename and
  • 条件编译和 Objective-C/Xcode

    因此 我正在开展一个学习项目 并尝试创建一个包含 URL 存储的头文件 以便您只需更改单个标志即可从调试更改为生产 这就是我试图用编译器做的事情 这显然是错误的 我找不到任何有关如何在 Objective C 中执行此操作的信息 所以这就是
  • SIMD 对超标量乱序 CPU 有什么好处?

    我一直在阅读最近可用的 AVX 512 说明 我觉得有一个基本概念我不理解 对于已经执行乱序执行的超标量 CPU SIMD 有什么好处 考虑以下伪汇编代码 使用 SIMD load 16 floats to register simd a
  • 异步更新 UI?

    考虑这个例子 Private Sub Button Click sender As Button e As RoutedEventArgs Handles btn Click sender IsEnabled False Thread Sl
  • ec2:无法在 Windows 实例上打开端口 5080 [已关闭]

    Closed 这个问题不符合堆栈溢出指南 目前不接受答案 我对 ec2 防火墙设置等还很陌生 所以我可能会遗漏一些明显的东西 但是 我创建了一个 Windows 入门 实例 具有指定 5080 的安全组 并且与弹性ip关联 在实例上我有一个
  • 如何在成员函数中使用“this”?

    我编写了 Node 类的成员函数来按后缀顺序读取节点树 它将由作为树的根节点的 Node 实例调用 所以 N postfix 这些似乎是非法的 this gt left postfix this gt right postfix 执行此操作
  • 将十进制年份转换为日期

    我的表格中有日期存储为十进制年份 一个例子是2003 024658这翻译成January 9 2003 我想将十进制年份转换为 Oracle 的日期格式 我发现有人在 Excel 中完成了此操作 十进制年份至今的公式 DATE INT B1
  • 读取Excel文件获取unicode

    我正在用 pandas 读取 Excel 文件 当我在 microsoft excel 中打开文件时 我得到这样的输出 当我在 libre office 中看到这个文件时 我得到了这样的输出 因此 在阅读Excel文件时 我执行了以下代码
  • Tensorflow:如何通过名称获取张量?

    我无法按名称恢复张量 我什至不知道这是否可能 我有一个创建图表的函数 def create structure tf x input size dropout with tf variable scope scale 1 as scope
  • 如何在 PHP 生成的 HTML 中将 URL 编码为 javascript 字符串?

    给定这个 PHP 代码 a 这将起作用 因为json encode已经返回带引号的 JavaScript 表达式 和htmlspecialchars需要转义可能的 HTML 元字符 a
  • 在Java Applet中调用Web服务方法

    我成功构建了一个简单的Java Web Service 作为例子你可以参考 构建简单的网络服务 在 Eclipse 中 使用教程中指出的 Java Web 服务代理技术 可以轻松创建 Web 服务客户端 我想运行一个 Java Applet
  • Visual C++ Express 如何运行该应用程序?

    我不知道如何在 Visual C Express 中运行应用程序 调试选项就在那里 但是运行应用程序怎么样 我检查了上面的每个按钮 并右键单击了所有可以单击的按钮 但我没有看到运行它的选项 无需调试 我不介意调试 但我丢失了 main 正在
  • 如何从非托管代码使用托管代码?

    如何从本机 C 非托管代码 调用 NET 代码 我想将 NET 代码公开给我的非托管 C 应用程序 然后使用它们 更具体地说 我想从本机 C 调用 C 我知道有很多方法 但你能告诉我每种方法的优缺点吗 顺便问一下 我不想使用 COM 那么现
  • 去除空格/制表符/换行符 - python

    我正在尝试删除 Linux 上 python 2 7 中的所有空格 制表符 换行符 我写了这个 应该可以完成这项工作 myString I want to Remove all white t spaces new lines n and
  • 尝试对 Django 应用进行 dockerize,Docker 找不到 ft2build.h

    我是 Docker 新手 我正在尝试对 Django 应用程序进行 dockerize 但是当我运行时docker build t sometag 我收到以下错误 9 23 05 Preparing metadata setup py st
  • 接收离线消息mqtt

    我使用 mosquitto 作为代理 使用 paho python 作为客户端 我正在尝试让订阅者接收离线消息 为此我做了以下更改 固定客户端 ID 服务质量级别 2 但是 订阅者仍然无法接收消息 有什么帮助吗 谢谢 拉胡尔 为了让您的客户