通过Node.js日志分析请求延迟,可以采用以下步骤:
收集日志:
winston、morgan等。解析日志:
计算延迟:
统计分析:
chart.js)来可视化这些数据。识别瓶颈:
监控和报警:
以下是一个简单的示例,展示如何使用Node.js和winston库来记录日志,并通过脚本分析请求延迟:
npm install winston
const winston = require('winston');
const express = require('express');
const app = express();
const logger = winston.createLogger({
level: 'info',
format: winston.format.json(),
transports: [
new winston.transports.File({ filename: 'error.log', level: 'error' }),
new winston.transports.File({ filename: 'combined.log' })
]
});
app.use((req, res, next) => {
const start = Date.now();
res.on('finish', () => {
const duration = Date.now() - start;
logger.info(`${req.method} ${req.url} ${res.statusCode} ${duration}ms`);
});
next();
});
app.get('/', (req, res) => {
res.send('Hello World!');
});
app.listen(3000, () => {
logger.info('Server is running on port 3000');
});
const fs = require('fs');
const readline = require('readline');
const logFile = 'combined.log';
const readInterface = readline.createInterface({
input: fs.createReadStream(logFile),
output: process.stdout,
console: false
});
const requests = [];
readInterface.on('line', (line) => {
const match = line.match(/(\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{3}Z) .* (\d+)ms/);
if (match) {
const timestamp = new Date(match[1]);
const duration = parseInt(match[2], 10);
requests.push({ timestamp, duration });
}
});
readInterface.on('close', () => {
requests.sort((a, b) => a.timestamp - b.timestamp);
const totalDuration = requests.reduce((sum, req) => sum + req.duration, 0);
const averageDuration = totalDuration / requests.length;
console.log(`Total Requests: ${requests.length}`);
console.log(`Average Response Time: ${averageDuration.toFixed(2)}ms`);
});
node analyze-logs.js
这个示例展示了如何记录请求日志并通过脚本分析请求延迟。你可以根据实际需求进一步扩展和优化这个过程。