修改请求正文，然后在 Node.js 中代理

Question

我是 Node.js 的相对新手。这两天我试图在 Node.js 中修改请求的正文，然后转发它。对于代理，我使用http-proxy 模块。

我要做的是在 JSON 对象中截取用户的密码，对其进行加密并在请求正文中设置新的加密密码。

问题是每次我尝试收集请求正文时都会使用它（即使用body-parser）。我怎样才能完成这项任务？我知道看到节点中的请求有一个流。

为了完整起见，我在代理之前使用express 链接多个操作。

编辑

我必须代理请求这一事实并非没有用。它遵循我尝试使用的代码。

function encipher(req, res, next){
    var password = req.body.password;
    var encryptionData = Crypto().saltHashPassword(password);
    req.body.password = encryptionData.passwordHash;
    req.body['salt'] = encryptionData.salt;
    next();
}

server.post("/users", bodyParser.json(), encipher, function(req, res) {
    apiProxy.web(req, res, {target: apiUserForwardingUrl});
});

服务器（由 Spring MVC 制作的 REST）给了我异常 Failed to read HTTP message: org.springframework.http.converter.HttpMessageNotReadableException: Could not read document: null

Answer 1

真正的问题是模块body-parser 和http-proxy 之间存在集成问题，如this 线程中所述。

一种解决方案是在http-proxy 之后配置body-parser。如果您无法更改中间件的顺序（如我的情况），您可以在代理请求之前重新传输已解析的正文。

// restream parsed body before proxying
proxy.on('proxyReq', function(proxyReq, req, res, options) {
    if (req.body) {
        let bodyData = JSON.stringify(req.body);
        // if content-type is application/x-www-form-urlencoded -> we need to change to application/json
        proxyReq.setHeader('Content-Type','application/json');
        proxyReq.setHeader('Content-Length', Buffer.byteLength(bodyData));
        // stream the content
        proxyReq.write(bodyData);
    }
}

Answer 2

为什么不为此使用快速链接？ 在您的第一个函数中，只需执行以下操作：

req.body.password = encrypt(req.body.password); next();

Answer 3

您只需要使用中间件。

body-parser也只是一个中间件，解析请求体，放到req.body下

你可以这样做：

app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());

function encryptPassword(req, res, next) {
    req.body.password = encrypt(req.body.password);
    // You can do anything really here and modify the req

    //call next after you are done to pass on to next function

    next();
}

app.use(encryptPassword);

通常人们使用中间件进行身份验证、基于角色的访问控制等.....

您也可以在特定路由中使用中间件：

app.post('/password', encryptPassword, function(req, res) {
     // Here the req.body.password is the encrypted password....

     // You can do other operations related to this endpoint, like store password in database

     return res.status(201).send("Password updated!!");
});