在Debian系統上使用Node.js進行并發處理,可以通過以下幾種方式實現:
const fs = require('fs').promises;
async function readFiles() {
try {
const file1 = await fs.readFile('file1.txt', 'utf-8');
const file2 = await fs.readFile('file2.txt', 'utf-8');
console.log(file1, file2);
} catch (error) {
console.error(error);
}
}
readFiles();
worker_threads
模塊允許你在多個線程中運行JavaScript代碼,從而實現并發處理。const { Worker, isMainThread, parentPort } = require('worker_threads');
if (isMainThread) {
const worker = new Worker(__filename);
worker.on('message', (message) => {
console.log('Message from worker:', message);
});
} else {
// Worker thread code
parentPort.postMessage('Hello from worker!');
}
cluster
模塊允許你創建多個子進程(workers),這些子進程共享相同的服務器端口。這樣可以充分利用多核CPU,提高并發處理能力。const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
console.log(`Master ${process.pid} is running`);
// Fork workers.
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
cluster.on('exit', (worker, code, signal) => {
console.log(`worker ${worker.process.pid} died`);
});
} else {
// Workers can share any TCP connection
// In this case, it is an HTTP server
http.createServer((req, res) => {
res.writeHead(200);
res.end('hello world\n');
}).listen(8000);
console.log(`Worker ${process.pid} started`);
}
async
、bluebird
等。這些庫提供了許多實用的并發控制工具,如并行執行、限流、重試等。選擇合適的并發處理方式取決于你的應用場景和需求。在實際項目中,可能需要組合使用多種方法來實現最佳的性能和可擴展性。