菜鸟求助各位牛人（关于Nodejs net模块data事件的）

菜鸟求助各位牛人（关于Nodejs net模块data事件的）

自己在折腾nodejs，想与java socket通讯，但是在接收数据的时候并不是一次性接收完，而是多次触发了data事件。如果返回的数据比较少的话就只触发一次，接收多的话一次两次三次也有可能，而且在接收完后end事件也没有触发，判断不了数据什么时候接收完啊。请教各位高手，这种情况怎么处理，node的socket通讯和java的有差别吗？

4 回复

当然可以！在Node.js中使用net模块进行网络通信时，确实会遇到你提到的data事件被多次触发的情况。这是因为TCP协议是流式协议，并不能保证一次接收的数据就是完整的数据包。为了处理这种情况，你可以通过缓冲区来累积接收到的数据，直到确定数据接收完毕。

以下是一个简单的示例代码，展示了如何处理这种情况：

const net = require('net');

// 创建一个服务器
const server = net.createServer((socket) => {
    console.log('客户端已连接');

    // 初始化一个空的缓冲区来存储接收到的数据
    let buffer = '';

    // 监听data事件
    socket.on('data', (data) => {
        console.log(`接收到数据: ${data.length} 字节`);
        buffer += data.toString(); // 将接收到的数据转换为字符串并添加到缓冲区

        // 这里可以根据你的业务逻辑来判断数据是否接收完整
        if (buffer.includes('\n')) { // 假设每条完整消息以换行符结尾
            console.log(`完整消息: ${buffer}`);
            buffer = ''; // 清空缓冲区，准备接收下一条消息
        }
    });

    // 监听end事件
    socket.on('end', () => {
        console.log('客户端断开连接');
    });
});

server.listen(8080, () => {
    console.log('服务器启动，监听端口 8080');
});

解释

  1. 初始化缓冲区：我们创建了一个名为buffer的字符串变量来存储接收到的数据。
  2. 监听data事件：当接收到数据时，将接收到的数据追加到buffer中，并将其转换为字符串格式。
  3. 判断数据完整性：在这个例子中，假设每条完整的消息以换行符\n结尾。你可以根据实际需求修改这个条件。
  4. 清空缓冲区：当检测到完整的消息后，将buffer清空，以便于接收新的数据。
  5. 监听end事件：当客户端断开连接时，触发end事件。

这种方法适用于大多数情况，但请注意，实际应用中可能需要更复杂的逻辑来处理不同格式的数据。希望这能帮助你解决问题！


自己在数据里面加结束符吧

但是我这java服务端是长连接，不能随便关了socket的

在Node.js中使用net模块进行socket通信时，确实会遇到多次触发data事件的情况，这是由于网络传输的特点决定的。数据可能会被分段发送，因此需要将接收到的数据片段拼接起来以完整地获取信息。另外，end事件通常在所有数据都接收完毕之后才会触发。

示例代码

const net = require('net');

// 创建服务器
const server = net.createServer((socket) => {
    console.log('客户端已连接');
    
    let receivedData = '';

    socket.on('data', (chunk) => {
        console.log(`接收到数据片段: ${chunk.length} 字节`);
        receivedData += chunk.toString(); // 将数据片段拼接到一起
    });

    socket.on('end', () => {
        console.log('所有数据已接收完毕');
        console.log('完整的数据:', receivedData);
        // 在这里处理接收到的数据
    });

    socket.on('error', (err) => {
        console.error(`发生错误: ${err.message}`);
    });
});

server.listen(3000, () => {
    console.log('服务器监听端口3000');
});

解释

  1. 创建服务器：使用net.createServer()创建一个TCP服务器。
  2. 处理连接：当有客户端连接时，data事件会被触发。
  3. 拼接数据：在data事件处理器中，通过将每次接收到的数据片段追加到receivedData字符串中来逐步构建完整的数据。
  4. 完成事件：当所有数据接收完毕时，end事件会被触发，在这个事件处理器中可以处理完整的数据。
  5. 错误处理：添加error事件处理器以处理可能发生的错误。

Node.js vs Java Socket通信

  • Node.js：更倾向于非阻塞I/O模型，利用事件循环处理并发，适用于高并发场景。
  • Java：通常使用阻塞I/O模型，适合处理大量计算密集型任务。

两种语言的socket编程方式有相似之处，但具体实现细节上存在差异。例如，Node.js中的异步事件驱动模型使得处理多个客户端连接更为高效，而Java则可能需要更多的线程管理。

回到顶部