Nodejs 一个tcp例子，解包

Node.js TCP 示例：解包

本文将介绍如何使用 Node.js 实现一个简单的 TCP 客户端和服务端通信，并且在服务端实现数据包的解析。

客户端代码

客户端的任务是连接到服务器并发送一个字符串。我们使用 net 模块创建一个 TCP 连接，并通过这个连接发送数据。

var net = require('net');

var socket = net.connect(5002, 'localhost', function() {
    var str = 'abc';
    var len = Buffer.byteLength(str);
    var buf = new Buffer(len + 2);
    buf.writeUInt16BE(len, 0);  // 写入长度前缀
    buf.write(str, 2);         // 写入实际数据
    for (var i = 0; i < 100; i++) {
        socket.write(buf);     // 发送数据包
    }
});

在这个例子中，我们首先计算字符串的长度（Buffer.byteLength(str)），然后创建一个包含长度前缀和实际数据的缓冲区。长度前缀是一个 2 字节的无符号整数，表示后面跟随的实际数据的长度。然后我们把这个缓冲区发送给服务器 100 次。

服务端代码

服务端的任务是接收客户端发送的数据，并正确地解析这些数据包。为了实现这一点，我们需要处理粘包问题（即多个数据包可能被合并成一个数据包发送）。

var net = require('net');

function getDataParser(emitter) {
    var waiting = 0;
    var buf;
    var bufOffset;

    function parseData(data, offset) {
        var len = data.length;
        var left = len - offset;

        if (waiting) {
            var toRead = Math.min(left, waiting);
            if (waiting <= left) {
                data.copy(buf, bufOffset, offset, offset + waiting);
                offset += waiting;
                waiting = 0;
                emitter.emit('message', buf);
                if (offset < len) {
                    parseData(data, offset);
                }
            } else {
                data.copy(buf, bufOffset, offset, len);
                waiting -= (len - offset);
            }
        } else {
            waiting = data.readUInt16BE(offset);
            buf = new Buffer(waiting);
            parseData(data, offset + 2);
        }
    }

    return parseData;
}

function handler(socket) {
    var parseData = getDataParser(socket);

    socket.on('data', function(data) {
        parseData(data, 0);
    });

    socket.on('message', function(buf) {
        console.log('Received message:', buf.toString());
    });
}

net.createServer(handler).listen(5002);

在服务端代码中，我们定义了一个 getDataParser 函数，该函数用于解析从客户端收到的数据。解析逻辑包括检查当前缓冲区是否已经包含了完整的消息，如果还没有，则继续读取更多的数据，直到完整的消息被读取为止。一旦完整的消息被读取，它就会被传递给 'message' 事件处理器。

最后，我们在 net.createServer 中注册了这个处理函数，并启动了服务器监听 5002 端口。

这样我们就完成了一个简单的 TCP 客户端和服务端通信的例子，其中服务端能够正确地解析客户端发送的数据包。