主体并不是作为响应的一部分完全存储的,这是因为主体可以包含非常大量的数据,如果它被存储在响应对象上,程序的内存将很快被消耗。
相反,Node.js使用一种叫做流的机制。这种机制允许只保留一小部分数据,并允许程序员决定是在内存中完全使用它,还是将数据的每个部分作为其流使用。
有多种方法可以将数据完全消耗到内存中,因为HTTP Response是可读流,所以res对象上所有可读方法都可用
监听“data”事件并保存传递给回调的数据块
Const chunks = []
Res.on ("data", (chunk) => {
chunks.push(块)
});
Res.on ("end", () => {
const body = Buffer.concat(chunk);
});
当使用这种方法时,您不会干扰流的行为,而只是收集应用程序可用的数据。
使用"readble"事件并调用res.read()
Const chunks = [];
Res.on ("readable", () => {
让块;
While (null !== (chunk = res.read())){
chunks.push(块)
}
});
Res.on ("end", () => {
const body = Buffer.concat(chunk);
});
当采用这种方法时,你完全负责流的流,直到res.read被调用,才会有更多的数据被传递到流中。
使用异步迭代器
Const chunks = [];
For await (const chunk of readable) {
chunks.push(块);
}
const body = Buffer.concat(chunk);
这种方法类似于“数据”事件方法。它将简化范围,并允许整个过程发生在相同的范围内。
虽然如上所述,完全使用响应中的数据是可能的,但如果确实有必要这样做,始终要记住这一点。在许多情况下,可以简单地将数据定向到目的地,而不将其完全保存到内存中。
Node.js读取流,包括HTTP响应,有一个内置的方法来做这件事,这个方法叫做pipe。用法很简单,readStream.pipe(writeStream);。
例如:
如果数据的最终目的地是文件系统,则可以简单地打开到文件系统的写流,然后将数据通过管道传输到其目的地。
const { createWriteStream } = require("fs");
const writeStream = createWriteStream("someFile");
res.pipe(writeStream);