Node.js在收到來自mqtt代理的訊息后執行mysql查詢

我有一個訂閱主題的 node.js 檔案，并在收到發布的訊息后掃描本地 mysql 資料庫以查找名為“command”的變數中的最新條目。命令值將觸發各種回應，但我已將這部分排除在外，因為我的問題在此之前。

我的 mysql 查詢似乎給了我錯誤。我正在嘗試查找命令列的最新條目并將值分配給 var 命令。我認為這段代碼可以解決問題：

var sql = 'SELECT command FROM motoron2 ORDER BY id DESC LIMIT 1';
        con.query(sql, function (err, result) {
            if (err) throw err;
        });
        console.log(result);
        var command = result[1];
        console.log(command);

但我收到以下回應，這似乎表明 mysql 查詢中有錯誤：

user@server.domain [bin]# node motorlistener.js
Connected to MYSQL!
Connected to Broker!
{"pulse":1}
1
/home/user/etc/domain/bin/motorlistener.js:62
    console.log(result);
                ^

ReferenceError: result is not defined
    at MqttClient.<anonymous> (/home/user/etc/domain/bin/motorlistener.js:62:17)
    at MqttClient.emit (events.js:314:20)
    at MqttClient._handlePublish (/home/user/node_modules/mqtt/lib/client.js:1277:12)
    at MqttClient._handlePacket (/home/user/node_modules/mqtt/lib/client.js:410:12)
    at work (/home/user/node_modules/mqtt/lib/client.js:321:12)
    at Writable.writable._write (/home/user/node_modules/mqtt/lib/client.js:335:5)
    at doWrite (/home/user/node_modules/readable-stream/lib/_stream_writable.js:409:139)
    at writeOrBuffer (/home/user/node_modules/readable-stream/lib/_stream_writable.js:398:5)
    at Writable.write (/home/user/node_modules/readable-stream/lib/_stream_writable.js:307:11)
    at TLSSocket.ondata (_stream_readable.js:718:22)

完整的代碼如下，但有誰知道是什么導致了這個錯誤？

////////////////////////////////////////////////////////////////////////////////
//setup
var mqtt    = require('mqtt'); //for client use
const fs = require('fs');
var caFile = fs.readFileSync("/home/user/etc/domain/bin/ca.crt");
var topic = "heartbeat";
var mysql      = require('mysql');

var con = mysql.createConnection({
  host     : 'localhost',
  user     : 'myuser',
  password : 'mypass',
  database : 'mydb'
});

var options={
    port:8883,
    clientId:"yo",
    username:"myuser2",
    password:"mypassw",
    protocol: 'mqtts',
    clean:true,
    rejectUnauthorized: false,
    retain:false, 
    ca:caFile
};


var client  = mqtt.connect("http://dns.org",options);

//mqtt connection dialog
client.on("connect",function(){
    console.log("Connected to Broker!");
    client.subscribe(topic, {qos:1});
});

//mqtt connection handle errors
client.on("error",function(error){
    console.log("Broker Connection Error");
    process.exit(1);
});

//database connection
con.connect(function(err) {
        if (err) throw err;
        console.log("Connected to MYSQL!");
});

//handle incoming messages from broker
client.on('message',function(topic, message, packet){
    var raw = "" message;
    console.log(raw);
    var obj = JSON.parse(raw);
    var pulse = obj.pulse; 
    console.log(pulse);
    
    var sql = 'SELECT command FROM motoron2 ORDER BY id DESC LIMIT 1';
    con.query(sql, function (err, result) {
        if (err) throw err;
    });
    console.log(result);
    var command = result[1];
    console.log(command);
    
    if (command == 1) {
        console.log("command=1");
    }
    else {
        console.log("command not equal to 0");
    }

});

uj5u.com熱心網友回復：

我收到以下回應，這似乎表明 mysql 查詢中有錯誤

這不是您的 MySQL 查詢中的錯誤。這是一個空參考錯誤，因為您試圖result在回呼之外使用。

將您的代碼更改為此將起作用：

var sql = 'SELECT command FROM motoron2 ORDER BY id DESC LIMIT 1';
con.query(sql, function (err, result) {
   if (err) { 
       throw err; 
   }
   // access result inside the callback
   console.log(result);
   var command = result[0];
   console.log(command);
});

根據您的環境，您可以使用Promise和async/await重新撰寫代碼以減少嵌套范圍。

為此，您需要將回呼轉換為承諾，然后您可以等待它，如下所示：

let sql = 'SELECT command FROM motoron2 ORDER BY id DESC LIMIT 1';

// 1 -- we turn the query into a promise 
const queryPromise = new Promise((resolve, reject) => {
  con.query(sql, function (queryError, queryResult) {
    if (queryError) { 
       reject(queryError); 
    }
    resolve(queryResult);
  });
});

try {
  // 2 -- we can now await the promise; note the await
  let result = await queryPromise;

  // 3 -- now we can use the result as if it executed synchronously
  console.log(result);
  let command = result[0];
  console.log(command);
} catch(err) {
  // we can catch query errors and handle them here
}

綜上所述，您應該能夠將 on message 事件處理程式更改為 async 函式，以便利用 async/await 模式，如上所示：

client.on('message', async function(topic, message, packet) {
    
    /* .. you can use await here .. */
    
});

標籤：mysql 节点.js MQTT

上一篇：使用morgan創建記錄器中間件

下一篇：DiscordJS錯誤，在命令處理程式中嵌入訊息