//调用方式 3秒后超时 重试2次 .net framework 4.5 HttpMessageHandler handler = new TimeoutHandler(2,3000); using (var client = new HttpClient(handler)) { using (var content = new StringContent(""), null, "application/json")) { var response = client.PostAsync("url", content).Result; string result = response.Content.ReadAsStringAsync().Result; JObject jobj = JObject.Parse(result); if (jobj.Value<int>("code") == 1) { } } }
public class TimeoutHandler : DelegatingHandler { private int _timeout; private int _max_count; /// <summary> /// 超时重试 /// </summary> /// <param name="max_count">重试次数</param> /// <param name="timeout">超时时间</param> public TimeoutHandler(int max_count = 3, int timeout = 5000) { base.InnerHandler = new HttpClientHandler(); _timeout = timeout; _max_count = max_count; } protected async override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) { HttpResponseMessage response = null; for (int i = 1; i <= _max_count + 1; i++) { var cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken); cts.CancelAfter(_timeout); try { response = await base.SendAsync(request, cts.Token); if (response.IsSuccessStatusCode) { return response; } } catch (Exception ex) { //请求超时 if (ex is TaskCanceledException) { MyLogService.Print("接口请求超时:" + ex.ToString()); if (i > _max_count) { return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent("{\"code\":-1,\"data\":\"\",\"msg\":\"接口请求超时\"}", Encoding.UTF8, "text/json") }; } MyLogService.Print($"接口第{i}次重新请求"); } else { MyLogService.Error("接口请求出错:" + ex.ToString()); return new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent("{\"code\":-1,\"data\":\"\",\"msg\":\"接口请求出错\"}", Encoding.UTF8, "text/json") }; } } } return response; } }
标签:count,c#,max,重试,int,new,超时,HttpClient From: https://www.cnblogs.com/xxxin/p/17468171.html