在Linux中,Node.js可以通过多种方式实现并发处理。以下是一些常见的方法:
const fs = require('fs');
fs.readFile('file1.txt', 'utf8', (err, data) => {
if (err) throw err;
console.log(data);
});
fs.readFile('file2.txt', 'utf8', (err, data) => {
if (err) throw err;
console.log(data);
});
事件循环:Node.js使用事件驱动模型来处理并发。事件循环允许Node.js在等待异步操作完成时继续执行其他任务。当异步操作完成时,事件循环会将回调函数添加到任务队列中,等待执行。
多线程:虽然Node.js是单线程的,但可以使用worker_threads模块来实现多线程并发。worker_threads模块允许你在Node.js中创建多个线程,每个线程可以运行自己的JavaScript代码。这对于执行CPU密集型任务非常有用。
const { Worker } = require('worker_threads');
const worker = new Worker('./worker.js');
worker.on('message', (result) => {
console.log(result);
});
worker.postMessage('Hello, worker!');
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`);
}
通过结合这些方法,Node.js可以在Linux环境中实现高效的并发处理。