У меня есть клиент NodeJS
, который подписывается на Брокер Mosquito MQTT. Для QoS
установлено значение 1. Но когда брокер отправляет несколько сообщений одновременно по множеству разных тем (и на все эти темы подписан клиент NodeJS
), код клиента не может получать сообщения. Я использую библиотеку это на стороне клиента, и код прослушивания сообщений выглядит следующим образом:
public_client.on('message', function (topic, message) {
console.info(message);
}
Он получает некоторые сообщения, но не все. Чтобы убедиться, что это проблема на стороне клиента, я также подписался на сообщения от MQTT.fx, и он смог успешно получить сообщения, даже если для QoS
установлено значение 0 в MQTT.fx.
Как я могу это решить?
Кажется, вы изолировали проблему от своего кода. Мы не сможем помочь, если вы не покажете свой код или хотя бы важные его части.
Не могли бы вы рассказать, как вы отправляете сообщение? Также можете ли вы подтвердить, что ваш слушатель сообщений подписывается на все темы?