前言

該Utils實現(xiàn)了以下封裝

• 根據(jù)API式樣對request數(shù)據(jù)按進行封裝
• 根據(jù)API式樣對response數(shù)據(jù)進行解析
• 使用co風格同步發(fā)送API請求

導入第三方Package

var request = require('request');

關于request，參考其github

Request封裝處理和Response解析處理

• 封裝處理用于對請求data添加共通部分(commonRequest)
• 解析處理用于從響應信息中獲取data

假設API式樣的共通部分如下
Request示例

{
  commonRequest: {
  },
  data: …
}

Response示例

{
  commonResponse: {
    code: I01001,
    message: success
  },
  data: …
}

** 處理用代碼如下 **

var setReqData = function(json) {
  var reqData = {
    commonRequest: {},
    data: json
  };
  return reqData;
};

var getResData = function(json) {
  var code = json.commonResponse.code;
  if (code !== 'I00001') {
    throw new Error(json.commonResponse.message);
  }
  return json.data;
};

使用co風格同步發(fā)送API請求

由于request本身不提供co風格的調(diào)用接口。
而且如果使用co-request，需要使用node --harmony simple.js的方法啟動nodejs，
為了避免不必要的麻煩，自己對request進行簡單封裝

var send = function*(api, data) {
  var options = {
    headers: {
      charset: 'UTF-8'
    },
    url: 'https://127.0.0.1:8080/' + api,
    method: 'POST',
    body: setReqData(data),
    json: true
  };
  var rep = yield new Promise(function(resolve, reject) {
    return request(options, function(err, response, body) {
      if (err) {
        reject(err);
      } else {
        resolve(response);
      }
    });
  });
  return getResData(rep);
};

調(diào)用示例

var restUtils = require('./rest_utils');
var co = require('co');

co(function*() {
  var retvalue = yield restUtils.send('test/list', {id:1000});
  console.log(retvalue);
});

完整代碼

'use strict';

var request = require('request');
var config = require('../config');

var setReqData = function(json) {
  var reqData = {
    commonRequest: {},
    data: json
  };

  return reqData;
};

var getResData = function(json) {
  var code = json.commonResponse.code;
  if (code !== 'I00001') {
    throw new Error(json.commonResponse.message);
  }
  return json.data;
};

var send = function*(api, data) {
  var options = {
    headers: {
      charset: 'UTF-8'
    },
    url: config.rest.PROTOCOL + '://' + config.rest.HOST + ':' +
      config.rest.PORT + '/' + api,
    method: 'POST',
    body: setReqData(data),
    json: true
  };

  var rep = yield new Promise(function(resolve, reject) {
    return request(options, function(err, response, body) {
      if (err) {
        reject(err);
      } else {
        resolve(response);
      }
    });
  });

  return getResData(rep);
};

module.exports = {
  send: send
};