前言
本文主要給大家介紹了關于.Net整合Json實現REST服務客戶端的相關內容,分享出來供大家參考學習,下面話不多說了,來一起看看詳細的介紹吧。
一. 準備工作
1. 點擊官網 或 本地 下載支持.Net4.0 的Json插件 Newtonsoft.Json
2. 找到 %壓縮包%\Bin\net40\Newtonsoft.Json.dll ,在工程中引用
二. 相關代碼介紹
1. HttpClientUtil.cs 封裝REST方法
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
using Newtonsoft.Json; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net; using System.Text; namespace psi.Common { public class HttpClientUtil { // REST @GET 方法,根據泛型自動轉換成實體,支持List<T> public static T doGetMethodToObj<T>( string url) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = "get" ; request.ContentType = "application/json;charset=UTF-8" ; HttpWebResponse response = null ; try { response = (HttpWebResponse)request.GetResponse(); } catch (WebException e) { response = (HttpWebResponse)e.Response; return default (T); } string json = getResponseString(response); return JsonConvert.DeserializeObject<T>(json); } // 將 HttpWebResponse 返回結果轉換成 string private static string getResponseString(HttpWebResponse response) { string json = null ; using (StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.GetEncoding( "UTF-8" ))) { json = reader.ReadToEnd(); } return json; } // 獲取異常信息 private static string getRestErrorMessage(HttpWebResponse errorResponse) { string errorhtml = getResponseString(errorResponse); string errorkey = "UnhandledException:" ; errorhtml = errorhtml.Substring(errorhtml.IndexOf(errorkey) + errorkey.Length); errorhtml = errorhtml.Substring(0, errorhtml.IndexOf( "\n" )); return errorhtml; } // REST @POST 方法 public static T doPostMethodToObj<T>( string url, string jsonBody) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = "post" ; request.ContentType = "application/json;charset=UTF-8" ; var stream = request.GetRequestStream(); using (var writer = new StreamWriter(stream)) { writer.Write(jsonBody); writer.Flush(); } HttpWebResponse response = (HttpWebResponse)request.GetResponse(); string json = getResponseString(response); return JsonConvert.DeserializeObject<T>(json); } // REST @PUT 方法 public static string doPutMethod( string url) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = "put" ; request.ContentType = "application/json;charset=UTF-8" ; HttpWebResponse response = (HttpWebResponse)request.GetResponse(); using (StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.GetEncoding( "UTF-8" ))) { return reader.ReadToEnd(); } } // REST @PUT 方法,帶發送內容主體 public static T doPutMethodToObj<T>( string url, string jsonBody) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = "put" ; request.ContentType = "application/json;charset=UTF-8" ; request.Timeout = 30 * 1000; var stream = request.GetRequestStream(); using (var writer = new StreamWriter(stream)) { writer.Write(jsonBody); writer.Flush(); } HttpWebResponse response = (HttpWebResponse)request.GetResponse(); string json = getResponseString(response); return JsonConvert.DeserializeObject<T>(json); } // REST @DELETE 方法 public static bool doDeleteMethod( string url) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = "delete" ; request.ContentType = "application/json;charset=UTF-8" ; HttpWebResponse response = (HttpWebResponse)request.GetResponse(); using (StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.GetEncoding( "UTF-8" ))) { string responseString = reader.ReadToEnd(); if (responseString.Equals( "1" )) { return true ; } return false ; } } } } |
2. 調用REST服務端方法,以Json作為數據格式
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
/// <summary> /// 取得升級服務端的url地址 /// </summary> /// <returns></returns> private String getServerUrl() { String result = "" ; UpgraderClient upgraderClient = getUpgraderClient(); if (upgraderClient != null ) { result += "http://" + upgraderClient.serverIP + ":" + upgraderClient.serverPort + "/upgraderServer/service/upgrade.do" ; } return result; } /// <summary> /// 測試與升級服務端的連接 /// </summary> /// <returns></returns> public bool testConnect() { FileRequest fileReq = new FileRequest(); fileReq.type = ( int )RequestType.TEST_CONNECT; string jsonData = JsonConvert.SerializeObject(fileReq); FileResponse rep = null ; try { rep = HttpClientUtil.doPostMethodToObj<FileResponse>(getServerUrl(), jsonData); } catch { throw new Exception( "連接遠程服務端失敗!" ); } return rep.status == 200; } |
總結
以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對服務器之家的支持。
原文鏈接:https://www.cnblogs.com/Mr-kevin/archive/2018/01/11/8269563.html