Nodejs net.Socket怎样主动断开某个客户端的连接

Nodejs net.Socket怎样主动断开某个客户端的连接

只引入这个模块的var net = require(‘net’); 程序有两个地方要服务器端主动断开客户端的连接的，使用了下面这两行代码： self.socket.end(packaging(‘login\n0’));//登录失败，主动断开他 if(client[client_index].socket.address())client[client_index].socket.end();//超时不活动，断开这个客户端的连接 测试时在一台电脑客户几个客户端，在另一台电脑登录几个客户端，然后把其中一台电脑的网线拨掉，让服务器会运行“超时不活动，断开这个客户端的连接”这个功能，有时会发现出现这样两种错误： dir error { [Error: This socket has been ended by the other party] code: ‘EPIPE’} dir error { [Error: read ECONNRESET] code: ‘ECONNRESET’, errno: ‘ECONNRESET’, syscall: ‘read’ } 我也不知该怎样确定是socket.end的错误，还是socket.write的错误，错误信息是sock.on(‘error’,function (err){ console.log(‘dir error’, err); 这行代码显示的。 请教：这个问题该怎样排查？或net.Socket主动断开某个客户端的连接应该是怎样的流程或调用什么方法才是正确的？


7 回复

可以用socket.setTimeout吧，超时时间根据你心跳的周期而定，我是用的这种，心跳2-3分钟，超时10分钟。不知道是否适合你的场景


要解决如何使用 Node.js 中的 net.Socket 主动断开某个客户端连接的问题，我们首先需要理解 Socket 的基本操作。当服务器需要断开与客户端的连接时，可以使用 socket.end() 方法来优雅地关闭连接，或者直接使用 socket.destroy() 来强制断开连接。

示例代码

const net = require('net');

// 创建一个简单的TCP服务器
const server = net.createServer((socket) => {
    console.log('Client connected.');

    // 设置一个超时计时器，用于检测不活跃的连接
    const timeout = 10000; // 超时时间为10秒
    let lastActivity = Date.now();

    socket.on('data', (data) => {
        console.log(`Received data from client: ${data}`);
        lastActivity = Date.now();
    });

    socket.on('timeout', () => {
        console.log('Socket timeout detected.');
        // 检查是否超过设定的超时时间
        if (Date.now() - lastActivity > timeout) {
            console.log('Closing connection due to inactivity.');
            socket.end(); // 主动结束连接
        }
    });

    socket.setTimeout(timeout);

    socket.on('end', () => {
        console.log('Client disconnected.');
    });

    // 在一定条件下主动断开连接
    setTimeout(() => {
        console.log('Forcing disconnection after 30 seconds.');
        socket.end('login\n0'); // 发送特定数据后结束连接
    }, 30000);
});

server.listen(8080, () => {
    console.log('Server is listening on port 8080');
});

流程说明

  1. 创建服务器：通过 net.createServer 创建一个TCP服务器。
  2. 监听连接：服务器接收到客户端连接时触发的回调函数。
  3. 设置超时：使用 socket.setTimeout(timeout) 设置超时时间，并绑定 timeout 事件处理器。
  4. 处理数据：每当接收到数据时，更新最后活动时间 (lastActivity)。
  5. 检查超时：如果在设定的时间内没有接收到任何数据，则认为连接不活跃并调用 socket.end() 主动关闭连接。
  6. 强制断开：使用 setTimeout 定时器模拟在30秒后强制断开连接。

错误处理

对于错误如 EPIPE 和 ECONNRESET，这些通常表示客户端已经关闭了连接，而此时服务器尝试向其发送数据。可以通过捕获 error 事件来处理这类异常：

socket.on('error', (err) => {
    console.error(`Socket error: ${err.message}`);
});

通过上述步骤，你可以有效地管理和断开客户端连接，同时确保错误得到妥善处理。

主动断在 客户端用socket.end(), 在服务端用getConnections()查看

比如是竞争对手或黑客知道我这服务器的IP和这个程序监听的端口的，他们写一个恶意客户端程序来连接，他们的客户端不肯配合关闭连接，他们会经常发数据，也不会发生socket.setTimeout，那我们服务器端该怎样断开他的连接？是socket.end还是什么方法？

[@50css](/user/50css) 这就需要你设计报文了，如果报文格式不正确，就果断end()这个客户端。

你可以试试前面setTimeout的时间心跳与报文格式相结合。。。。

要主动断开某个客户端的连接，可以使用 net.Socket 对象上的 end() 方法。但是，当客户端突然断开连接时（例如，通过拔掉网线），服务器可能会收到 EPIPE 或 ECONNRESET 错误。这些错误通常表示客户端已经断开了连接，但你的代码仍在尝试向该连接写入数据。

示例代码

const net = require('net');

const server = net.createServer((client) => {
    console.log('Client connected:', client.remoteAddress);

    client.on('data', (data) => {
        console.log('Received data:', data.toString());
        
        // 假设我们接收到的数据是一个包含指令的字符串
        if (data.toString().trim() === 'logout') {
            client.end(); // 主动断开连接
        }
    });

    client.on('timeout', () => {
        console.log('Client timed out');
        client.destroy(); // 强制关闭连接
    });

    client.setTimeout(60000); // 设置超时时间
});

server.on('error', (err) => {
    console.error('Server error:', err.message);
});

server.listen(1234, () => {
    console.log('Server listening on port 1234');
});

解释

  1. client.end()：这是正常情况下断开连接的方法。它发送一个EOF信号给客户端，并允许所有挂起的数据被处理后才完全关闭连接。

  2. client.destroy()：如果客户端突然断开连接，你可以使用 destroy() 方法强制关闭连接。这个方法立即关闭套接字，不等待任何未完成的操作。

排查错误

  • 当客户端突然断开连接时，服务器可能会收到 EPIPE 或 ECONNRESET 错误。这两种错误通常是由于客户端已经断开连接导致的。

  • 使用 try...catch 包裹可能出错的代码块，或者在写入数据前检查 socket.writable 属性是否为 true。

if (client.writable) {
    client.write('Some data');
} else {
    console.log('Socket is not writable, maybe the client disconnected');
}
  • 在 socket.on('error', ...) 事件中，捕获并处理这些错误，以便进行适当的清理和记录。
client.on('error', (err) => {
    console.error('Socket error:', err.message);
});

这样可以更好地处理客户端突然断开连接的情况，避免程序崩溃。

回到顶部