请求rest web服务client

  1 using System;
  2 using System.Globalization;
  3 using System.IO;
  4 using System.Net;
  5 using System.Text;
  6 
  7 [assembly: CLSCompliant(true)]
  8 namespace Downloader
  9 {
 10     public enum HttpVerb
 11     {
 12         Get,
 13         Post,
 14         Put,
 15         Delete
 16     }
 17 
 18     /// <summary>
 19     /// Restful Service Client
 20     /// </summary>
 21     public class RestClient
 22     {
 23         /// <summary>
 24         /// application/json
 25         /// </summary>
 26         private string _contentType = "application/json";
 27         /// <summary>
 28         /// 15000
 29         /// </summary>
 30         private int _timeout = 15000;
 31         /// <summary>
 32         /// Service Uri
 33         /// </summary>
 34         public string EndPoint { get; set; }
 35         /// <summary>
 36         /// Post || Get
 37         /// </summary>
 38         public HttpVerb Method { get; set; }
 39         /// <summary>
 40         /// Default "text/xml"
 41         /// </summary>
 42         public string ContentType { get { return _contentType; } set { _contentType = value; } }
 43         /// <summary>
 44         /// eg. "‘test‘:‘abcd‘"
 45         /// </summary>
 46         public string PostData { get; set; }
 47         /// <summary>
 48         /// TimeOut ms
 49         /// </summary>
 50         public int Timeout { get { return _timeout; } set { _timeout = value; } }
 51         /// <summary>
 52         /// Default Constructor
 53         /// </summary>
 54         public RestClient()
 55         {
 56             EndPoint = "";
 57             Method = HttpVerb.Get;
 58             ContentType = _contentType;
 59             PostData = "{}";
 60             Timeout = _timeout;
 61         }
 62         /// <summary>
 63         /// Constructor
 64         /// </summary>
 65         /// <param name="endpoint">Service Uri</param>
 66         public RestClient(string endpoint)
 67         {
 68             EndPoint = endpoint;
 69             Method = HttpVerb.Get;
 70             ContentType = _contentType;
 71             PostData = "{}";
 72             Timeout = _timeout;
 73         }
 74         /// <summary>
 75         /// Constructor
 76         /// </summary>
 77         /// <param name="endpoint">Service Uri</param>
 78         /// <param name="method">Post || Get</param>
 79         public RestClient(string endpoint, HttpVerb method)
 80         {
 81             EndPoint = endpoint;
 82             Method = method;
 83             ContentType = _contentType;
 84             PostData = "{}";
 85             Timeout = _timeout;
 86         }
 87         /// <summary>
 88         /// Constructor
 89         /// </summary>
 90         /// <param name="endpoint">Service Uri</param>
 91         /// <param name="method">Post || Get</param>
 92         /// <param name="postData">eg. "{‘test‘:‘abcd‘}"</param>
 93         public RestClient(string endpoint, HttpVerb method, string postData)
 94         {
 95             EndPoint = endpoint;
 96             Method = method;
 97             ContentType = _contentType;
 98             PostData = postData;
 99             Timeout = _timeout;
100         }
101         /// <summary>
102         /// Request server
103         /// </summary>
104         /// <returns></returns>
105         public string MakeRequest()
106         {
107             return MakeRequest("");
108         }
109         /// <summary>
110         /// Request server
111         /// </summary>
112         /// <param name="parameters">eg. "?q=1234"</param>
113         /// <returns></returns>
114         public string MakeRequest(string parameters)
115         {
116             var service = new Uri(EndPoint + parameters);
117             var request = WebRequest.Create(service);
118             request.Timeout = Timeout;
119             request.Method = Method.ToString().ToUpper(CultureInfo.CurrentCulture);
120             request.ContentLength = 0;
121             request.ContentType = ContentType;
122 
123             if (Method == HttpVerb.Post)
124             {
125                 PostData = "{" + PostData + "}";
126                 var bytes =Encoding.UTF8.GetBytes(PostData);
127                 request.ContentLength = bytes.Length;
128 
129                 using (var writeStream = request.GetRequestStream())
130                 {
131                     writeStream.Write(bytes, 0, bytes.Length);
132                 }
133             }
134 
135             using (var response = (HttpWebResponse)request.GetResponse())
136             {
137                 var responseValue = string.Empty;
138                 if (response.StatusCode != HttpStatusCode.OK)
139                 {
140                     var message = String.Format(CultureInfo.CurrentCulture, "Request failed. Received HTTP {0}", response.StatusCode);
141                     throw new WebException(message);
142                 }
143                 using (var responseStream = response.GetResponseStream())
144                 {
145                     if (responseStream != null)
146                         using (var reader = new StreamReader(responseStream))
147                         {
148                             responseValue = reader.ReadToEnd();
149                         }
150                 }
151                 return responseValue;
152             }
153         }
154         /// <summary>
155         /// 同步更新二进制文件
156         /// </summary>
157         /// <param name="parameters">URL参数</param>
158         /// <param name="postData">表单提交参数</param>
159         /// <returns></returns>
160         public byte[] MakeRequest(string parameters, string postData)
161         {
162             var service = new Uri(EndPoint + parameters);
163             var request = WebRequest.Create(service);
164             request.Timeout = Timeout;
165             request.Method = Method.ToString().ToUpper(CultureInfo.CurrentCulture);
166             request.ContentLength = 0;
167             request.ContentType = ContentType;
168 
169             if (Method == HttpVerb.Post)
170             {
171                 PostData = "{" + postData + "}";
172                 var bytes = Encoding.UTF8.GetBytes(PostData);
173                 request.ContentLength = bytes.Length;
174 
175                 using (var writeStream = request.GetRequestStream())
176                 {
177                     writeStream.Write(bytes, 0, bytes.Length);
178                 }
179             }
180 
181             using (var response = (HttpWebResponse)request.GetResponse())
182             {
183                 if (response.StatusCode != HttpStatusCode.OK)
184                 {
185                     var message = String.Format(CultureInfo.CurrentCulture, "Request failed. Received HTTP {0}", response.StatusCode);
186                     throw new WebException(message);
187                 }
188                 using (var result = new MemoryStream())
189                 {
190                     const int bufferLen = 2048;
191                     var buffer = new byte[bufferLen];
192                     using (var responseStream = response.GetResponseStream())
193                     {
194                         var len = responseStream.Read(buffer, 0, bufferLen);
195                         while (len > 0)
196                         {
197                             result.Write(buffer, 0, len);
198                             len = responseStream.Read(buffer, 0, bufferLen);
199                         }
200                     }
201                     return result.ToArray();
202                 }
203             }
204         }
205 
206     } 
207 
208 }