У меня есть код node.js (сторона устройства), который прослушивает сообщения в очереди устройств в лазурном IotHub.
В следующем сценарии:
Устройство не читает старое сообщение из очереди, просто если я отправлю новое сообщение - оно его прочитает.
Как я могу изменить код устройства, чтобы также слушать старые сообщения?
Вы можете просмотреть эту статью, чтобы понять Azure Обмен сообщениями между облаком и устройством в Центре Интернета вещей. На диаграмме, которая показывает график состояния жизненного цикла для сообщения из облака на устройство в Центре Интернета вещей, Центр Интернета вещей сохраняет сообщения из облака на устройство в очередях для каждого устройства. Устройства должны явно подтвердить завершение, чтобы Центр Интернета вещей удалил их из очереди. Такой подход гарантирует отказоустойчивость от сбоев подключения и устройств.
В документе, который описывает, как отправить сообщения из облака на устройство с Центром Интернета вещей для node.js, если сначала запустить SendCloudToDeviceMessage.js, сообщение будет поставлено в очередь, а затем при запуске SimulatedDevice.js (обратите внимание на модификацию файла connectCallback для обработки сообщений с помощью метода Complete), клиент получит сообщения.
var connectCallback = function (err) {
if (err) {
console.log('Could not connect: ' + err);
} else {
console.log('Client connected');
client.on('message', function (msg) {
console.log('Id: ' + msg.messageId + ' Body: ' + msg.data);
client.complete(msg, printResultFor('completed'));
});
}
};
