ipc - Node-IPC从服务器向客户端发送消息

Question

当使用node-ipc通过IPC在NodeJS进程之间进行通信时，启动服务器并监听连接，或者创建客户端并连接到服务器似乎非常简单。

但是有些事情看起来并不那么简单:

How can the server push a message to a client?

手册上说，

在客户端，监听服务器的消息:

ipc.connectTo('world', function(){
        ipc.of.world.on('hello', function(data){
                console.log(data);
            }
        )
    }
);

非常简单...但是:

在服务器上，发送消息

// Start server
ipc.serve(function(){

    // Listen for connecting clients
    ipc.server.on('connect', socket => {
        // From here I can do ipc.server.emit(socket, 'message', {});
        // But I still do not know the ID of the client that just connected
        // There could be 10 child processes connecting, I do not know which client this is
    });
});

因此，假设我按照上面给定的示例设置服务器，并且客户端已连接。稍后在不同的时间范围内，在服务器端，您会期望这是向客户端发送消息的方式:

ipc.server.of[TheClientIdThatJustConnected].emit('myMessage')

但这不起作用，因为 ipc.server.of 始终是一个空对象，而且我仍然不知道套接字客户端 ID..

所以我能想到的唯一方法是作为服务器和客户端启动每个进程...或者在客户端连接后，我发送带有硬编码 ID 的“_identification”事件并将该套接字存储在单独的对象，但这没有任何意义，因为套接字已经在 ipc.serve() 的 on('connect') 函数中给出...

那么，node-ipc 服务器如何向连接的客户端发送消息？

谢谢!

Answer 1

在查看了文档并深入研究了源代码之后，我想我可以得出结论，没有一种方法可以完全实现您正在寻找的内容。尽管您可以看到服务器在内部维护信息，但套接字的 ID 根本没有公开 here并在 socket.disconnected 事件上公开它。

据我所知，有两种解决方案，都需要您进行跑腿工作:

1. 使用 ipc.server.broadcast 向所有客户端发送消息。除了要传输的有效负载之外，您还需要包含某种标识符。然后，客户端将使用为其识别的消息执行某些操作，否则忽略有效负载。

2. 将负担放在客户端上，通过 ipc.of.world.emit() 向服务器请求消息。这可能是一种“有效同步”操作，其中服务器立即响应，但此模型也可以在异步情况下工作，客户端识别其请求，服务器在获得客户端请求的结果时做出响应。

当然，“稍微更激烈”的解决方案始终是 fork node-ipc 并使其适合您的用例:)