我正在尝试在 node.js 中编写一个小型中继脚本，用于监听本地套接字上传入的 TCP 连接，并在获得连接时将流量转发给第 3 方。它还必须从第 3 方获取任何返回的数据并将其发送回原始本地套接字。我试过像 http://delog.wordpress.com/2011/07/19/a-tcp-relay-mechanism-with-node-js/ 这样的代码它确实有效，但它要求发送者是一个正在监听套接字本身的服务器，我的实用程序旨在与任何试图创建出站 TCP 连接的程序一起使用。不幸的是，我遇到的问题是第一次一切都很好，客户端将数据发送到“路由器”程序，路由器将其转发到另一台服务器，然后从客户端返回数据。但是，当客户端程序结束或终止并尝试重新连接时，我得到:

events.js:72
    throw er; // Unhandled 'error' event
          ^
Error: This socket has been ended by the other party
at Socket.writeAfterFIN [as write] (net.js:275:12)
at Socket.<anonymous> (/root/tcp_loop.js:37:17)
at Socket.emit (events.js:117:20)
at Socket.<anonymous> (_stream_readable.js:748:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:410:10)
at emitReadable (_stream_readable.js:406:5)
at readableAddChunk (_stream_readable.js:168:9)
at Socket.Readable.push (_stream_readable.js:130:10)
at TCP.onread (net.js:528:21)

我去掉了所有的逻辑并将测试用例提炼成一小段代码:一个服务器既充当路由器(监听端口 8124)又充当“远程”服务器(端口 9999)，尽管我的测试表明远程服务器在同一台机器上、在 Internet 上等都没有区别。这是服务器代码:

var net = require('net'),
    util = require('util')
;

// The loop_server simulates a remote service.
// The error occurs whether using it here, or actually forwarding
// the data to a remote host.
var loop_server = net.createServer(function(loop) {
    console.log("Loop server connected");
    loop.on("end", function() {
        console.log("Loop server disconnected");
    });
    loop.on("data", function(data) {
        console.log("Loop got data: " + data);
        loop.write(data);
    });
}).listen(9999, function() {
    console.log("Loop server bound");
});

var remote_socket = net.connect(9999, function() {
    console.log("Remote connected");

    var local_server = net.createServer(function(local_socket) { //'connection' listener
        console.log('Local server connected');
        local_socket.on('end', function() {
            console.log('Local server disconnected');
            // local_socket.destroy();
        });

        local_socket.on('data', function(ldata) {
            console.log("Local socket got data: " + ldata);
            remote_socket.write(ldata);
        });

        remote_socket.on('data', function(rdata) {
            console.log("Remote socket got data: " + rdata);
            local_socket.write(rdata);
        });

        local_socket.write('hello\r\n');
    }).listen(8124, function() { //'listening' listener
        console.log('Local server bound');
    });
}); // remote_socket

失败的是 remote_socket.on('data', ... 处理程序中的 local_socket.write(rdata);。它第一次工作路由器启动，客户端连接，但再也没有连接。

作为引用，这里是我一直在使用的小客户端应用程序的代码。我用 perl 脚本、telnet 等得到了相同的结果:

var net = require('net');

var client = new net.Socket();
client.connect(8124, function() {
    console.log('CONNECTED TO: localhost:8124');
    client.write('Single text message from the client app');
});

client.on('data', function(data) {
    console.log('DATA: ' + data);
});

client.on('close', function() {
    sconsole.log('Connection closed');
});

任何见解将不胜感激。我觉得我一定在这里遗漏了一些非常简单的东西......

更新:

下面 Nitzin 的解决方案是一个更好的方法，但在我下面的特定示例中，解决方案是在创建新监听器之前删除旧的 remote_socket.on('data') 监听器，例如:

var remote_socket = net.connect(9999, function() {
    console.log("Remote connected");

    var local_server = net.createServer(function(local_socket) { //'connection' listener
        console.log('Local server connected');

        remote_socket.removeAllListeners('data');

        ...

        remote_socket.on('data', function(rdata) {
            console.log("Remote socket got data: " + rdata);
            local_socket.write(rdata);
        });

最佳答案

您不应该销毁 套接字。它关闭 socket 的两端。你应该只 .end() 它，它关闭你的写作结束。

编辑

破坏套接字是不好的，正如我最初写的那样，但你真正的问题是完全不同的东西:你有你的代理(你称之为“本地”)和回显(你称之为“远程”)服务器倒退: < em="">proxy 服务器应该为代理服务器获得的每个新连接建立到 echo 服务器的新连接，而不是像现在这样相反。

唯一需要的 end() 是在客户端中，让服务器知道您已完成编写。

这是client.js:

var net = require('net');

var client = new net.Socket();

client.connect(8124, function() {
    console.log('CLIENT: CONNECTED: localhost:8124');
    client.write('single text message from the client app');
    client.end();
});

client.on('data', function(data) {
    console.log('CLIENT: GOT DATA: ' + data);
});

client.on('close', function() {
    console.log('CLIENT: CONNECTION CLOSED');
});

这里是servers.js:

var net = require('net'),
    util = require('util');

net.createServer(function(conn) {
    console.log('ECHO_SERVER: CONN: new connection');
    conn.on('end', function() {
        console.log('ECHO_SERVER: CONN: disconnected');
    });
    conn.on('data', function(data) {
        console.log('ECHO_SERVER: CONN: GOT DATA: ' + data);
        conn.write(data);
    });
}).listen(9999, function() {
    console.log('ECHO_SERVER STARTED');
});

net.createServer(function(conn) {

    console.log('PROXY_SERVER: CONN: new connection');

    var remote = net.connect(9999, function() {
        console.log('PROXY_SERVER: CONNECTED TO ECHO_SERVER');
        conn.on('end', function() {
            console.log('PROXY_SERVER: CONN: disconnected');
            remote.end();
        });
        conn.on('data', function(data) {
            console.log('PROXY_SERVER: CONN: GOT DATA FOR  ECHO_SERVER: ' + data);
            remote.write(data);
        });
        remote.on('data', function(data) {
            console.log('PROXY_SERVER: CONN: GOT DATA FROM ECHO_SERVER: ' + data);
            conn.write(data);
        });
    });

}).listen(8124, function() {
    console.log('PROXY_SERVER STARTED');
});

如您所见，对于到代理服务器的每个 conn，都有一个新的 remote 到 echo 服务器。

关于node.js - Node : TCP socket server only returns data the first time，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24876248/