HttpHelp 請求幫助類


using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json.Linq;

namespace Share
{
    public class HttpHelp
    {
        /// <summary>
        /// url為請求的網址,param參數為需要查詢的條件(服務端接收的參數,沒有則為null)
        /// </summary>
        /// <param name="url"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static string Get(string url, Dictionary<string, string> param)
        {
            if (param != null) //有參數的情況下,拼接url
            {
                url = url + "?";
                url = param.Aggregate(url, (current, item) => current + item.Key + "=" + item.Value + "&");
                url = url.Substring(0, url.Length - 1);
            }
            #region 寫日記

            LogHelp.WriteLog(url);
            #endregion
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;//創建請求
            request.Method = "GET"; //請求方法為GET
            HttpWebResponse res; //定義返回的response
            try
            {
                res = (HttpWebResponse)request.GetResponse(); //此處發送了請求並獲得響應
            }
            catch (WebException ex)
            {
                res = (HttpWebResponse)ex.Response;
            }
            StreamReader sr = new StreamReader(res.GetResponseStream(), Encoding.UTF8);
            string content = sr.ReadToEnd(); //響應轉化為String字符串
            return content;
        }
        //url為請求的網址,param為需要傳遞的參數
        //返回服務端的額響應
        /// <summary>
        /// url為請求的網址,param為需要傳遞的參數
        /// </summary>
        /// <param name="url"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static string Post(string url, Dictionary<String, String> param)
        {
            #region 寫日記
            string parameterSt = "";
            if (param.Count != 0) //將參數添加到json對象中
            {
                foreach (var item in param)
                {
                    parameterSt += "&" + item.Key + "=" + item.Value;
                }
            }
            LogHelp.WriteLog(url + parameterSt);
            #endregion

            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest; //創建請求
            CookieContainer cookieContainer = new CookieContainer();
            request.CookieContainer = cookieContainer;
            request.AllowAutoRedirect = true;
            //request.AllowReadStreamBuffering = true;
            request.MaximumResponseHeadersLength = 1024;
            request.Method = "POST"; //請求方式為post
            request.AllowAutoRedirect = true;
            request.MaximumResponseHeadersLength = 1024;
            request.ContentType = "application/json";
            JObject json = new JObject();
            if (param.Count != 0) //將參數添加到json對象中
            {
                foreach (var item in param)
                {
                    json.Add(item.Key, item.Value);
                }
            }
            string jsonstring = json.ToString();//獲得參數的json字符串
            byte[] jsonbyte = Encoding.UTF8.GetBytes(jsonstring);
            Stream postStream = request.GetRequestStream();
            postStream.Write(jsonbyte, 0, jsonbyte.Length);
            postStream.Close();
            //發送請求並獲取相應回應數據       
            HttpWebResponse res;
            try
            {
                res = (HttpWebResponse)request.GetResponse();
            }
            catch (WebException ex)
            {
                res = (HttpWebResponse)ex.Response;
            }
            StreamReader sr = new StreamReader(res.GetResponseStream(), Encoding.UTF8);
            string content = sr.ReadToEnd(); //獲得響應字符串
            return content;
        }

        //url為請求的網址,param為需要傳遞的參數
        //返回服務端的額響應
        /// <summary>
        /// url為請求的網址,param為需要傳遞的參數
        /// </summary>
        /// <param name="url"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static string Post(string url, string jsonstring = "")
        {
            #region 寫日記
           
            LogHelp.WriteLog(url + jsonstring);
            #endregion

            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest; //創建請求
            CookieContainer cookieContainer = new CookieContainer();
            request.CookieContainer = cookieContainer;
            request.AllowAutoRedirect = true;
            //request.AllowReadStreamBuffering = true;
            request.MaximumResponseHeadersLength = 1024;
            request.Method = "POST"; //請求方式為post
            request.AllowAutoRedirect = true;
            request.MaximumResponseHeadersLength = 1024;
            request.ContentType = "application/json";
           
            byte[] jsonbyte = Encoding.UTF8.GetBytes(jsonstring);
            Stream postStream = request.GetRequestStream();
            postStream.Write(jsonbyte, 0, jsonbyte.Length);
            postStream.Close();
            //發送請求並獲取相應回應數據       
            HttpWebResponse res;
            try
            {
                res = (HttpWebResponse)request.GetResponse();
            }
            catch (WebException ex)
            {
                res = (HttpWebResponse)ex.Response;
            }
            StreamReader sr = new StreamReader(res.GetResponseStream(), Encoding.UTF8);
            string content = sr.ReadToEnd(); //獲得響應字符串
            return content;
        }
        
