Nodejs中socket.write方法能否确保数据正确发送到系统缓冲区？

Nodejs中socket.write方法能否确保数据正确发送到系统缓冲区？

一些开发语言调用类似socket.write的方法时，会返回一个整形值，表示已经正确发送到系统缓冲区的字节数。 如：int sent=socket.write(array),这里array是一个长度1000的字节数组.此时sent的返回值可能是1000,100,20都有可能。所以，需要通过一些方法循环调用write方法，直至每次返回的sent的和等于array的长度。

但是，在node中我看到很多的代码都是直接一句socket.write。根据node文档的描述:如果所有数据被成功刷新到内核缓冲区，则返回true.如果返回false,则表示不是所有数据都已经成功发送到系统缓冲区，此时该怎么做？

再调用一次，肯定不合理，因为可能已经有部分数据已经存在于缓冲区中。大家怎么看这个问题？


2 回复

Node.js 中 socket.write 方法能否确保数据正确发送到系统缓冲区？

在 Node.js 中，socket.write 方法用于向网络连接写入数据。它的工作方式与一些其他编程语言中的类似方法有所不同。具体来说，socket.write 方法不会保证数据立即发送到系统缓冲区，而是将数据放入 Node.js 的内部缓冲区。

返回值解释

  • 返回 true：这表示数据已经被放入 Node.js 的内部缓冲区，但不一定已经发送到操作系统缓冲区或网络中。
  • 返回 false：这表示当前无法将数据放入内部缓冲区，因为内部缓冲区已满。此时，你需要监听 'drain' 事件来得知何时可以再次尝试写入数据。

示例代码

以下是一个简单的示例，演示如何使用 socket.write 并处理返回值：

const net = require('net');

const client = new net.Socket();

client.connect(8080, 'localhost', () => {
  console.log('Connected to server');
});

client.on('connect', () => {
  const data = Buffer.from('Hello, World!');
  
  // 尝试写入数据
  if (client.write(data)) {
    console.log('Data written to buffer successfully');
  } else {
    console.log('Buffer is full, waiting for drain event');
    
    // 监听 drain 事件
    client.on('drain', () => {
      console.log('Buffer drained, trying to write again');
      
      // 重新尝试写入数据
      if (client.write(data)) {
        console.log('Data written to buffer successfully after drain');
      }
    });
  }
});

解释

  1. 连接到服务器：首先，客户端连接到指定的服务器。
  2. 写入数据：尝试将数据写入套接字。如果 socket.write 返回 true，表示数据已成功放入内部缓冲区。如果返回 false，则表示内部缓冲区已满，需要等待 'drain' 事件触发后才能继续写入数据。
  3. 处理 'drain' 事件：当 'drain' 事件触发时，表示内部缓冲区已清空，可以再次尝试写入数据。

这种方式可以确保数据最终被正确发送到系统缓冲区，并且可以处理内部缓冲区满的情况。


在Node.js中，socket.write() 方法用于将数据写入套接字，并返回一个布尔值来指示数据是否已成功写入内核缓冲区。具体来说：

  • 如果 socket.write() 返回 true，表示所有数据都已经被成功刷新到内核缓冲区。
  • 如果返回 false，表示数据没有完全写入内核缓冲区，这意味着数据被暂时放入了套接字的输出缓冲区。

在这种情况下，需要监听 'drain' 事件来知道何时可以再次安全地调用 socket.write() 方法，以继续发送剩余的数据。

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

const net = require('net');

const client = new net.Socket();

client.connect(3000, 'localhost', () => {
    console.log('Connected to server');
});

const message = Buffer.from('Hello, Server!');

function writeMessage() {
    if (!client.writable) {
        console.error('Socket is not writable.');
        return;
    }
    
    const bytesWritten = client.write(message);
    
    if (bytesWritten < message.length) {
        // Not all data was written, wait for the 'drain' event
        client.on('drain', () => {
            writeMessage(); // Continue writing the remaining data
        });
    }
}

writeMessage();

这段代码中，我们首先尝试写入数据，如果数据不能完全写入（即返回的字节数小于预期），则监听 'drain' 事件。一旦事件触发，表示可以安全地继续发送剩余的数据。这种方式避免了不必要的重试，并且能够有效管理套接字的输出缓冲区。

回到顶部