8

我有一个简单的节点应用程序，应该从客户端写入指标。客户端以使用 python 的 zlib 模块压缩的 json 格式发送指标，我正在尝试添加一个中间件以在快速 bodyParse 发生之前解压缩请求帖子。

我的中间件只是 express 默认提供的中间件：

app.configure(function(){
    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(express.methodOverride());
    app.use(express.cookieParser('your secret here'));
    app.use(express.session());
    app.use(app.router);
    app.use(require('less-middleware')({ src: __dirname + '/public' }));
    app.use(express.static(path.join(__dirname, 'public')));
});

我尝试添加一个简单的中间件来获取数据然后解压缩它：

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

    req.addListener("end", function() {
        zlib.inflate(data, function(err, buffer) {
            if (!err) {
                req.body = buffer;
                next();
            } else {
                next(err);
            }
        });
    });
});

问题出在 zlib.inflate 我收到此错误：

Error: incorrect header check

数据已使用 python 的 zlib 模块压缩：

zlib.compress(jsonString)

但似乎解压缩、膨胀、gunzip 都不起作用。

4

2 回答 2

13

我自己找到了解决方案，问题出在这段代码上：

req.addListener("data", function(chunk) {
    data += chunk;
});

似乎连接请求数据不正确，所以我将中间件切换为：

app.use(function(req, res, next) {
    var data = [];
    req.addListener("data", function(chunk) {
        data.push(new Buffer(chunk));
    });
    req.addListener("end", function() {
        buffer = Buffer.concat(data);
        zlib.inflate(buffer, function(err, result) {
            if (!err) {
                req.body = result.toString();
                next();
            } else {
                next(err);
            }
        });
    });
});

连接缓冲区完美运行，我现在可以解压缩请求正文。

于 2013-01-07T14:59:43.810 回答
3

我知道这是一个非常晚的响应，但是使用 module body-parser，它将：

返回仅解析 json 的中间件。此解析器接受正文的任何​​ Unicode 编码，并支持 gzip 和 deflate 编码的自动膨胀。

var bodyParser = require('body-parser');
app.use( bodyParser.json() );       // to support JSON-encoded bodies
于 2015-04-29T07:51:55.827 回答