javascript - 如何在 Node.js 中处理 fs.createReadStream() 的错误？

Question

我构建了一个简单的服务器来处理错误(例如，找不到文件)，它工作正常:

    fs.readFile(fullPath, function(err, data) {

        // If there is an error, return 404
        if (err) {
            res.writeHead(404);
            res.end();
            debug.log("File denied: " + fullPath);
        } else {
            var length      = data.length;
            var extension   = getExtension(path);
            var type        = getType(extension);

            // If the type doesn't match a MIME type that this app serves, return 404
            if (!type) {
                res.writeHead(404);
                res.end();
                debug.log("File denied: " + fullPath);

            // Otherwise, serve the file
            } else {
                res.writeHead(200, {
                    'Content-Length' : length,
                    'Content-Type' : type
                });
                res.write(data);
                res.end();
                debug.log("File served: " + fullPath);
            }
        }
    });

但我决定要支持压缩，所以我需要使用 fs.createReadStream() 来读取文件，就像我正在查看的这个示例:

//Check request headers
var acceptEncoding = req.headers['accept-encoding'];
if (!acceptEncoding) {
    acceptEncoding = '';
}

var raw = fs.createReadStream(fullPath);

// Note: this is not a conformant accept-encoding parser.
// See http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.3
if (acceptEncoding.match(/\bdeflate\b/)) {
    response.writeHead(200, { 'content-encoding': 'deflate' });
    raw.pipe(zlib.createDeflate()).pipe(response);
} else if (acceptEncoding.match(/\bgzip\b/)) {
    response.writeHead(200, { 'content-encoding': 'gzip' });
    raw.pipe(zlib.createGzip()).pipe(response);
} else {
    response.writeHead(200, {});
    raw.pipe(response);
}

所以我的问题是，由于 fs.createReadStream() 不采用回调函数，我正在尝试弄清楚如何将我的错误处理合并到流方法中。

我如何处理 Node.js fs.createReadStream() 的错误？

Answer 1

Streams 可以发出一个error 事件。您可以监听此事件以防止引发错误的默认行为:

raw.on('error', function(err) {
  // do something with `err`
});