Node.js怎样处理并发

Node.js 处理并发的主要方式是通过异步编程和非阻塞I/O。这使得 Node.js 能够在单个线程上同时处理多个任务，从而实现高并发。以下是一些处理并发的方法：

1. 回调函数（Callback Functions）：Node.js 中的许多操作都是异步的，这意味着它们不会阻塞事件循环。当一个异步操作完成时，回调函数会被调用。这种方式允许 Node.js 在等待一个操作完成时继续执行其他任务。

fs.readFile('file.txt', 'utf8', function(err, data) {
  if (err) {
    console.error(err);
    return;
  }
  console.log(data);
});

2. Promises：Promises 是一种更优雅的处理异步操作的方式。它们表示一个尚未完成但预计将在未来完成的操作。Promises 可以链式调用，使得代码更易读和维护。

fs.readFile('file.txt', 'utf8')
  .then(data => console.log(data))
  .catch(err => console.error(err));

3. Async/Await：Async/await 是基于 Promises 的一种更简洁的语法。通过在函数前添加 async 关键字，可以在函数内部使用 await 关键字等待 Promise 完成。

async function readFile() {
  try {
    const data = await fs.promises.readFile('file.txt', 'utf8');
    console.log(data);
  } catch (err) {
    console.error(err);
  }
}

4. 事件驱动（Event-driven）：Node.js 的核心是基于事件的。许多模块（如 HTTP、FS 等）都是事件驱动的，它们在特定事件发生时触发回调函数。这种方式允许 Node.js 在单个线程上处理多个并发请求。

const http = require('http');

const server = http.createServer((req, res) => {
  console.log('Request received');
  res.end('Hello World');
});

server.listen(3000, () => {
  console.log('Server is running on port 3000');
});

5. 使用集群（Cluster）模块：Node.js 的 Cluster 模块允许您在多个 CPU 核心上运行多个 Node.js 实例，从而充分利用硬件资源并提高并发处理能力。

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 能够有效地处理并发请求，实现高性能和可扩展性。