Update:

我扩展 Http 类，当我deleteDocument()我想要处理错误getTicket()然后重试ma请求deleteDocument()与新的this.TICKET :

@Injectable()
export class HttpService extends Http {
    public SERVER_URL: string = 'http://10.0.0.183:8080/alfresco/s/'
    public TICKET: string = ''
    
    constructor(backend: ConnectionBackend, defaultOptions: RequestOptions) {
        super(backend, defaultOptions);
    }
    

    post(url: string, body: any, options?: RequestOptionsArgs): Observable<Response> {
        return this.intercept(super.post(url,body, options));
    }

    intercept(observable: Observable<Response>): Observable<Response> {
        return observable.catch(initialError => {
            if (initialError.status === 401) {
                return this.getTicket()
                    .do(res => {
                        // HERE I WANT RETRY MY FIRST REQUEST
                        this.TICKET = res.json().data.ticket
                    })
            } else {
                return Observable.throw(initialError);
            }
        })
    }

    getTicket() {
        return this.post(this.SERVER_URL + 'api/login', JSON.stringify({username: 'admin', password: 'admin'}))
    }


    deleteDocument(idFile: number) {
        return this.post(this.SERVER_URL + 'dms/file/delfile?idfile=' + idFile + '&alf_ticket=' + this.TICKET, {}).map((data: Response) => data.json())
    }
}

收到新票后，我想使用新网址重试我的第一个请求。谢谢

我不知道是否有更简单的方法，但我会使用concatMap()运算符并递归调用deleteDocument()使用上次调用返回的 id：

这应该模拟您的情况：

import {Observable} from 'rxjs';

function deleteDocument(willFail: bool, id) {
  return Observable.of("I'm your response: " + id)
    // process response and eventualy throw error
    .concatMap(val => {
      if (willFail) {
        return Observable.throw({response: val, message: "It's broken"});
      } else {
        return Observable.of(val);
      }
    })
    // recover from the error
    .catch(initialError => {
      return deleteDocument(false, initialError.response.length);
    });
}

deleteDocument(true, 42).subscribe(result => console.log(result));

观看现场演示：http://plnkr.co/edit/rUbLgEwtw7lSBueKJ5HN?p=preview

这会打印到控制台：

I'm your response: 21

我正在模拟错误willFail争论。操作员concatMap服务器在这里区分错误和正确响应。我也把原件传上来id以及一些仅用于演示目的的处理。

在你的情况下，你会附加到intercept()还有重建原始 HTTP 请求所需的所有参数，而不是this.getTicket().do() use:

return this.getTicket().concatMap(response => {
    var newBody = {id: response.ticketId};
    return this.post(originalUrl, newBody, ...);
});

操作员do()对于调试操作符链中发生的情况最有用，它不会以任何方式修改链。

我不知道你的代码实际上做了什么，但我希望这对你有意义。

也许和你有类似的问题：Observable 继续调用 API 并根据条件更改参数