在node.js应用中，直接获取所有正在运行的promise或异步操作状态并非内置功能。本教程将介绍如何利用`on-finished`中间件，结合express.js，高效地追踪和统计应用程序中未完成的http请求。通过创建一个请求追踪器，我们能实时监控活跃的客户端请求数量，从而了解应用负载和响应情况，避免编写繁琐的特定业务状态检查代码。
Node.js 异步操作与请求状态追踪的挑战
在构建高性能的Node.js应用程序时，尤其是在处理大量并发请求的Web服务中，了解当前有多少个客户端请求正在处理中（即未决请求）是至关重要的。这有助于监控应用程序的负载、识别潜在的性能瓶颈，并优化资源分配。然而，Node.js 的事件驱动和非阻塞特性使得直接获取所有正在执行的 Promise 或“运行中的进程”变得复杂，因为它没有提供一个内置的API来列出所有处于待定（pending）状态的 Promise 实例或所有活跃的异步操作。
开发者通常会考虑为每个业务逻辑手动实现状态追踪，但这无疑会增加大量的开发工作和维护成本。尤其对于一个包含众多异步路由的复杂应用而言，这种方法既不高效也不优雅。本教程将提供一种通用的、基于中间件的解决方案，利用 on-finished 库来追踪和统计 Express.js 应用中未完成的 HTTP 请求。
利用 on-finished 中间件追踪未决请求
on-finished 是一个轻量级的 Node.js 模块，它提供了一种可靠的方式来检测 HTTP 请求或响应何时完成。它能确保在响应被发送完毕、连接关闭或请求发生错误时触发回调函数。这使得它成为追踪请求生命周期的理想工具。
我们将创建一个自定义的 Express.js 中间件，结合一个全局的 Set 数据结构来存储每个活跃请求的唯一标识符。当一个请求进入系统时，我们为其生成一个唯一ID并添加到 Set 中；当该请求的响应完成时，我们从 Set 中移除对应的ID。通过这种方式，Set 的大小就代表了当前未完成的请求数量。
1. 安装 on-finished
首先，确保你的项目中安装了 on-finished 库：
npm install on-finished
2. 实现请求追踪中间件
创建一个名为 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
};3. 集成中间件到 Express.js 应用
你可以选择将 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}`);
});4. 获取未决请求数量
通过上述设置，你可以随时访问 /getUnresolvedRequestCount 端点来获取当前正在处理的 HTTP 请求数量：
// 示例：通过 HTTP GET 请求获取数量
// curl http://localhost:3000/getUnresolvedRequestCount
// 响应示例: {"unresolvedRequestCount": 5}注意事项与总结
- 追踪范围： 此方法主要追踪的是 HTTP 请求的生命周期，即从请求进入到响应完成的整个过程。它并不能直接追踪应用程序中所有独立的 Promise 实例或非请求相关的异步操作。如果你的目标是监控更广泛的异步任务，可能需要结合其他机制（如自定义任务队列、Promise 包装器等）来扩展追踪能力。
- 唯一标识符： 示例中使用了 Math.random() 来生成请求ID，这在大多数情况下足够用，但在高并发场景下，为了绝对的唯一性，可以考虑使用 UUID 或其他更健壮的 ID 生成算法。
- 全局与局部： 将 requestTracker 作为全局中间件使用最为便捷，但它会统计所有请求。如果需要更精细的控制，例如只追踪特定业务逻辑的请求，则应将其应用于特定的路由或路由组。
- 性能开销： on-finished 库本身非常高效，引入此中间件的性能开销可以忽略不计。Set 数据结构的操作（添加、删除、获取大小）也是 O(1) 或平均 O(1) 复杂度，在高并发下也能保持良好性能。
- 监控与告警： 结合此端点，你可以集成到现有的监控系统中（如 Prometheus, Grafana），定期抓取 unresolvedRequestCount 的值，并设置阈值进行告警，以便及时发现应用负载过高或响应缓慢的问题。
通过这种基于 on-finished 中间件的策略，开发者可以高效且非侵入性地监控 Node.js 应用中未决的 HTTP 请求数量，为应用性能分析和运维提供了宝贵的数据支持。
