如何强制ReadableStream按原始顺序输出分块数据

Fetch API返回的 response.body 流本身是严格的先进先出序列，reader.read() 返回的分块字节顺序永远和服务端发送的原始顺序完全一致，不存在流本身乱序的问题。你得到的拼接结果每次不一致，根本原因是 把传输层的随机分块当成了解密逻辑的合法输入边界，和流顺序无关。

• HTTP/TCP传输层的分块大小、拆分位置完全由网络MTU、缓冲区状态、协议拥塞控制逻辑决定，每次请求的分块拆分方式本来就是随机的，没有任何固定规则。
• 绝大多数加解密算法（包括CBC、GCM等常见块加密、流加密模式）都要求输入的密文是连续的字节序列，不能把传输层随机拆分的密文片段直接独立解密——只要某一次分块切在了加密块的中间位置，单块解密的结果就是无效乱码，最终拼接结果自然每次都不一样。
• 你当前的逻辑是「拿到单块传输分片→独立解密单块→拼接解密后的明文」，从流程上就错了。

根据你的需求二选一即可，不需要做任何“强制流顺序”的操作——流本身的顺序已经是对的。

方案1：无需流式处理时，先拼完整密文再解密 #

如果不需要边接收边展示/处理内容，直接先按接收顺序拼完所有密文，再一次性解密，结果100%一致：

fetch(myRequest, myInit).then(async response => {
  const reader = response.body.getReader();
  const cipherChunks = [];
  let totalLen = 0;
  // 按顺序收集所有密文分块
  while (true) {
    const { done, value } = await reader.read();
    if (done) break;
    cipherChunks.push(value);
    totalLen += value.length;
  }
  // 拼接完整密文
  const fullCipher = new Uint8Array(totalLen);
  let offset = 0;
  for (const chunk of cipherChunks) {
    fullCipher.set(chunk, offset);
    offset += chunk.length;
  }
  // 一次性解密
  const decryptedResult = cryptor.decrypt(fullCipher).toArrayBuffer();
  if (counter == length) {
    callback(obj);
  }
  return decryptedResult;
})

方案2：需要流式处理时，用增量解密器维护上下文 #

如果要边接收边解密降低内存占用，不要每次对单个传输分块调用decrypt，初始化一个支持增量处理的解密实例，按接收顺序把每个分片喂给解密器，由解密器内部维护加密块边界、偏移量和校验状态，只拼接解密器输出的明文段：

fetch(myRequest, myInit).then(response => {
  const reader = response.body.getReader();
  // 初始化支持增量更新的解密器，对应你所用加密库的流式解密方法（如CryptoJS的createDecryptor）
  const incrementalDecryptor = cryptor.createDecryptor();
  const plainChunks = [];
  return new ReadableStream({
    async start(controller) {
      while (true) {
        const { done, value } = await reader.read();
        if (done) {
          // 解密收尾，拿到最后一段残留明文
          const finalPlain = incrementalDecryptor.finalize().toArrayBuffer();
          if (finalPlain) plainChunks.push(finalPlain);
          // 拼接最终完整明文
          const fullPlain = arrayBufferConcat(...plainChunks);
          if (counter == length) {
            callback(obj);
          }
          controller.close();
          break;
        }
        // 按接收顺序喂给增量解密器，不要独立解密单个传输分块
        const plainChunk = incrementalDecryptor.process(value).toArrayBuffer();
        if (plainChunk) {
          plainChunks.push(plainChunk);
          controller.enqueue(plainChunk);
        }
      }
    }
  })
})

注意：不要尝试通过配置固定传输层的分块大小，上层JS代码没有权限控制网络栈的拆包逻辑，也完全不需要做这种控制——只要保证密文字节按接收顺序连续输入解密逻辑，结果就不会出错。

内容的提问来源于stack exchange，提问作者Jacob