zoukankan      html  css  js  c++  java
  • http连接基础类,负责底层的http通信

    /// <summary>
        /// http连接基础类,负责底层的http通信
        /// </summary>
        public class HttpService
        {
    
            public static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
            {
                //直接确认,否则打不开    
                return true;
            }
    
            public static string Post(string xml, string url, int timeout)
            {
                System.GC.Collect();//垃圾回收,回收没有正常关闭的http连接
    
                string result = "";//返回结果
    
                HttpWebRequest request = null;
                HttpWebResponse response = null;
                Stream reqStream = null;
    
                try
                {
                    //设置最大连接数
                    ServicePointManager.DefaultConnectionLimit = 200;
                    //设置https验证方式
                    if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
                    {
                        ServicePointManager.ServerCertificateValidationCallback =
                                new RemoteCertificateValidationCallback(CheckValidationResult);
                    }
    
                    /***************************************************************
                    * 下面设置HttpWebRequest的相关属性
                    * ************************************************************/
                    request = (HttpWebRequest)WebRequest.Create(url);
    
                    request.Method = "POST";
                    request.Timeout = timeout * 1000;
    
                    //设置代理服务器
                    //WebProxy proxy = new WebProxy();                          //定义一个网关对象
                    //proxy.Address = new Uri(WxPayConfig.PROXY_URL);              //网关服务器端口:端口
                    //request.Proxy = proxy;
    
                    //设置POST的数据类型和长度
                    request.ContentType = "application/json";
                    byte[] data = System.Text.Encoding.UTF8.GetBytes(xml);
                    request.ContentLength = data.Length;
    
                    //往服务器写入数据
                    reqStream = request.GetRequestStream();
                    reqStream.Write(data, 0, data.Length);
                    reqStream.Close();
    
                    //获取服务端返回
                    response = (HttpWebResponse)request.GetResponse();
    
                    //获取服务端返回数据
                    StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
                    result = sr.ReadToEnd().Trim();
                    sr.Close();
                }
                catch (System.Threading.ThreadAbortException e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService,"+ "Thread - caught ThreadAbortException - resetting.");
                    WriteErrorLog.WriteLogWeb("Exception message: {0}"+ e.Message);
                    System.Threading.Thread.ResetAbort();
                }
                catch (WebException e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService,"+ e.ToString());
                    if (e.Status == WebExceptionStatus.ProtocolError)
                    {
                        WriteErrorLog.WriteLogWeb("HttpService,"+ "StatusCode : " + ((HttpWebResponse)e.Response).StatusCode);
                        WriteErrorLog.WriteLogWeb("HttpService,"+ "StatusDescription : " + ((HttpWebResponse)e.Response).StatusDescription);
                    }
                    throw e;
                }
                catch (Exception e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService,"+ e.ToString());
                    throw e;
                }
                finally
                {
                    //关闭连接和流
                    if (response != null)
                    {
                        response.Close();
                    }
                    if (request != null)
                    {
                        request.Abort();
                    }
                }
                return result;
            }
    
            /// <summary>
            /// 处理http GET请求,返回数据
            /// </summary>
            /// <param name="url">请求的url地址</param>
            /// <returns>http GET成功后返回的数据,失败抛WebException异常</returns>
            public static string Get(string url)
            {
                System.GC.Collect();
                string result = "";
                WriteErrorLog.WriteLogWeb("HttpService Get 请求地址:"+ url);
                HttpWebRequest request = null;
                HttpWebResponse response = null;
    
                //请求url以获取数据
                try
                {
                    //设置最大连接数
                    ServicePointManager.DefaultConnectionLimit = 200;
                    //设置https验证方式
                    if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
                    {
                        ServicePointManager.ServerCertificateValidationCallback =
                                new RemoteCertificateValidationCallback(CheckValidationResult);
                    }
    
                    /***************************************************************
                    * 下面设置HttpWebRequest的相关属性
                    * ************************************************************/
                    request = (HttpWebRequest)WebRequest.Create(url);
    
                    request.Method = "GET";
    
                    //设置代理
                    //WebProxy proxy = new WebProxy();
                    //proxy.Address = new Uri(WxPayConfig.PROXY_URL);
                    //request.Proxy = proxy;
    
                    //获取服务器返回
                    response = (HttpWebResponse)request.GetResponse();
    
                    //获取HTTP返回数据
                    StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
                    result = sr.ReadToEnd().Trim();
                    sr.Close();
                }
                catch (System.Threading.ThreadAbortException e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService"+ ",Thread - caught ThreadAbortException - resetting.");
                    WriteErrorLog.WriteLogWeb("Exception message: {0}"+ e.Message);
                    System.Threading.Thread.ResetAbort();
                }
                catch (WebException e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService"+ e.ToString());
                    if (e.Status == WebExceptionStatus.ProtocolError)
                    {
                        WriteErrorLog.WriteLogWeb("HttpService"+",StatusCode : " + ((HttpWebResponse)e.Response).StatusCode);
                        WriteErrorLog.WriteLogWeb("HttpService"+ ",StatusDescription : " + ((HttpWebResponse)e.Response).StatusDescription);
                    }
                    throw e;
                }
                catch (Exception e)
                {
                    WriteErrorLog.WriteLogWeb("HttpService,"+ e.ToString());
                    throw e;
                }
                finally
                {
                    //关闭连接和流
                    if (response != null)
                    {
                        response.Close();
                    }
                    if (request != null)
                    {
                        request.Abort();
                    }
                }
                return result;
            }
        }
    

      

  • 相关阅读:
    第六周Java学习总结
    结对编程练习_四则运算(一)
    实验一Java开发环境的熟悉
    第四周Java学习总结
    第三周Java学习总结
    2019-2020-2 20175230滕星《网络对抗技术》Exp9 Web安全基础
    2019-2020-2 20175230 滕星《网络对抗技术》Exp 8 Web基础
    2019-2020-2 20175230滕星《网络对抗技术》Exp7 网络欺诈防范
    2019-2020-2 网络对抗技术 20175230滕星 Exp6 MSF基础应用
    2019-2020-2 网络对抗技术 20175230滕星 Exp5 信息搜集与漏洞扫描
  • 原文地址:https://www.cnblogs.com/vincentvoid/p/6321883.html
Copyright © 2011-2022 走看看