为什么 Streams API 改变了 Web 开发者的游戏规则-js教程-PHP中文网

为什么 Streams API 改变了 Web 开发者的游戏规则

DDD

发布： 2024-09-16 08:06:04

转载

686人浏览过

我们首先解释一下数据是如何通过网络发送的。它不是作为单个连续流发送的；相反，它被分成更小的块。在接收端，消费者或应用程序负责在收到所有数据后以正确的顺序和格式重新组装这些块。对于图像、视频和其他相对较大的数据类型，此过程会自动发生。

为什么 Streams API 改变了 Web 开发者的游戏规则

因此 streams api 提供的是一种无需等待完整数据可用的方法

在消费者阶段以块的形式接收数据时实时处理数据，这在处理大量数据（如我在本文中展示的示例）时非常有用且至关重要。
它还允许您将我们的数据视为流，当您想要发送特定类型的块时，这在后端非常有用，而当您使用类似的工作人员通过网络发送大文件时，这在前端非常有用”

修订文本：“streams api 提供的是一种在数据到达时处理数据的方法，而不是等待整个数据集可用。以下是两个主要优点：

实时数据处理：它允许您实时处理分块接收的数据。在处理大量数据时，例如我将在本文中讨论的示例，此功能至关重要。（本文重点关注第一部分）
基于流的数据管理：streams api 使您能够将数据视为连续流。这对于后端以特定块发送数据以及在前端使用 web worker 高效上传大文件非常有用。

让我们首先比较使用 fetch api 接收数据的传统方法与新的 streams api 方法。

使用 fetch api 的传统方法

fetch("url") .then((response) => {
// note that there is a middle step before we receive the final data
// let's see what we actually receive
console.log(response.body); return response.text(); }) .then((data) => { // perform operations with the data
});

登录后复制

在此示例中，response.body 是一个 readablestream 对象：

readablestream { locked: false, state: 'readable', supportsbyob: true }

登录后复制

在这里，我们遇到了 streams api 的第一个组件：readablestream。 readablestream 构造函数创建并返回一个可读的流对象，这使我们能够更有效地处理流数据。我们可以使用这个构造函数来管理数据块，而不是等待整个数据集可用。

{ arraybuffer(): promise<arraybuffer>; blob(): promise<blob>; formdata(): promise<formdata>; json(): promise<any>; text(): promise<string>; }

登录后复制

我们需要实现一个函数来处理对象以访问实时发送的数据。这个函数应该：
1 接收 readablestream 作为承诺。

等待接收所有数据块。
将块合并到完整数据集中。返回完整数据作为承诺。

为什么 Streams API 改变了 Web 开发者的游戏规则

深入 readablestream

interface readablestream<r = any> {
  readonly locked: boolean;
  cancel(reason?: any): promise<void>;
  getreader(options: { mode: "byob" }): readablestreambyobreader;
  getreader(): readablestreamdefaultreader<r>;
  getreader(options?: readablestreamgetreaderoptions): readablestreamreader<r>;
  pipethrough<t>(
    transform: readablewritablepair<t, r>,
    options?: streampipeoptions
  ): readablestream<t>;
  pipeto(
    destination: writablestream<r>,
    options?: streampipeoptions
  ): promise<void>;
  tee(): [readablestream<r>, readablestream<r>];
}

登录后复制

interface readablestreamdefaultreader<r = any>
  extends readablestreamgenericreader {
  read(): promise<readablestreamreadresult<r>>;
  releaselock(): void;
}

登录后复制

为了使用流，我们使用 getreader() ，它返回一个 readablestreamdefaultreader。

下面是一个示例，我们向 lichess.org 的 api 向某个用户请求 pgn 格式（将其视为文本）的游戏。最终结果应该以文本形式呈现。

fetch("https://lichess.org/api/games/user/gg").then((response) => {
  console.log(response);
  const readablestream = response.body;
  console.log(readablestream);
  const reader = readablestream.getreader();
  console.log(reader);
});

登录后复制

