时间戳

首页 > 解决方案 > 如何在中间件中获取响应体？

node.js - 如何在中间件中获取响应体？

问题描述

我想用响应信息记录每个请求。

我尝试使用中间件，但我遇到了问题。

res.body是未定义的。

app.use((req, res, next) => {

    var time = Date.now();

    res.on('finish', function() {
        var clientIp = req.headers['x-forwarded-for'] || req.connection.remoteAddress;
        var method = req.method;
        var path = req.baseUrl;
        var duration = Date.now() - time;

        console.log({
            clientIp,
            elapsedTime: `${duration}ms`,
            hostname: req.headers.host,
            level: 'INFO',
            method,
            path,
            phase: process.env.NODE_ENV,
            reqBody: req.body,
            reqHeaders: req.headers,
            resBody: res.body,
            resHeaders: res.getHeaders(),
            status: res.statusCode
        });
    });

    next();
});

实际上客户端上有响应数据。

如何在中间件中获取响应正文？

标签： node.jsexpress

解决方案

响应可以被覆盖response.json函数拦截。通过这样做，并添加我们的custom function, 每次response.json()被调用，我们的拦截函数就会被触发。

中间件/response.filter.js：

// Response Interceptor Middleware
export default (request, response, next) => {
    try {
        const oldJSON = response.json;
        response.json = (data) => {
            // For Async call, handle the promise and then set the data to `oldJson`
            if (data && data.then != undefined) {
                // Resetting json to original to avoid cyclic call.
                return data.then((responseData) => {
                    // Custom logic/code.
                    response.json = oldJSON;
                    return oldJSON.call(response, responseData);
                }).catch((error) => {
                    next(error);
                });
            } else {
                // For non-async interceptor functions
                // Resetting json to original to avoid cyclic call.
                // Custom logic/code.
                response.json = oldJSON;
                return oldJSON.call(response, finalResponse);
            }
        }
    } catch (error) {
        next(error);
    }
}

在Server.js文件中，注册中间件：

// Server.js file
import externalResponseFilter from "./middleware/response.filter.js:";

// Create Express server
const app = express();

// Response interceptor - Initialization.
app.use(externalResponseFilter);

在您返回的控制器中response，返回response.json()函数而不是response.send().

让我知道是否需要任何其他解释。

推荐阅读