如何在RxJava2中嵌套调用两个Retrofit请求？

嘿，这个问题我刚好有经验，来给你捋清楚～首先明确告诉你：完全可以用flatMap（或者RxJS里更推荐的concatMap/mergeMap）来实现你的需求，哪怕两个Observable返回不同类型、值相互独立也没关系！

核心思路 #

你需要apiService.getFeed()完成后再调用apiService.getProfile()，本质是要顺序执行两个Observable，而concatMap是最适合这个场景的操作符——它会等待前一个Observable完成后，再订阅并执行下一个Observable。

场景1：只需要第二个请求的结果 #

如果页面只需要getProfile()的数据，或者getFeed()只是一个前置初始化请求（不需要在页面展示），可以直接忽略第一个请求的返回值：

import { concatMap, catchError, EMPTY } from 'rxjs';

apiService.getFeed()
  .pipe(
    // 等getFeed完成后，调用getProfile，忽略feed的返回值
    concatMap(() => apiService.getProfile()),
    // 全局捕获错误，这里可以根据需求返回默认值或终止流
    catchError(error => {
      console.error('请求过程出错:', error);
      // 返回EMPTY会让流直接进入complete状态，也可以返回of(defaultProfile)
      return EMPTY;
    })
  )
  .subscribe({
    next: (profileData) => {
      // 拿到profile数据后渲染页面
      console.log('Profile数据:', profileData);
    },
    complete: () => {
      console.log('两个请求都执行完成');
    }
  });

场景2：需要同时保留两个请求的结果 #

如果页面需要同时展示feed和profile的数据，可以在concatMap里把两个值组合成一个对象返回：

import { concatMap, catchError, map, of } from 'rxjs';

apiService.getFeed()
  .pipe(
    concatMap(feedData => 
      // 调用getProfile后，把feed和profile数据合并
      apiService.getProfile().pipe(
        map(profileData => ({ feedData, profileData }))
      )
    ),
    catchError(error => {
      console.error('请求出错:', error);
      // 返回默认值，保证页面能正常渲染
      return of({ feedData: null, profileData: null });
    })
  )
  .subscribe(({ feedData, profileData }) => {
    // 拿到两个数据后渲染页面
    console.log('Feed数据:', feedData);
    console.log('Profile数据:', profileData);
  });

错误处理的进阶：单独处理每个请求的错误 #

如果希望某个请求出错时，不中断另一个请求的执行（比如getFeed出错了，依然要加载profile数据），可以给每个Observable单独添加catchError：

import { concatMap, catchError, map, of } from 'rxjs';

// 定义默认数据
const defaultFeed = { items: [] };
const defaultProfile = { name: '默认用户' };

apiService.getFeed()
  .pipe(
    // 单独处理feed请求的错误，返回默认feed数据
    catchError(() => of(defaultFeed)),
    concatMap(feedData => 
      apiService.getProfile().pipe(
        // 单独处理profile请求的错误，返回默认profile数据
        catchError(() => of(defaultProfile)),
        map(profileData => ({ feedData, profileData }))
      )
    )
  )
  .subscribe(data => {
    // 不管哪个请求出错，都能拿到数据渲染页面
    renderPage(data.feedData, data.profileData);
  });

关于flatMap的疑问 #

你提到的flatMap其实是RxJS中mergeMap的别名，它和concatMap的区别在于：

• concatMap：严格顺序执行，必须等前一个Observable完成才会执行下一个
• mergeMap：只要前一个Observable发出值就会执行下一个（如果前一个是多值流，可能会并发）

因为你的两个请求都是单次HTTP请求（只会发出一次值然后完成），所以mergeMap和concatMap的效果是一样的，但concatMap更能明确表达“顺序执行”的意图，所以更推荐用它。

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