1.網絡編程 1.1計算機網絡概述 網絡編程的實質就是兩個(或多個)設備(例如計算機)之間的數據傳輸。 按照計算機網絡的定義,通過一定的物理設備將處于不同位置的計算機連接起來組成的網絡,這個網絡中包含的設備有:計算機、路由器、交換機等等。 其實從軟件編程的角度來說,對于物理設備的理解不需要很深刻,就像你打電話時不需要很熟悉通信網絡的底層實現是一樣的,但是當深入到網絡編程的底層時,這些基礎知識是必須要補的。 路由器和交換機組成了核心的計算機網絡,計算機只是這個網絡上的節點以及控制等,通過光纖、網線等連接將設備連接起來,從而形成了一張巨大的計算機網絡。 網絡最主要的優勢在于共享:共享設備和數據,現在共享設備最常見的是打印機,一個公司一般一個打印機即可,共享數據就是將大量的數據存儲在一組機器中,其它的計算機通過網絡訪問這些數據,例如網站、銀行服務器等等。 如果需要了解更多的網絡硬件基礎知識,可以閱讀《計算機網絡》教材,對于基礎進行強化,這個在基礎學習階段不是必須的,但是如果想在網絡編程領域有所造詣,則是一個必須的基本功。 對于網絡編程來說,最主要的是計算機和計算機之間的通信,這樣首要的問題就是如何找到網絡上的計算機呢?這就需要了解ip地址的概念。 為了能夠方便的識別網絡上的每個設備,網絡中的每個設備都會有一個唯一的數字標識,這個就是IP地址。在計算機網絡中,現在命名IP地址的規定是IPv4協議,該協議規定每個IP地址由4個0-255之間的數字組成,例如10.0.120.34。每個接入網絡的計算機都擁有唯一的IP地址,這個IP地址可能是固定的,例如網絡上各種各樣的服務器,也可以是動態的,例如使用ADSL撥號上網的寬帶用戶,無論以何種方式獲得或是否是固定的,每個計算機在聯網以后都擁有一個唯一的合法IP地址,就像每個手機號碼一樣。 但是由于IP地址不容易記憶,所以為了方便記憶,有創造了另外一個概念——域名(Domain Name),例如sohu.com等。一個IP地址可以對應多個域名,一個域名只能對應一個IP地址。域名的概念可以類比手機中的通訊簿,由于手機號碼不方便記憶,所以添加一個姓名標識號碼,在實際撥打電話時可以選擇該姓名,然后撥打即可。 在網絡中傳輸的數據,全部是以IP地址作為地址標識,所以在實際傳輸數據以前需要將域名轉換為IP地址,實現這種功能的服務器稱之為DNS服務器,也就是通俗的說法叫做域名解析。例如當用戶在瀏覽器輸入域名時,瀏覽器首先請求DNS服務器,將域名轉換為IP地址,然后將轉換后的IP地址反饋給瀏覽器,然后再進行實際的數據傳輸。 當DNS服務器正常工作時,使用IP地址或域名都可以很方便的找到計算機網絡中的某個設備,例如服務器計算機。當DNS不正常工作時,只能通過IP地址訪問該設備。所以IP地址的使用要比域名通用一些。 IP地址和域名很好的解決了在網絡中找到一個計算機的問題,但是為了讓一個計算機可以同時運行多個網絡程序,就引入了另外一個概念——端口(port)。 在介紹端口的概念以前,首先來看一個例子,一般一個公司前臺會有一個電話,每個員工會有一個分機,這樣如果需要找到這個員工的話,需要首先撥打前臺總機,然后轉該分機號即可。這樣減少了公司的開銷,也方便了每個員工。在該示例中前臺總機的電話號碼就相當于IP地址,而每個員工的分機號就相當于端口。 有了端口的概念以后,在同一個計算機中每個程序對應唯一的端口,這樣一個計算機上就可以通過端口區分發送給每個端口的數據了,換句話說,也就是一個計算機上可以并發運行多個網絡程序,而不會在互相之間產生干擾。 在硬件上規定,端口的號碼必須位于0-65535之間,每個端口唯一的對應一個網絡程序,一個網絡程序可以使用多個端口。這樣一個網絡程序運行在一臺計算上時,不管是客戶端還是服務器,都是至少占用一個端口進行網絡通訊。在接收數據時,首先發送給對應的計算機,然后計算機根據端口把數據轉發給對應的程序。 有了IP地址和端口的概念以后,在進行網絡通訊交換時,就可以通過IP地址查找到該臺計算機,然后通過端口標識這臺計算機上的一個唯一的程序。這樣就可以進行網絡數據的交換了。 但是,進行網絡編程時,只有IP地址和端口的概念還是不夠的,下面就介紹一下基礎的網絡編程相關的軟件基礎知識。
1.2網絡編程概述 按照前面的介紹,網絡編程就是兩個或多個設備之間的數據交換,其實更具體的說,網絡編程就是兩個或多個程序之間的數據交換,和普通的單機程序相比,網絡程序最大的不同就是需要交換數據的程序運行在不同的計算機上,這樣就造成了數據好換的復雜。雖然通過IP地址和端口號可以找到網絡上運行的一個程序,但是如果需要進行網絡編程,則需要了解網絡通訊的過程。 網絡通訊基于“請求—響應”模型。在網絡通訊中,第一次主動發起通訊的程序被稱為客戶端(client)程序,簡稱客戶端,而第一次通訊中等待鏈接的程序被稱為服務器端(Server)程序,簡稱服務器。一旦通訊建立,則客戶端和服務器端完全一樣,沒有本質區別。 由此,網絡編程中的兩種程序就分別是客戶端和服務器端,例如QQ程序,每個QQ用戶安裝的都是QQ客戶端程序,而QQ服務器端程序則在騰訊公司的機房中,為大量的QQ用戶提供服務。這種網絡編程的結構被稱為客戶端/服務器結構,也叫Client/Serverj結構,簡稱C/S結構。 使用C/S結構的程序,在開發時需要分別開發客戶端和服務器端,這種結構的優勢在于客戶端是專門開發的,所以根據需要實現各種效果,專業點的說就是表現力豐富,而服務器端也需要專門進行開發。但是這種結構也存在著很多不足,例如通用性差,幾乎不能通用,也就是說一種程序的客戶端只能和對應的服務器端通訊,而不能和其他服務器端通訊,在實際維護中,也需要維護專門的客戶端和服務器端,維護的壓力比較大。 其實在運行很多程序時,沒有必要使用專門的客戶端,而需要使用通用的客戶端,例如瀏覽器,使用瀏覽器作為客戶端的結構稱為瀏覽器/服務器結構,也叫做Browser/Server結構,簡稱B/S結構。 使用B/S結構的程序,在開發時只需要開發服務器端即可,這種優勢在于開發壓力比較小,不需要維護客戶端,但是這種結構也存在這很多不足,例如瀏覽器的限制比較大,表現了不強,不能進行系統級別的操作等。 總之C/S結構和B/S結構是現在網絡編程中常見的兩種結構,B/S結構其實也就是一種特殊的C/S結構。 另外簡單的介紹一下P2P(Point to Point)程序,常見的如BT、電驢等。P2P程序是一種特殊的程序,應該一個P2P程序中既包含客戶端程序,也包含服務器端程序,例如BT,使用客戶端程序部分連接其它的種子(服務器端),而使用服務器端向其它的BT客戶端傳輸數據。如果這個還不是很清楚,其實P2P程序和手機是一樣的,當手機撥打電話時就是使用客戶端的作用,而手機處于待機狀態時,可以接收到其它用戶撥打的電話則起的就是服務器端的功能,只是一般的手機不能同時使用撥打電話和接聽電話的功能,而P2P程序實現了該功能。 最后介紹一下網絡編程中最重要的,也是最復雜的概念——協議(PRotocol)。按照前面的介紹,網絡編程就是運行在不同計算機中兩個程序之間的數據交換。在實際進行數據交換時,為了讓接收端理解該數據,計算機比較笨,什么都不懂的,那么久需要規定該數據的格式,這個數據的格式就是協議。 如果沒有理解協議的概念,那么再舉一個例子,記得有個電影叫《永不消逝的電波》,講述的是地下黨通過電臺發送情報的故事,這里我們不探討電影的劇情,而只關 心電臺發送的數據。在實際發報時,需要首先將需要發送的內容轉換為電報編碼,然后將電報編碼發送出去,而接收端接收的是電報編碼,如果需要理解電報的內容 則需要根據密碼本翻譯出該電報的內容。這里的密碼本就規定了一種數據格式,這種對于網絡中傳輸的數據格式在網絡編程中就被稱作協議。 那么如何編寫協議格式呢?答案是隨意。只要按照這種協議格式能夠生成唯一的編碼,按照該編碼可以唯一的解析出發送數據的內容即可。也正因為各個網絡程序之間協議格式的不同,所以才導致了客戶端程序都是專用的結構。 在實際的網絡編程中,最麻煩的內容不是數據的發送和接受,因為這個功能在幾乎所有編程語言中都提供了封裝好的API進行調用,最麻煩的內容就是協議的設計及協議的生產和解析,這個才是網絡編程最核心的內容。 1.3網絡通訊方式 在現有的網絡中,網絡通訊的方式主要有兩種: 1.TCP(傳輸控制協議)方式。 2.UDP(用戶數據協議)方式。 為了方便理解這兩種方式,還是先來看個例子。大家使用手機時,向別人傳遞信息時有兩種方式:撥打電話和發送短信。使用撥打電話的方式可以保證該信息傳遞給別人,因為別人接電話時本身就確認收到了該信息。而發送短信的方式價格低廉,使用方便,但是接受人可能收不到。 在網絡通訊中,TCP方式就類似于撥打電話,使用該種方式進行網絡通訊時,需要建立專門的虛擬連接,然后進行可靠的數據傳輸,如果數據發送失敗,則客戶端會自動重發該數據,而UDP方式就類似于發送短信,使用這種方式進行網絡通訊時,不需要建立專門的虛擬連接,傳輸也不是很可靠,如果發送失敗則客戶端無法獲得。 這兩種傳輸方式都是實際的網絡編程中進行使用,重要的數據一般使用TCP方式進行數據傳輸,而大量的非核心數據則都通過UDP方式進行傳遞,在一些程序中甚至結合使用這兩種方式進行數據的傳遞。 由于TCP需要建立專用的虛擬連接以及確認傳輸是否正確,所以使用TCP方式的速度稍微慢一些,而且傳輸時產生的數據量要比UDP稍微大一些。 關于網絡編程的基礎知識就介紹這么多,如果需要深入了解相關知識請閱讀專門的計算機網絡書籍,下面開始介紹java語言中網絡編程的相關技術。
1.3網絡編程步驟 按照前面的基礎知識介紹,無論使用TCP方式還是UDP方式進行網絡通訊,網絡編程都是由客戶端和服務器端組成,所以,下面介紹網絡編程的步驟時,均以C/S結構為基礎進行介紹。 1.3.1客戶端網絡編程步驟 客戶端是指網絡編程中首先發起連接的程序,客戶端一般實現程序界面和基本邏輯實現,在進行實際的客戶端編程時,無論客戶端復雜還是簡單,以及客戶端實現的方式,客戶端的編程主要由三個步驟實現: 1.建立網絡連接 客戶端網絡編程的第一步都是建立網絡連接。在建立網絡連接時需要指定連接的服務器的IP地址和端口號,建立完成以后,會形成一條虛擬的連接,后續的操作就可以通過該連接實現數據交換了。 2.交換數據 連接建立以后,就可以通過這個連接交換數據了,交換數據嚴格要求按照請求響應模型進行,由客戶端發送一個請求數據到服務器,服務器反饋一個響應數據后給客戶端,如果客戶端不發送請求則服務器就不響應。 根據邏輯需要,可以多次交換數據,但是還是必須遵循請求響應模型。 3.關閉網絡連接 在數據交換完成后,關閉網絡連接,釋放程序占用的端口、內存等系統資源,結束網絡編程。 最基本的步驟一般都是這三個步驟,在實際實現時,步驟2會出現重復,在進行代碼組織時,由于網絡編程是比較耗時的操作,所以一般開啟專門的現場進行網絡通訊。
1.4服務器端網絡編程步驟 服務器是指網絡編程中被等待連接的程序,服務器端一般實現程序的核心邏輯以及數據存儲等核心功能。服務器端的編程步驟和客戶端不同,是由四個步驟實現,依次是: 1.監聽端口 服務器端屬于被動等待連接,所以服務器端啟動以后,不需要發起連接,而只需要監聽本地計算機的某個固定端口即可。這個端口就是服務器端開放給客戶端的端口,服務器端程序運行的本地計算機的IP地址就是服務器端程序的IP地址。 2.獲得連接 當客戶端連接到服務器端時,服務器端就可以獲得一個連接,這個連接包含客戶端信息,例如客戶端IP地址等,服務器端和客戶端通過該連接進行數據交換。 一般在服務器端編程中,當獲得連接時,需要開啟專門的線程處理該連接,每個連接都由獨立的線程實現。 3.交換數據 服務器端通過獲得的連接進行數據交換。服務器端的數據交換步驟是首先接收客戶端發送過來的數據,然后進行邏輯處理,再把處理以后的結果數據發送給客戶端。簡單來說,就是先接收再發送,這個和客戶端的數據交換順序不同。 其實,服務器端獲得的連接和客戶端的連接是一樣的,只是數據交換的步驟不同。當然,服務器端的數據交換也是可以多次進行的。在數據交換完成以后,關閉和客戶端的連接。 4.關閉連接 當服務器程序關閉時,需要關閉服務器端,通過關閉服務器端使得服務器監聽的端口以及占用的內存可以釋放出來,實現了連接的關閉。 其實服務器端編程的模型和呼叫中心的實現是類似的,例如移動的客服電話10086就是典型的呼叫中心,當一個用戶撥打10086時,轉接給一個專門的客服人員,由該客服實現和該用戶的問題解決,當另外一個用戶撥打10086時,則轉接給另一個客服,實現問題解決,依次類推。 在服務器端編程時,10086這個電話號碼就類似于服務器端的端口號碼,每個用戶就相當于一個客戶端程序,每個客服人員就相當于服務器端啟動的專門和客戶端連接的線程,每個線程都是獨立進行交互的。 這就是服務器端編程的模型,只是TCP方式是需要建立連接的,對于服務器端的壓力比較大,而UDP是不需要建立連接的,對于服務器端的壓力比較小罷了。 總之,無論使用任何語言,任何方式進行基礎的網絡編程,都必須遵循固定的步驟進行操作,在熟悉了這些步驟以后,可以根據需要進行邏輯上的處理,但是還是必須遵循固定的步驟進行。 其實,基礎的網絡編程本身不難,也不需要很多的基礎網絡知識,只是由于編程的基礎功能都已經由API實現,而且需要按照固定的步驟進行,所以在入門時有一定的門檻,希望下面的內容能夠將你快速的帶入網絡編程技術的大門。
2.Java網絡編程技術 和網絡編程有關的基本API位于Java.NET包中,該包中包含了基本的網絡編程實現,該包是網絡編程的基礎。該包既包含基本的網絡編程類,也包含封裝后的專門處理WEB相關的處理類。 首先來介紹一下基礎的網絡類-InetAddress類。該類的功能是代表一個IP地址,并且將IP地址和域名相關的操作方法包含在該類的內部。關于該類的使用,下面通過一個基礎的代碼演示該類的使用。
import java.net.InetAddress;import java.net.UnknownHostException;public class InetAddressDemo { public static void main(String[] args) { try { InetAddress inet1 = InetAddress.getByName("www.163.com"); System.out.println(inet1); InetAddress inet2=InetAddress.getByName("127.0.0.1"); System.out.println(inet2); InetAddress inet3=InetAddress.getLocalHost(); System.out.println(inet3); String host =inet3.getHostName(); System.out.println("域名:"+host); String ip=inet3.getHostAddress(); System.out.println("IP:"+ip); } catch (UnknownHostException e) { e.printStackTrace(); } }}在該示例代碼中,演示了InetAddress類的基本使用,并使用了該類的幾個常用方法,該代碼的執行結果是: www.163.com/202.201.14.182 /127.0.0.1 DESKTOP-HRHF03J/192.168.1.196 域名:DESKTOP-HRHF03J IP:192.168.1.196 說明:由于該代碼中包含一個互聯網的網址,所以運行該程序時需要聯網,否則將產生異常。 在后續的使用中,經常包含需要使用InetAddress對象代表IP地址的構造方法,當然,該類的使用補水必須的,也可以使用字符串來代表IP地址。
3.TCP編程 在Java語言中,對于TCP方式的網絡編程提供了良好的支持,在實際實現時,以java.net.socket類代表客戶端連接,以java.net.ServerSocket類作為服務器端連接。在進行網絡編程時,底層網絡通訊的細節已經實現了比較高的封裝,所以在程序員實際編程時,只需要指定IP地址和端口號就可以建立連接了。正是由于這種高度的封裝,一方面,簡化了Java語言網絡編程的難度,另外也使得使用Java語言進行網絡編程無法深入到網絡的底層,所以使用Java語言進行網絡底層系統編程很困難,具體點說,Java語言無法事先底層的網絡嗅探以及獲得IP包結構等消息。但是由于Java語言的網絡編程比較簡答,所以還是獲得了廣泛的使用。 在使用TCP方式進行網絡編程時,需要按照前面介紹的網絡編程的步驟進行,下面分別介紹一下在Java語言中客戶端和服務器端的實現步驟。在客戶端網絡編程中,首先需要建立連接,在Java API中以及java.net.socket類的對象代表網絡連接,所以建立客戶端網絡連接,也就是創建Socket類型的對象,該對象代表網絡連接,示例如下: Socket socket1=new Socket(“192.168.1.103”,10000); Socket socket2=new Socket(“www.sohu.com”,80); 上面的代碼中,socket1實現的是連接到IP地址是192.168.1.103的計算機的10000號端口,而socket2實現的是連接到域名是www.sohu.com的計算機的80號端口,至于底層網絡如何實現建立連接,對于程序員來說是完全透明的。如果建立連接時,本機網絡不通,或服務器端程序未開啟,則會拋出異常。 連接一旦建立,則完成了客戶端編程的第一步,緊接著的步驟就是按照“請求-響應”模型進行網絡數據交換,在Java語言中,數據傳輸功能由Java IO實現,也就是說只需要從連接中獲得輸入流和輸出流即可,然后將需要發送的數據寫入連接對象的輸出流中,在發送完成后從輸入流中讀取數據即可。示例代碼如下: OutputStream os=socket1.getOutputStream(); InputStream is=socket1,getInputStream(); 上面的代碼中,分別從socket1這個連接對象獲得了輸出流和輸入流對象,在整個網絡編程中,后續的數據交換就變成了IO操作,也就是遵循“請求-響應”模式的規定,先向輸出流中寫入數據,這些數據會被系統發送出去,然后再從輸入流中讀取服務器端的反饋信息,這樣就完成了一次數據交換工作,當然這個數據交換可以多次進行。 這里獲得的只是最基本的輸出流和輸入流對象,還可以根據前面學習到的IO知識,使用流的嵌套將這些獲得的基本流對象轉換成需要的裝飾流對象,從而方便數據的操作。 最后當數據交換完成以后,關閉網絡連接,釋放網絡連接占用的系統端口和內存等資源,完成網絡操作,示例代碼如下: socket1.close(); 這就是最基本的網絡編程功能介紹,下面是一個簡單的網絡客戶端程序示例,該程序的作用是向服務器發送一個字符串“Hello”,并將服務器端的反饋顯示到控制臺,數據交換只進行一次,當數據交換完成以后關閉網絡連接,程序結束,實現的代碼如下:
package tcp;import java.io.*;import java.net.*;/** * 簡單的Socket客戶端 * 功能為:發送字符串“Hello”到服務器端,并打印出服務器端的反饋 */public class SimpleSocketClient { public static void main(String[] args) { Socket socket = null; InputStream is = null; OutputStream os = null; //服務器端IP地址 String serverIP = "127.0.0.1"; //服務器端端口號 int port = 10000; //發送內容 String data = "Hello"; try { //建立連接 socket = new Socket(serverIP,port); //發送數據 os = socket.getOutputStream(); os.write(data.getBytes()); //接收數據 is = socket.getInputStream(); byte[] b = new byte[1024]; int n = is.read(b); //輸出反饋數據 System.out.println("服務器反饋:" + new String(b,0,n)); } catch (Exception e) { e.printStackTrace(); //打印異常信息 }finally{ try { //關閉流和連接 is.close(); os.close(); socket.close(); } catch (Exception e2) {} } }}在該示例代碼中建立了一個連接到IP地址為127.0.0.1,端口號為10000的TCP類型的網絡連接,然后獲得連接的輸出流對象,將需要發送的字符串“Hello”轉換為波耶特數組寫入到輸出流中,由系統自動完成將輸出流中的數據發送出去,如果需要強制發送,可以調用輸出流對象中的flush方法實現。在數據發送出去后,從連接對象的輸入流中讀取服務器端的反饋信息,讀取時可以使用IO中的各種讀取方法進行讀取,這里使用最簡單的方法進行讀取。從輸入流中讀取到的內容就是服務器端的反饋,并將讀取到的內容在客戶端的控制臺進行輸出,最后依次關閉打開的流對象和網絡連接對象。 這是一個簡單的功能示例,在該示例中演示了TCP類型的網絡客戶端基本方法的使用,該代碼只起演示目的,還無法達到實用的級別。 如果需要在控制臺下面編譯和運行該代碼,需要首先在控制臺下切換到源代碼所在的目錄,然后依次輸入編譯和運行命令:
javac –d . SimpleSocketClient.java java tcp.SimpleSocketClient和下面將要介紹的SimpleSocketServer服務器端組合運行時,程序的輸出結果為:
服務器反饋:Hello介紹完一個簡單的客戶端編程的示例,下面接著介紹一下TCP類型的服務器端的編寫。首先需要說明的是,客戶端的步驟和服務器端的編寫步驟不同,所以在學習服務器端編程時注意不要和客戶端混淆起來。 在服務器端程序編程中,由于服務器端實現的是被動等待連接,所以服務器端編程的第一個步驟是監聽端口,也就是監聽是否有客戶端連接到達。實現服務器端監聽的代碼為: ServerSocket ss = new ServerSocket(10000); 該代碼實現的功能是監聽當前計算機的10000號端口,如果在執行該代碼時,10000號端口已經被別的程序占用,那么將拋出異常。否則將實現監聽。 服務器端編程的第二個步驟是獲得連接。該步驟的作用是當有客戶端連接到達時,建立一個和客戶端連接對應的Socket連 接對象,從而釋放客戶端連接對于服務器端端口的占用。實現功能就像公司的前臺一樣,當一個客戶到達公司時,會告訴前臺我找某某某,然后前臺就通知某某某, 然后就可以繼續接待其它客戶了。通過獲得連接,使得客戶端的連接在服務器端獲得了保持,另外使得服務器端的端口釋放出來,可以繼續等待其它的客戶端連接。 實現獲得連接的代碼是: Socket socket = ss.accept(); 該代碼實現的功能是獲得當前連接到服務器端的客戶端連接。需要說明的是accept和前面IO部分介紹的read方法一樣,都是一個阻塞方法,也就是當無連接時,該方法將阻塞程序的執行,直到連接到達時才執行該行代碼。另外獲得的連接會在服務器端的該端口注冊,這樣以后就可以通過在服務器端的注冊信息直接通信,而注冊以后服務器端的端口就被釋放出來,又可以繼續接受其它的連接了。 連接獲得以后,后續的編程就和客戶端的網絡編程類似了,這里獲得的Socket類型的連接就和客戶端的網絡連接一樣了,只是服務器端需要首先讀取發送過來的數據,然后進行邏輯處理以后再發送給客戶端,也就是交換數據的順序和客戶端交換數據的步驟剛好相反。這部分的內容和客戶端很類似,所以就不重復了,如果還不熟悉,可以參看下面的示例代碼。 最后,在服務器端通信完成以后,關閉服務器端連接。實現的代碼為:ss.close(); 這就是基本的TCP類型的服務器端編程步驟。下面以一個簡單的echo服務實現為例子,介紹綜合使用示例。echo的意思就是“回聲”,echo服務器端實現的功能就是將客戶端發送的內容再原封不動的反饋給客戶端。實現的代碼如下:
package tcp;import java.io.*;import java.net.*;/** * echo服務器 * 功能:將客戶端發送的內容反饋給客戶端 */public class SimpleSocketServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; OutputStream os = null; InputStream is = null; //監聽端口號 int port = 10000; try { //建立連接 serverSocket = new ServerSocket(port); //獲得連接 socket = serverSocket.accept(); //接收客戶端發送內容 is = socket.getInputStream(); byte[] b = new byte[1024]; int n = is.read(b); //輸出 System.out.println("客戶端發送內容為:" + new String(b,0,n)); //向客戶端發送反饋內容 os = socket.getOutputStream(); os.write(b, 0, n); } catch (Exception e) { e.printStackTrace(); }finally{ try{ //關閉流和連接 os.close(); is.close(); socket.close(); serverSocket.close(); }catch(Exception e){} } }}在該示例代碼中建立了一個監聽當前計算機10000號端口的服務器端Socket連接,然后獲得客戶端發送過來的連接,如果有連接到達時,讀取連接中發送過來的內容,并將發送的內容在控制臺進行輸出,輸出完成以后將客戶端發送的內容再反饋給客戶端。最后關閉流和連接對象,結束程序。 在控制臺下面編譯和運行該程序的命令和客戶端部分的類似。 這樣,就以一個很簡單的示例演示了TCP類型的網絡編程在Java語言中的基本實現,這個示例只是演示了網絡編程的基本步驟以及各個功能方法的基本使用,只是為網絡編程打下了一個基礎,下面將就幾個問題來深入介紹網絡編程深層次的一些知識。 為了一步一步的掌握網絡編程,下面再研究網絡編程中的兩個基本問題,通過解決這兩個問題將對網絡編程的認識深入一層。 1、如何復用Socket連接? 在前面的示例中,客戶端中建立了一次連接,只發送一次數據就關閉了,這就相當于撥打電話時,電話打通了只對話一次就關閉了,其實更加常用的應該是撥通一次電話以后多次對話,這就是復用客戶端連接。 那么如何實現建立一次連接,進行多次數據交換呢?其實很簡單,建立連接以后,將數據交換的邏輯寫到一個循環中就可以了。這樣只要循環不結束則連接就不會被關 閉。按照這種思路,可以改造一下上面的代碼,讓該程序可以在建立連接一次以后,發送三次數據,當然這里的次數也可以是多次,示例代碼如下:
package tcp;import java.io.*;import java.net.*;/** * 復用連接的Socket客戶端 * 功能為:發送字符串“Hello”到服務器端,并打印出服務器端的反饋 */public class MulSocketClient { public static void main(String[] args) { Socket socket = null; InputStream is = null; OutputStream os = null; //服務器端IP地址 String serverIP = "127.0.0.1"; //服務器端端口號 int port = 10000; //發送內容 String data[] ={"First","Second","Third"}; try { //建立連接 socket = new Socket(serverIP,port); //初始化流 os = socket.getOutputStream(); is = socket.getInputStream(); byte[] b = new byte[1024]; for(int i = 0;i < data.length;i++){ //發送數據 os.write(data[i].getBytes()); //接收數據 int n = is.read(b); //輸出反饋數據 System.out.println("服務器反饋:" + new String(b,0,n)); } } catch (Exception e) { e.printStackTrace(); //打印異常信息 }finally{ try { //關閉流和連接 is.close(); os.close(); socket.close(); } catch (Exception e2) {} } }}該示例程序和前面的代碼相比,將數據交換部分的邏輯寫在一個for循環的內容,這樣就可以建立一次連接,依次將data數組中的數據按照順序發送給服務器端了。 如果還是使用前面示例代碼中的服務器端程序運行該程序,則該程序的結果是:
java.net.SocketException: Software caused connection abort: recv failed at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketInputStream.read(SocketInputStream.java:129) at java.net.SocketInputStream.read(SocketInputStream.java:90) at tcp.MulSocketClient.main(MulSocketClient.java:30)服務器反饋:First顯然,客戶端在實際運行時出現了異常,出現異常的原因是什么呢?如果仔細閱讀前面的代碼,應該還記得前面示例代碼中的服務器端是對話一次數據以后就關閉了連接,如果服務器端程序關閉了,客戶端繼續發送數據肯定會出現異常,這就是出現該問題的原因。 按照客戶端實現的邏輯,也可以復用服務器端的連接,實現的原理也是將服務器端的數據交換邏輯寫在循環中即可,按照該種思路改造以后的服務器端代碼為:
package tcp;import java.io.*;import java.net.*;/** * 復用連接的echo服務器 * 功能:將客戶端發送的內容反饋給客戶端 */public class MulSocketServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; OutputStream os = null; InputStream is = null; //監聽端口號 int port = 10000; try { //建立連接 serverSocket = new ServerSocket(port); System.out.println("服務器已啟動:"); //獲得連接 socket = serverSocket.accept(); //初始化流 is = socket.getInputStream(); os = socket.getOutputStream(); byte[] b = new byte[1024]; for(int i = 0;i < 3;i++){ int n = is.read(b); //輸出 System.out.println("客戶端發送內容為:" + new String(b,0,n)); //向客戶端發送反饋內容 os.write(b, 0, n); } } catch (Exception e) { e.printStackTrace(); }finally{ try{ //關閉流和連接 os.close(); is.close(); socket.close(); serverSocket.close(); }catch(Exception e){} } }}在該示例代碼中,也將數據發送和接收的邏輯寫在了一個for循環內部,只是在實現時硬性的將循環次數規定成了3次,這樣代碼雖然比較簡單,但是通用性比較差。 以該服務器端代碼實現為基礎運行前面的客戶端程序時,客戶端的輸出為: 服務器反饋:First 服務器反饋:Second 服務器反饋:Third 服務器端程序的輸出結果為: 服務器已啟動: 客戶端發送內容為:First 客戶端發送內容為:Second 客戶端發送內容為:Third 在該程序中,比較明顯的體現出了“請求-響應”模型,也就是在客戶端發起連接以后,首先發送字符串“First”給服務器端,服務器端輸出客戶端發送的內容“First”,然后將客戶端發送的內容再反饋給客戶端,這樣客戶端也輸出服務器反饋“First”,這樣就完成了客戶端和服務器端的一次對話,緊接著客戶端發送“Second”給服務器端,服務端輸出“Second”,然后將“Second”再反饋給客戶端,客戶端再輸出“Second”,從而完成第二次會話,第三次會話的過程和這個一樣。在這個過程中,每次都是客戶端程序首先發送數據給服務器端,服務器接收數據以后,將結果反饋給客戶端,客戶端接收到服務器端的反饋,從而完成一次通訊過程。 在該示例中,雖然解決了多次發送的問題,但是客戶端和服務器端的次數控制還不夠靈活,如果客戶端的次數不固定怎么辦呢?是否可以使用某個特殊的字符串,例如quit,表示客戶端退出呢,這就涉及到網絡協議的內容了,會在后續的網絡應用示例部分詳細介紹。下面開始介紹另外一個網絡編程的突出問題。 2、如何使服務器端支持多個客戶端同時工作? 前面介紹的服務器端程序,只是實現了概念上的服務器端,離實際的服務器端程序結構距離還很遙遠,如果需要讓服務器端能夠實際使用,那么最需要解決的問題就是——如何支持多個客戶端同時工作。 一個服務器端一般都需要同時為多個客戶端提供通訊,如果需要同時支持多個客戶端,則必須使用前面介紹的線程的概念。簡單來說,也就是當服務器端接收到一個連接時,啟動一個專門的線程處理和該客戶端的通訊。 按照這個思路改寫的服務端示例程序將由兩個部分組成,MulThreadSocketServer類實現服務器端控制,實現接收客戶端連接,然后開啟專門的邏輯線程處理該連接,LogicThread類實現對于一個客戶端連接的邏輯處理,將處理的邏輯放置在該類的run方法中。該示例的代碼實現為:
package tcp;import java.net.ServerSocket;import java.net.Socket;/** * 支持多客戶端的服務器端實現 */public class MulThreadSocketServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; //監聽端口號 int port = 10000; try { //建立連接 serverSocket = new ServerSocket(port); System.out.println("服務器已啟動:"); while(true){ //獲得連接 socket = serverSocket.accept(); //啟動線程 new LogicThread(socket); } } catch (Exception e) { e.printStackTrace(); }finally{ try{ //關閉連接 serverSocket.close(); }catch(Exception e){} } }}在該示例代碼中,實現了一個while形式的死循環,由于accept方法是阻塞方法,所以當客戶端連接未到達時,將阻塞該程序的執行,當客戶端到達時接收該連接,并啟動一個新的LogicThread線程處理該連接,然后按照循環的執行流程,繼續等待下一個客戶端連接。這樣當任何一個客戶端連接到達時,都開啟一個專門的線程處理,通過多個線程支持多個客戶端同時處理。 下面再看一下LogicThread線程類的源代碼實現:
package tcp;import java.io.*;import java.net.*;/** * 服務器端邏輯線程 */public class LogicThread extends Thread { Socket socket; InputStream is; OutputStream os; public LogicThread(Socket socket){ this.socket = socket; start(); //啟動線程 } public void run(){ byte[] b = new byte[1024]; try{ //初始化流 os = socket.getOutputStream(); is = socket.getInputStream(); for(int i = 0;i < 3;i++){ //讀取數據 int n = is.read(b); //邏輯處理 byte[] response = logic(b,0,n); //反饋數據 os.write(response); } }catch(Exception e){ e.printStackTrace(); }finally{ close(); } } /** * 關閉流和連接 */ private void close(){ try{ //關閉流和連接 os.close(); is.close(); socket.close(); }catch(Exception e){} } /** * 邏輯處理方法,實現echo邏輯 * @param b 客戶端發送數據緩沖區 * @param off 起始下標 * @param len 有效數據長度 * @return */ private byte[] logic(byte[] b,int off,int len){ byte[] response = new byte[len]; //將有效數據拷貝到數組response中 System.arraycopy(b, 0, response, 0, len); return response; }}在該示例代碼中,每次使用一個連接對象構造該線程,該連接對象就是該線程需要處理的連接,在線程構造完成以后,該線程就被啟動起來了,然后在run方法內部對客戶端連接進行處理,數據交換的邏輯和前面的示例代碼一致,只是這里將接收到客戶端發送過來的數據并進行處理的邏輯封裝成了logic方法,按照前面介紹的IO編程的內容,客戶端發送過來的內容存儲在數組b的起始下標為0,長度為n個中,這些數據是客戶端發送過來的有效數據,將有效的數據傳遞給logic方法,logic方法實現的是echo服務的邏輯,也就是將客戶端發送的有效數據形成以后新的response數組,并作為返回值反饋。 在線程中將logic方法的返回值反饋給客戶端,這樣就完成了服務器端的邏輯處理模擬,其他的實現和前面的介紹類似,這里就不在重復了。 這里的示例還只是基礎的服務器端實現,在實際的服務器端實現中,由于硬件和端口數的限制,所以不能無限制的創建線程對象,而且頻繁的創建線程對象效率也比較低,所以程序中都實現了線程池來提高程序的執行效率。 這里簡單介紹一下線程池的概念,線程池(Thread pool)是池技術的一種,就是在程序啟動時首先把需要個數的線程對象創建好,例如創建5000個線程對象,然后當客戶端連接到達時從池中取出一個已經創建完成的線程對象使用即可。當客戶端連接關閉以后,將該線程對象重新放入到線程池中供其它的客戶端重復使用,這樣可以提高程序的執行速度,優化程序對于內存的占用等。
新聞熱點
疑難解答