16.网络《果壳中的c#》
16.1 網絡體系結構
System.Net.* 命名空間包含各種支持標準網絡協議的通信。
- WebClient 外觀類:支持通信HTTP或FTP執行簡單的下載/上傳操作。
- WebRequest 和 WebResponse 類:支持更多的客戶端HTTP或FTP操作。
- HttpListener 類:可用來編寫HTTP服務器。
- SmtpClient類:支持通過 SMTP 創建和發送電子郵件。
- DNS類:支持域名和地址之間的轉換。
- TcpClient、UdpClient、TcpListener和Socket類:支持傳輸層和網絡層的直接訪問。
16.2 地址與端口
IPv4
- 目前主流,32位。用點號分隔的4個十進制數(101.102.103.104)。地址可能是唯一,也可能是一個特定子網中的唯一(例如,企業網絡)。
IPv6
- 128位地址。這些地址用冒號分隔的十六進制數(例如,[3EA0:FFFF:198A:E4A3:4FF2:54fA:41BC:8D31])。.NET FrameWork要求加方括號。
System.Net 命名空間的 IPAddress 類是采用其中一種協議地址。它有一個構造函數可以接收字節數組,以及一個靜態的 Parse 方法接收正確字符串:
IPAddress a1 = new IPAddress(new byte[] { 101, 102, 103, 104 });IPAddress a2 = IPAddress.Parse("101.102.103.104");Console.WriteLine(a1.Equals(a2)); //trueConsole.WriteLine(a1.AddressFamily); //InterNetworkIPAddress a3 = IPAddress.Parse("[3EA0:FFFF:198A:E4A3:4FF2:54fA:41BC:8D31]");Console.WriteLine(a3.AddressFamily); //InterNetworkV6TCP和UDP協議將每一個IP地址劃分為65535個端口,從而允許一臺計算機在一個地址上運行多個應用程序,每一個應用程序使用一個端口。許多應用程序都分配有標準端口,例如,HTTP使用端口80,SMTP使用端口25。
49152到65535的TCP和UDP端口官方保留,它們只用于測試和小規模部署。
IP地址和端口組合在.NETFramwork 使用 IPEndPoint 類表示:
IPAddress a = new IPAddress(new byte[] { 101, 102, 103, 104 });IPEndPoint ep = new IPEndPoint(a, 222); //端口:222Console.WriteLine(ep.ToString()); //101.102.103.104:22216.3 URI
URI描述了一個 Internet 或 LAN 的資源,例如網頁。文件或電子郵件地址。
URI一般氛圍三個元素:協議(scheme)、權限(authority)和路徑(path)。System.Uri 類正是采用這種劃分方式,為每一種元素提供對應的屬性。
在構造函數中傳入以下字符串之一,就可以創建一個 Uri 對象:
- URI字符串,例如http://www.ebay.com 或 file://janespc/sharedpics/dolphin.jpg
- 硬盤中一個文件的絕對路徑,例如 c:\myfiles\data.xls
- LAN中一個文件的 UNC路徑,例如 \janespc\sharedpics\dolphin.jpg
文件和UNC路徑會自動轉換為URI:添加協議 "file:",反斜杠會轉換為斜杠。Uri的構造函數在創建Uri之前也會對傳入的字符串執行一些基本的清理操作,包括將協議和主機名轉換為小寫、刪除默認端口和空端口號。如果傳入一個不帶協議的URI字符串,例如"www.test.com",那么會拋出一個 UriFormatException 異常。
Uri 有一個 IsLoopback 屬性,它表示 Uri 是否引用本地主機(IP地址為127.0.0.1),以及一個 IsFile 屬性,它表示Uri是否引用一個本地或UNC(IsUnc)路徑。如果 IsFile 返回 true,LocalPath 屬性會返回一個符合本地操作系統習慣的 AbsolutePath(帶反斜杠),然后可以用它來調用 File.OPen。
Uri 的實例有一些只讀屬性。要修改一個 Uri,我們需要實例化一個 UriBuilder 對象,這是一個可寫屬性,它可以通過 Uri 屬性轉換為 Uri。
Uri info = new Uri("http://www.domain.com:80/hosting/");Uri page = new Uri("http://www.domain.com/hosting/page.html");Console.WriteLine(info.Host); //www.domain.comConsole.WriteLine(info.Port); //80Console.WriteLine(page.Port); //80Console.WriteLine(info.IsBaseOf(page)); //TrueUri relative = info.MakeRelativeUri(page);Console.WriteLine(relative.IsAbsoluteUri); //FlaseConsole.WriteLine(relative.ToString()); //page.htmlUri 一些靜態方法:
Uri.EscapeDataString(url); UriHostNameType type = Uri.CheckHostName(url); bool isScheme = Uri.CheckSchemeName(url);16.4 客戶端類
WebRequest 和 WebRespone是管理 HTTP 和 FTP 客戶端活動及 "file:" 協議的通用基類。
WebClient 是一個便利的門面類。它負責調用 WebRequest 和 WebRespone,可以節省很多編碼。WebClient 支持字符串、字節數組、文件和流,而 WebRequest 和 WebRespone 只支持流。但是,WebClient不是萬能的,因為它不支持某些特性(如cookie)。
HttpClient 是另一個基于 WebRequest 和 WebRespone 的類(更準確說基于HttpWebRequest和HttpWebResponse),Framework 4.5 引入。
WebClient主要作為請求/響應類之上薄薄的一層,而 HttpClient 則增加更多功能,能夠處理基于HTTP的Web API、基于REST的服務和自定義驗證模式。
WebClient和HttpClient都支持以字符串或字節數組方式處理簡單的文件下載/上傳操作。它們都擁有一些異步方法,但是只有 WebClient 支持進度報告。
| WebClient | 薄薄一層 | - | 有 |
| HttpClient | 處理基于HTTP的Web API等 | Framework 4.5 | 無 |
提示:WinRT應用程序不能使用 WebClient,必須使用WebRequest/WebResponse或HttpClient(用于HTTP連接)
16.4.1 WebClient
WebClient 使用步驟:
下載方法有:
public void DownloadFile(string address, string fileName); public string DownloadString(string address); public byte[] DownloadData(string address); public Stream OpenRead(string address);每一個方法都有重載,接收 URI 對象代替字符串地址的參數。上傳類似,返回包含服務器響應的值:
public byte[] UploadFile(string address, string fileName); public byte[] UploadFile(Uri address, string fileName); public byte[] UploadFile(string address, string method, string fileName); public byte[] UploadFile(Uri address, string method, string fileName); ... public string UploadString(string address, string data); public byte[] UploadData(string address, byte[] data); public Stream OpenWrite(string address); ...UploadValues 方法可用于以 POST 方法參數提交一個 HTTP 表單的值。WebClient 還包含一個 BaseAddress 屬性,可用于為所有地址添加一個字符串前綴,如http://www.mysite.com/data。
public byte[] UploadValues(string address, NameValueCollection data); ...例子,下載 http://www.cnblogs.com/artwl/archive/2012/03/07/2382848.html 并以 code111.htm 保存
System.Net.WebClient webClient = new System.Net.WebClient();webClient.Proxy = null;webClient.DownloadFile("http://www.cnblogs.com/artwl/archive/2012/03/07/2382848.html", "code111.htm");System.Diagnostics.Process.Start("code111.htm");從 Framework 4.5 開始,WebClient 提供了長任務方法的異步版本,他們會返回可以等待的任務
await webClient.DownloadFileTaskAsync("http://www.qq.com", "wegpage.htm");這些方法使用"TaskAsync"后綴,不同于使用"Async"后綴的EAP舊異步方法。但是,新方法不支持取消操作和進步報告的標準“TAP”模式。相反,在處理延續時,必須調用 WebClient 對象的 CanceAsync 方法;而處理報告時,需要處理 DownloadProgressChanged/UploadProgressChanged 事件。
下面例子下載一個網頁并顯示進度報告,如果下載超過5秒,則取消下載。
//winform.private void button1_Click(object sender, EventArgs e){Test();}async Task Test(){var wc = new WebClient();wc.DownloadProgressChanged += (sender, args) =>// 獲取異步任務的進度百分比Console.WriteLine(args.ProgressPercentage + "% 完成");Task.Delay(5000).ContinueWith(ant => wc.CancelAsync());await wc.DownloadFileTaskAsync("http://www.qq.com", "wegpage.htm");}提示: 當請求取消時,程序會拋出一個 WebException 異常,它的 Status 屬性是 WebExceptionStatus.RequestCanceled.(歷史原因不拋出 OpeerationCanceledException 異常。)
捕捉與進度相關的事件,將它們提交到激活的同步上下文,所以它們的處理器不需要使用 Dispatcher.BeginInvoke,就可以更新UI控件。
警告: 如果需要使用取消操作或進度報告,要避免使用同一個 WebClient 對象依次執行多個操作,因為這樣形成競爭條件。
16.4.2 WebRequest 和 WebResponse
比 WebClient 復雜,但是更靈活。
1.使用一個 URI 調用 WebRequest.Create,創建一個 Web 請求實例。
2.設置 Proxy 屬性。
3.如果需要身份驗證,設置 Credentials 屬性。
如果要上傳數據,則:
4.調用請求對象的 GetRequestStream,然后在流中寫入數據。如果需要處理響應,則轉到第5步。
如果要下載數據,則:
5.調用請求對象的 GetResponse,創建一個 Web 響應實例。
6.調用響應對象的 GetResponseStream,然后(可以使用 StreamReader)從流中讀取數據。
下面例子演示如何下載和顯示一個示例網頁
//同步public static void Test1(){WebRequest req = WebRequest.Create("http://www.baidu.com"); //1.req.Proxy = null; //2.using (WebResponse res = req.GetResponse()) //5.下載{using (Stream rs = res.GetResponseStream()) //6.{using (FileStream fs = File.Create("code.html")){rs.CopyTo(fs);}}}}異步方式
//異步public static async void AsyncTest(){WebRequest req = WebRequest.Create("http://www.qq.com");req.Proxy = null;using (WebResponse res = await req.GetResponseAsync()){using (Stream rs = res.GetResponseStream()){using (FileStream fs = File.Create("code2.html")){await rs.CopyToAsync(fs);}}}}靜態方法 Create 會創建一個 WebRequest 類型的子類實例,如 HttpWebRequest 或 FtpWebRequest。
它選擇的子類取決 URI 的前綴。
| http:或https: | HttpWebRequest |
| ftp: | FtpWebRequest |
| file: | FileWebRequest |
此外,調用 WebRequest.RegisterPrefix,可以注冊自定義前綴。
WebRequest 包含一個 Timeout 屬性,單位為毫秒。如果出現超時,那么會拋出一個 WebException 異常,其中包含一個 Status 屬性,WebExceptionStatus.Timeout。HTTP默認超時時間為100秒,而FTP超時時間為無限。
WebRequest 對象不能回收并用于處理多個請求——每個實例只適用于一個作業。
16.4.3 HttpClient
HttpClient 在 HttpWebRequest 和 HttpWebRespone 之上提供了另一層封裝。它的設計是為了支持越來越多的 Web API 和 REST 服務,在處理比獲取網頁等更復雜的協議時實現比 WebClient 更佳的體驗。
- 一個 HttpClient 就可以支持并發請求。(使用 WebClient 處理并發請求,需要為每一個并發線程創建一個新實例,需要自定義請求頭、cookies和驗證模式,因此很麻煩)
- HttpClient 可用于編寫和插入自定義消息處理器。這樣可以創建單元測試樁函數,以及創建自定義管道(用于記錄日志、壓縮、加密等)調用WebClient的單元測試代碼則很難編寫。
HttpClient 包含豐富的可擴展的請求頭與內容類型系統。
HttpClient 不能完全替代 WebClient,因為它不支持進度報告。WebClient 也有一個有點,它支持 FTP、file://和自定義URI模式,適應所有Framework版本。
簡單 HttpClient 使用方法創建一個實例,然后使用 URI 調用 其中一個 Get* 方法:
string html = await new HttpClient().GetStringAsync("http://linqpad.net");(另外還有 GetByteArrayAsync和GetStreamAsync)HttpClient的所有 I/O 密集型方法都是異步的(沒有同步版本)。
與 WebClient 不同,想獲取最佳性能 HttpClient,必須重用相同的實例。HttpClient 允許并發操作,所以下面語句合法。同時下載兩個網頁:
var client = new HttpClient();var tast1 = client.GetStringAsync("http://www.linqpad.net");var tast2 = client.GetStringAsync("http://www.albahari.com");Console.WriteLine(await task1);Console.WriteLine(await task2);HttpClinet 包含一個 TimeOut 屬性和一個 BaseAddress 屬性,為每一個請求添加一個 URI 前綴。
HttpClient 在一定程度上就是一層實現:通常使用的大部分屬性都定義在另一個類中,即 HttpClientHandler。要訪問這個類,先創建一個實例,然后將這個實例傳遞給 HttpClient 的構造方法:
這個例子在處理器中禁用了代理支持。此外,還有其他一些屬性可用于控制 cookies、自動重定向、驗證等(后續看16.5“HTTP訪問”)
1.GetAsync與響應消息
GetStringAsync、GetByteArrayAsync和GetStreamAsync方法是更常用的 GetAsync 方法的快捷方法。GetAsync方法會返回一個響應消息:
var client = new HttpClient();//GetAsync 方法也接受一個 CancellationTokenHttpResponseMessage response = await client.GetAsync("http://www.baidu.com");response.EnsureSuccessStatusCode();string html = await response.Content.ReadAsStringAsync();Console.WriteLine(html);HttpResponseMessage 包含一些訪問請求頭,和HTTP StatusCode 的屬性,與 WebClient 不同。除非顯示地調用 EnsureSuccessStatusCode,否則返回不成功狀態(如404,資源未找到)不會拋出異常,然而,通信或DNS錯誤會拋出異常。
HttpResponseMessage 包含一個 CopyToAsync 方法,它可以將數據寫到一個流中,適用于將輸入寫到一個文件中:
using (var fileStream =File.Create("linqpad.htm")) {await response.Content.CopyToAsync(fileStream); }GetAsync 是與 HTTP 的4種動作相關的4個方法之一(PostAsync,PutAsync,DeleteAsync)
2.SendAsync與請求消息
這是訪問所有數據的唯一低層方法,要使用這個類,首先要創建一個 HttpRequestMessage
var client = new HttpClient(); var request = new HttpRequestMessage(HttpMethod.Get, "http://www.weibo.com");HttpResponseMessage response = await client.SendAsync(request);response.EnsureSuccessStatusCode();...創建一個 HttpResponseMessage 對象,意味著可以自定義請求的屬性,如請求頭和內容本身,它們可用于上傳數據。
3.上傳數據與HttpContent
創建一個 HttpRequestMessage 對象以后,設置它的 Content 屬性,就可以上傳內容。這個屬性類型是抽象類 HttpContent。
Framework包含下面子類,對應不同類型。
- ByteArrayContent
- StreamContent
- FormUrlEncodedContent
- StreamContent
4.HttpMessageHandler
前面說過,大多數自定義請求屬性不在 HttpClient 中定義,而在 HttpClientHandler 中定義。后者實際是 HttpMessageHandler 的子類,
public abstract class HttpMessageHandler : IDisposable {protected internal abstract Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken);public void Dispose();protected virtual void Dispose(bool disposing); }SendAsync 方法是在 HttpClient 的 SendAsync 方法中調用。
HttpMessageHandler 非常容易繼承,同時提供 HttpClient 的擴展點。
5.單元測試與樁處理器
創建 HttpMessageHandler 的子類,就可以創建一個幫助進行單元測試的樁處理器:
...
6.使用實現處理器鏈
創建 DelegatingHandler 的子類,就可以創建一個調用其他消息處理器的消息處理器(形成處理器鏈)。這種方法適用于實現自定義身份驗證、壓縮和加密協議。
例子,簡單的日志處理器:
這里重寫 SendAsync 時保持異步性。在重載任務的方法時添加 async 修飾符是絕對合法的如這個例子。
相對于將信息直接寫到控制臺,更好的方法是給構造方法傳入某種日志記錄對象。最好是接受一對 Action<T> 代理,然后讓他們記錄請求和響應對象的日志信息。
16.4.4 代理
16.4.5 身份驗證
創建一個 NetworkCredential 對象,...
16.4.6 異常處理
16.5 HTTP訪問
16.5.1 請求頭
WebClient、WebRequest 和 HttpClient 都可以添加自定義HTTP請求頭,以及在響應中列舉請求頭信息。
請求頭只是一些鍵/值對,其中包含相應的元數據,如消息內容類型或服務器軟件。
例子演示如何在請求中添加自定義請求頭信息,然后在 HttpClient 的響應消息中列舉所有請求頭信息:
WebClient wc =new WebClient();wc.Proxy = null;wc.Headers.Add("CustomHeader","JustPlaying/1.0");wc.DownloadString("http://www.cnblogs.com");foreach (string name in wc.ResponseHeaders.Keys){Console.WriteLine(name + "=" + wc.ResponseHeaders[name]);}相反,HttpClient 包含一些強類型集合,其中包含與標準HTTP頭信息相對應的屬性。
DefaultRequestHeaders 屬性包含適用于每一個請求的頭信息:
而 HttpRequestMessage 類的 Headers 屬性則包含請求頭特有的頭信息。
16.5.2 查詢字符串
?key1=value1&key2=value2&key3=value3...
WebClient 包含一個字段風格的屬性,它可以簡化查詢字符串的操作。
例子,在百度搜索單詞 "WebClient" ,然后顯示結果:
如果要使用 WebRequest 或 HttpClient 實現相同效果,那么必須手工賦值給請求URL正確格式字符串:
string requestURI = "https://www.baidu.com/s?wd=webclient";如果查詢中包含符號或空格,那么使用 URI 的 EscapeDataString 方法:
string search = Uri.EscapeDataString("(WebClient OR HttpClient)");string language = Uri.EscapeDataString("fr");string requestURI = "http://www.google.com/search?q=" + search +"&hl=" + language;結果為 http://www.google.com/search?q=(WebClient%20OR%20HttpClient)&hl=fr
16.5.3 上傳表單數據
WebClent 的 UploadValues 方法可以把HTML表單的方式提交數據:
WebClient wc = new WebClient();wc.Proxy = null;var data = new System.Collections.Specialized.NameValueCollection();data.Add("Name", "Joe Albahari");data.Add("Company", "O'Reilly");byte[] result = wc.UploadValues("http://www.albahari.com/EchoPost.aspx","POST", data);Console.WriteLine(Encoding.UTF8.GetString(result));結果:
You posted=Name=Joe+Albahari&Company=O'Reilly
NameValueCollection 中的鍵(如 searchtextbox 和 searchMode) 與HTML表單的輸入框相對應。使用 WebRequest 上傳表單數據操作更復雜。(如果需要使用 cookies等特性,則必須采用這種方法)
下面是具體操作過程:
name1=value1&name2=value2&name3=value3...
如果使用 HttpClient,則要創建和生成 FormUrlEncodedContent 對象,然后再傳遞到 PostAsync 方法,或者設置到請求的 Content 屬性上。
//HttpClient 上傳表單數據 string uri = "http://www.albahari.com/EchoPost.aspx"; var client = new HttpClient(); var dict = new Dictionary<string,string> {{ "Name", "Joe Albahari" },{ "Company", "O'Reilly" } }; var values = new FormUrlEncodedContent (dict); var response = await client.PostAsync (uri, values); response.EnsureSuccessStatusCode(); Console.WriteLine (await response.Content.ReadAsStringAsync());16.5.4 Cookies
Cookies是名稱/值字符串對,它是HTTP服務器通過響應頭發送到客戶端。Web瀏覽器客戶端一般會記住cookie,然后在終止之前,后續請求都會將它們重復發送給服務器(相同地址)。
Cookie 使服務器知道它是否正在連接之前連接過的相同客戶端,從而不需要在URI重復添加負責查詢字符串。
默認情況,HttpWebRequest 會忽略從服務器接收的任意 cookie。為了接收 cookie,必須創建一個 CookieCotainer 對象,然后分配到WebRequest。然后,就可以列舉響應中接收到的 cookie:
CookieContainer cc = new CookieContainer();var request = (HttpWebRequest) WebRequest.Create ("http://www.baidu.com"); request.Proxy = null; request.CookieContainer = cc; using (var response = (HttpWebResponse) request.GetResponse()) {foreach (Cookie c in response.Cookies){Console.WriteLine (" Name: " + c.Name);Console.WriteLine (" Value: " + c.Value);Console.WriteLine (" Path: " + c.Path);Console.WriteLine (" Domain: " + c.Domain);}// Read response stream 讀取響應流... }
如果使用 HttpClient,則需要創建一個 HttpClientHandler 實例:
WebClient 不支持 cookie。
如果需要在將來的請求上接收到的 cookie,則只需要給每一個新的 WebRequest 對象設置相同的 CookieContainer 對象,或者在 HttpClient 中使用相同對象發送請求。
CookieContainer 是可序列化的類,所以它可以寫到磁盤中。此外,可以先使用一個新的 CookieContainer,然后再按照下面的方法手動添加cookie:
16.5.5 表單驗證
16.4.5 身份驗證 介紹如何使用 NetworkCredentials 對象實現其中一些類型的驗證,如Basic或NTLM(在 Web瀏覽器彈出一個對話框)。然而,大多數驗證的網站都使用某種基于表單的方法。
用戶在文本框輸入用戶名和密碼,單擊按鈕提交數據,然后在成功驗證之后接收到 cookie,這個 cookie 屬于所訪問網頁的私有數據。通過 WebRequest 或 HttpClient,就可以實現。
下面演示 WebRequest/WebResponse 登錄網站:
string loginUri = "http://www.somesite.com/login"; string username = "username"; // (Your username) string password = "password"; // (Your password) string reqString = "username=" + username + "&password=" + password; byte[] requestData = Encoding.UTF8.GetBytes (reqString);CookieContainer cc = new CookieContainer(); var request = (HttpWebRequest)WebRequest.Create (loginUri); request.Proxy = null; request.CookieContainer = cc; request.Method = "POST";request.ContentType = "application/x-www-form-urlencoded"; request.ContentLength = requestData.Length;using (Stream s = request.GetRequestStream())s.Write (requestData, 0, requestData.Length);using (var response = (HttpWebResponse) request.GetResponse())foreach (Cookie c in response.Cookies)Console.WriteLine (c.Name + " = " + c.Value);//我們現在已經成功登錄,只要給后續的 WebRequest 對象添加 cc,就可以保持已驗證用戶的狀態使用 HttpClient 實現的方法:
string loginUri = "http://www.somesite.com/login"; string username = "username"; string password = "password";CookieContainer cc = new CookieContainer(); var handler = new HttpClientHandler { CookieContainer = cc };var request = new HttpRequestMessage (HttpMethod.Post, loginUri); request.Content = new FormUrlEncodedContent (new Dictionary<string,string> {{ "username", username },{ "password", password } });var client = new HttpClient (handler); var response = await client.SendAsync (request); response.EnsureSuccessStatusCode();16.5.6 SSL
16.6 編寫HTTP服務器
我們可以使用 HttpListener 類編寫自定義 HTTP 服務器,下面是一個監聽端口 51111 的簡單服務器,它會等待一個客戶端請求,然后返回一行回復。
static void Main() {ListenAsync(); // Start serverWebClient wc = new WebClient(); // Make a client request.Console.WriteLine (wc.DownloadString("http://localhost:51111/MyApp/Request.txt")); }async static void ListenAsync() {HttpListener listener = new HttpListener();listener.Prefixes.Add ("http://localhost:51111/MyApp/"); // Listen onlistener.Start(); // port 51111.// Await a client request:HttpListenerContext context = await listener.GetContextAsync();// Respond to the request:string msg = "You asked for: " + context.Request.RawUrl;context.Response.ContentLength64 = Encoding.UTF8.GetByteCount (msg);context.Response.StatusCode = (int) HttpStatusCode.OK;using (Stream s = context.Response.OutputStream)using (StreamWriter writer = new StreamWriter (s))await writer.WriteAsync (msg);listener.Stop(); }輸出:You asked for: /MyApp/Request.txt
HttpListener 內部并步使用 .net Socket 對象,相反,它調用 Windows HTTP Server API。支持計算機中多個應用程序監聽相同的IP地址和端口,前提是每一個應用程序都注冊不同的地址前綴。
調用 GetContext 時,HttpListener 會等待下一個客戶端請求,這個方法會返回一個對象,其中包含 Request 和 Response 屬性。每一個屬性都與 WebRequest 和 WebResponse 對象類似,但是它們屬于服務器。例如,我們可以讀寫請求和響應對象的頭信息和 Cookie,使用的方法與客戶端非常類似。
我們可以基于預期客戶端類型選擇如何支持 HTTP 協議特性。至少,每一個請求都需要設置內容長度和狀態碼。
下面這個簡單網頁服務器,最多支持50并發請求:
using System; using System.IO; using System.Net; using System.Threading.Tasks;class WebServer {HttpListener _listener;string _baseFolder; // Your web page folder.public WebServer (string uriPrefix, string baseFolder){_listener = new HttpListener();_listener.Prefixes.Add (uriPrefix);_baseFolder = baseFolder;}public async void Start(){_listener.Start();while (true)try {var context = await _listener.GetContextAsync();Task.Run (() => ProcessRequestAsync (context));}catch (HttpListenerException) { break; } // Listener stopped.catch (InvalidOperationException) { break; } // Listener stopped.}public void Stop() { _listener.Stop(); }async void ProcessRequestAsync (HttpListenerContext context){try{string filename = Path.GetFileName (context.Request.RawUrl);string path = Path.Combine (_baseFolder, filename);byte[] msg;if (!File.Exists (path)){Console.WriteLine ("Resource not found: " + path);context.Response.StatusCode = (int) HttpStatusCode.NotFound;msg = Encoding.UTF8.GetBytes ("Sorry, that page does not exist");}else{context.Response.StatusCode = (int) HttpStatusCode.OK;msg = File.ReadAllBytes (path);}context.Response.ContentLength64 = msg.Length;using (Stream s = context.Response.OutputStream)await s.WriteAsync (msg, 0, msg.Length);}catch (Exception ex) { Console.WriteLine ("Request error: " + ex); }} }下面是啟動程序的 Main 方法:
static void Main() {// Listen on port 51111, serving files in d:\webroot:var server = new WebServer ("http://localhost:51111/", @"d:\webroot");try{server.Start();Console.WriteLine ("Server running... press Enter to stop");Console.ReadLine();}finally { server.Stop(); } }可以使用任何一個 Web 瀏覽器作為客戶端進行測試,這里的URI是 http://localhost/ 加上網站名稱。
警告: 如果其他軟件占用同一個端口,那么 HttpListener 不會啟動(除非這個軟件也使用Windows HTTP Server API)
使用異步函數可以實現服務器的可擴展性和提高運行效率。然而,從UI線程開始都可能會影響可擴展性,因為每一個請求中,執行過程都會在每一次等待之后返回UI線程。這種等待毫無意義,因為沒有共享的狀態。所以UI中,最好去掉UI線程,或者這樣:
Task.Run(start);
或者在調用 GetContextAsync 之后調用 ConfigureAwait(false)。
注意,即使這些方法是異步的,但我們仍然在 Task.Run 中調用 ProcessRequestAsync。這樣就尅允許調用者馬上能夠處理另一個請求,而不需要同步等待方法執行結束(一直到第一個 await)。
轉載于:https://www.cnblogs.com/tangge/p/6933880.html
總結
以上是生活随笔為你收集整理的16.网络《果壳中的c#》的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: oracle基本操作手册
- 下一篇: 撑不下去的时候,请看看这19张照片