30

我正在使用 node.js 和 socket.io 来让我的网页访问由 TCP 套接字提供的字符数据。我对 node.js 很陌生。

用户 ----> 网页 <--(socket.io)--> node.js <--(TCP)--> TCP服务器

代码非常简短：

io.on('connection', function (webSocket) {
    tcpConnection = net.connect(5558, 'localhost', function() {});

    tcpConnection.on('error', function(error) {
        webSocket.emit('error', error);
        tcpConnection.close();
    });

    tcpConnection.on('data', function(tcpData) {
        webSocket.emit('data', { data: String.fromCharCode.apply(null, new Uint8Array(tcpData))});
    });
});

在正常情况下一切正常，但我不能保证 TCP 服务器会一直在那里。如果不是，则 TCP 堆栈将 ECONNREFUSED 返回给 node.js - 这完全是意料之中的，我需要优雅地处理它。目前，我看到：

events.js:72
    throw er; // Unhandled 'error' event
          ^
Error: connect ECONNREFUSED
    at errnoException (net.js:904:11)
    at Object.afterConnect [as oncomplete] (net.js:895:19)

...整个过程结束。

我已经做了很多寻找解决方案的工作；大多数点击似乎来自程序员询问为什么首先收到 ECONNREFUSED - 并且建议只是确保 TCP 服务器可用。没有讨论处理失败的情况。

这篇文章 - Node.js connectListener 仍然调用套接字错误- 建议为“错误”事件添加一个处理程序，就像我在上面的代码中所做的那样。这正是我希望它工作的方式......除了它没有（对我而言），我的程序不会捕获 ECONNREFUSED。

我尝试过 RTFM，http ://nodejs.org/api/net.html#net_event_error_1 上的 node.js 文档表明确实存在“错误”事件 - 但几乎没有给出如何使用它的线索。

对其他类似 SO 帖子（例如Node.js Error: connect ECONNREFUSED）的回答建议使用全局未捕获异常处理程序，但这对我来说似乎是一个糟糕的解决方案。这不是我的程序由于代码错误而引发异常，它工作正常 - 它应该按照设计的方式处理外部故障。

所以

  • 我是否以正确的方式处理这个问题？（很高兴承认这是一个新手错误）
  • 是否可以做我想做的事，如果可以，怎么做？

哦，还有：

$ node -v
v0.10.31
4

2 回答 2

32

我运行了以下代码：

var net = require('net');

var client = net.connect(5558, 'localhost', function() {
  console.log("bla");
});
client.on('error', function(ex) {
  console.log("handled error");
  console.log(ex);
});

由于我没有打开 5558，因此输出为：

$ node test.js
handled error
{ [Error: connect ECONNREFUSED]
  code: 'ECONNREFUSED',
  errno: 'ECONNREFUSED',
  syscall: 'connect' }

这证明错误得到了很好的处理......表明错误发生在其他地方。

正如另一个答案中所讨论的，问题实际上是这一行：

webSocket.emit('error', error);

'error' 事件很特殊，需要在某个地方处理（如果不是，则流程结束）。

简单地将事件重命名为“问题”或“警告”会导致整个错误对象通过 socket.io 套接字传输回网页：

webSocket.emit('warning', error);
于 2014-09-15T11:30:31.567 回答
0

我发现解决此问题的唯一方法是将网络内容包装在域中：

const domain = require('domain');
const net = require('net');

const d = domain.create();

d.on('error', (domainErr) => {
    console.log(domainErr.message);
});

d.run(() => {
    const client = net.createConnection(options, () => {

        client.on('error', (err) => {
            throw err;
        });
        client.write(...);
        client.on('data', (data) => {
            ...
        });
    });
});

域错误捕获在创建网络客户端之前出现的错误条件，例如无效的主机。

另请参阅：https ://nodejs.org/api/domain.html

于 2018-04-23T12:46:05.977 回答