如何从mosquitto中清除所有保留的mqtt消息

Question

我已经看到了mosquitto_pub -h [server] -r -n -t [XYZ]语法,用于清除一条消息.我的问题是设备开发人员发布了大量垃圾邮件.我有一个java/paho代码库,我想根据需要自动修改它,但我似乎无法发布零字节消息.我试过了

client.publish(topic,null);

但这似乎不起作用.

关于如何删除所有内容的任何建议.

Answer 1

以下是如何使用shell脚本正确执行此操作.

#!/bin/sh
echo "cleaning " $1 " :: usage: cleanmqtt <host>"
mosquitto_sub -h $1 -t "#" -v | while read line; do mosquitto_pub -h $1 -t "${line% *}" -r -n; done

把它放在一个名为somthing的文件中

finally_a_working_way_to_remove_all_those_annoying_messages.sh

然后跑

sh finally_a_working_way_to_remove_all_those_annoying_messages.sh localhost

收到所有消息后,你必须在一段时间后按ctrl + c.这个解决方案很粗糙.你不能指定删除什么或任何东西.

Answer 2

Mosquitto 客户端提供 --remove-retained 选项：

mosquitto_sub -h $host --remove-retained -t '#' -W 1 

tunning -t 可以处理要清除的特定主题。

Answer 3

根据publish您使用的两种方法中的哪一种，使用 paho 客户端代码有两种选择。

MqttMessage msg = new MqttMessage(new byte[0]);
msg.setRetained(true);
client.publish(topic, msg);

或者

client.publish(topic, new byte[0],0,true);

另一种选择是停止 mosquitto 并删除持久性文件并重新启动