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

标签 ipc child-process

当使用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 服务器如何向连接的客户端发送消息?

谢谢!

最佳答案

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

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

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

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

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

关于ipc - Node-IPC从服务器向客户端发送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39826776/

相关文章:

c - 共享内存程序行为异常

c - 如何从 C 应用程序发送 tcl 命令到 tcl/tk 解释器

javascript - Node.js虚拟内存在使用子进程时不断增加

node.js - 如何在 Windows 上以不同用户身份生成子进程?

c++ - 我可以使用非阻塞套接字使用 "sendmsg/recvmsg"将 FD 从一个进程发送到另一个进程吗?

c++ - 通知父进程恢复工作

c - 具有 3 个元素的信号量

c# - 运行 child_process.execFile 后 uglify 崩溃

c - 从 SIGCHLD 返回的信号似乎是错误的

go - 读取子进程的 stdout 和 stderr 的竞争条件