当前位置: 首页 > 知识库问答 >
问题:

当订阅者重新连接时,mosquitto不重新发送消息

沃威
2023-03-14

我正在与eclipse泛美卫生组织和蚊子工作。我正在发送QOS-1级别的消息。我已经改变了mosquitto的配置,就像在这个问题中回答的那样。我正在使用mqtt镜头来测试。在用户断开连接后,Mosquitto不发送消息。

共有1个答案

魏烨熠
2023-03-14

将clean session设置为true将告诉代理删除为客户端排队的任何消息。

如果要接收为该客户端排队的任何消息,则需要将其设置为false

HiveMQ的工作人员有一篇关于持久会话和MQTT消息队列的博客文章:http://www.HiveMQ.com/blog/mqt-essentials-part-7-persistent-session-queuing-messages

 类似资料:
  • 我的服务器代码使用将消息发送到特定的套接字,请参阅https://socket.io/docs/emit-cheatsheet/ 但是,当连接坏了,客户机断开并再次连接时,socketId会发生变化,并且会失败。那么如何实现re-emit方法来处理重新连接呢? 我的问题与此相反,socket.io在x秒/第一次尝试获得响应失败后停止重新发出事件,从中我了解到socket.io客户端在重新连接时可以

  • 我看到一个问题,我的主题中的所有消息都被我的消费者重新阅读。我只有1个消费者,我在开发/测试时打开/关闭它。我注意到,有时在几天没有运行消费者之后,当我再次打开它时,它会突然重新阅读我的所有消息。 客户端 ID 和组 ID 始终保持不变。我显式调用提交同步,因为我的启用.我确实设置了 auto.offset.reset=最早,但据我所知,只有在服务器上删除了偏移量时,才应该启动。我正在使用 IBM

  • 我正在使用azure iot设备SDK(1.3.31)连接模拟设备。对于某些设备,我在进行此调用时会出现此异常: 另一个注意:新设备连接/订阅成功,似乎它们在重新连接时更经常失败。如果我将打开的呼叫放在一个循环中,并在睡眠1秒后重试,设备最终会成功连接。

  • 在官方的akka 2.0.4文档中,它说: actor重新启动只替换实际的actor对象;邮箱的内容不受重新启动的影响,因此在postRestart钩子返回后,将继续处理邮件。不会再收到触发异常的消息。在重新启动时发送给参与者的任何消息都将像往常一样排队到其邮箱。 我唯一能想到的是,如果消息由于某种原因出现畸形,它将永远不会离开系统,并导致演员定期重新启动...

  • 我在项目中使用solace作为JMS提供者。我使用spring CachingConnectionFactory检索连接。在这个连接上,我创建了一个新会话。我在那个会话中创建了一个消费者的线程。 我正在做一些故障转移测试。当我将服务器从网络连接上拔下时,它会失败。当我再次连接服务器时,仍会收到相同的异常: 更重要的是,CachingConnectionFactory默认将reConnectOnEx