输出：

readablestream { locked: false, state: 'readable', supportsbyob: true } readablestreamdefaultreader { stream: readablestream { locked: true, state: 'readable', supportsbyob: true }, readrequests: 0, close: promise { <pending> } }

登录后复制

请注意，您不能同时拥有多个读取器，因为如果 readablestream.locked = true，getreader() 将抛出错误，因此如果您想更改读取器，您必须首先使用 readablestreamdefaultreader 释放锁定。释放锁()

fetch("https://lichess.org/api/games/user/gg").then((response) => {
  const readablestream = response.body;
  console.log(readablestream);
  const reader = readablestream.getreader();
  console.log(reader);
  try {
    reader.releaselock();
    const reader2 = readablestream.getreader(); 
// won't throw an error
    const reader3 = readablestream.getreader(); 
// will throw an error
  } catch (e) {
    console.error(e.message); 
// invalid state: readablestream is locked
  }
});

登录后复制

现在我们在阅读器中使用 read 函数，它有两个变量

value：在 uintarray 中包含当前块内容，我们可以通过将每个 int 转换为 char 并合并或简单地使用 textdecoder().decode() 将其转换为字符串

let string = result.push(
  value.reduce((p, c) => {
    return p + c.fromcharcode();
  }, "")
); // or
let string = new textdecoder().decode(value); 
// both achieve the same thing converting uint8array to string

登录后复制

完整代码示例

这是处理流和合并块的完整示例：

fetch("https://lichess.org/api/games/user/gg")
  .then((response) => {
    return new promise((resolve, reject) => {
      const readablestream = response.body;
      const reader = readablestream.getreader();
      let result = [];
      reader.read().then(function handlechunks({ done, value }) {
        if (done) {
          resolve(result);
          return;
        }
        const pgn = new textdecoder().decode(value);
        result.push(pgn);
        reader.read().then(handlechunks);
      });
    });
  })
  .then((result) => {
    console.log(result);
  });

登录后复制

// console.log(value)
uint8array(551) [
     91,  69, 118, 101, 110, 116,  32,  34,  82,  97, 116, 101,
    100,  32,  98, 108, 105, 116, 122,  32, 103,  97, 109, 101,
     34,  93,  10,  91,  83, 105, 116, 101,  32,  34, 104, 116,
    116, 112, 115,  58,  47,  47, 108, 105,  99, 104, 101, 115,
    115,  46, 111, 114, 103,  47,  90, 122,  78,  66,  90, 119,
    100,  71,  34,  93,  10,  91,  68,  97, 116, 101,  32,  34,
     50,  48,  50,  48,  46,  48,  49,  46,  49,  48,  34,  93,
     10,  91,  87, 104, 105, 116, 101,  32,  34,  86, 101, 101,
    118, 101, 101,  50,
    ... 451 more items
  ]
// console.log(new textdecoder().decode(value))
[event "rated blitz game"]
[site "https://lichess.org/zznbzwdg"]
[date "2020.01.10"]
[white "veevee222"]
[black "gg"]
[result "0-1"]
[utcdate "2020.01.10"]
[utctime "20:21:02"]
[whiteelo "1858"]
[blackelo "1863"]
[whiteratingdiff "-6"]
[blackratingdiff "+35"]
[variant "standard"]
[timecontrol "180+0"]
[eco "c00"]
[termination "normal"]

登录后复制

1. e4 e6 2. d4 d6 3. c4 Nf6 4. Nc3 c5 5. f4 cxd4 6. Qxd4 Nc6 7. Qd1 b6 8. g3 Bb7 9. Bg2 Rc8 10. Nf3 Be7 11. O-O O-O 12. b3 Nb4 13. Bb2 a5 14. Re1 Qc7 15. a3 Na6 16. Rc1 Nc5 17. Qd4 Nxb3 18. Qd1 Nxc1 19. e5 0-1

登录后复制

例如链接

例如，完整代码请

为什么 Streams API 改变了 Web 开发者的游戏规则