我的代码结构大致如下:
readLine.on('line', function (line) {
async.parallel([
function (callback) {
// HTTP request #1 sent with accompanied JSON, get JSON as result
},
function (callback) {
// HTTP request #2 sent with accompanied JSON, get JSON as result
}],
function (error, results) {
// write to local file
})
line-by-line
我用模块实现了输入流。我的问题是,一旦我的代码开始运行 30 秒左右,就会ECONNREFUSED
出现ECONNRESET
错误,我认为这是因为我的所有 TCP 连接都超载(所有 HTTP 请求都转到 localhost 服务器)。我必须阅读的文本文件有大约 200,000 行,这绝对无济于事。
有什么方法可以批量处理线路和HTTP请求,等到所有请求都通过并成功返回,这样我的TCP套接字就不会超载了?
提前感谢您的任何帮助和建议。