使用node.js的bodyParser中间件读取post数据解析

昨天我们使用的网关转发数据时出了点问题！

情景是这样的，另一方以Post的形式向我的node.js服务推送JSON数据。但是使用bodyParser中间件后，在req.body中拿不到任何信息。

代码如下：

    app.use(bodyParser.json());
                 app.post('/api/*',function(req,res){
                             _option.onMessage({url:req.url,query:req.query,body:req.body},function(error,data){
                             res.header('Access-Control-Allow-Origin','*');
                             res.header('Access-Control-Allow-Headers','X-Requested-With, Content-Type');
                             console.log(req.params);console.log(req.body.data);
                             res.send(data);
                       });

 当时百思不得其解，后来发现推送方的Post请求中请求头的Content-Type的值为"text/xml"。当时觉得和这个值有很大的关系，经过检测果然不出所料。

自己模拟一个Post请求时将Content-type设置为"application/json"那么传过来的JSON数据就可以通过bodyParser中间件后由req.body拿到。但是另一方并没有以Content-type="application/json"的形式进行传送，我们只能从自己的node.js服务下手，坚信一定会想到办法。

在网上大概找了30多分钟的资料但是没有任何眉目！！！   无奈之下只能自己读bodyParser源码，而且我始终相信读别人的代码是最快的进步方式。

果然功夫不负有心人，在长达半个多小时与bodyParser源码的”作战中“，找到了解决问题的方法！

源代码分析如下：

bodyParser一定是对Content-Type进行了校验，那么我们就从这里入手，首先找到了bodyParser.json方法，代码如下：

function json(options) {
  options = options || {}

  var limit = typeof options.limit !== 'number'
    ? bytes(options.limit || '100kb')
    : options.limit
  var inflate = options.inflate !== false
  var reviver = options.reviver
  var strict = options.strict !== false
  var type = options.type || 'json'
  var verify = options.verify || false

  if (verify !== false && typeof verify !== 'function') {
    throw new TypeError('option verify must be function')
  }

  function parse(body) {
    if (body.length === 0) {
      // special-case empty json body, as it's a common client-side mistake
      // TODO: maybe make this configurable or part of "strict" option
      return {}
    }

    if (strict) {
      var first = firstchar(body)

      if (first !== '{' && first !== '[') {
        throw new Error('invalid json')
      }
    }

    return JSON.parse(body, reviver)
  }

  return function jsonParser(req, res, next) {
    if (req._body) return next()
    req.body = req.body || {}

    if (!typeis(req, type)) return next()

    // RFC 7159 sec 8.1
    var charset = typer.parse(req).parameters.charset || 'utf-8'
    if (charset.substr(0, 4).toLowerCase() !== 'utf-') {
      var err = new Error('unsupported charset')
      err.status = 415
      next(err)
      return
    }

    // read
    read(req, res, next, parse, {
      encoding: charset,
      inflate: inflate,
      limit: limit,
      verify: verify
    })
  }
}

那么上述代码的 if (!typeis(req, types_))则为关键点，如果if执行了next()那下面的语句就将无法执行，我们也就无法进行read方法中，所以这个typeis方法即为突破口。

而typeis方法的位置在type-is模块中，关键代码如下：

function typeis(value, types_) {
  var i
  var types = types_

  // remove parameters and normalize
  value = typenormalize(value)

  // no type or invalid
  if (!value) {
    return false
  }

  // support flattened arguments
  if (types && !Array.isArray(types)) {
    types = new Array(arguments.length - 1)
    for (i = 0; i < types.length; i++) {
      types[i] = arguments[i + 1]
    }
  }

  // no types, return the content type
  if (!types || !types.length) return value;

  var type
  for (i = 0; i < types.length; i++) { if (mimeMatch(normalize(type = types[i]), value)) {
      return type[0] === '+' || ~type.indexOf('*')
        ? value
        : type
    }
  }

  // no matches
  return false;
}
................
function typenormalize(value) {
  try {
    var type = typer.parse(value)
    delete type.parameters
    return typer.format(type)
  } catch (err) {
    return null
  }
}

 

上述代码的value实则为传进来的req对象，也就是请求对象。那么请求对象通过'media-typer'模块中的parse方法将req判断为对象类型。代码如下：

function parse(string) {
  if (!string) {
    throw new TypeError('argument string is required')
  }

  // support req/res-like objects as argument
  if (typeof string === 'object') {
    string = getcontenttype(string)
  }

  if (typeof string !== 'string') {
    throw new TypeError('argument string is required to be a string')
  }
.................................

function getcontenttype(obj) {
  if (typeof obj.getHeader === 'function') {
    // res-like
    return obj.getHeader('content-type')
  }

  if (typeof obj.headers === 'object') {
    // req-like
    return obj.headers && obj.headers['content-type']
  }
}

之后在通过getcontenttype方法取出content-type的值将其返回，最后由typeis方法中的value接收。在红色的for循环中可以看出typeis函数中的types_可以为数组类型，并且会循环与value进行匹配，如果相同则直接返回。那么返回之后就不会再去执行next()，这样我们就可以继续执行下面的代码，我们就可以利用bodyParser中间件从req.body中获取数据了至于types_数组中写几种content-type值就由你的需要决定！

解决问题代码例如：

app.use(bodyParser.json( { type: ['text/xml','application/json'] } ));
                 app.post('/api/*',function(req,res){
                             _option.onMessage({url:req.url,query:req.query,body:req.body},function(error,data){
                             res.header('Access-Control-Allow-Origin','*');
                             res.header('Access-Control-Allow-Headers','X-Requested-With, Content-Type');
                             console.log(req.params);console.log(req.body.data);
                             res.send(data);
                       });