如何在Node.js单线程模型下构建可并发处理多客户端且无阻塞的轻量TCP服务器

哥们，我太懂这种困惑了——Node.js的非阻塞模型说起来简单，但实际玩TCP服务器的时候，很容易因为对事件循环、socket缓冲区这些细节没抠透，就碰到看似“阻塞”的诡异问题。先帮你拆解清楚问题出在哪，再给你一套稳的优化方案。

首先得给你吃个定心丸：你用setTimeout模拟异步处理的思路完全是对的，它不会阻塞事件循环——Node.js的事件循环会把每个setTimeout的回调放到定时器队列，到点了就执行，各个客户端的回调是完全独立的。那你看到的“客户端互相等”大概率是两个原因：

1. 测试时的错觉：比如你用telnet测试时，可能是在同一个窗口开多个会话（或者用了行缓冲没即时发送），导致你误以为第二个客户端的回复要等第一个的超时结束。其实你换两个独立的终端分别开telnet，第一个发消息后，第二个隔1秒发，第一个会在2秒后收到回复，第二个会在自己发送后的2秒（也就是第一个回复后的1秒）收到，这才是正确的并发表现。
2. 未处理socket发送缓冲区溢出：这才是核心隐患！你调用socket.write()的时候，它会返回一个布尔值——如果是false，说明操作系统的发送缓冲区已经满了，Node.js会把待发送的数据暂存到内存队列里。如果客户端多了、发送频率高了，内存里的积压数据会越来越多，最后导致全局的发送延迟，看起来就像“阻塞”了其他客户端。

优化后的代码及解释 #

我给你调整了代码，补上了关键的改进点，解决你碰到的延迟问题：

const net = require('net');

const server = net.createServer((socket) => {
    console.log('New client connected');
    socket.setEncoding('utf8');

    // 给每个客户端单独维护请求队列，保证同一客户端的回复不会乱序
    let requestQueue = [];
    let isProcessing = false;

    // 封装独立的请求处理逻辑
    const handleRequest = (data) => {
        console.log(`Received data from client: ${data.trim()}`);
        // 模拟异步处理（比如查库、调API这种真实场景的耗时操作）
        setTimeout(() => {
            // 尝试发送数据，注意判断返回值
            const canContinueWriting = socket.write(`Echo: ${data}`);
            if (!canContinueWriting) {
                // 缓冲区满了，先暂停读取客户端的新数据，避免积压
                socket.pause();
            }

            // 处理队列里的下一个请求
            requestQueue.shift();
            if (requestQueue.length > 0) {
                handleRequest(requestQueue[0]);
            } else {
                isProcessing = false;
            }
        }, 2000);
    };

    socket.on('data', (data) => {
        requestQueue.push(data);
        // 如果当前没有在处理请求，就启动队列的第一个
        if (!isProcessing) {
            isProcessing = true;
            handleRequest(requestQueue[0]);
        }
    });

    // 关键：监听drain事件，缓冲区空了就恢复读取数据
    socket.on('drain', () => {
        socket.resume();
    });

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

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

// 修正了你代码里的语法错误（listen参数少了个逗号）
server.listen(3000, "192.168.1.13", () => {
    console.log('TCP Server listening on port 3000');
});

核心改进说明 #

1. 每个客户端独立的请求队列
   如果同一个客户端连续发多条消息，这个队列能保证回复的顺序（比如客户端先发A再发B，服务器不会先回复B再回复A），但不同客户端的队列是完全独立的，不会互相干扰。

2. 处理drain事件避免数据积压
   当socket.write()返回false时，说明操作系统的发送缓冲区已满，此时暂停读取客户端的新数据，等drain事件触发（缓冲区空了）再恢复读取。这能彻底避免内存数据积压，保证每个客户端的发送都不会拖慢全局。

最后几个小提醒 #

• 绝对不要在事件循环里写同步的耗时逻辑：比如用while循环模拟延迟，那会真的阻塞整个事件循环，所有客户端都得等。所有耗时操作一定要用异步API（比如setTimeout、Promise、async/await这些）。
• 一定要监听socket的error事件：你已经做了，但再强调一遍——如果不处理error事件，一旦某个socket出问题，整个服务器会直接崩溃。
• 测试要到位：用多个独立的终端（或者用nc命令）测试，别在同一个窗口搞多个会话，避免行缓冲的干扰。

内容来源于stack exchange