使用 websockets 进行节点集群
Node clustering with websockets
我有一个节点 集群，主节点在其中响应 http 请求。
服务器还监听 websocket 连接（通过 socket.io）。客户端通过所述 websocket 连接到服务器。现在客户端在各种游戏之间进行选择（每个节点进程处理一个游戏）。
我的问题如下：
- 我应该为每个节点进程打开一个新连接吗？如何告诉客户端他应该连接到确切的节点进程 X？ （因为服务器可能会处理传入的连接请求）
- 是否可以将套接字传递给节点进程，从而无需打开新连接？
- 如果我只使用一个连接（在主进程中）并将用户消息传递给各个节点进程并将进程消息返回给用户，有什么缺点？ （我觉得在进程间发送消息时，复制比较大的对象，开销很大CPU）
Is it possible to pass a socket to a node process, so that there is no
need for opening a new connection?
您可以将普通 TCP 套接字发送到另一个节点进程，如 node.js doc here 中所述。基本思路是这样的：
const child = require('child_process').fork('child.js');
child.send('socket', socket);
然后，在 child.js 中，您将得到：
process.on('message', (m, socket) => {
if (m === 'socket') {
// you have a socket here
}
});
'socket' 消息标识符可以是您选择的任何消息名称 - 它并不特殊。 node.js 有代码，当您使用 child.send() 并且您发送的数据被识别为套接字时，它使用特定于平台的进程间通信与其他进程共享该套接字。
但是，我相信这只适用于除了 TCP 状态之外还没有建立任何本地状态的普通套接字。我自己没有尝试使用已建立的 webSocket 连接，但我认为它不起作用，因为一旦 webSocket 具有与其关联的更高级别的状态，而不仅仅是 TCP 套接字（例如加密密钥），就会出现问题，因为 OS 不会自动将该状态转移到新进程。
Should I open a new connection for each node process? How to tell the
client that he should connect to the exact node process X? (Because
the server might handle incoming connection-requests on its on)
这可能是获得 socket.io 连接到新进程的最简单方法。如果您确保您的新进程正在侦听一个唯一的端口号并且它支持 CORS，那么您可以只使用主进程和客户端之间已有的 socket.io 连接并向客户端发送消息在它上面告诉客户端重新连接到哪里（什么端口号）。然后客户端可以包含代码来侦听该消息并建立到新目的地的连接。
What are the drawbacks if I just use one connection (in the master
process) and pass the user messages to the respective node processes
and the process messages back to the user? (I feel that it costs a lot
of CPU to copy rather big objects when sending messages between the
processes)
缺点如您所料。您的主进程只需要花费 CPU 能量作为双向转发数据包的中间人。这项额外工作对您是否重要完全取决于上下文，并且必须通过测量来确定。
这是我发现的更多信息。看起来，如果到达主节点的传入 socket.io 连接在连接建立其初始 socket.io 状态之前立即传送到集群子节点，那么这个概念可能适用于 socket.io 连接也是。
这里是 an article on sending a connection to another server 和实现代码。这似乎是在连接时立即完成的，因此它应该适用于发往特定集群的传入 socket.io 连接。这里的想法是对特定集群进程进行粘性分配，并且所有到达主进程的任何类型的传入连接在它们建立任何状态之前立即转移到集群子进程。
我有一个节点 集群，主节点在其中响应 http 请求。 服务器还监听 websocket 连接（通过 socket.io）。客户端通过所述 websocket 连接到服务器。现在客户端在各种游戏之间进行选择（每个节点进程处理一个游戏）。
我的问题如下：
- 我应该为每个节点进程打开一个新连接吗？如何告诉客户端他应该连接到确切的节点进程 X？ （因为服务器可能会处理传入的连接请求）
- 是否可以将套接字传递给节点进程，从而无需打开新连接？
- 如果我只使用一个连接（在主进程中）并将用户消息传递给各个节点进程并将进程消息返回给用户，有什么缺点？ （我觉得在进程间发送消息时，复制比较大的对象，开销很大CPU）
Is it possible to pass a socket to a node process, so that there is no need for opening a new connection?
您可以将普通 TCP 套接字发送到另一个节点进程，如 node.js doc here 中所述。基本思路是这样的：
const child = require('child_process').fork('child.js');
child.send('socket', socket);
然后，在 child.js 中，您将得到：
process.on('message', (m, socket) => {
if (m === 'socket') {
// you have a socket here
}
});
'socket' 消息标识符可以是您选择的任何消息名称 - 它并不特殊。 node.js 有代码，当您使用 child.send() 并且您发送的数据被识别为套接字时，它使用特定于平台的进程间通信与其他进程共享该套接字。
但是，我相信这只适用于除了 TCP 状态之外还没有建立任何本地状态的普通套接字。我自己没有尝试使用已建立的 webSocket 连接，但我认为它不起作用，因为一旦 webSocket 具有与其关联的更高级别的状态，而不仅仅是 TCP 套接字（例如加密密钥），就会出现问题，因为 OS 不会自动将该状态转移到新进程。
Should I open a new connection for each node process? How to tell the client that he should connect to the exact node process X? (Because the server might handle incoming connection-requests on its on)
这可能是获得 socket.io 连接到新进程的最简单方法。如果您确保您的新进程正在侦听一个唯一的端口号并且它支持 CORS，那么您可以只使用主进程和客户端之间已有的 socket.io 连接并向客户端发送消息在它上面告诉客户端重新连接到哪里（什么端口号）。然后客户端可以包含代码来侦听该消息并建立到新目的地的连接。
What are the drawbacks if I just use one connection (in the master process) and pass the user messages to the respective node processes and the process messages back to the user? (I feel that it costs a lot of CPU to copy rather big objects when sending messages between the processes)
缺点如您所料。您的主进程只需要花费 CPU 能量作为双向转发数据包的中间人。这项额外工作对您是否重要完全取决于上下文，并且必须通过测量来确定。
这是我发现的更多信息。看起来，如果到达主节点的传入 socket.io 连接在连接建立其初始 socket.io 状态之前立即传送到集群子节点，那么这个概念可能适用于 socket.io 连接也是。
这里是 an article on sending a connection to another server 和实现代码。这似乎是在连接时立即完成的，因此它应该适用于发往特定集群的传入 socket.io 连接。这里的想法是对特定集群进程进行粘性分配，并且所有到达主进程的任何类型的传入连接在它们建立任何状态之前立即转移到集群子进程。