场景
SpringBoot整合MQTT服务器实现消息的发送与订阅(推送消息与接收推送):
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/112394731
在上面使用SpringBoot进行连接MQTT服务器进行消息的发送与订阅的基础上。
在发布完消息后,另一个新的订阅者在开始订阅这个消息后会收到之前发布的历史消息,现在不需要使其收到历史消息,只需要收到即时消息
在进行发布消息时调用发布消息时
有一个参数叫retained。
Retained 消息是指在 PUBLISH 数据包中 Retain 标识设为 1 的消息,Broker 收到这样的 PUBLISH 包以后,将保存这个消息,当有一个新的订阅者订阅相应主
题的时候,Broker 会马上将这个消息发送给订阅者。
注:
博客:
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。
实现
所以在进行发布消息时将retrained设置为false即可
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/136418.html