基于socket的Java網(wǎng)絡(luò )編程集粹

事實(shí)上網(wǎng)絡(luò )編程簡(jiǎn)單的理解就是兩臺計算機相互通訊數據而已，對于程序員而言，去掌握一種編程接口并使用一種編程模型相對就會(huì )顯得簡(jiǎn)單的多了，JavaSDK提供一些相對簡(jiǎn)單的Api來(lái)完成這些工作。Socket就是其中之一，對于Java而言，這些Api存在與java.net這個(gè)包里面，因此只要導入這個(gè)包就可以準備網(wǎng)絡(luò )編程了。

網(wǎng)絡(luò )編程的基本模型就是客戶(hù)機到服務(wù)器模型，簡(jiǎn)單的說(shuō)就是兩個(gè)進(jìn)程之間相互通訊，然后其中一個(gè)必須提供一個(gè)固定的位置，而另一個(gè)則只需要知道這個(gè)固定的位置。并去建立兩者之間的聯(lián)系，然后完成數據的通訊就可以了，這里提供固定位置的通常稱(chēng)為服務(wù)器，而建立聯(lián)系的通常叫做客戶(hù)端，基于這個(gè)簡(jiǎn)單的模型，就可以進(jìn)入網(wǎng)絡(luò )編程啦。

Java對這個(gè)模型的支持有很多種Api，而這里我只想介紹有關(guān)Socket的編程接口，對于Java而言已經(jīng)簡(jiǎn)化了Socket的編程接口。首先我們來(lái)討論有關(guān)提供固定位置的服務(wù)方是如何建立的。Java提供了ServerSocket來(lái)對其進(jìn)行支持.事實(shí)上當你創(chuàng )建該類(lèi)的一個(gè)實(shí)力對象并提供一個(gè)端口資源你就建立了一個(gè)固定位置可以讓其他計算機來(lái)訪(fǎng)問(wèn)你，ServerSocketserver=newServerSocket(6789);這里稍微要注意的是端口的分配必須是唯一的。因為端口是為了唯一標識每臺計算機唯一服務(wù)的，另外端口號是從0~65535之間的，前1024個(gè)端口已經(jīng)被Tcp/Ip作為保留端口，因此你所分配的端口只能是1024個(gè)之后的。好了，我們有了固定位置.現在所需要的就是一根連接線(xiàn)了.該連接線(xiàn)由客戶(hù)方首先提出要求。因此Java同樣提供了一個(gè)Socket對象來(lái)對其進(jìn)行支持，只要客戶(hù)方創(chuàng )建一個(gè)Socket的實(shí)例對象進(jìn)行支持就可以了。Socketclient=newSocket(InetAddress.getLocalHost(),5678);客戶(hù)機必須知道有關(guān)服務(wù)器的IP地址，對于著(zhù)一點(diǎn)Java也提供了一個(gè)相關(guān)的類(lèi)InetAddress該對象的實(shí)例必須通過(guò)它的靜態(tài)方法來(lái)提供，它的靜態(tài)方法主要提供了得到本機IP和通過(guò)名字或IP直接得到InetAddress的方法。

上面的方法基本可以建立一條連線(xiàn)讓兩臺計算機相互交流了，可是數據是如何傳輸的呢？事實(shí)上I/O操作總是和網(wǎng)絡(luò )編程息息相關(guān)的。因為底層的網(wǎng)絡(luò )是繼續數據的，除非遠程調用，處理問(wèn)題的核心在執行上，否則數據的交互還是依賴(lài)于IO操作的，所以你也必須導入java.io這個(gè)包.java的IO操作也不復雜，它提供了針對于字節流和Unicode的讀者和寫(xiě)者，然后也提供了一個(gè)緩沖用于數據的讀寫(xiě)。

BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

PrintWriterout=newPrintWriter(server.getOutputStream());

上面兩句就是建立緩沖并把原始的字節流轉變?yōu)閁nicode可以操作，而原始的字節流來(lái)源于Socket的兩個(gè)方法，getInputStream()和getOutputStream()方，分別用來(lái)得到輸入和輸出，那么現在有了基本的模型和基本的操作工具，我們可以做一個(gè)簡(jiǎn)單的Socket例程了。

服務(wù)方:

importjava.io.*;

importjava.net.*;

publicclassMyServer{

publicstaticvoidmain(String[]args)throwsIOException{

ServerSocketserver=newServerSocket(5678);

Socketclient=server.accept();

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

while(true){

Stringstr=in.readLine();

System.out.println(str);

out.println(hasreceive....);

out.flush();

if(str.equals(end))

break;

}

client.close();

}

}

這個(gè)程序的主要目的在于服務(wù)器不斷接收客戶(hù)機所寫(xiě)入的信息只到，客戶(hù)機發(fā)送End字符串就退出程序，并且服務(wù)器也會(huì )做出Receive為回應，告知客戶(hù)機已接收到消息。

客戶(hù)機代碼:

importjava.net.*;

importjava.io.*;

publicclassClient{

staticSocketserver;

publicstaticvoidmain(String[]args)throwsException{

server=newSocket(InetAddress.getLocalHost(),5678);

BufferedReaderin=newBufferedReader(newInputStreamReader(server.getInputStream()));

PrintWriterout=newPrintWriter(server.getOutputStream());

BufferedReaderwt=newBufferedReader(newInputStreamReader(System.in));

while(true){

Stringstr=wt.readLine();

out.println(str);

out.flush();

if(str.equals(end)){

break;

}

System.out.println(in.readLine());

}

server.close();

}

}

客戶(hù)機代碼則是接受客戶(hù)鍵盤(pán)輸入,并把該信息輸出，然后輸出End用來(lái)做退出標識。

這個(gè)程序只是簡(jiǎn)單的兩臺計算機之間的通訊，如果是多個(gè)客戶(hù)同時(shí)訪(fǎng)問(wèn)一個(gè)服務(wù)器呢？你可以試著(zhù)再運行一個(gè)客戶(hù)端，結果是會(huì )拋出異常的。那么多個(gè)客戶(hù)端如何實(shí)現呢?

其實(shí),簡(jiǎn)單的分析一下，就可以看出客戶(hù)和服務(wù)通訊的主要通道就是Socket本身，而服務(wù)器通過(guò)accept方法就是同意和客戶(hù)建立通訊.這樣當客戶(hù)建立Socket的同時(shí)。服務(wù)器也會(huì )使用這一根連線(xiàn)來(lái)先后通訊，那么既然如此只要我們存在多條連線(xiàn)就可以了。那么我們的程序可以變?yōu)槿缦?

服務(wù)器:

importjava.io.*;

importjava.net.*;

publicclassMyServer{

publicstaticvoidmain(String[]args)throwsIOException{

ServerSocketserver=newServerSocket(5678);

while(true){

Socketclient=server.accept();

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

while(true){

Stringstr=in.readLine();

System.out.println(str);

out.println(hasreceive....);

out.flush();