1. 程式人生 > >C# http請求工具類

C# http請求工具類

    /// <summary>
    /// Http請求操作類之HttpWebRequest
    /// </summary>
    public class HttpHelper
    {
        #region properties

        private ILog _logger;
        private readonly Encoding ENCODING = Encoding.UTF8;
        #endregion

        #region constructor
        public HttpHelper()
        {
            
this._logger = LogManager.GetLogger("HttpHelper"); } #endregion #region public methods /// <summary> /// Post /// </summary> /// <param name="url"></param> /// <param name="msg"></param> /// <returns></returns>
public string HTTPJsonPost(string url, string msg) { string result = string.Empty; try { this._logger.InfoFormat("HTTPJsonPostUrl:{0}", url); this._logger.InfoFormat("HTTPJsonPostMsg:{0}", msg); result
= CommonHttpRequest(msg, url, "POST"); //if (!result.Contains("\"Code\":200")) //{ // throw new Exception(result); //} } catch (WebException ex) { if (ex.Response != null) { HttpWebResponse response = (HttpWebResponse)ex.Response; Console.WriteLine("Error code: {0}", response.StatusCode); switch (response.StatusCode) { case HttpStatusCode.BadRequest: case HttpStatusCode.Forbidden: case HttpStatusCode.InternalServerError: { using (Stream data = response.GetResponseStream()) { using (StreamReader reader = new StreamReader(data)) { string text = reader.ReadToEnd(); throw new Exception(text); } } } break; } } this._logger.ErrorFormat("HTTPJsonPost異常:{0}", ex.Message); } catch (Exception ex) { this._logger.ErrorFormat("HTTPJsonPost異常:{0}", ex.Message); throw new Exception(ex.Message); } return result; } /// <summary> /// Get /// </summary> /// <param name="url"></param> /// <returns></returns> public string HTTPJsonGet(string url) { string result = string.Empty; try { this._logger.InfoFormat("HTTPJsonPostUrl:{0}", url); HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest; request.ContentType = "application/json"; request.Method = "GET"; HttpWebResponse resp = request.GetResponse() as HttpWebResponse; System.IO.StreamReader reader = new System.IO.StreamReader(resp.GetResponseStream(), this.ENCODING); result = reader.ReadToEnd(); } catch (Exception ex) { this._logger.ErrorFormat("HTTPJsonGet異常:{0}", ex.Message); } return result; } /// <summary> /// Put /// </summary> /// <param name="data"></param> /// <param name="uri"></param> /// <returns></returns> public string HTTPJsonDelete(string url, string data) { return CommonHttpRequest(data, url, "DELETE"); } /// <summary> /// Put /// </summary> /// <param name="data"></param> /// <param name="uri"></param> /// <returns></returns> public string HTTPJsonPut(string url, string data) { return CommonHttpRequest(data, url, "PUT"); } #endregion #region private public string CommonHttpRequest(string data, string uri, string type) { //Web訪問物件,構造請求的url地址 string serviceUrl = uri; //構造http請求的物件 HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(serviceUrl); myRequest.Timeout = 600000; //轉成網路流 byte[] buf = this.ENCODING.GetBytes(data); //設定 myRequest.Method = type; myRequest.ContentLength = buf.LongLength; myRequest.ContentType = "application/json"; //將客戶端IP加到標頭檔案中 string sRealIp = GetHostAddress(); if (!string.IsNullOrEmpty(sRealIp)) { myRequest.Headers.Add("ClientIp", sRealIp); } using (Stream reqstream = myRequest.GetRequestStream()) { reqstream.Write(buf, 0, (int)buf.Length); } HttpWebResponse resp = myRequest.GetResponse() as HttpWebResponse; System.IO.StreamReader reader = new System.IO.StreamReader(resp.GetResponseStream(), this.ENCODING); string ReturnXml = reader.ReadToEnd(); reader.Close(); resp.Close(); return ReturnXml; } #endregion /// <summary> /// 獲取客戶端IP地址(無視代理) /// </summary> /// <returns>若失敗則返回回送地址</returns> public static string GetHostAddress() { try { string userHostAddress = HttpContext.Current.Request.UserHostAddress; if (string.IsNullOrEmpty(userHostAddress)) { userHostAddress = HttpContext.Current.Request.ServerVariables["REMOTE_ADDR"]; } //最後判斷獲取是否成功,並檢查IP地址的格式(檢查其格式非常重要) if (!string.IsNullOrEmpty(userHostAddress) && IsIP(userHostAddress)) { return userHostAddress; } return "127.0.0.1"; } catch { return "127.0.0.1"; } } /// <summary> /// 檢查IP地址格式 /// </summary> /// <param name="ip"></param> /// <returns></returns> public static bool IsIP(string ip) { return System.Text.RegularExpressions.Regex.IsMatch(ip, @"^((2[0-4]\d|25[0-5]|[01]?\d\d?)\.){3}(2[0-4]\d|25[0-5]|[01]?\d\d?)$"); } public static long ConvertDataTimeLong(DateTime dt) { DateTime dtStart = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1)); TimeSpan toNow = dt.Subtract(dtStart); long timeStamp = toNow.Ticks; timeStamp = long.Parse(timeStamp.ToString().Substring(0, timeStamp.ToString().Length - 4)); return timeStamp; } public static DateTime ConvertLongDateTime(long d) { DateTime dtStart = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1)); long lTime = long.Parse(d + "0000"); TimeSpan toNow = new TimeSpan(lTime); DateTime dtResult = dtStart.Add(toNow); return dtResult; }    private string ConvertToJsonString<T>(T model) { DataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(T)); var stream = new MemoryStream(); serializer.WriteObject(stream, model); byte[] dataBytes = new byte[stream.Length]; stream.Position = 0; stream.Read(dataBytes, 0, (int)stream.Length); string dataString = Encoding.UTF8.GetString(dataBytes); return dataString; } } /// <summary> /// Http請求操作類之WebClient /// </summary> public static class WebClientHelper { public static string Post(string url, string jsonData) { var client = new WebClient(); client.Headers.Add(HttpRequestHeader.ContentType, "application/json"); client.Encoding = System.Text.Encoding.UTF8; byte[] data = Encoding.UTF8.GetBytes(jsonData); byte[] responseData = client.UploadData(new Uri(url), "POST", data); string response = Encoding.UTF8.GetString(responseData); return response; } public static void PostAsync(string url, string jsonData, Action<string> onComplete, Action<Exception> onError) { var client = new WebClient(); client.Headers.Add(HttpRequestHeader.ContentType, "application/json"); client.Encoding = System.Text.Encoding.UTF8; byte[] data = Encoding.UTF8.GetBytes(jsonData); client.UploadDataCompleted += (s, e) => { if (e.Error == null && e.Result != null) { string response = Encoding.UTF8.GetString(e.Result); onComplete(response); } else { onError(e.Error); } }; client.UploadDataAsync(new Uri(url), "POST", data); } }  
http請求工具類