nodejs错误：解析错误在Socket.ondata

Question

我有一些错误，当使用http.request做客户端请求（节点v0.6.18，v0.6.3），下面的代码产生的错误，我有一些问题。

var http = require('http'); 
var url = require('url'); 

http.createServer(function(req, res) { 
    var data = '多情自古空余恨'; 
    res.writeHead(200, { 
     'Content-Type': 'text/plain', 
     'Content-Length': 1 //ERROR 
    }); 
    res.end(data); 
}).listen(3000); 

function request(options, callback) { 
    var req = http.request(options, function(res) { 
     var data = ''; 
     res.setEncoding = 'utf8'; 
     res.on('data', function(chunk) { 
      data += chunk; 
     }); 
     res.on('error', function(err) { 
      callback(new Error('res error: ' + err)); 
     }); 
     res.on('end', function() { 
      console.log('res on end'); 
      callback(null, data); 
     }); 
    }); 
    req.on('socket', function(socket) { 
     socket.on('error', function(err) { 
      console.log('socket on error'); 
      callback('socket error: ' + err); 
      req.abort(); 
     }); 
    }); 
    req.end(); 
} 

request({ 
    host: 'localhost', 
    port: 3000, 
    method: 'GET' 
}, function(err, data) { 
    console.log('result, err: ' + err + ', data: ' + data); 
}); 

输出：

res on end 
result, err: null, data: � 
socket on error 
result, err: socket error: Error: Parse Error, data: undefined 

这里是我的问题：

1. 为什么资源的 '结束' 事件早于插座的 '错误' 的事件发生？
2. 如果我确实想回调一个错误，当“解析错误在Socket.ondata”发生像上面的代码或在任何其他情况下，如何回调一次，而不是上述输出的两倍（IF res的'结束'事件真的比套接字的'错误'事件早发生）？

我需要你的帮助！谢谢。

===============================

我发现相同的代码输出：

res on end 
result, err: null, data: � 

在节点v0.6.6和v0.6.11中。为什么？

Answer 1

由于内容长度标题为1，因此当request只收到1个八位字节的数据时，它会假设全部存在，并触发end回调。之后，会收到更多的数据，表明套接字不知道如何处理，所以会引发错误。

要解决这个问题，您可能需要等待一段时间才能解除成功回调并跟踪是否已被解雇。例如：

var req = http.request(options, function(res) { 

    var data = ''; 
    res.setEncoding = 'utf8'; 
    res.on('data', function(chunk) { 
     data += chunk; 
    }); 
    res.on('error', function(err) { 
     if(!callback.called) { // check before firing the callback 
      callback(new Error('res error: ' + err)); 
      callback.called = true; // set after firing the callback 
     } // .. 
    }); 
    res.on('end', function() { 
     process.nextTick(function() { // use setTimeout if nextTick is too short 
      if(!callback.called) { //.. 
      console.log('res on end'); 
      callback(null, data); 
      callback.called = true; // .. 
      } // .. 
     }); // .. 
    }); 
}); 
req.on('socket', function(socket) { 
    socket.on('error', function(err) { 
     if(!callback.called) { // .. 
      console.log('socket on error'); 
      callback('socket error: ' + err); 
      callback.called = true; // .. 
     } // .. 
     req.abort(); 
    }); 
}); 
req.end(); 

（我试过之后的所有新生产线的补充意见，使他们脱颖而出一点。）如果我问为什么这对你很重要