C#实现的全能HTTP POST工具类-编程阁

C#实现的全能HTTP POST工具类，整合了多种协议格式、安全认证和扩展能力，支持JSON、表单、文件上传等场景：

一、核心工具类实现

usingSystem;usingSystem.Collections.Generic;usingSystem.IO;usingSystem.Net;usingSystem.Net.Http;usingSystem.Text;usingSystem.Threading.Tasks;usingNewtonsoft.Json;publicclassHttpPostHelper{privatereadonlyHttpClient_httpClient;privatereadonlyDictionary<string,string>_defaultHeaders=new();publicHttpPostHelper(){_httpClient=newHttpClient();_httpClient.DefaultRequestHeaders.ExpectContinue=false;_httpClient.DefaultRequestHeaders.ConnectionClose=true;}// 添加全局HeaderpublicvoidAddHeader(stringkey,stringvalue){_defaultHeaders[key]=value;}// 基础POST方法（同步）publicstringPost(stringurl,objectdata=null,ContentTypecontentType=ContentType.Json,stringtoken=null,Encodingencoding=null){varrequest=CreateRequest(url,HttpMethod.Post,data,contentType,token);returnExecuteRequest(request);}// 基础POST方法（异步）publicasyncTask<string>PostAsync(stringurl,objectdata=null,ContentTypecontentType=ContentType.Json,stringtoken=null,Encodingencoding=null){varrequest=CreateRequest(url,HttpMethod.Post,data,contentType,token);returnawaitExecuteRequestAsync(request);}// 文件上传publicasyncTask<HttpResponseMessage>UploadFile(stringurl,stringfilePath,stringfieldName="file",objectformData=null){usingvarcontent=newMultipartFormDataContent();varfileContent=newByteArrayContent(File.ReadAllBytes(filePath));fileContent.Headers.ContentType=MediaTypeHeaderValue.Parse("application/octet-stream");content.Add(fileContent,fieldName,Path.GetFileName(filePath));if(formData!=null){foreach(varpropinformData.GetType().GetProperties()){content.Add(newStringContent(prop.GetValue(formData)?.ToString()??""),prop.Name);}}varresponse=await_httpClient.PostAsync(url,content);response.EnsureSuccessStatusCode();returnresponse;}privateHttpRequestMessageCreateRequest(stringurl,HttpMethodmethod,objectdata,ContentTypecontentType,stringtoken){varrequest=newHttpRequestMessage(method,url);// 设置认证信息if(!string.IsNullOrEmpty(token)){request.Headers.Authorization=newAuthenticationHeaderValue("Bearer",token);}// 合并Headersforeach(varheaderin_defaultHeaders){request.Headers.Add(header.Key,header.Value);}// 处理请求体if(data!=null){varcontent=newStringContent(JsonConvert.SerializeObject(data),Encoding.UTF8);content.Headers.ContentType=MediaTypeHeaderValue.Parse($"application/{contentType}");request.Content=content;}returnrequest;}privatestringExecuteRequest(HttpRequestMessagerequest){try{varresponse=_httpClient.Send(request);response.EnsureSuccessStatusCode();returnresponse.Content.ReadAsStringAsync().Result;}catch(HttpRequestExceptionex){HandleHttpRequestException(ex);returnnull;}}privateasyncTask<string>ExecuteRequestAsync(HttpRequestMessagerequest){try{varresponse=await_httpClient.SendAsync(request);response.EnsureSuccessStatusCode();returnawaitresponse.Content.ReadAsStringAsync();}catch(HttpRequestExceptionex){awaitHandleHttpRequestExceptionAsync(ex);returnnull;}}privatevoidHandleHttpRequestException(HttpRequestExceptionex){// 实现自定义异常处理逻辑Console.WriteLine($"HTTP请求失败:{ex.Message}");}privateasyncTaskHandleHttpRequestExceptionAsync(HttpRequestExceptionex){// 实现异步异常处理逻辑awaitTask.Run(()=>Console.WriteLine($"HTTP请求失败:{ex.Message}"));}}publicenumContentType{Json,FormUrlEncoded,MultipartFormData}

二、核心功能说明

1. 多协议格式支持

// JSON格式varjson=new{Name="Test",Age=30};stringresponse=helper.Post("https://api.example.com",json,ContentType.Json);// 表单格式varformData=new{Username="user",Password="123456"};stringformResponse=helper.Post("https://api.example.com/login",formData,ContentType.FormUrlEncoded);// 文件上传awaithelper.UploadFile("https://api.example.com/upload","test.txt","file",new{description="测试文件"});

2. 安全认证机制

// 添加Bearer Tokenhelper.AddHeader("Authorization","Bearer your_token_here");// 添加自定义认证头helper.AddHeader("X-Api-Key","your_api_key");

3. 高级配置选项

// 配置超时时间helper._httpClient.Timeout=TimeSpan.FromSeconds(30);// 禁用SSL验证（仅测试环境使用）helper._httpClient.DefaultRequestHeaders.Add("Unsafe-SSL","true");

三、扩展功能实现

1. 自定义序列化

publicclassCustomSerializer{publicstaticstringSerialize(objectobj){// 使用System.Text.JsonreturnJsonSerializer.Serialize(obj);// 或使用XmlSerializer// var serializer = new XmlSerializer(obj.GetType());// using var writer = new StringWriter();// serializer.Serialize(writer, obj);// return writer.ToString();}}// 扩展HttpHelperpublicstaticclassHttpPostHelperExtensions{publicstaticstringPostWithCustomSerializer(thisHttpPostHelperhelper,stringurl,objectdata,ContentTypecontentType){varcontent=newStringContent(CustomSerializer.Serialize(data),Encoding.UTF8);content.Headers.ContentType=MediaTypeHeaderValue.Parse($"application/{contentType}");returnhelper.Post(url,data,contentType);}}

2. 自动重试机制

publicstaticclassRetryPolicy{publicstaticasyncTask<string>WithRetry(thisHttpPostHelperhelper,stringurl,Func<Task<string>>action,intmaxRetries=3){intattempt=0;ExceptionlastException=null;do{try{returnawaitaction();}catch(Exceptionex){lastException=ex;attempt++;awaitTask.Delay(TimeSpan.FromSeconds(Math.Pow(2,attempt)));}}while(attempt<maxRetries);thrownewException($"请求失败，已尝试{maxRetries}次",lastException);}}// 使用示例varresult=awaithelper.WithRetry("https://api.example.com",()=>helper.PostAsync("data",retryCount:5));

四、工程实践建议

1. 配置管理

publicclassHttpConfig{publicstringBaseUrl{get;set;}publicintTimeoutSeconds{get;set;}=30;publicboolEnableLogging{get;set;}=true;}// 初始化工具类varconfig=newHttpConfig{BaseUrl="https://api.example.com",TimeoutSeconds=60};varhttpClient=newHttpClient{BaseAddress=newUri(config.BaseUrl),Timeout=TimeSpan.FromSeconds(config.TimeoutSeconds)};

2. 日志记录

publicstaticclassLogger{publicstaticvoidLogRequest(stringmethod,stringurl,objectdata){varlogMessage=$"[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] "+$"{method}{url}\n"+$"Data:{JsonConvert.SerializeObject(data)}";File.AppendAllText("http.log",logMessage+Environment.NewLine);}}// 在HttpHelper中添加日志publicHttpRequestMessageCreateRequest(stringurl,HttpMethodmethod,objectdata,ContentTypecontentType,stringtoken){Logger.LogRequest(method.ToString(),url,data);// ...原有逻辑}

五、使用示例

varhelper=newHttpPostHelper();helper.AddHeader("X-Custom-Header","CustomValue");// 同步请求varresponse=helper.Post("https://api.example.com/data",new{Id=1,Name="Test"},ContentType.FormUrlEncoded,token:"your_token");// 异步请求awaithelper.PostAsync("https://api.example.com/upload",new{File="test.pdf"},ContentType.MultipartFormData);// 文件上传varuploadResponse=awaithelper.UploadFile("https://api.example.com/upload",@"C:\files\document.pdf","document",new{description="季度报告",projectId=1001});