在Ubuntu上使用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();
child_process
模块允许你创建子进程,从而实现并发执行任务。const { spawn } = require('child_process');
const child1 = spawn('node', ['script1.js']);
const child2 = spawn('node', ['script2.js']);
child1.stdout.on('data', (data) => {
console.log(`Child1 output: ${data}`);
});
child2.stdout.on('data', (data) => {
console.log(`Child2 output: ${data}`);
});
cluster
模块允许你创建多个工作进程,这些进程共享相同的服务器端口。这样可以充分利用多核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`);
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
cluster.on('exit', (worker, code, signal) => {
console.log(`worker ${worker.process.pid} died`);
});
} else {
http.createServer((req, res) => {
res.writeHead(200);
res.end('hello world\n');
}).listen(8000);
console.log(`Worker ${process.pid} started`);
}
async
和bluebird
。这些库提供了许多实用的功能,如并行执行、限流、重试等。const async = require('async');
const tasks = [
(callback) => {
setTimeout(() => {
console.log('Task 1 completed');
callback();
}, 1000);
},
(callback) => {
setTimeout(() => {
console.log('Task 2 completed');
callback();
}, 2000);
},
];
async.parallel(tasks, () => {
console.log('All tasks completed');
});
通过以上方法,你可以在Ubuntu上的Node.js应用程序中实现并发。