Nodejs Http 阻塞业务接口 压测
时间:2024-1-29 10:06 作者:xiang 分类: nodejs
const http = require('http');
// 创建一个 HTTP 服务器
const server = http.createServer((req, res) => {
// 设置响应头
res.writeHead(200, {'Content-Type': 'application/json'});
// 定义接口路径
if (req.url === '/index') {
// 模拟返回的数据
const data = {
message: 'Hello, this is the API response!'
};
var currentTime = new Date();
data.message=currentTime;
// 将数据转换为 JSON 格式并发送响应
res.end(JSON.stringify(data));
} else if (req.url === '/google') {
const options = {
hostname: 'cn.bing.com',
path:'/HPImageArchive.aspx?format=js&idx=0&n=1',
port: 80,
method: 'GET',
timeout:1000,
};
// 模拟返回的数据
fetchDataFromServer(options, (error, data) => {
if (error) {
res.writeHead(200, {'Content-Type': 'application/json'});
res.end(JSON.stringify(error));
} else {
const googleData = {
message: data
};
res.writeHead(200, {'Content-Type': 'application/json'});
res.end(JSON.stringify(googleData));
}
});
} else {
// 处理未知路径的请求
res.writeHead(200, {'Content-Type': 'application/json'});
res.end('Not Found');
}
});
function fetchDataFromServer(options, callback) {
const req = http.request(options, (res) => {
let data = '';
// 接收响应数据
res.on('data', (chunk) => {
data += chunk;
});
// 响应完成后处理数据
res.on('end', () => {
// 调用回调函数并传递获取的数据
callback(null, data);
});
});
// 处理请求错误
req.on('error', (e) => {
// 调用回调函数并传递错误信息
callback(e, null);
});
// 结束请求
req.end();
}
// 监听端口
const port = 3000;
server.listen(port, () => {
console.log(`Server is running on http://localhost:${port}`);
});
阻塞接口压测
wrk -c 100 -t 10 -d 15s http://127.0.0.1:3000/google
QPS几十
同时压测普通接口
wrk -c 100 -t 10 -d 10s http://127.0.0.1:3000/index
QPS 3万左右,没有明显影响.