SpringBoot连接MQTT进行发布消息时取消保留消息

痛定思痛。 2023-01-08 12:30 294阅读 0赞

场景

SpringBoot整合MQTT服务器实现消息的发送与订阅(推送消息与接收推送)：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/112394731

在上面使用SpringBoot进行连接MQTT服务器进行消息的发送与订阅的基础上。

在发布完消息后，另一个新的订阅者在开始订阅这个消息后会收到之前发布的历史消息，现在不需要使其收到历史消息，只需要收到即时消息

在进行发布消息时调用发布消息时

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBREFPX0xJVU1BTkdfUUlaSEk_size_16_color_FFFFFF_t_70

有一个参数叫retained。

Retained 消息是指在 PUBLISH 数据包中 Retain 标识设为 1 的消息，Broker 收到这样的 PUBLISH 包以后，将保存这个消息，当有一个新的订阅者订阅相应主

题的时候，Broker 会马上将这个消息发送给订阅者。

注：

博客：
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

所以在进行发布消息时将retrained设置为false即可

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBREFPX0xJVU1BTkdfUUlaSEk_size_16_color_FFFFFF_t_70 1

发表评论

表情：
评论列表 （有 0 条评论，294人围观）

还没有评论，来说两句吧...

相关阅读