node.js 网络服务器中的写入结束错误

Question

由于 "write after end" 错误，我正在努力完成我的 node.js 爱好项目。我创建了一个 node.js 网络服务器，它使用以下代码将从 HTML 页面接收到的命令向前发送到另一个进程：

var netSocket = require('net').Socket();
netSocket.connect(9090);
netSocket.write(messages);
netSocket.end();

这一直有效，直到流量开始增加（即发送的消息量和/或消息的大小）。此时我收到以下错误：

Error: write after end
    at writeAfterEnd (_stream_writable.js:132:12)
    at Socket.Writable.write (_stream_writable.js:180:5)
    at Socket.write (net.js:615:40)
    at Socket.<anonymous> (/Users/mark/Documents/GitHub Repos/voice_controlled_zumo/speech_module/web_server_HTTPS.js:66:15)
    at Socket.emit (events.js:95:17)
    at Socket.onevent (/Users/mark/Documents/GitHub Repos/voice_controlled_zumo/node_modules/socket.io/lib/socket.js:327:8)
    at Socket.onpacket (/Users/mark/Documents/GitHub Repos/voice_controlled_zumo/node_modules/socket.io/lib/socket.js:287:12)
    at Client.ondecoded (/Users/mark/Documents/GitHub Repos/voice_controlled_zumo/node_modules/socket.io/lib/client.js:193:14)
    at Decoder.Emitter.emit (/Users/mark/Documents/GitHub Repos/voice_controlled_zumo/node_modules/socket.io/node_modules/socket.io-parser/node_modules/component-emitter/index.js:134:20)

我的猜测是 9090 的服务器被大量的流量所淹没，从而导致错误。作为 node.js 世界的新手，我非常感谢任何有关如何解决此问题的提示。

另请注意，网络服务器正在通过 SSL 提供页面（以防万一）。

感谢您花时间阅读本文！

马克

Answer 1

NodeJS 是一个非阻塞异步平台。

在你的情况下，

netSocket.write(messages);

是一个异步方法；因此，netSocket.end() 在 write 完成之前被调用。

正确的用法是：

netSocket.write(messages, function(err) { netSocket.end(); });

这里的第二个参数是一个回调函数，一旦 'write' 方法完成它的工作就会被调用。

我会向您推荐 read/watch 更多关于 NodeJS、异步样式和回调的信息。

这是一个很好的起点：https://www.youtube.com/watch?v=GJmFG4ffJZU

当然，关于网络套接字的 NodeJS API docs。

Answer 2

首先，我认为关于 socket.write() 和 socket.end() 的另一个答案中存在错误信息。在同一个滴答中背靠背做它们是完全正常和可以的：

socket.write(everythingIPlanToSend);
socket.end();

您不需要向 write 提供回调。回调会告诉您数据何时完全从连接中清除，但这是一个可选的通知，典型的程序不需要自己关心。

但是，查看您的堆栈跟踪，我认为您的事件处理控制流以这种方式中断。您连接了一个 socket.io 客户端，它会发出您监听的事件。当这些事件触发时，您将它们发送到您的上游服务器。然后结束上游套接字连接。那时，您必须取消绑定 (removeListener) 您的 socket.io 连接侦听器，以便随着更多事件的到来，您不会尝试将它们发送到您已经关闭的连接上。

另一种说法是，每当您在上游套接字上调用 .end() 时，您必须确保来自浏览器的未来传入事件不会使用同一个套接字。或者您必须更改代码以对来自相应浏览器套接字的所有事件使用相同的上游套接字（可能更多 efficient/correct），但在这种情况下不要调用 .end() 直到浏览器套接字实际上断开连接。

Answer 3

我在节点模块压缩方面遇到了类似的问题，在我将其更新到最新版本 1.6 后，问题已解决

npm install compression@1.6.0

node.js 网络服务器中的写入结束错误

Write After End error in node.js webserver

javascript

node.js

sockets