HarmonyOS 鸿蒙Next如何实现类似iOS token无感刷新功能

Demo如下：

import rcp from '@hms.collaboration.rcp';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

//拦截器接收数据对象
class ResponseCache {
  private readonly cache: Record<string, rcp.Response> = {};

  getResponse(url: string): rcp.Response {
    return this.cache[url];
  }

  setResponse(url: string, response: rcp.Response): void {
    this.cache[url] = response;
  }
}

let storage: LocalStorage = new LocalStorage();
async function refreshToken(): Promise<string> {
  // 发送请求获取并返回token
  const response = await rcp.createSession().post('https://your-server.com/refresh-token');
  if (response.statusCode === 200) {
    // 注意这里需要返回实际获取的token
    return 'response.refreshToken';
  } else {
    throw new Error('Failed to refresh token');
  }
}


//自定义拦截器
class ResponseCachingInterceptor implements rcp.Interceptor {
  private readonly cache: ResponseCache;

  constructor(cache: ResponseCache) {
    this.cache = cache;
  }

  //拦截器获取数据方法定义
  intercept(context: rcp.RequestContext, next: rcp.RequestHandler): Promise<rcp.Response> {
    // 缓存
    const url = context.request.url.href;
    const responseFromCache = this.cache.getResponse(url);
    if (responseFromCache) {
      return Promise.resolve(responseFromCache);
    }

    const promise = next.handle(context);
    promise.then((resp) => {
      if (resp.statusCode == 401) { // Token 过期
        try {
          refreshToken().then((newToken) => {
            if (context.request.headers) {
              context.request.headers.authorization = 'Bearer ' + newToken
              // 重新用新的token发送原始请求
              const retryResponse = next.handle(context);
              retryResponse.then(res => {
                return retryResponse
              })
            }
          })
        } catch (error) {
          // 处理重新发送失败的请求
        }
      }
      this.cache.setResponse(url, resp);
    });
    return promise;
  }
}

@Entry
@Component
struct Index {
  @State message: string = 'Hello World';
  testUrl = "https://www.baidu.com"

  //get请求方式获取数据
  rcpGetData() {
    let testUrl = this.testUrl
    //定义通信会话对象
    const sessionConfig = rcp.createSession();
    //get请求
    sessionConfig.get(testUrl).then((response) => {
      hilog.info(0x0000, 'testTag', "test---------" + JSON.stringify(response));
      //页面展示请求结果
      AlertDialog.show(
        {
          title: 'request接口回调结果',
          message: '请求网站：' + testUrl + '\n\n' + 'Callback Data: ' + JSON.stringify(response),
        })
    }).catch((err: BusinessError) => {
      AlertDialog.show(
        {
          title: 'request接口回调结果',
          message: '请求失败，错误信息：' + err.data,
        })
      hilog.error(0x0000, 'testTag', "test err:" + JSON.stringify(err));
    });
  }


  //拦截器
  getDataByInterceptor() {
    const cache = new ResponseCache();
    const session = rcp.createSession({
      interceptors: [new ResponseCachingInterceptor(cache)]
    });

    session.get(this.testUrl).then((response) => {
      hilog.info(0x0000, 'testTag', 'get requestData ：' + JSON.stringify(response.request))
      hilog.info(0x0000, 'testTag', 'get headersData ：' + JSON.stringify(response.headers))
    }).catch((err: BusinessError) => {
      hilog.info(0x0000, 'testTag', `err: err code is ${err.code}, err message is ${err.message}`);
    });
  }

  build() {
    Row() {
      Column() {
        //get请求方式获取数据
        Button('getData')
          .onClick(() => {
            this.rcpGetData();
          })
          .type(ButtonType.Capsule)
          .margin({ top: 4 })
          .backgroundColor('#ff1198ee')
          .width('67%')
          .height('4%')
      }
      .width('100%')
    }
    .height('100%')
  }
}