时间戳

首页 > 解决方案 > Node JS Fork TCP 客户端

javascript - Node JS Fork TCP 客户端

问题描述

我对在 Node JS 中分叉 TCP 客户端有疑问。这是场景。

  1. 客户端将连接到服务器（建立？）。
  2. 客户端将第一条消息写入服务器。
  3. 客户端将第二条消息写入服务器。
  4. 'write' 方法将无限循环，延迟 5 秒。
  5. 点号 1-4 将被分叉并创建一个新的 TCP 连接（与以前不同），延迟为 8 秒。

到目前为止，这是我的做法。

// tcp_client.js

const cluster = require('cluster')

if (cluster.isMaster) {
  for (let i = 0; i < 2; i += 1) {
    setTimeout(() => {
      cluster.fork()
    }, 8000) // I expect this will delay between one and another fork
  }
} else {
  console.log(`Connected on ${process.pid}`)
  require('./sender').send()
}
cluster.on('exit', (worker) => {
  console.log('server',`Worker %d died :( ${worker.id}`);
  cluster.fork();
})

// sender.js

const net = require('net')
const send = () => {
  const client = new net.Socket()
  client.connect(8090, 'localhost', () => {
    const firstMessage = 'first_message'
    const secondMessage = 'second_message'
    const write = function () {
      client.write(firstMessage)
      /*
        The reason why I'm using setTimeout() is because if I write it as
        `client.write(firstMessage)
        client.write(secondMessage)`
        The second message won't be sent. Is there any better methods?
      */
      setTimeout(() => {
          client.write(secondMessage)
      }, 1);
    }

    setTimeout(write, 5000) // I expect this will loop infinitely
  })
}

module.exports = { send }

当我运行代码时，fork 不会延迟，消息也不会循环。有什么解决办法吗？谢谢你。

标签： javascriptnode.jsnetworkingtcpfork

解决方案

如果您希望您的两个分叉相隔 8 秒，则您需要在setTimeout(). setTimeout()没有阻塞，所以你所有的代码都在安排两个setTimeout()s - 从现在开始每个 8 秒。这将安排一个 8 秒和一个 16 秒：

// tcp_client.js

const cluster = require('cluster')

if (cluster.isMaster) {
  for (let i = 0; i < 2; i += 1) {
    setTimeout(() => {
      cluster.fork()
    }, (i + 1) * 8000);
  }
} else {
  console.log(`Connected on ${process.pid}`)
  require('./sender').send()
}
cluster.on('exit', (worker) => {
  console.log('server',`Worker %d died :( ${worker.id}`);
  cluster.fork();
})

而且，您的编写代码没有循环，因为setTimeout(write, 5000)它位于connect事件处理程序内部，而不是write()函数内部。因此，它在connect事件触发时被调用一次，并且永远不会再次被调用。如果要write()重复，请将其放在write()函数本身（或使用setInterval()）中。

// sender.js

const net = require('net')
const send = () => {
  const client = new net.Socket()
  client.connect(8090, 'localhost', () => {
    const firstMessage = 'first_message'
    const secondMessage = 'second_message'
    const write = function () {
      client.write(firstMessage)

      setTimeout(() => {
          client.write(secondMessage)
      }, 1);

      setTimeout(write, 5000) // I expect this will loop infinitely
    }
    write();

  })
}

module.exports = { send }

此外，client.write()连续进行两次这样的调用是完全可以的——两者都会被发送。但是，TCP 可能会将它们组合成同一个数据包。TCP 是流协议，而不是基于消息的协议。因此，要描述消息之间的差异，您必须在读取时解析流。您不应依赖于到达与发送数据完全相同的数据块的数据。它可以被分解成更小的块，或者多个单独写入的块可以组合成同一个到达的数据包。例如，在这种情况下，您可以在每条消息的末尾放置一个 \n，并在读取 TCP 流时将其用作消息分隔符，这样您就可以单独解析每条传入消息，即使它们被 TCP 组合到相同的数据包。

或者，您可以在 TCP 之上使用基于消息的协议，例如 webSocket，它会为您打包和解包成不同的消息，并且只会向您传递一个完整且单独的消息。

推荐阅读