在 express 中获取 rawBody

Question

您好，我正在尝试从帖子中检索某些内容，并且需要来自传入请求的 rawBody 属性。我怎样才能找回它？？

我尝试使用 express.bodyParser()，在我的 post 处理程序中，我正在寻找 req.rawBody，它是未定义的。

我什至用 connect.bodyParser() 尝试过它，但我仍然没有运气。我的 rawBody 未定义。

我在 stackoverflow 网站上看到说他们已经删除了 rawBody 功能，但提到将它添加到我们自己的中间件文件中是一种快速修复。我是新手，所以我不知道如何实现这一目标。下面是我的代码 sn-p。

/**
 * Module dependencies.
 */

var express = require('express')
  , connect = require('connect')
  , routes = require('./routes')
  , user = require('./routes/user')
  , http = require('http')
  , path = require('path');

var app = express();

// all environments
app.set('port', process.env.PORT || 3000);
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.favicon());
app.use(express.logger('dev'));
//app.use(express.bodyParser());
app.use(connect.bodyParser());
app.use(express.methodOverride());
app.use(app.router);
app.use(express.static(path.join(__dirname, 'public')));

// development only
if ('development' == app.get('env')) {
  app.use(express.errorHandler());
}

app.get('/', routes.index);
app.get('/users', user.list);



/**custom stuff**/

app.post('/upload',function(req, res){
        console.log(req.header('Content-Type'));
        console.log(req.header('Host'));
        console.log(req.header('User-Agent'));

        console.log(req.rawBody);
        console.log(req.body);
        res.send("<h1> Hello the response is "+req.body.username);
});

/** end**/

http.createServer(app).listen(app.get('port'), function(){
  console.log('Express server listening on port ' + app.get('port'));
});

非常感谢您提供任何帮助。

谢谢。

Answer 1

我找到的最佳解决方案在这里：https://stackoverflow.com/a/9931478/1768033

因为使用

req.on('data', function(chunk){ data += chunk})

不知何故改变了我在多格式数据请求中发送的文件的位，因此它们不再有效。

Answer 2

基于@Rikky 的解决方案，在数据事件处理程序中避免竞争条件的方法是在设置处理程序后立即继续调用中间件链。不要等待 req.on('end') 调用 next()，因为 next() 调用允许 json 正文解析器注册自己的数据和结束处理程序；如果您等到请求触发结束，他们将错过所有相关事件。相反，使用承诺：

const process = require('process');

const bodyParser = require('body-parser');
const express = require('express');

function main() {
  const app = express();

  app.use((req, res, next) => {
    req.rawBody = new Promise(resolve => {
      buf = '';
      req.on('data', x => buf += x);
      req.on('end', () => {
        resolve(buf);
      });
    });
    next();
  });

  app.use(bodyParser.json());

  app.use('/', async (req, res) => {
    console.log('raw body:', await req.rawBody);
    console.log('json parsed:', req.body);
    res.send('bye\n');
  });

  app.listen('3000', 'localhost', (e) => {
    if (e) {
      console.error(e);
      process.exit(1);
    }
    console.log('Listening on localhost:3000');
  });
}

main();

Answer 3

我又回来了：D。在阅读了 connect.bodyParser 之后，我发现了一些东西：bodyParser 只解析 mime 类型为以下之一的数据：application/json、application/x-www-form-urlencoded 和 multipart/form-data。所以我认为这是另一种方法，它通常不优雅但可以接受：当您尝试将原始数据发送到服务器时，将 mime 类型更改为不同的类型。作为您的问题，它是一个字符串，所以我选择 text/plain 作为示例：

// if the request's mime type is text/plain, read it as raw data
var myRawParser = function(req, res, next){
    req.rawData = '';
    if(req.header('content-type') == 'text/plain'){
        req.on('data', function(chunk){
            req.rawData += chunk;
        })
        req.on('end', function(){
            next();
        })
    } else {
        next();
    }
}

// ... 
app.use(myRawParser);
app.use(express.bodyParser());
// ...

// Here is my test route:
app.post('/test', function(req, res){
    console.log('Mime type is:'+req.header('content-type'));
    console.log('Raw data is:'+req.rawData);
    console.log('Body via bodyParser is:');
    console.dir(req.body);
    res.send('Hello!');
})

我已经通过 curl 对其进行了测试：

$ curl -d 'test=hello' 127.0.0.1:3000/test

// console result:
Mime type is:application/x-www-form-urlencoded
Raw data is: 
Body via bodyParser is:
{ test: 'hello' }

和：

$ curl -d 'test=hello' -H  'Content-Type:text/plain' 127.0.0.1:3000/test
// console result:
Mime type is:text/plain
Raw data is:test=hello
Body via bodyParser is: 
{}

它实际上并没有将你的中间件集成到 bodyParser 中，只是让它们一起工作。

Answer 4

您可以使用自己的中间件来做到这一点：

app.use(function(req, res, next){
   var data = "";
   req.on('data', function(chunk){ data += chunk})
   req.on('end', function(){
      req.rawBody = data;
      next();
   })
})

// Your route registration:
app.get('/', function(){// whatever...})

app.post('/test', function(req, res){
    console.log(req.rawBody);
    res.send("your request raw body is:"+req.rawBody);
})