NodeJS 在express中获取rawBody

e4eetjau  于 2023-05-28  发布在  Node.js
关注(0)|答案(4)|浏览(365)

我试图从帖子中检索一些东西,需要传入请求的rawBody属性。我怎么才能找回它?
我尝试使用express.bodyParser(),在我的post处理程序中,我正在寻找req.rawBody,它是未定义的。
我甚至用connect.bodyParser()尝试过,但还是没有成功。我正在为rawBody进行undefined。
我在stackoverflow网站上阅读,他们已经删除了rawBody功能,但提到将其添加到我们自己的中间件文件中是一个快速解决方案。我是一个新手,所以我不知道如何实现这一点。下面是我的代码片段。

/**
 * 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'));
});

任何帮助这是非常感谢。

dxxyhpgq

dxxyhpgq1#

你可以使用你自己的中间件来实现这一点:

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);
})
ahy6op9u

ahy6op9u2#

我又回来了: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中,只是让它们一起工作。

vkc1a9a2

vkc1a9a23#

基于@Rikky的解决方案,避免数据事件处理程序中的竞争条件的方法是在设置处理程序后立即继续调用中间件链。不要等待req.on('end')调用next(),因为next()调用允许json主体解析器注册自己的数据和结束处理程序;如果你一直等到请求触发了end,它们就会错过所有相关的事件。使用promises:

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();
0dxa2lsx

0dxa2lsx4#

我找到的最佳解决方案是:https://stackoverflow.com/a/9931478/1768033
因为使用

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

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

相关问题