1、http代码，server端：

var express = require('express');
var bodyParser = require('body-parser');
var app = express();
app.use(bodyParser({limit: '1mb'}));
var count = 1;
app.post('/rec/data', function(req, res){
  var bufLen = (req.body.content || '').length
  res.send({
      len:bufLen,
      count:count++
  })
});
app.listen(4001);

2、http代码，client端

var request = require('request');
var assert = require('assert');
var async = require('async')
var host = 'http://127.0.0.1:4001'
var buf = new Buffer(1024)
var content = buf.fill('a').toString()
console.time('http1000');
var count = 0
var needCount  = 0
var reqList = []
for(var i=1;i<=1000;i++){
    needCount += i
    reqList.push(function(callback){
        request.post({url:host+'/rec/data', 
        form: {content:content}}, 
        function(err,httpResponse,body){
            if(err){
                callback(err)
                return console.log(err)
            }
            //console.log(body)
            var resJson = JSON.parse(body)
            assert(resJson.len === content.length)
            count += resJson.count
            callback()
        })          
    })
}
async.series(reqList, function(err){
    if(err){
        console.log(err)
    }
    assert(count === needCount)
    console.timeEnd('http1000');
})

3、thrift接口文件：

struct SendMsg {
  1: string content,
}

struct ResMsg {
  1: i32 len = 1,
  2: i32 count,
}

service Message{
   ResMsg send(1:SendMsg data),
}

4、thrif端的server代码：

var express = require('express');
var bodyParser = require('body-parser');
var app = express();
app.use(bodyParser());
var count = 1;
app.post('/rec/data', function(req, res){
  
  var bufLen = (req.body.content || '').length
  res.send({
      len:bufLen,
      count:count++
  })
});
app.listen(4001);

5、thrift端的client代码：

var thrift = require('thrift');
var assert = require('assert');
var async = require('async');
var transport = thrift.TBufferedTransport();
var protocol = thrift.TBinaryProtocol();
var Message = require('./gen-nodejs/Message.js');
var ttypes = require('./gen-nodejs/nodejs_msg_types.js');

var connection = thrift.createConnection("127.0.0.1", 9090, {
  transport : transport,
  protocol : protocol
});
connection.on('error', function(err) {
  console.log(err)
});

var client = thrift.createClient(Message, connection);
var buf = new Buffer(1024)
var content = buf.fill('a').toString()

console.time('thrift1000');
var count = 0
var needCount  = 0
var reqList = []
for(var i=1;i<=1000;i++){
    needCount += i
    reqList.push(function(callback){
        
        var sendData = new ttypes.SendMsg()
        sendData.content = content
        client.send(sendData, function(err, response) {
            if(err){
                return callback(err)
            }
            //console.log(response)
            assert(response.len == content.length)
            count += response.count
            callback()
        });
                        
    })
}

async.series(reqList, function(err){
    if(err){
        console.log(err)
    }
    assert(count === needCount)
    console.timeEnd('thrift1000');
})

6、测试结果对比 网络环境，内网千兆，依次循环1000次，发送数据包为1k

http：
http1000: 4879ms
thrift：
thrift1000: 1254ms

网络环境，内网千兆，依次循环1000次，发送数据包为100k

http：
http1000: 16924ms
thrift：
thrift1000: 2105ms

网络环境，内网千兆，并行执行1000次，发送数据包为1k，就是将async改为parallel

http：
http1000: 4265ms
thrift：
thrift1000: 437ms

总结一下，在内网大数据包的传输上，还是用thrift性能更出色