HttpHelper类的调用方法详解

/// <summary>
 /// Http操作类
 /// </summary>
 public class HttpHelper
 {
  private static log4net.ILog mLog = log4net.LogManager.GetLogger("HttpHelper");

  [DllImport("wininet.dll", CharSet = CharSet.Auto, SetLastError = true)]
  public static extern bool InternetSetCookie(string lpszUrlName, string lbszCookieName, string lpszCookieData);

  [DllImport("wininet.dll", CharSet = CharSet.Auto, SetLastError = true)]
  public static extern bool InternetGetCookie(string lpszUrlName, string lbszCookieName, StringBuilder lpszCookieData, ref int lpdwSize);
  public static StreamReader mLastResponseStream = null;
  public static System.IO.StreamReader LastResponseStream
  {
   get { return mLastResponseStream; }
  }
  private static CookieContainer mCookie = null;
  public static CookieContainer Cookie
  {
   get { return mCookie; }
   set { mCookie = value; }
  }
  private static CookieContainer mLastCookie = null;
  public static HttpWebRequest CreateWebRequest(string url, HttpRequestType httpType, string contentType, string data, Encoding requestEncoding, int timeout, bool keepAlive)
  {
   if (String.IsNullOrWhiteSpace(url))
   {
    throw new Exception("URL为空");
   }
   HttpWebRequest webRequest = null;
   Stream requestStream = null;
   byte[] datas = null;
   switch (httpType)
   {
    case HttpRequestType.GET:
    case HttpRequestType.DELETE:
     if (!String.IsNullOrWhiteSpace(data))
     {
      if (!url.Contains('?'))
      {
       url += "?" + data;
      }
      else url += "&" + data;
     }
     if(url.StartsWith("https:"))
     {
      System.Net.ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12;
      ServicePointManager.ServerCertificateValidationCallback = new System.Net.Security.RemoteCertificateValidationCallback(CheckValidationResult);
     }
     webRequest = (HttpWebRequest)WebRequest.Create(url);
     webRequest.Method = Enum.GetName(typeof(HttpRequestType), httpType);
     if (contentType != null)
     {
      webRequest.ContentType = contentType;
     }
     if (mCookie == null)
     {
      webRequest.CookieContainer = new CookieContainer();
     }
     else
     {
      webRequest.CookieContainer = mCookie;
     }
     if (keepAlive)
     {
      webRequest.KeepAlive = keepAlive;
      webRequest.ReadWriteTimeout = timeout;
      webRequest.Timeout = 60000;
      mLog.Info("请求超时时间..." + timeout);
     }
     break;
    default:
     if (url.StartsWith("https:"))
     {
      System.Net.ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12;
      ServicePointManager.ServerCertificateValidationCallback = new System.Net.Security.RemoteCertificateValidationCallback(CheckValidationResult);
     }
     webRequest = (HttpWebRequest)WebRequest.Create(url);
     webRequest.Method = Enum.GetName(typeof(HttpRequestType), httpType);
     if (contentType != null)
     {
      webRequest.ContentType = contentType;
     }
     if (mCookie == null)
     {
      webRequest.CookieContainer = new CookieContainer();
     }
     else
     {
      webRequest.CookieContainer = mCookie;
     }
     if (keepAlive)
     {
      webRequest.KeepAlive = keepAlive;
      webRequest.ReadWriteTimeout = timeout;
      webRequest.Timeout = 60000;
      mLog.Info("请求超时时间..." + timeout);
     }
     if (!String.IsNullOrWhiteSpace(data))
     {
      datas = requestEncoding.GetBytes(data);
     }
     if (datas != null)
     {
      webRequest.ContentLength = datas.Length;
      requestStream = webRequest.GetRequestStream();
      requestStream.Write(datas, 0, datas.Length);
      requestStream.Flush();
      requestStream.Close();
     }
     break;
   }
   //mLog.InfoFormat("请求 Url:{0},HttpRequestType:{1},contentType：{2},data:{3}", url, Enum.GetName(typeof(HttpRequestType), httpType), contentType, data);
   return webRequest;
  }
  public static CookieContainer GetLastCookie()
  {
   return mLastCookie;
  }
  /// <summary>
  /// 设置HTTP的Cookie，以后发送和请求用此Cookie
  /// </summary>
  /// <param name="cookie">CookieContainer</param>
  public static void SetHttpCookie(CookieContainer cookie)
  {
   mCookie = cookie;
  }
  private static HttpWebRequest mLastAsyncRequest = null;
  public static HttpWebRequest LastAsyncRequest
  {
   get { return mLastAsyncRequest; }
   set { mLastAsyncRequest = value; }
  }
  /// <summary>
  /// 发送请求
  /// </summary>
  /// <param name="url">请求Url</param>
  /// <param name="httpType">请求类型</param>
  /// <param name="contentType">contentType：application/x-www-form-urlencoded</param>
  /// <param name="data">请求数据</param>
  /// <param name="encoding">请求数据传输时编码格式</param>
  /// <returns>返回请求结果</returns>
  public static string SendRequest(string url, HttpRequestType httpType, string contentType, string data, Encoding requestEncoding, Encoding reponseEncoding, params AsyncCallback[] callBack)
  {

   int timeout = 0;
   bool keepAlive = false;
   if (callBack != null && callBack.Length > 0 && callBack[0] != null)
   {
    keepAlive = true;
    timeout = 1000*60*60;
    mLog.Info("写入读取超时时间..." + timeout);
   }
   // mLog.Info("开始创建请求....");
   HttpWebRequest webRequest = CreateWebRequest(url, httpType, contentType, data, requestEncoding,timeout,keepAlive);
   string ret = null;
   // mLog.Info("创建请求结束....");
   if (callBack != null && callBack.Length > 0 && callBack[0] != null)
   {
    // mLog.Info("开始异步请求....");
    mLastAsyncRequest = webRequest;
    webRequest.BeginGetResponse(callBack[0], webRequest);
   }
   else
   {
    // mLog.Info("开始同步请求....");
    StreamReader sr = new StreamReader(webRequest.GetResponse().GetResponseStream(), reponseEncoding);
    ret = sr.ReadToEnd();
    sr.Close();
   }
   mLastCookie = webRequest.CookieContainer;
   //mLog.InfoFormat("结束请求 Url:{0},HttpRequestType:{1},contentType：{2},结果：{3}", url, Enum.GetName(typeof(HttpRequestType), httpType), contentType,ret);
   return ret;
  }

  /// <summary>
  /// Http上传文件
  /// </summary>
  public static string HttpUploadFile(string url, string path)
  {
   using (FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read))
   {
    // 设置参数
    HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
    CookieContainer cookieContainer = new CookieContainer();
    request.CookieContainer = cookieContainer;
    request.AllowAutoRedirect = true;
    request.AllowWriteStreamBuffering = false;
    request.SendChunked = true;
    request.Method = "POST";
    request.Timeout = 300000;

    string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
    request.ContentType = "multipart/form-data;charset=utf-8;boundary=" + boundary;
    byte[] itemBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "\r\n");
    byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
    int pos = path.LastIndexOf("\\");
    string fileName = path.Substring(pos + 1);

    //请求头部信息
    StringBuilder sbHeader = new StringBuilder(string.Format("Content-Disposition:form-data;name=\"file\";filename=\"{0}\"\r\nContent-Type:application/octet-stream\r\n\r\n", fileName));
    byte[] postHeaderBytes = Encoding.UTF8.GetBytes(sbHeader.ToString());
    request.ContentLength = itemBoundaryBytes.Length + postHeaderBytes.Length + fs.Length + endBoundaryBytes.Length;
    using (Stream postStream = request.GetRequestStream())
    {
     postStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
     postStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
     int bytesRead = 0;

     int arrayLeng = fs.Length <= 4096 ? (int)fs.Length : 4096;
     byte[] bArr = new byte[arrayLeng];
     int counter = 0;
     while ((bytesRead = fs.Read(bArr, 0, arrayLeng)) != 0)
     {
      counter++;
      postStream.Write(bArr, 0, bytesRead);
     }
     postStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
    }

    //发送请求并获取相应回应数据
    using (HttpWebResponse response = request.GetResponse() as HttpWebResponse)
    {
     //直到request.GetResponse()程序才开始向目标网页发送Post请求
     using (Stream instream = response.GetResponseStream())
     {
      StreamReader sr = new StreamReader(instream, Encoding.UTF8);
      //返回结果网页（html）代码
      string content = sr.ReadToEnd();
      return content;
     }
    }
   }
  }

  public static string HttpUploadFile(string url, MemoryStream files, string fileName)
  {
   using (MemoryStream fs = files)
   {
    // 设置参数
    HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
    CookieContainer cookieContainer = new CookieContainer();
    request.CookieContainer = cookieContainer;
    request.AllowAutoRedirect = true;
    request.AllowWriteStreamBuffering = false;
    request.SendChunked = true;
    request.Method = "POST";
    request.Timeout = 300000;

    string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
    request.ContentType = "multipart/form-data;charset=utf-8;boundary=" + boundary;
    byte[] itemBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "\r\n");
    byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");

    //请求头部信息
    StringBuilder sbHeader = new StringBuilder(string.Format("Content-Disposition:form-data;name=\"file\";filename=\"{0}\"\r\nContent-Type:application/octet-stream\r\n\r\n", fileName));
    byte[] postHeaderBytes = Encoding.UTF8.GetBytes(sbHeader.ToString());
    request.ContentLength = itemBoundaryBytes.Length + postHeaderBytes.Length + fs.Length + endBoundaryBytes.Length;
    using (Stream postStream = request.GetRequestStream())
    {
     postStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
     postStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
     int bytesRead = 0;

     int arrayLeng = fs.Length <= 4096 ? (int)fs.Length : 4096;
     byte[] bArr = new byte[arrayLeng];
     int counter = 0;
     fs.Position = 0;
     while ((bytesRead = fs.Read(bArr, 0, arrayLeng)) != 0)
     {
      counter++;
      postStream.Write(bArr, 0, bytesRead);
     }
     postStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
    }

    //发送请求并获取相应回应数据
    using (HttpWebResponse response = request.GetResponse() as HttpWebResponse)
    {
     //直到request.GetResponse()程序才开始向目标网页发送Post请求
     using (Stream instream = response.GetResponseStream())
     {
      StreamReader sr = new StreamReader(instream, Encoding.UTF8);
      //返回结果网页（html）代码
      string content = sr.ReadToEnd();
      return content;
     }
    }
   }
  }

  #region public static 方法

  /// <summary>
  /// 将请求的流转化为字符串
  /// </summary>
  /// <param name="info"></param>
  /// <returns></returns>
  public static string GetStr(Stream info)
  {
   string result = "";
   try
   {
    using (StreamReader sr = new StreamReader(info, System.Text.Encoding.UTF8))
    {
     result = sr.ReadToEnd();
     sr.Close();
    }
   }
   catch
   {
   }
   return result;
  }

  /// <summary>
  /// 参数转码
  /// </summary>
  /// <param name="str"></param>
  /// <returns></returns>
  public static string stringDecode(string str)
  {
   return HttpUtility.UrlDecode(HttpUtility.UrlDecode(str, System.Text.Encoding.GetEncoding("UTF-8")), System.Text.Encoding.GetEncoding("UTF-8"));
  }

  /// <summary>
  /// json反序列化
  /// </summary>
  /// <typeparam name="T"></typeparam>
  /// <param name="json"></param>
  /// <returns></returns>
  public static T Deserialize<T>(string json)
  {
   try
   {
    T obj = Activator.CreateInstance<T>();
    using (MemoryStream ms = new MemoryStream(System.Text.Encoding.UTF8.GetBytes(json)))
    {
     DataContractJsonSerializer serializer = new DataContractJsonSerializer(obj.GetType());
     return (T)serializer.ReadObject(ms);
    }
   }
   catch
   {
    return default(T);
   }
  }

  #endregion

  public static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
  { // 总是接受 
   return true;
  }
 
 }
 public enum HttpRequestType
 {
  POST,
  GET,
  DELETE,
  PUT,
  PATCH,
  HEAD,
  TRACE,
  OPTIONS
 }

