在Ubuntu上使用Node.js實現并發處理,可以通過以下幾種方式:
異步編程:Node.js的核心特性之一是異步I/O。你可以使用回調函數、Promises或者async/await語法來實現異步操作,從而允許你的應用程序在等待某些操作(如文件讀寫、數據庫查詢等)完成時繼續執行其他任務。
使用Cluster模塊:Node.js的Cluster模塊允許你創建多個工作進程,這些進程可以共享服務器端口并運行在同一臺主機上。這樣可以充分利用多核CPU的優勢,提高應用程序的并發處理能力。
示例代碼:
const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
console.log(`主進程 ${process.pid} 正在運行`);
// 衍生工作進程。
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
cluster.on('exit', (worker, code, signal) => {
console.log(`工作進程 ${worker.process.pid} 已退出`);
});
} else {
// 工作進程可以共享任何TCP連接。
// 在本例子中,共享的是一個HTTP服務器。
http.createServer((req, res) => {
res.writeHead(200);
res.end('你好世界\n');
}).listen(8000);
console.log(`工作進程 ${process.pid} 已啟動`);
}
示例代碼:
const { Worker, isMainThread, parentPort } = require('worker_threads');
if (isMainThread) {
// 主線程
const worker = new Worker(__filename);
worker.on('message', (message) => {
console.log('Message from worker:', message);
});
worker.postMessage('Hello from main thread');
} else {
// 工作線程
parentPort.on('message', (message) => {
console.log('Message from main thread:', message);
parentPort.postMessage('Hello from worker thread');
});
}
通過這些方法,你可以在Ubuntu上的Node.js應用程序中實現并發處理,從而提高性能和響應時間。