        /// <summary>
        /// HttpUploadFile 上傳文件 HttpUploadFile("http://localhost/Test", new string[] { @"E:\Index.htm", @"E:\test.rar" }, data));
        /// </summary>
        /// <param name="url"></param>
        /// <param name="files"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public static string HttpUploadFile(string url, string[] files, Dictionary<string, string> param = null)
        {
            Encoding encoding = Encoding.UTF8;
            string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
            byte[] boundarybytes = Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
            byte[] endbytes = Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");

            //1.HttpWebRequest
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.ContentType = "multipart/form-data; boundary=" + boundary;
            request.Method = "POST";
            request.KeepAlive = true;
            request.Credentials = CredentialCache.DefaultCredentials;

            using (Stream stream = request.GetRequestStream())
            {
                //1.1 key/value
                string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}";
                if (param != null)
                {
                    foreach (string key in param.Keys)
                    {
                        stream.Write(boundarybytes, 0, boundarybytes.Length);
                        string formitem = string.Format(formdataTemplate, key, param[key]);
                        byte[] formitembytes = encoding.GetBytes(formitem);
                        stream.Write(formitembytes, 0, formitembytes.Length);
                    }
                }

                //1.2 file
                string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: application/octet-stream\r\n\r\n";
                byte[] buffer = new byte[4096];
                int bytesRead = 0;
                for (int i = 0; i < files.Length; i++)
                {
                    stream.Write(boundarybytes, 0, boundarybytes.Length);
                    string header = string.Format(headerTemplate, "file" + i, Path.GetFileName(files[i]));
                    byte[] headerbytes = encoding.GetBytes(header);
                    stream.Write(headerbytes, 0, headerbytes.Length);
                    using (FileStream fileStream = new FileStream(files[i], FileMode.Open, FileAccess.Read))
                    {
                        while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
                        {
                            stream.Write(buffer, 0, bytesRead);
                        }
                    }
                }

                //1.3 form end
                stream.Write(endbytes, 0, endbytes.Length);
            }
            //2.WebResponse
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            using (StreamReader stream = new StreamReader(response.GetResponseStream()))
            {
                return stream.ReadToEnd();
            }

        }

        
        /// <summary>
        /// 文件下載
        /// </summary>
        /// <param name="url">抓取url</param>
        /// <param name="filePath">保存文件名</param>
        /// <param name="oldurl">來源路徑</param>
        /// <returns></returns>
        public static void HttpDownloadFile(string url, string filePath)
        {
            try
            {
                HttpWebRequest Myrq = (HttpWebRequest)HttpWebRequest.Create(url);


                HttpWebResponse myrp = (HttpWebResponse)Myrq.GetResponse();
                long totalBytes = myrp.ContentLength;
                Stream st = myrp.GetResponseStream();
                Stream so = new FileStream(filePath, FileMode.Create);
                long totalDownloadedByte = 0;
                byte[] by = new byte[1024];
                int osize = st.Read(by, 0, (int)by.Length);
                while (osize > 0)
                {
                    totalDownloadedByte = osize + totalDownloadedByte;
                    so.Write(by, 0, osize);
                    osize = st.Read(by, 0, (int)by.Length);
                }
                so.Close();
                st.Close();
            }

            catch (Exception ex)
            {
                LogHelp.WriteLog(ex.Message + ex.StackTrace);
            }
        }
    }
}

用法:

  public FindCabinetListRpModel FindCabinetList(FindCabinetListRt rt)
        {
            GetToken(rt);
            ConvertHelp.NoProperties.Clear();
            string parameterSt = ConvertHelp.GetProperties(rt);
            Uri address = new Uri(_baseAddress + "/pickup/findCabinetList?" + parameterSt);
            string rpJson = HttpHelp.Post(address.ToString());

            try
            {
                //調用接口
                var rpModel = JSONHelp.parse<FindCabinetListRpModel>(rpJson);
                return rpModel;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM