MyWebClient.cs 5.9 KB
using log4net;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.NetworkInformation;
using System.Net.Security;
using System.Reflection;
using System.Text;

namespace RemoteSheardObject
{
    public class MyWebClient : WebClient
    {
        private int _timeout;

        /// <summary>
        /// 超时时间(毫秒)
        /// </summary>
        public int Timeout
        {
            get
            {
                return _timeout;
            }
            set
            {
                _timeout = value;
            }
        }

        public MyWebClient()
        {
            this._timeout = 60000;
        }

        public MyWebClient(int timeout)
        {
            this._timeout = timeout;
        }

        protected override WebRequest GetWebRequest(Uri address)
        {
            HttpWebRequest result = (HttpWebRequest)base.GetWebRequest(address);
            result.Timeout = this._timeout;
            return result;
        }
    }
    public class HttpHelper
    {
        static ILog Log = LogManager.GetLogger("RollingLogFileAppender");
        public static bool PingURLIP(string url, int ms = 100)
        {
            string[] urlArray = url.Split('/');
            if (urlArray.Length > 3)
            {
                string ip = urlArray[2];

                Ping pingSender = new Ping();
                PingReply reply = pingSender.Send(ip, ms);//第一个参数为ip地址,第二个参数为ping的时间 
                if (reply.Status == IPStatus.Success)
                {
                    //通
                    return true;
                }
                else
                {
                    //不通 
                    return false;
                }
            }
            return true;
        }
        public static string Post(string url, string paramData, int timeOut = 10000)
        {
            return Post(url, paramData, Encoding.UTF8, timeOut);
        }

        public static string Post(string url, string paramData, Encoding encoding, int timeOut = 10000)
        {

            string result = "";

            if (url.ToLower().IndexOf("https", System.StringComparison.Ordinal) > -1)
            {
                ServicePointManager.ServerCertificateValidationCallback =
                               new RemoteCertificateValidationCallback((sender, certificate, chain, errors) => { return true; });
            }

            try
            {
                using (var wc = new MyWebClient(timeOut))
                {
                    if (string.IsNullOrEmpty(wc.Headers["Content-Type"]))
                    {
                        wc.Headers.Add("Content-Type", "application/json;charset=UTF-8");
                    }
                    wc.Headers.Add("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                    wc.Encoding = encoding;

                    result = wc.UploadString(url, "POST", paramData);
                }
                //LogUtil.info(result);
            }
            catch (Exception e)
            {
                Log.Error("POST ERROR:" + e.ToString()+"\r\n"+ url);
            }

            return result;
        }

        public static string Post(string url, NameValueCollection paramData, int timeOut = 10000)
        {

            string result = "";

            if (url.ToLower().IndexOf("https", System.StringComparison.Ordinal) > -1)
            {
                ServicePointManager.ServerCertificateValidationCallback =
                               new RemoteCertificateValidationCallback((sender, certificate, chain, errors) => { return true; });
            }

            try
            {
                using (var wc = new MyWebClient(timeOut))
                {
                    byte[] buf = wc.UploadValues(url, "POST", paramData);
                    result = Encoding.UTF8.GetString(buf);
                }
                //LogUtil.info(result);
            }
            catch (Exception e)
            {
                Log.Error("POST ERROR:" + e.ToString() + "\r\n" + url);
            }

            return result;
        }
        static object lockpost = new object();
 
        public static T2 Post<T1,T2>(string url, T1 jsonobject, int timeout = 5000, bool printlog = false)
        {
            string json = "";
            string result = "";
            try
            {
                json = JsonConvert.SerializeObject(jsonobject);
                result = Post(url, json, timeout);
                T2 op = JsonConvert.DeserializeObject<T2>(result);
                if (printlog)
                {
                    Log.Info("Send [" + json + "]  Revice [" + result + "]");
                }
                return op;
            }
            catch (Exception ex)
            {
                Log.Error("Post 出错【"+ json + "】:result:"+ result+"\r\n" + ex);
            }
            return default;
        }
        public static string Get(string url,bool needlog=true)
        {
            return Get(url, Encoding.UTF8);
        }
        public static string Get(string url, Encoding encoding, bool needlog = true, int timeOut = 10000)
        {
            try
            {
                Debug.WriteLine("HTTP GET FROM: " + url);
                using (var wc = new MyWebClient { Encoding = encoding })
                {
                    var readStream = wc.OpenRead(url);
                    using (var sr = new StreamReader(readStream, encoding))
                    {
                        var result = sr.ReadToEnd();
                        Debug.WriteLine("receive << " + result);
                        return result;
                    }
                }
            }
            catch (Exception e)
            {
                Log.Error("HTTP GET ERROR:" + e.Message);
            }
            return "";
        }
    }
}