打开server.js 文件
server.js文件
async function run()
{
// Open the interactive server.
await interactiveServer();
// Open the interactive client.
if (process.env.INTERACTIVE === 'true' || process.env.INTERACTIVE === '1')
await interactiveClient();
// Run a mediasoup Worker.
await runMediasoupWorkers(); //内部会创建worker
// Create Express app.
await createExpressApp();
// Run HTTPS server.
await runHttpsServer();
// Run a protoo WebSocketServer.
await runProtooWebSocketServer();
// Log rooms status every X seconds.
setInterval(() =>
{
for (const room of rooms.values())
{
room.logStatus();
}
}, 120000);
}
runMediasoupWorkers()函数,首先获得当前机器cpu核数,有几核就创建几个woker
// Number of mediasoup workers to launch.
numWorkers : Object.keys(os.cpus()).length,
创建woker的函数