public bool ConnectServer()
    {
      try
      {
        string url = "https://i.cnblogs.com";

        string xml = HttpHelper.SendRequest(url, HttpRequestType.POST, null, null, Encoding.UTF8, Encoding.UTF8);
        NormalResponse nr = HuaweiXMLHelper.GetNormalResponse(xml);
        if (nr.Code == "0")
        {
HttpHelper.SetHttpCookie(HttpHelper.GetLastCookie());
          mIsConnect = true;
          return true;
        }
        else
        {
          mIsConnect = false;
          return false;
        }
      }
      catch (System.Exception ex)
      {
        mIsConnect = false;
        return false;
      }
    }

private bool HandleIntelligentTask(string taskId,bool bStop)
    {
      try
      {
        if (!mIsConnect)
        {
          return false;
        }
        StringBuilder sb = new StringBuilder();
        sb.AppendFormat("<request>\r\n");
        sb.AppendFormat("<task_id>{0}</task_id>\r\n", taskId);//<!-- task-id为调用方生成的UUID或其它串 -->
        sb.AppendFormat("<status>{0}</status>\r\n",bStop?0:1);
        sb.AppendFormat("</request>\r\n");
        string xml = sb.ToString();
        string url = mIAServerUrl + "/sdk_service/rest/video-analysis/handle-intelligent-analysis";
        string xml2 = HttpHelper.SendRequest(url, HttpRequestType.POST, "text/plain;charset=utf-8", xml, Encoding.UTF8, Encoding.UTF8);
        NormalResponse nr = HuaweiXMLHelper.GetNormalResponse(xml2);
        if (nr.Code == "0")
        {
          return true;
        }
        else
        {
          return false;
        }
      }
      catch (System.Exception ex)
      {
        return false;
      }

    }

