分类导航

程序问答发布时间：2022-06-02 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了使用堆栈 Angular/Express/MongoDB 拆分 HTTP 请求，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决使用堆栈 Angular/Express/MongoDB 拆分 http 请求？

开发过程中遇到使用堆栈 Angular/Express/MongoDB 拆分 http 请求的问题如何解决？下面主要结合日常开发的经验，给出你关于使用堆栈 Angular/Express/MongoDB 拆分 http 请求的解决方法建议，希望对你解决使用堆栈 Angular/Express/MongoDB 拆分 http 请求有所启发或帮助；

我有数百个元素要从 MongoDB 数据库中获取并在前端打印。将所有内容提取到单个请求中可能会降低性能，因为它在正文响应中携带大量有效负载。因此，我正在寻找一种解决方案，将我的 Angular 请求拆分为多个并且同时约束。

示例：

@H_993_2@mongoDB 集合：元素（_ID，名称，子项，...）文档：10000+

但我们只需要大约 100-500 个元素

角度：

    const observables = [];
    const iteration = 5,IDParent = 'eufe4839ffcdsj489483'; // example
    for (let i = 0; i < iteration; i++) {
      observables.push(
        this.myhttpservice.customgetmethod<Element>(ColLECTION_name,endpoint,'IDParent=' + IDParent + '&limit=??')); // url with query
    }

    forkJoin(observables).subscribe(
      data => {
           this.elements.push(data[0]);
           this.elements.push(data[1]);
      },err => console.error(err)
    );

我使用 forkJoin 是因为我需要同时请求以获得更好的性能。这个想法是向后端发送多个具有不同限制参数值的请求，并在最后将整个元素集放入数据对象中。唯一的目的是拆分请求以避免由于有效负载主体的大小而导致的大延迟和可能的错误。

我如何继续使用给定的堆栈来执行这样的操作？我想避免使用 websockets。

解决方法

我认为 fork.join 用于并行解析所有 observable，但您需要等待所有请求，如果一个请求失败怎么办？ forkJoin 会在遇到第一个错误时立即完成，您有点无法知道它来自哪个 observable ，但是如果您处理内部 observable 中的错误，您可以轻松实现这一点。

const observables = [];
    const iteration = 5,idParent = 'eufe4839ffcdsj489483'; // example
    for (let i = 0; i < iteration; i++) {
      observables.push(
        this.myhttpservice.customGetMethod<Element>(COLLECTION_NAME,endpoint,'idParent=' + idParent + '&limit=??')).pipe(catchError(() => {
       throw `an Error request #: ${i}`;
     }); // url with query
    }

    forkJoin(observables).subscribe(
      data => {
           this.elements.push(data[0]);
           this.elements.push(data[1]);
      },err => console.error(err)
    );