node.js - 如何从NodeJS中的缓冲区流式传输范围http请求
问题描述
在节点中测试 http 范围请求,当我们从
fs.createReadStream('index.html').pipe(res)
到res
http服务器的http,来自节点的http客户端接受它。
但是,当我通过管道传输缓冲区流时,使用:
const content = fs.readFileSync("src/index.html");
const stream = new Readable();
stream.push(
opts.start && opts.end
? content.slice(opts.start, opts.end + 1)
: content
);
stream.push(null);
stream.pipe(res);
Curl 和浏览器接受它,除了 NodeJShttp
客户端,它会抛出:
events.js:180
throw er; // Unhandled 'error' event
^
Error: Parse Error
at Socket.socketOnData (_http_client.js:452:22)
at Socket.emit (events.js:203:13)
at addChunk (_stream_readable.js:294:12)
at readableAddChunk (_stream_readable.js:275:11)
at Socket.Readable.push (_stream_readable.js:210:10)
at TCP.onStreamRead (internal/stream_base_commons.js:166:17)
Emitted 'error' event at:
at Socket.socketOnData (_http_client.js:458:9)
at Socket.emit (events.js:203:13)
[... lines matching original stack trace ...]
at TCP.onStreamRead (internal/stream_base_commons.js:166:17) {
bytesParsed: 234,
code: 'HPE_INVALID_CONSTANT',
reason: 'Expected HTTP/'
}
要对其进行测试,只需将第 56 行从更改'read'
为'buffer'
:
index.js
const http = require("http");
const fs = require("fs");
const Readable = require("stream").Readable;
const stats = fs.statSync("index.html");
const handler = function(read_or_buffer) {
return function(req, res) {
let code = 200;
const opts = {};
const headers = {
"Content-Length": stats.size,
"Content-Type": "text/html",
"Last-Modified": stats.mtime.toUTCString()
};
if (req.headers.range) {
code = 206;
let [x, y] = req.headers.range.replace("bytes=", "").split("-");
let end = (opts.end = parseInt(y, 10) || stats.size - 1);
let start = (opts.start = parseInt(x, 10) || 0);
if (start >= stats.size || end >= stats.size) {
res.setHeader("Content-Range", `bytes */${stats.size}`);
res.statusCode = 416;
return res.end();
}
headers["Content-Range"] = `bytes ${start}-${end}/${stats.size}`;
headers["Content-Length"] = end - start + 1;
headers["Accept-Ranges"] = "bytes";
}
res.writeHead(code, headers);
if (read_or_buffer == "read")
fs.createReadStream("index.html", opts).pipe(res);
if (read_or_buffer == "buffer") {
const content = fs.readFileSync("index.html");
const stream = new Readable();
stream.push(
opts.start && opts.end
? content.slice(opts.start, opts.end + 1)
: content
);
stream.push(null);
stream.pipe(res);
}
};
};
http.createServer(handler("read")).listen(8080);
// TESTS
const options = { headers: { Range: "bytes=0-4" } };
http.get("http://127.0.0.1:8080/", options, response => {
let data = "";
response.on("data", chunk => (data += chunk));
response.on("end", () => {
console.log(data);
process.exit();
});
});
index.html
Hello world!
解决方案
当服务器接收到从以下地址开始的 http 范围请求时0
:
opts.start && opts.end
评估为 false 因为代码发送的opts.start
是0
整个缓冲区而不是预期的切片。
由于 NodeJS 严格符合 HTTP 规范,因此它不接受请求。
解决方案是验证是否opts.start
存在zero
:
opts.start || opts.start === 0 && opts.end
推荐阅读
- xcode12.5 - 为什么 Xcode 12.5 `xcodebuild -archive` 抱怨没有 AppClip 的应用程序中缺少 appclip 权利?
- c++ - 如果传递了一个数组,如何禁用模板的推导?
- jasper-reports - Jasper 报告 - 不显示列表的第一行
- flask - 如何使用当前图像文件名预填充 WTForm FileField?
- java - 将加密代码从 Java 移至 Flutter
- c# - 如何处理实例化的依赖关系?
- javascript - 具有单独增量的 Javascript 计数器
- javascript - 使用 jquery 和 js 将元素动态添加到元素中
- jsplumb - JSPlumb 工具包许可证
- python - 自动化不适用于我的创建项目过程