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

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

# 场景 #

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

[https://blog.csdn.net/BADAO\_LIUMANG\_QIZHI/article/details/112394731][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][https_blog.csdn.net_badao_liumang_qizhi]  
关注公众号  
霸道的程序猿  
获取编程相关电子书、教程推送与免费下载。

# 实现 #

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBREFPX0xJVU1BTkdfUUlaSEk_size_16_color_FFFFFF_t_70 1][]

[https_blog.csdn.net_BADAO_LIUMANG_QIZHI_article_details_112394731]: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/112394731
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBREFPX0xJVU1BTkdfUUlaSEk_size_16_color_FFFFFF_t_70]: /images/20221119/70102a13fb53494d999a87540a28f4b2.png
[https_blog.csdn.net_badao_liumang_qizhi]: https://blog.csdn.net/badao_liumang_qizhi
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBREFPX0xJVU1BTkdfUUlaSEk_size_16_color_FFFFFF_t_70 1]: /images/20221119/81720af13a7f46f3967addb0448dbb60.png