nodejs在ubuntu上如何实现并发

5月 7th, 2025

在Node.js中，实现并发的主要方法是使用异步编程。Node.js是单线程的，但它可以通过事件循环和非阻塞I/O操作来实现高并发。以下是一些在Ubuntu上实现Node.js并发的方法：

回调函数（Callback Functions）：
回调函数是Node.js中实现异步编程的基本方法。通过在函数中传递回调函数，可以在异步操作完成时执行特定的代码。

const fs = require('fs');

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

Promises：
Promises是一种更高级的异步编程方法，它表示一个尚未完成但预计将来会完成的操作。Promises可以帮助您更简洁地处理异步操作，避免回调地狱（Callback Hell）。

const fs = require('fs').promises;

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

async/await：
async/await是基于Promises的一种更简洁的异步编程方法。通过将函数声明为async并在需要等待的操作前添加await关键字，可以使代码看起来更像同步代码。

const fs = require('fs').promises;

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

readFile();

事件驱动（Event-driven）：
Node.js是基于事件驱动的，可以使用事件监听器来处理并发操作。例如，可以使用HTTP模块创建一个Web服务器，并在每次收到请求时触发事件。

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');
});

使用集群（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`);
}