httpClient 請(qǐng)求接口失敗要重試,一般人想到的可能是 做try catch 然后循環(huán)請(qǐng)求,但是這種方法寫起來很麻煩,而且不優(yōu)雅。今天就說下另外一種重試的方法,就是引入Microsoft.Extensions.Http.Polly,來進(jìn)行請(qǐng)求的重試。
Polly 添加策略分為三種:
1. AddTransientHttpErrorPolicy:是處理Http請(qǐng)求的錯(cuò)誤,如HTTP 5XX 的狀態(tài)碼,HTTP 408 的狀態(tài)碼 以及System.Net.Http.HttpRequestException異常
2. AddPolicyHandler:添加自定義策列
3. AddPolicyHandlerFromRegistry:從Policy注冊(cè)表集合里面選擇添加
1. AddTransientHttpErrorPolicy
//錯(cuò)誤重試上面是間隔都是500毫秒
services.AddHttpClient("client1")
.AddTransientHttpErrorPolicy(builder => builder.WaitAndRetryAsync(3, t => TimeSpan.FromMilliseconds(500))));
或者
//定義每次重試的時(shí)間間隔
services.AddHttpClient("client1")
.AddTransientHttpErrorPolicy(builder => builder.WaitAndRetryAsync(new[] {
TimeSpan.FromSeconds(5),
TimeSpan.FromSeconds(10),
TimeSpan.FromSeconds(30)
})
2. AddPolicyHandler
先定義策略,通過AddPolicyHandler方法添加,該方法接收一個(gè)泛型的IAsyncPolicy<HttpResponseMessage>。HttpResponseMessage我理解為出站請(qǐng)求上下文
var retryPolicy = Policy.Handle<HttpRequestException>()
.OrResult<HttpResponseMessage>(response => {
//異常處理的邏輯
return true;
}).WaitAndRetryAsync(3,t => TimeSpan.FromMilliseconds(50));
services.AddHttpClient("client1")
.AddPolicyHandler(retryPolicy);
3. AddPolicyHandlerFromRegistry
先注冊(cè)策略表服務(wù),為策略表添加策略,最后通過AddPolicyHandlerFromRegistry方法選用某個(gè)或幾個(gè)策略
//注冊(cè),策略表服務(wù)
var registry = services.AddPolicyRegistry();//創(chuàng)建策略var retryPolicy = Policy.Handle<HttpRequestException>().OrResult<HttpResponseMessage>(response => {//異常處理的邏輯return true;
}).WaitAndRetryAsync(3, t => TimeSpan.FromMilliseconds(500));registry.Add("registry1", retryPolicy);
services.AddHttpClient("client1")
.AddPolicyHandlerFromRegistry("registry1");
做一個(gè)例子看下,創(chuàng)建一個(gè)控制臺(tái)程序
using Microsoft.Extensions.DependencyInjection;
using Polly;
using System;
using System.Net.Http;
namespace ConsoleAppTest
{ class Program
{ static void Main(string[] args)
{ Console.WriteLine("Hello World!");
var service = new ServiceCollection();
service.AddHttpClient("client1").AddTransientHttpErrorPolicy(builder => builder.WaitAndRetryAsync(3, t => TimeSpan.FromMilliseconds(500)));
IHttpClientFactory httpClientFactory = service.BuildServiceProvider().GetService<IHttpClientFactory>(); var httpClient = httpClientFactory.CreateClient("client1");
var response = httpClient.GetAsync("http://www.pikoudai.com/");
Console.ReadKey(); } }}
這里的http://www.pikoudai.com/ 其實(shí)是訪問不通的,就是要看看重試是否生效了。
抓包看下程序效果:

可以看到http://www.pikoudai.com/訪問了一次,之后又重試了3次。
Polly除了重試功能外還有斷路器、超時(shí)、隔板隔離、回退、緩存等功能
重試策略(Retry)
重試策略針對(duì)的前置條件是短暫的故障延遲且在短暫的延遲之后能夠自我糾正。允許我們做的是能夠自動(dòng)配置重試機(jī)制。
斷路器(Circuit-breaker)
斷路器策略針對(duì)的前置條件是當(dāng)系統(tǒng)繁忙時(shí),快速響應(yīng)失敗總比讓用戶一直等待更好。保護(hù)系統(tǒng)故障免受過載,Polly可以幫其恢復(fù)。
超時(shí)(Timeout)
超時(shí)策略針對(duì)的前置條件是超過一定的等待時(shí)間,想要得到成功的結(jié)果是不可能的,保證調(diào)用者不必等待超時(shí)。
隔板隔離(Bulkhead Isolation)
隔板隔離針對(duì)的前置條件是當(dāng)進(jìn)程出現(xiàn)故障時(shí),多個(gè)失敗一直在主機(jī)中對(duì)資源(例如線程/ CPU)一直占用。下游系統(tǒng)故障也可能導(dǎo)致上游失敗。這兩個(gè)風(fēng)險(xiǎn)都將造成嚴(yán)重的后果。都說一粒老鼠子屎攪渾一鍋粥,而Polly則將受管制的操作限制在固定的資源池中,免其他資源受其影響。
緩存(Cache)
緩存策略針對(duì)的前置條件是數(shù)據(jù)不會(huì)很頻繁的進(jìn)行更新,為了避免系統(tǒng)過載,首次加載數(shù)據(jù)時(shí)將響應(yīng)數(shù)據(jù)進(jìn)行緩存,如果緩存中存在則直接從緩存中讀取。
回退(Fallback)
操作仍然會(huì)失敗,也就是說當(dāng)發(fā)生這樣的事情時(shí)我們打算做什么。也就是說定義失敗返回操作。