使用net模块遇到的问题 Nodejs

使用net模块遇到的问题 Nodejs

简单概括一下：当客户端连续两次调用write数据的时候，服务端有可能会把两次的数据合并到一次data事件中，据说还有可能会把一次的数据分多次data事件接受(由于每次数据都比较小没有遇到这种情况)，据说zmq可以解决这种问题，不知道大家遇到这种情况没，求详解。

4 回复

使用 net 模块遇到的问题

在使用 Node.js 的 net 模块时，你可能会遇到一个常见问题：当客户端连续发送多条数据时，服务端可能会将这些数据合并到同一个 data 事件中。同样地，服务端也可能将一条数据分多次发送到客户端。

问题描述

假设客户端连续两次调用 socket.write() 方法发送数据：

// 客户端代码
const net = require('net');

const client = new net.Socket();
client.connect(8080, '127.0.0.1', () => {
    console.log('Connected to server');
    client.write('Hello, ');
    client.write('world!');
});

client.on('data', (data) => {
    console.log(`Received: ${data.toString()}`);
});

client.on('close', () => {
    console.log('Connection closed');
});

服务器端代码如下：

// 服务器端代码
const net = require('net');

const server = net.createServer((socket) => {
    socket.on('data', (data) => {
        console.log(`Received data: ${data.toString()}`);
        // 假设我们想将接收到的数据回传给客户端
        socket.write(data);
    });

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

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

问题分析

在这个例子中，客户端发送了两段数据 Hello, 和 world!。但是，服务器端可能只会触发一次 data 事件，并且接收到的数据可能是 Hello, world! 或者其他形式的合并或分割。

解决方案

为了解决这个问题，一种常见的方法是在数据包的开头或结尾添加一些标志位，以明确标识每个数据包的开始和结束。例如，可以使用 \n 作为行尾标志：

// 客户端代码
const net = require('net');

const client = new net.Socket();
client.connect(8080, '127.0.0.1', () => {
    console.log('Connected to server');
    client.write('Hello, \n');
    client.write('world!\n');
});

client.on('data', (data) => {
    console.log(`Received: ${data.toString()}`);
});

client.on('close', () => {
    console.log('Connection closed');
});

服务器端需要解析这些标志位来正确处理每个数据包：

// 服务器端代码
const net = require('net');

const server = net.createServer((socket) => {
    let buffer = '';

    socket.on('data', (data) => {
        buffer += data.toString();
        const lines = buffer.split('\n');
        
        for (let i = 0; i < lines.length - 1; i++) {
            const line = lines[i];
            if (line.length > 0) {
                console.log(`Received data: ${line}`);
                // 将接收到的数据回传给客户端
                socket.write(line + '\n');
            }
        }
        
        buffer = lines[lines.length - 1];
    });

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

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

通过这种方式，你可以确保每次 data 事件都能正确处理一个完整的数据包，避免数据被合并或分割的问题。


这个就必须得你自己定义一个交互的格式, 比如你每次都在你要发送的数据前加上一个头标识实体有多长, 比如你可以这样 5\r\n12345\r\n 这样 当你第一次开始解析肯定遇到5 你就知道后面的实体有5字节 就不会乱了 说简单点就是一定要有一个协议来支撑

嗯 明白了 谢谢

在使用Node.js的net模块时，如果你发现服务端在处理客户端发送的多个write操作时，将数据合并到同一个data事件中，这其实是因为TCP协议本身是流式的，而不是消息式的。这意味着，接收端可能无法区分数据包的边界，尤其是在数据量较小的情况下。

示例

假设客户端发送了两段数据，每段数据长度较短：

// 客户端代码
const net = require('net');
const client = new net.Socket();
client.connect(3000, '127.0.0.1', () => {
    console.log('Connected to server!');
    client.write('Hello ');
    client.write('World!');
});

// 服务器端代码
const net = require('net');
const server = net.createServer((socket) => {
    socket.on('data', (data) => {
        console.log(`Received: ${data.toString()}`);
    });
});
server.listen(3000);

在这种情况下，服务端可能接收到的数据不是Hello World!，而是被分割成多个data事件，或者两个写入合并为一个。

解决方案

  1. 添加消息边界：可以在每个消息前后添加特殊字符或长度前缀来标识消息的开始和结束。

    // 客户端代码
const net = require('net');
const client = new net.Socket();
client.connect(3000, '127.0.0.1', () => {
    console.log('Connected to server!');
    client.write('06Hello World!');
});

// 服务器端代码
const net = require('net');
const server = net.createServer((socket) => {
    socket.on('data', (data) => {
        let received = data.toString();
        while (received.length >= 6) {
            let length = parseInt(received.substring(0, 5));
            if (received.length < length + 5) break; // 不足一个完整消息
            let message = received.substring(5, 5 + length);
            console.log(`Received: ${message}`);
            received = received.substring(5 + length); // 剩余部分继续处理
        }
    });
});
server.listen(3000);

  2. 使用ZeroMQ：如你提到的，ZeroMQ确实提供了一种更高级的消息传递机制，可以更好地处理这类问题，但需要额外引入库并学习其API。

希望这些信息对你有所帮助！

回到顶部