如何在Asp.Net Core中集成Refit_实用技巧_

 using System; using System.Collections.Generic; using System.ComponentModel.DataAnnotations; using System.Net; using System.Net.Http; using System.Net.Http.Headers; using System.Text; using System.Threading.Tasks; using System.Web; using Abp.Domain.Services; using Microsoft.Extensions.Logging; using Newtonsoft.Json;   namespace Sunlight.Dms.Parts.Domain.Web {     /// 
     /// HttpClient的帮助类     /// 
     public class DcsPartClientService : DomainService {         private readonly HttpClient _httpClient;         private readonly ILogger _loggerHelper;           public DcsPartClientService(IHttpClientFactory httpClientFactory,                                     ILogger loggerHelper) {             _loggerHelper = loggerHelper;             _httpClient = httpClientFactory.CreateClient(PartsConsts.DcsPartClientName);             if (_httpClient.BaseAddress == null) {                 throw new ArgumentNullException(nameof(httpClientFactory), $"没有配置名称为 {PartsConsts.DcsPartClientName} 的HttpClient，或者接口服务的地址为空");             }         }           /// 
         /// Post请求返回实体         /// 
         /// 请求相对路径         /// 请求数据         /// 实体T         public async Task> PostResponse(string relativeUrl, object postObj) where T : class {               var postData = JsonConvert.SerializeObject(postObj);               _httpClient.DefaultRequestHeaders.Add("user-agent", "Dcs-Parts");             _httpClient.CancelPendingRequests();             _httpClient.DefaultRequestHeaders.Clear();             HttpContent httpContent = new StringContent(postData);               httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");             var result = default(List);             var response = await _httpClient.PostAsync(_httpClient.BaseAddress + relativeUrl, httpContent);             if (response.StatusCode == HttpStatusCode.NotFound) {                 throw new ValidationException("找不到对应的DcsParts服务");             }             var responseContent = await response.Content.ReadAsAsync>>();             if (response.IsSuccessStatusCode) {                 result = responseContent?.Payload;             } else {                 if (!string.IsNullOrWhiteSpace(responseContent?.Message)) {                     throw new ValidationException(responseContent.Message);                 }                   _loggerHelper.LogDebug($"请求返回结果：{0} 请求内容：{1}", response.StatusCode, postData);             }               return await Task.FromResult(result);         }           public async Task> GetResponse(string relativeUrl, object queryObj) where T : class {             var queryData = ModelToUriQueryParam(queryObj);             _httpClient.DefaultRequestHeaders.Add("user-agent", "Dcs-Parts");             _httpClient.CancelPendingRequests();             _httpClient.DefaultRequestHeaders.Clear();             _httpClient.DefaultRequestHeaders.Add("accept", "application/json");               var result = default(List);             var response = await _httpClient.GetAsync(_httpClient.BaseAddress + relativeUrl + queryData);             if (response.StatusCode == HttpStatusCode.NotFound) {                 throw new ValidationException("找不到对应的DcsParts服务");             }             var responseContent = await response.Content.ReadAsAsync>>();             if (response.IsSuccessStatusCode) {                 result = responseContent?.Payload;             } else {                 if (!string.IsNullOrWhiteSpace(responseContent?.Message)) {                     throw new ValidationException(responseContent.Message);                 }             }               return await Task.FromResult(result);         }           private string ModelToUriQueryParam(T t, string url = "") {             var properties = t.GetType().GetProperties();             var sb = new StringBuilder();             sb.Append(url);             sb.Append("?");             foreach (var p in properties) {                 var v = p.GetValue(t, null);                 if (v == null)                     continue;                   sb.Append(p.Name);                 sb.Append("=");                 sb.Append(HttpUtility.UrlEncode(v.ToString()));                 sb.Append("&");             }               sb.Remove(sb.Length - 1, 1);               return sb.ToString();         }     }       public class ReceiveResponseBody where T : class {         public string Message { get; set; }           public T Payload { get; set; }     }       public class ReceiveResponseBody {         public string Message { get; set; }     }     }

 public IServiceProvider ConfigureServices(IServiceCollection services) {           //dcs.part服务           services.AddHttpClient(PartsConsts.DcsPartClientName, config => {               config.BaseAddress = new Uri(_appConfiguration["DependencyServices:DcsParts"]);               config.Timeout = TimeSpan.FromSeconds(60);           });            }　　

 public Startup(IHostingEnvironment env) {             _appConfiguration = env.GetAppConfiguration();             Clock.Provider = ClockProviders.Local;             Environment = env;             Console.OutputEncoding = System.Text.Encoding.UTF8;         }　　

 "DependencyServices": {    "BlobStorage": "http://blob-storage/",    "DcsParts": "http://dcs-parts/",    "DmsAfterSales": "http://dms-after-sales/"  }

 /// 
        /// Post请求返回实体        /// 
        /// 请求相对路径        /// 请求数据        /// 实体T        public async Task> PostResponse(string relativeUrl, object postObj) where T : class {              var postData = JsonConvert.SerializeObject(postObj);              _httpClient.DefaultRequestHeaders.Add("user-agent", "Dcs-Parts");            _httpClient.CancelPendingRequests();            _httpClient.DefaultRequestHeaders.Clear();            HttpContent httpContent = new StringContent(postData);              httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");            var result = default(List);            var response = await _httpClient.PostAsync(_httpClient.BaseAddress + relativeUrl, httpContent);            if (response.StatusCode == HttpStatusCode.NotFound) {                throw new ValidationException("找不到对应的DcsParts服务");            }            var responseContent = await response.Content.ReadAsAsync>>();            if (response.IsSuccessStatusCode) {                result = responseContent?.Payload;            } else {                if (!string.IsNullOrWhiteSpace(responseContent?.Message)) {                    throw new ValidationException(responseContent.Message);                }                  _loggerHelper.LogDebug($"请求返回结果：{0} 请求内容：{1}", response.StatusCode, postData);            }              return await Task.FromResult(result);        }