如何在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);        }

 public interface IDmsAfterSalesApi {          [Headers("User-Agent: Dms-Parts")]        [Post("/internal/api/v1/customerAccounts/update")]        Task UpdateCustomerAmount([Body]PartRetailSettlementModel input);          [Headers("User-Agent: Dms-Parts")]        [Post("/internal/api/v1/repairShortagePart/checkCustomerAccount")]        Task RepairShortagePartCheckCustomerAccount([Body]RepairShortagePartModel input);          [Headers("User-Agent: Dms-Parts")]        [Post("/internal/api/v1/vehiclesAndMemberCode/forCoupons")]        Task GetMemberCodeBrandCodeForVehicle(Guid vehicleId);    }

 public class DmsAfterSalesClientService : DomainService {     private readonly IDmsAfterSalesApi _api;     private readonly ILogger _logger;     private const string From = "Dms After Sales";       public DmsAfterSalesClientService(IDmsAfterSalesApi api, ILogger logger) {         _api = api;         _logger = logger;     }       private async Task WrapException(ApiException exception) {         if (exception.StatusCode == System.Net.HttpStatusCode.BadRequest) {             var receivedBody = await exception.GetContentAsAsync();             return new ValidationException($"业务校验失败，{receivedBody.Message} ({From})", exception);         } else {             _logger.LogWarning(exception, "Call Dms After Sales API failed");             return new ApplicationException($"内部调用失败，{exception.Message} ({exception.StatusCode}) ({From})", exception);         }     }       private Exception WrapException(HttpRequestException exception) {         _logger.LogWarning(exception, "Call Dms After Sales API failed");         return new ApplicationException($"内部调用失败，{exception.Message} ({From})", exception);     }       public async Task UpdateCustomerAmount([Body] PartRetailSettlementModel input) {         try {             await _api.UpdateCustomerAmount(input);         } catch (ApiException ex) {             throw await WrapException(ex);         } catch (HttpRequestException ex) {             throw WrapException(ex);         }     }       public async Task RepairShortagePartCheckCustomerAccount([Body] RepairShortagePartModel input) {         try {             var result = await _api.RepairShortagePartCheckCustomerAccount(input);             return result.Payload.BalanceAmount;         } catch (ApiException ex) {             throw await WrapException(ex);         } catch (HttpRequestException ex) {             throw WrapException(ex);         }     }       public async Task GetMemberCodeBrandCodeForVehicle([Body]Guid vehicleId) {         try {             var result = await _api.GetMemberCodeBrandCodeForVehicle(vehicleId);             return result.Payload;         } catch (ApiException ex) {             throw await WrapException(ex);         } catch (HttpRequestException ex) {             throw WrapException(ex);         }     } }

 ///  [global::System.Diagnostics.CodeAnalysis.ExcludeFromCodeCoverage] [global::System.Diagnostics.DebuggerNonUserCode] [Preserve] [global::System.Reflection.Obfuscation(Exclude=true)] partial class AutoGeneratedIDmsAfterSalesApi : IDmsAfterSalesApi {     ///      public HttpClient Client { get; protected set; }     readonly IRequestBuilder requestBuilder;       ///      public AutoGeneratedIDmsAfterSalesApi(HttpClient client, IRequestBuilder requestBuilder)     {         Client = client;         this.requestBuilder = requestBuilder;     }       ///      Task IDmsAfterSalesApi.UpdateCustomerAmount(PartRetailSettlementModel input)     {         var arguments = new object[] { input };         var func = requestBuilder.BuildRestResultFuncForMethod("UpdateCustomerAmount", new Type[] { typeof(PartRetailSettlementModel) });         return (Task)func(Client, arguments);     }       ///      Task IDmsAfterSalesApi.RepairShortagePartCheckCustomerAccount(RepairShortagePartModel input)     {         var arguments = new object[] { input };         var func = requestBuilder.BuildRestResultFuncForMethod("RepairShortagePartCheckCustomerAccount", new Type[] { typeof(RepairShortagePartModel) });         return (Task)func(Client, arguments);     }       ///      Task IDmsAfterSalesApi.GetMemberCodeBrandCodeForVehicle(Guid vehicleId)     {         var arguments = new object[] { vehicleId };         var func = requestBuilder.BuildRestResultFuncForMethod("GetMemberCodeBrandCodeForVehicle", new Type[] { typeof(Guid) });         return (Task)func(Client, arguments);     } }　　

 public IServiceProvider ConfigureServices(IServiceCollection services) {           //refit dms after sales服务           services.AddRefitClient()               .ConfigureHttpClient(c => {                   c.BaseAddress = new Uri(_appConfiguration["DependencyServices:DmsAfterSales"]);                   c.Timeout = TimeSpan.FromMilliseconds(_appConfiguration.GetValue("AppSettings:ServiceTimeOutMs"));               });       }

 [Headers("User-Agent: Dms-Parts", "Content-Type: application/json")]