在 CentOS 系統上使用 Node.js 處理并發請求,通常會采用以下幾種方法和技術:
Node.js 的內置 HTTP 模塊可以用來創建一個簡單的 HTTP 服務器,該服務器可以處理并發請求。Node.js 的事件驅動和非阻塞 I/O 模型使其能夠高效地處理大量并發連接。
const http = require('http');
const server = http.createServer((req, res) => {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end('Hello World\n');
});
server.listen(3000, () => {
console.log('Server running at http://localhost:3000/');
});
Express 是一個流行的 Node.js Web 應用框架,它簡化了 HTTP 服務器的創建和路由處理。Express 也利用了 Node.js 的非阻塞 I/O 特性來處理并發請求。
const express = require('express');
const app = express();
const port = 3000;
app.get('/', (req, res) => {
res.send('Hello World!');
});
app.listen(port, () => {
console.log(`Example app listening at http://localhost:${port}`);
});
Node.js 的 cluster
模塊允許你創建多個工作進程,每個進程都可以處理請求,從而提高并發處理能力。
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`);
}
PM2 是一個流行的 Node.js 進程管理器,它可以管理多個 Node.js 應用實例,并提供負載均衡功能。
npm install pm2 -g
pm2 start app.js -i max
Nginx 是一個高性能的 HTTP 和反向代理服務器,它可以用來處理靜態文件、負載均衡和 SSL/TLS 加密。將 Nginx 配置為 Node.js 應用的反向代理可以進一步提高并發處理能力。
server {
listen 80;
server_name example.com;
location / {
proxy_pass http://localhost:3000;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection 'upgrade';
proxy_set_header Host $host;
proxy_cache_bypass $http_upgrade;
}
}
對于需要實時通信的應用,可以使用 WebSocket 技術。Node.js 有多個 WebSocket 庫,如 ws
和 socket.io
,可以用來實現實時通信。
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });
wss.on('connection', function connection(ws) {
ws.on('message', function incoming(message) {
console.log('received: %s', message);
});
ws.send('something');
});
通過結合這些技術和方法,你可以在 CentOS 系統上使用 Node.js 高效地處理并發請求。