当客户端断开连接时，node.js的websocket崩溃了。

Question

我对NodeJS和Websockets非常陌生，但我正在尝试使用它。

我的做法是从串口读取输入数据，然后使用WebSocket将这些数据发送到网页。到此为止，一切都运行正常。

• 我使用node-static来提供网页服务
• 我使用ws来进行WebSocket通信

问题是当客户端关闭浏览器时，我的NodeJS WebSocket服务器崩溃，并显示以下错误：

root@WS-SERVER-2:~/app# node socketserver.js
open serial communication
Client disconnected.

/root/node-v0.10.29/lib/node_modules/ws/lib/WebSocket.js:187
    else throw new Error('not opened');
               ^
Error: not opened
    at WebSocket.send (/root/node-v0.10.29/lib/node_modules/ws/lib/WebSocket.js:187:16)
    at sendAll (/root/app/socketserver.js:30:16)
    at SerialPort.<anonymous> (/root/app/socketserver.js:58:8)
    at SerialPort.emit (events.js:95:17)
    at Object.module.exports.raw [as parser] (/root/node-v0.10.29/bin/node_modules/serialport/parsers.js:8:13)
    at Object.SerialPort.options.dataCallback (/root/node-v0.10.29/bin/node_modules/serialport/serialport.js:143:15)
    at SerialPortFactory.SerialPort._emitData (/root/node-v0.10.29/bin/node_modules/serialport/serialport.js:312:20)
    at afterRead (/root/node-v0.10.29/bin/node_modules/serialport/serialport.js:290:18)
    at /root/node-v0.10.29/bin/node_modules/serialport/serialport.js:304:9
    at Object.wrapper [as oncomplete] (fs.js:459:17)

这是我的 WebSocket / 串口代码：

var WebSocketServer = require('../node-v0.10.29/lib/node_modules/ws').Server;
var SerialPort = require('../node-v0.10.29/bin/node_modules/serialport').SerialPort;

var serialPort;
var portName = '/dev/ttyACM0';
var sendData = "";
var wss = new WebSocketServer({port: 8080});

var CLIENTS=[];

wss.on('connection', function(ws) {
       CLIENTS.push(ws);
    ws.on('message', function(message) {
        console.log('received: %s', message);
        sendAll(message);
    });
    ws.on('close', function() {
        console.log('Client disconnected.');
    });
    ws.on('error', function() {
        console.log('ERROR');
    });
    ws.send("");
});

function sendAll(message)
{
for(var i=0;i<CLIENTS.length;i++)
    {
    CLIENTS[i].send(message);
    }
}

serialListener();

function serialListener(debug)
{
    var receivedData = "";
    serialPort = new SerialPort(portName, {
        baudrate: 9600,
         dataBits: 8,
         parity: 'none',
         stopBits: 1,
         flowControl: false
    });

    serialPort.on("open", function () {
      console.log('open serial communication');
            // Listens to incoming data
        serialPort.on('data', function(data) {
             receivedData += data.toString();
          if (receivedData .indexOf('E') >= 0 && receivedData .indexOf('B') >= 0) {
           sendData = receivedData .substring(receivedData .indexOf('B') + 1, receivedData .indexOf('E'));
           receivedData = '';
         }
         // send the incoming data to browser with websockets.
       sendAll(sendData);
      });
    });
}

有人能帮我弄清楚这里出了什么问题吗？

- user2196728

Answer 1

我认为，在close和error事件中，你应该从CLIENTS数组中删除套接字。否则，它会尝试向已关闭的套接字发送消息。

- rkusa

---

看起来你是对的，因为如果我在“关闭”事件上重新初始化我的数组，它就不会再崩溃了。然而，从现在开始，我正在寻找一种方法来识别已断开连接的客户端并将其从数组中删除。 - user2196728

也许可以使用 CLIENTS.splice(CLIENTS.indexOf(ws), 1)？ - rkusa

太好了，运行正常！！我会进一步研究这个（我正在学习中...）。谢谢。 - user2196728

有时候它仍然会崩溃...我会尝试在发生时隔离上下文。 - user2196728

Answer 2

我曾经遇到过同样的问题。结果发现我试图向处于“关闭”状态的套接字发送事件。在广播消息之前检查每个套接字是否特别打开，这为我解决了问题：

    function sendAll(data){
        for(var i = 0; i < clients.length; i++){
            if(this.clients[i].readyState != this.clients[0].OPEN){
                console.error('Client state is ' + this.clients[i].readyState);
            }
            else{
                this.clients[i].send(data);
            }
        }
    }

- jbll

---

官方文档使用以下方式测试 readyState：if (this.clients[i].readyState === WebSocket.OPEN)，我认为这比针对第一个数组元素的属性进行测试更可取。 - NoChecksum

Answer 3

尝试在向客户端发送数据时使用以下代码： - socket是当前的Web套接字对象。它覆盖了默认的WebSocket.js类条件，该条件会抛出“未打开错误”。

if (socket.readyState != socket.OPEN) {
    console.error('Client state is ' + socket.readyState);
    //or any message you want
} else {
    socket.send(JSON.stringify(object)); //send data to client
}

- mudit mishra