在node.js应用中，直接获取所有正在运行的promise或异步操作状态并非内置功能。本教程将介绍如何利用`on-finished`中间件，结合express.js，高效地追踪和统计应用程序中未完成的http请求。通过创建一个请求追踪器，我们能实时监控活跃的客户端请求数量，从而了解应用负载和响应情况，避免编写繁琐的特定业务状态检查代码。
在构建高性能的Node.js应用程序时，尤其是在处理大量并发请求的Web服务中，了解当前有多少个客户端请求正在处理中（即未决请求）是至关重要的。这有助于监控应用程序的负载、识别潜在的性能瓶颈，并优化资源分配。然而，Node.js 的事件驱动和非阻塞特性使得直接获取所有正在执行的 Promise 或“运行中的进程”变得复杂，因为它没有提供一个内置的API来列出所有处于待定（pending）状态的 Promise 实例或所有活跃的异步操作。
开发者通常会考虑为每个业务逻辑手动实现状态追踪，但这无疑会增加大量的开发工作和维护成本。尤其对于一个包含众多异步路由的复杂应用而言，这种方法既不高效也不优雅。本教程将提供一种通用的、基于中间件的解决方案，利用 on-finished 库来追踪和统计 Express.js 应用中未完成的 HTTP 请求。
on-finished 是一个轻量级的 Node.js 模块，它提供了一种可靠的方式来检测 HTTP 请求或响应何时完成。它能确保在响应被发送完毕、连接关闭或请求发生错误时触发回调函数。这使得它成为追踪请求生命周期的理想工具。
我们将创建一个自定义的 Express.js 中间件，结合一个全局的 Set 数据结构来存储每个活跃请求的唯一标识符。当一个请求进入系统时，我们为其生成一个唯一ID并添加到 Set 中；当该请求的响应完成时，我们从 Set 中移除对应的ID。通过这种方式，Set 的大小就代表了当前未完成的请求数量。
首先，确保你的项目中安装了 on-finished 库：
npm install on-finished
创建一个名为 requestTracker.js 的文件（或直接在主应用文件中实现），包含以下中间件逻辑：
const onFinished = require('on-finished');
// 使用 Set 存储所有未完成请求的唯一标识符
const unresolvedRequestIds = new Set();
/**
* 请求追踪中间件
* 为每个进入的请求生成一个唯一ID，并在响应完成后将其从追踪列表中移除。
*/
const requestTracker = (req, res, next) => {
// 为当前请求生成一个简单的唯一ID
// 实际应用中可以使用更健壮的ID生成策略，如UUID
const requestId = Math.random().toString(36).substring(2, 15) + Math.random().toString(36).substring(2, 15);
unresolvedRequestIds.add(requestId);
// 当响应完成（无论成功或失败）时，从追踪列表中移除此请求ID
onFinished(res, () => {
unresolvedRequestIds.delete(requestId);
});
next(); // 继续处理请求
};
/**
* 获取当前未完成请求的数量
* @returns {number} 未完成请求的数量
*/
const getUnresolvedRequestCount = () => {
return unresolvedRequestIds.size;
};
module.exports = {
requestTracker,
getUnresolvedRequestCount
};你可以选择将 requestTracker 中间件应用到特定的路由，或者作为全局中间件应用到整个 Express.js 应用。
方法一：应用于特定路由
如果你只想追踪某些关键的异步路由，可以在这些路由定义之前单独添加 requestTracker：
const express = require('express');
const router = express.Router();
const { requestTracker, getUnresolvedRequestCount } = require('./requestTracker'); // 假设你已将中间件保存到 requestTracker.js
router.post('/someEndpoint', requestTracker, async (req, res) => {
// 模拟一个异步操作
await new Promise(resolve => setTimeout(resolve, 1000));
res.status(200).json({ message: 'Operation completed' });
});
// 其他路由...
module.exports = router;方法二：作为全局中间件
为了简化部署和确保所有请求都被追踪，你可以将 requestTracker 作为全局中间件添加到 Express.js 应用的顶部。需要注意的是，这种方式会追踪所有类型的请求，包括静态文件、健康检查等，而不仅仅是那些涉及复杂异步操作的请求。
const express = require('express');
const app = express();
const { requestTracker, getUnresolvedRequestCount } = require('./requestTracker'); // 假设你已将中间件保存到 requestTracker.js
// 将请求追踪中间件应用于所有路由
app.use(requestTracker);
// 定义一个示例路由
app.post('/api/data', async (req, res) => {
// 模拟一个耗时操作
await new Promise(resolve => setTimeout(resolve, 2000));
res.status(200).json({ status: 'Data processed successfully' });
});
// 定义一个获取未决请求数量的端点
app.get('/getUnresolvedRequestCount', (req, res) => {
const count = getUnresolvedRequestCount();
res.status(200).json({ unresolvedRequestCount: count });
});
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
console.log(`Server running on port ${PORT}`);
});通过上述设置，你可以随时访问 /getUnresolvedRequestCount 端点来获取当前正在处理的 HTTP 请求数量：
// 示例：通过 HTTP GET 请求获取数量
// curl http://localhost:3000/getUnresolvedRequestCount
// 响应示例: {"unresolvedRequestCount": 5}通过这种基于 on-finished 中间件的策略，开发者可以高效且非侵入性地监控 Node.js 应用中未决的 HTTP 请求数量，为应用性能分析和运维提供了宝贵的数据支持。
以上就是Node.js 应用中未决请求的有效追踪与监控的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告
收藏
收藏
收藏
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
456
