Alamofire/RxSwift如何在状态代码401时自动刷新令牌和重试请求

import Alamofire
import RxSwift

// 定义一个用于刷新令牌的方法
func refreshToken() -> Observable<Void> {
    return Observable.create { observer in
        // 发送刷新令牌请求，并在响应中获取新令牌
        // 这里使用了一个示例的刷新令牌接口，具体实现需要根据后端接口进行修改
        Alamofire.request("http://example.com/refresh_token").responseJSON { response in
            if response.result.isSuccess {
                // 成功获取到新令牌
                // 在这里更新令牌参数或者存储新令牌
                observer.onNext(())
                observer.onCompleted()
            } else {
                // 刷新令牌失败
                observer.onError(response.error ?? NSError(domain: "refreshToken", code: 0, userInfo: nil))
            }
        }
        return Disposables.create()
    }
}

// 创建一个Alamofire的拦截器
let interceptor = Interceptor(retryClosure: { request, response, data, error in
    let statusCode = response?.statusCode ?? 0
    if statusCode == 401 {
        // 当状态代码为401时，触发刷新令牌逻辑
        return refreshToken()
            .flatMap { _ in
                // 更新令牌参数并重新发送原始请求
                var originalRequest = request
                // 在这里更新令牌参数
                originalRequest.headers.update(name: "Authorization", value: "Bearer newToken")
                return Alamofire.request(originalRequest)
            }
    }
    return Observable.error(error ?? AFError.responseSerializationFailed(reason: .inputDataNil))
})

// 创建Alamofire的SessionManager，并设置拦截器
let sessionManager = SessionManager(configuration: URLSessionConfiguration.default, interceptor: interceptor)

// 使用Alamofire发送请求
sessionManager.rx
    .request(.get, "http://example.com/api")
    .responseData()
    .subscribe(onNext: { response, data in
        // 处理请求结果
    }, onError: { error in
        // 处理错误
    })
    .disposed(by: disposeBag)