三、Mediasoup进程通信实现的原理

Mediasoup 创建父子进程，js与c++进程交互的通道

worker.js构造函数中创建父子进程，c++通过libuv的socket可以实现 JavaScript 与 C++ 之间的相互收发消息

一、 父子进程通信

这是一个简单的示例，演示了如何使用 libuv 在父子进程之间进行通信。以下是一个基于 Node.js 和 C++ 的示例：

在 C++ 程序（child.cpp）中，使用 libuv 创建一个管道，然后向父进程发送消息：

#include <uv.h>int main() {uv_pipe_t pipe;uv_loop_t* loop = uv_default_loop();uv_pipe_init(loop, &pipe, 0);uv_write_t write_req;const char* message = "Hello from child";uv_buf_t buf = uv_buf_init(const_cast<char*>(message), strlen(message));uv_write(&write_req, reinterpret_cast<uv_stream_t*>(&pipe), &buf, 1, nullptr);uv_run(loop, UV_RUN_DEFAULT);return 0;
}
```在 Node.js 程序（parent.js）中，使用 libuv 监听管道上的数据事件，并从子进程接收消息：```javascript
const { spawn } = require('child_process');
const uv = require('uv');const pipe = new uv.Pipe();
pipe.open(0);pipe.onData((data) => {console.log('Received:', data.toString());
});const childProcess = spawn('./child'); // 启动子进程const pipeFd = childProcess.stdio[0].fd;
pipe.open(pipeFd); // 将子进程的管道连接到 Node.js 的管道childProcess.on('exit', () => {pipe.close();
});

在上述示例中，C++ 程序通过 `uv_pipe_init` 创建了一个管道，并使用 `uv_write` 向管道写入消息。Node.js 程序使用 `uv.Pipe` 创建了一个管道对象，并通过 `pipe.open` 将子进程的管道连接到 Node.js 的管道上。然后，通过监听管道的 `onData` 事件，Node.js 可以接收到来自子进程的消息。

在实际运行时，首先需要编译和生成 C++ 程序的可执行文件（例如 `child`），然后运行 Node.js 程序（parent.js）。父进程将启动子进程，并与子进程建立管道通信，实现了父子进程之间的通信。

二、子进程中添加了读取父进程

以下是更新后的 C++ 示例代码，在子进程中添加了读取父进程发送的消息的逻辑：

#include <uv.h>
#include <iostream>void on_read(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {if (nread > 0) {std::cout << "Received: " << buf->base << std::endl;} else if (nread < 0) {if (nread != UV_EOF) {std::cerr << "Read error: " << uv_strerror(nread) << std::endl;}uv_close(reinterpret_cast<uv_handle_t*>(stream), nullptr);}delete[] buf->base;
}void alloc_buffer(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf) {buf->base = new char[suggested_size];buf->len = suggested_size;
}int main() {uv_loop_t* loop = uv_default_loop();uv_pipe_t pipe;uv_pipe_init(loop, &pipe, 0);uv_pipe_open(&pipe, 0);uv_read_start(reinterpret_cast<uv_stream_t*>(&pipe), alloc_buffer, on_read);uv_run(loop, UV_RUN_DEFAULT);return 0;
}

在更新后的代码中，使用 `uv_read_start` 函数在子进程中启动对管道的读取操作。当有数据到达时，触发 `on_read` 回调函数，并打印接收到的消息。如果读取出错或遇到 EOF（文件结束），则关闭管道并终止子进程。