使用串行端口时 Node.js 停止响应

Question

我第一次使用 Node.js 通过一个简单的网站来控制电机。

网站上有 2 个按钮:“左”和“右”。您必须按住“向左”或“向右”按钮才能转动电机。当您松开按钮时，电机停止。电机通过服务器的串口连接到 Arduino。它有效，但是

问题

当我在手机上使用它并向按钮发送垃圾邮件时，服务器有时会停止对每个人进行响应，直到我重新启动服务器。我认为由于 WiFi 延迟，这些函数调用得太快了。所以我尝试调用Chrome控制台中的函数。

LeftPressed();LeftReleased();LeftPressed();LeftReleased();

事实上，运行它们几次后，服务器停止响应。没有错误，没有崩溃..

当我删除 motorPort.write(message); 时，服务器会保持响应。

如何防止服务器停止响应？

客户端(浏览器中的 JavaScript)

function LeftPressed() {      
    socket.emit('steer', { left: true });
}
function LeftReleased() {       
    socket.emit('steer', { left: false });
}
function RightPressed() {        
    socket.emit('steer', { right: true });
}
function RightReleased() {        
    socket.emit('steer', { right: false });
}

服务器(node.js)

const SerialPort = require("serialport");
const express = require('express');
const app = express();
const server = require('http').createServer(app);
const io = require('socket.io')(server)    
const motorPort = new SerialPort('/dev/arduinoUnoMicroUSB', {
    baudrate: 9600,
});

app.use(express.static('web'));
server.listen(8081, function () {
    console.log("Server running...");
});

io.on('connection', function (socket) {  
    socket.on('steer', function (data) {
        var message = "2"; //stop   

        if (data.left != undefined) {
            console.log("Left: " + data.left); //log to Console (below)
            if (data.left) {
                message = "1" //turn left
            }
        }    

        if (data.right != undefined) {
            console.log("Right: " + data.right);
            if (data.right) {
                message = "3"; //turn right
            }
        }    

        motorPort.write(message); //send message over serial port            
    });   
});

控制台输出示例:单击“向左”按钮

Server running...
Left: true        //pressed   (motor turning left)
Left: false       //released  (motor stops)

Answer 1

我用这个就可以了。虽然不是 100% 完美，但至少服务器一直在响应。如果您认为有更好的方法，我随时欢迎改进。

const SerialPort = require("serialport");
const express = require('express');
const app = express();
const server = require('http').createServer(app);
const io = require('socket.io')(server);
const motorPort = new SerialPort('/dev/arduinoUnoMicroUSB', {
    baudrate: 9600,
});

app.use(express.static('web'));
server.listen(8081, function () {
    console.log("Server running...");
});
var ready = true;
var NotSendMessages = [];
io.on('connection', function (socket) {
    socket.on('steer', function (data) {
        var message = "2"; //stop   
        if (data.left != undefined) {
            console.log("Left: " + data.left);
            if (data.left) {
                message = "1" //turn left
            }
        }

        if (data.right != undefined) {
            console.log("Right: " + data.right);
            if (data.right) {
                message = "3"; //turn right
            }
        }
        if (!ready) {
            console.log("cats!!!");
            NotSendMessages.push(message);
        } else {
            send(message);
        }
    });
});
function send(message) {
    motorPort.write(message, function () {
        ready = false;
        motorPort.drain(function () {
            motorPort.flush(function () {
                ready = true;
            });
        });
    });
}
setInterval(function () {
    if (NotSendMessages.length > 0 && ready) {
        send(NotSendMessages.shift());
    }
}, 50);