У меня возникла ситуация после получения сообщения от брокера MQTT. Во время обработки данных предположим, что БД не работает и не выполнила задачу. В этой конкретной ситуации полученные данные должны быть отправлены обратно в Брокер, что моя задача не выполнена, я имею в виду откат.
Как этого добиться и как сообщить брокеру, что при обработке данных возникло какое-то исключение и нужно отправить данные заново.
может ли кто-нибудь помочь в этом?
Это можно сделать, но только с определенными клиентскими библиотеками MQTT, которые позволяют полностью контролировать процесс рукопожатия QOS.
Предполагая, что клиент подписался в QOS 1 или 2 на тему, он может затем выбрать удержание отправки пакета PUBACK или PUBREC обратно брокеру. Он может отложить завершение рукопожатия QOS до тех пор, пока сообщение не будет полностью обработано. Если обработка не удалась и полное рукопожатие не завершено, брокер попытается повторно доставить сообщение клиенту, поэтому в случае сбоя клиент должен отключиться, чтобы сообщение было поставлено в очередь.
Когда серверная часть (хранилище данных) возвращается в оперативный режим, клиент может повторно подключиться к брокеру, и сообщения из очереди будут доставлены повторно.
