Mediasoup 創(chuàng)建父子進(jìn)程，js與c++進(jìn)程交互的通道

worker.js構(gòu)造函數(shù)中創(chuàng)建父子進(jìn)程，c++通過libuv的socket可以實現(xiàn) JavaScript 與 C++ 之間的相互收發(fā)消息

一、 父子進(jìn)程通信

這是一個簡單的示例，演示了如何使用 libuv 在父子進(jìn)程之間進(jìn)行通信。以下是一個基于 Node.js 和 C++ 的示例：

在 C++ 程序（child.cpp）中，使用 libuv 創(chuàng)建一個管道，然后向父進(jìn)程發(fā)送消息：

#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 監(jiān)聽管道上的數(shù)據(jù)事件，并從子進(jìn)程接收消息：```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'); // 啟動子進(jìn)程const pipeFd = childProcess.stdio[0].fd;
pipe.open(pipeFd); // 將子進(jìn)程的管道連接到 Node.js 的管道childProcess.on('exit', () => {pipe.close();
});

在上述示例中，C++ 程序通過 `uv_pipe_init` 創(chuàng)建了一個管道，并使用 `uv_write` 向管道寫入消息。Node.js 程序使用 `uv.Pipe` 創(chuàng)建了一個管道對象，并通過 `pipe.open` 將子進(jìn)程的管道連接到 Node.js 的管道上。然后，通過監(jiān)聽管道的 `onData` 事件，Node.js 可以接收到來自子進(jìn)程的消息。

在實際運行時，首先需要編譯和生成 C++ 程序的可執(zhí)行文件（例如 `child`），然后運行 Node.js 程序（parent.js）。父進(jìn)程將啟動子進(jìn)程，并與子進(jìn)程建立管道通信，實現(xiàn)了父子進(jìn)程之間的通信。

二、子進(jìn)程中添加了讀取父進(jìn)程

以下是更新后的 C++ 示例代碼，在子進(jìn)程中添加了讀取父進(jìn)程發(fā)送的消息的邏輯：

#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` 函數(shù)在子進(jìn)程中啟動對管道的讀取操作。當(dāng)有數(shù)據(jù)到達(dá)時，觸發(fā) `on_read` 回調(diào)函數(shù)，并打印接收到的消息。如果讀取出錯或遇到 EOF（文件結(jié)束），則關(guān)閉管道并終止子進(jìn)程。
?