节点请求 - 如何确定请求期间是否发生错误？

Question

我正在尝试利用node-request module，但文档不是那么好。如果我向有效资源发出请求并将其通过管道传输到可写流，则一切正常。但是，如果我向无效对象发出请求，仍会创建可写流。例如，取下面的sn-p：

var x = request("http://localhost:3000/foo.jpg");
var st = fs.createWriteStream("foo.jpg");
x.pipe(st);

如果服务器上存在 foo.jpg 资源，则将数据通过管道传输到流中，并在服务器上正常创建文件。但是，如果服务器上 不存在 foo.jpg，则仍会创建一个空白容器文件。似乎没有错误事件或任何可用于确定请求是否返回 404 的事件。我尝试过类似以下的操作：

var x = request("http://localhost:3000/foo.jpg", function(err, response, body) {
    if(response.statusCode === 200) {
        // Success
        var st = fs.createWriteStream("foo.jpg");
        x.pipe(st);
    }
});

还有：

request("http://localhost:3000/foo.jpg", function(err, response, body) {
    if(response.statusCode === 200) {
        // Success
        var x = response.request;
        var st = fs.createWriteStream("foo.jpg");
        x.pipe(st);
    }
});

无济于事。这个想法很简单。我只想将由 URL 标识的文件复制到本地服务器。如果请求无效（404 等），请不要通过管道传输文件；如果请求有效，则通过管道传输文件。有什么建议吗？

Answer 1

我写了请求:)

你可能想试试这个

var r = request(url)
r.on('response', function (resp) {
   resp.headers 
   resp.statusCode
   r.pipe(new WritableStream())
})

Answer 2

我最终在节点中成功使用新流的方式：

function doQuery(){
    var r = request(url)
    r.pause()
    r.on('response', function (resp) {
       if(resp.statusCode === 200){
           r.pipe(new WritableStream()) //pipe to where you want it to go
           r.resume()
       }else{  }
    })
}

这真的很灵活——如果你想重试，你可以用setTimeout递归调用函数

function doQuery(){
    var r = request(url)
    r.pause()
    r.on('response', function (resp) {
       if(resp.statusCode === 200){
           r.pipe(new WritableStream()) //pipe to where you want it to go
           r.resume()
       }else{ 
           setTimeout(doQuery,1000)
       }
    })
}

Answer 3

@Mikeal 解决方案看起来不错，但管道可能存在一些问题（可能会丢失前几个字节）。 熙是更新的代码：

var r = request(url)
r.pipe(new WritableStream());
r.on('response', function (resp) {
   resp.headers 
   resp.statusCode
   // Handle error case and remove your writablestream if need be.
})

Answer 4

为什么不直接使用http模块。http.request

它有一个“错误”事件，您可以使用它来捕获错误。