如何使用MQTT處理Node.js中的消息處理失敗？

Question

我正在使用寫在Node.js中的服務通過MQTT（https://www.npmjs.com/package/mqtt）接收消息，然後寫入數據庫（使用mssql的SQL Server）。

當一切正常工作時，這將工作得非常好，我創建了mqtt偵聽器並訂閱了新的消息事件。

但是，如果與數據庫的連接失敗（這可能會由於網絡中斷等原因而週期性發生），那麼將消息寫入數據庫將失敗，並且該消息將被丟棄。

我想告訴MQTT經紀人 - 「我無法處理該消息，直到我可以將其保存在緩衝區中。」

var mqtt = require('mqtt') 
var client = mqtt.connect('mymqttbroker') 

client.on('connect', function() { 
    client.subscribe('messagequeue') 
}) 

client.on('message', function (topic, message) { 
    writeMessageToDB(message).then((result) => {console.log('success'};).catch((err) => {/* What can I do here ?*/}); 
}) 

Answer 1

也許在重發功能上設置超時？可能應該改進爲在嘗試刪除郵件之前只嘗試n次，但這絕對是的一種方式來做到這一點。這顯然沒有經過測試，但它應該有希望給你一些想法...

var resend = function(message){ 

    writeMessageToDB(message).then((result) => { 

     console.log('Resend success!') 

    }) 
    .catch((err) => { 

     setTimeout(function(message){ 
      resend(message); 
     }, 60000); 

    }); 
} 

client.on('message', function (topic, message) { 

    writeMessageToDB(message).then((result) => { 

     console.log('success') 

    }) 
    .catch((err) => { 

     resend(message); 

    }); 
});