private void ReStartAlarmServer(List<string> list, string alarmUrl, Thread[] listThread)
    {
      StopAlarm(alarmUrl, listThread);
      listThread[0]= new Thread(new ThreadStart(delegate()
            {
              try
              {
                if (!mIsConnect)
                {
                  mLog.Error("未登录！--ReStartAlarmServer-结束！");
                  return;
                }
                mLog.Info("ReStartAlarmServer开始报警连接....");
                if (String.IsNullOrWhiteSpace(alarmUrl)) return;
                mLog.InfoFormat("ReStartAlarmServer请求报警：URL={0}", alarmUrl);
                string xml = "task-id=0";
                string xml2 = HttpHelper.SendRequest(alarmUrl, HttpRequestType.POST, "application/x-www-form-urlencoded", xml, Encoding.UTF8, Encoding.UTF8, AlarmCallBack);
                mLog.Info("ReStartAlarmServer报警连接成功！");
              }
              catch (System.Threading.ThreadAbortException ex)
              {
                mLog.Info("ReStartAlarmServer线程已人为终止！" + ex.Message, ex);
              }
              catch (System.Exception ex)
              {
                mLog.Error("ReStartAlarmServer开始报警连接失败:" + ex.Message, ex);
                mLog.Info("ReStartAlarmServer开始重新报警连接....");
                mTimes = 50;
              }
              finally
              {
                
              }
            }));
      listThread[0].IsBackground = true;
      listThread[0].Start();
    }
    private void AlarmCallBack(IAsyncResult ir)
    {
      try
      {
        HttpWebRequest webRequest = (HttpWebRequest)ir.AsyncState;
        string salarmUrl = webRequest.Address.OriginalString;
        Thread[] alarmThead = dicAlarmUrls[salarmUrl];
        HttpWebResponse response = (HttpWebResponse)webRequest.EndGetResponse(ir);
        Stream stream = response.GetResponseStream();
        alarmThead[1]= new Thread(new ThreadStart(delegate()
        {
          try
          {
            byte[] buffer = new byte[mAlarmReadCount];
            int count = 0;
            string strMsg = "";
            int startIndex = -1;
            int endIndex = -1;

            NormalResponse res = null;
            DateTime dtStart = DateTime.Now;
            DateTime dtEnd = DateTime.Now;
            while (!mIsCloseAlarm)
            {
              count = stream.Read(buffer, 0, mAlarmReadCount);
              if (count > 0)
              {
                strMsg += Encoding.UTF8.GetString(buffer, 0, count);
                startIndex = strMsg.IndexOf("<response>");
                endIndex = strMsg.IndexOf("</response>");
                string xml = strMsg.Substring(startIndex, endIndex - startIndex + "</response>".Length);
                res = HuaweiXMLHelper.GetNormalResponse(xml);
                strMsg = strMsg.Substring(endIndex + "</response>".Length);
                startIndex = -1;
                endIndex = -1;
                break;
              }
              dtEnd = DateTime.Now;
              if ((dtEnd - dtStart).TotalSeconds > 10)
              {
                throw new Exception("连接信息未有获取到，需要重启报警！");
              }
            }
            while (!mIsCloseAlarm)
            {
              count = stream.Read(buffer, 0, mAlarmReadCount);
              if (count > 0)
              {
                string temp = Encoding.UTF8.GetString(buffer, 0, count);
                strMsg += temp;
                while (strMsg.Length > 0)
                {
                  if (startIndex == -1)//未发现第一个<task-info>
                  {
                    startIndex = strMsg.IndexOf("<task-info>");
                    if (startIndex == -1)
                    {
                      if (strMsg.Length >= "<task-info>".Length)
                      {
                        strMsg = strMsg.Substring(strMsg.Length - "<task-info>".Length);
                      }
                      break;
                    }
                  }
                  if (startIndex >= 0)
                  {
                    int i = startIndex + "<task-info>".Length;
                    int taskInfoEndIndex = strMsg.IndexOf("</task-info>", i);
                    if (taskInfoEndIndex > 0)//必须有任务结束节点
                    {
                      i = taskInfoEndIndex + "</task-info>".Length;
                      int i1 = strMsg.IndexOf("</attach-rules>", i);//找到轨迹节点结束
                      int i2 = strMsg.IndexOf("</alarm>", i);//找到报警节点结束,发现一条报警
                      if (i1 == -1 && i2 == -1)//没有标志结束
                      {
                        break;
                      }
                      else if (i1 >= 0 && (i1 < i2 || i2 == -1))//找到轨迹结束节点
                      {
                        strMsg = strMsg.Substring(i1 + "</attach-rules>".Length);
                        startIndex = -1;
                        endIndex = -1;
                        continue;
                      }
                      else if (i2 > 0 && (i2 < i1 || i1 == -1))//找报警节点
                      {
                        endIndex = i2;//找到报警节点结束,发现一条报警
                        string alarmXml = "<taskalarm>" + strMsg.Substring(startIndex, endIndex - startIndex + "</alarm>".Length) + "</taskalarm>";

                        Thread th = new Thread(new ThreadStart(delegate()
                        {
                          ParseAlarmXml(alarmXml);
                        }));
                        th.IsBackground = true;
                        th.Start();

                        strMsg = strMsg.Substring(endIndex + "</alarm>".Length);
                        startIndex = -1;
                        endIndex = -1;
                        continue;
                      }
                    }
                    else
                    {
                      break;
                    }
                  }
                }
              }
              else
              {
                Console.WriteLine("##########读取报警反馈：无");
                Thread.Sleep(1000);
              }
            }
          }
          catch (System.Threading.ThreadAbortException ex)
          {
            mLog.Info("AlarmCallBack...7");
            try
            {
              if (stream != null)
              {
                stream.Close();
                stream.Dispose();
                response.Close();
              }
            }
            catch
            {
            }
            mLog.Info("AlarmCallBack线程已人为终止！--0" + ex.Message, ex);
          }
          catch(IOException ex)
          {
            mLog.Info("AlarmCallBack...8");
            try
            {
              if (stream != null)
              {
                stream.Close();
                stream.Dispose();
                response.Close();
              }
            }
            catch
            {
            }
          }
          catch (ObjectDisposedException ex)
          {
            mLog.Info("AlarmCallBack...9");
            mLog.Info("AlarmCallBack读取流已人为终止！--2" + ex.Message, ex);
            try
            {
              if (stream != null)
              {
                stream.Close();
                stream.Dispose();
                response.Close();
              }
            }
            catch
            {
            }
          }
          catch (System.Exception ex)
          {
            mLog.Info("AlarmCallBack...10");
             mLog.Error("AlarmCallBack 0:" + ex.Message,ex);
             try
             {
               if (stream != null)
               {
                 stream.Close();
                 stream.Dispose();
                 response.Close();
               }
             }
             catch
             {
             }
             
            
          }
          finally
          {
            
          }
        }));
        alarmThead[1].IsBackground = true;
        alarmThead[1].Start();

      }
      catch (System.Exception ex)
      {
        mLog.Info("AlarmCallBack...11");
        mLog.Error("AlarmCallBack 1:" + ex.Message,ex);
        mLog.Info("AlarmCallBack开始重新报警连接....3");
        mTimes = 50;
      }
      finally
      {
        
      }
    }