Как удалить ВСЕ сохраненные сообщения mqtt от Mosquitto?

Для этого есть 2 варианта использования клиентского кода paho в зависимости от того, какой из 2 publish методов вы используете.

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

or

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

Другой вариант - остановить mosquitto, удалить файл сохранения и перезапустить

Вот как это правильно сделать с помощью сценария оболочки.

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

Просто поместите его в файл с названием что-то вроде

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 после того, как вы предположите, что он получил все сообщения.

Это должно работать:

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

Также вас может заинтересовать этот скрипт из Eclipse Paho Python, чтобы очистить иерархию заданных тем. Возможно, вы захотите реализовать подобное поведение на Java, но похоже, что вы ищете одноразовое решение, поэтому, возможно, просто используйте скрипт Python :)

Поскольку у меня недостаточно очков для комментариев, бегу

#!/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

может вызвать бесконечный цикл из-за задержек публикации / подписки. Добавление --retained-only к mosquitto_sub, похоже, удаляет бесконечный цикл.

для пользователей PowerShell

была эта проблема в Windows, поэтому здесь с PowerShell. Mosquitto должен быть установлен на командном хосте.

получить сохраненные сообщения

Я не хотел удалять все сохраненные сообщения. Например, только те, которые содержат "octo" в своей теме. Посмотрим, что там:

mosquitto_sub.exe -h <mqtt host> -v -u <mqtt user> -P <mqtt password> -t '#' --retained-only|
Select-String octo

(при необходимости замените хост mqtt, пользователя и пароль)

удалить сохраненные сообщения

используйте здесь ту же строку поиска (в этом примере "octo"):

mosquitto_sub.exe -h <mqtt host> -v -u <mqtt user> -P <mqtt password> -t '#' --retained-only|
Select-String octo |
Out-String -Stream|ForEach-Object -Process {$_.Split(" ")[0]}|
%{mosquitto_pub.exe -h <mqtt host> -u <mqtt user> -P <mqtt password> -t "$_" -r -n}

Снова замените все вхождения mqtt host, user, password.

Просто проверьте еще раз с шага 1, если что-то осталось :)

Если вы используете Mosquitto MQTT Broker, отключите «Сохраненные сообщения» официальным методом, предоставленным Mosquitto.

Сначала найдите файл mosquitto.conf

(В моем экземпляре Ubuntu / EC2 он хранится в каталоге / etc / mosquitto, я предполагаю, что ваш путь к файлу mosquitto.conf /etc/mosquitto/mosquitto.conf)

Редактируйте с помощью вашего любимого текстового редактора, мой - nano.

sudo nano /etc/mosquitto/mosquitto.conf

и в этом файле замените "постоянство ложным" вместо "постоянство истинным"

persistence false

Теперь сохраните файл (при использовании nano нажмите ctrl + o, а затем введите, чтобы сохранить, ctrl + x, чтобы выйти)

теперь перезапустите mosquitto, используя следующие команды

sudo service mosquitto stop
sudo service mosquitto start

Примечание. Если этот путь конфигурации не существует в вашем случае, найдите файл конфигурации с помощью этой команды -

sudo find / -name mosquitto.conf