事實上網(wǎng)絡(luò)編程簡單的理解就是兩臺計算機相互通訊數(shù)據(jù)而已。對于程序員而言，去掌握一種編程接口并使用一種編程模型相對就會顯得簡單的多了。Java SDK提供一些相對簡單的Api來完成這些工作，Socket就是其中之一。
對于Java而言。這些Api存在與Java.net這個包里面。因此只要導(dǎo)入這個包就可以準備網(wǎng)絡(luò)編程了。網(wǎng)絡(luò)編程的基本模型就是客戶機到服務(wù)器模型。簡單的說就是兩個進程之間相互通訊，然后其中一個必須提供一個固定的位置，而另一個則只需要知道這個固定的位置，并去建立兩者之間的聯(lián)系。然后完成數(shù)據(jù)的通訊就可以了。這里提供固定位置的通常稱為服務(wù)器，而建立聯(lián)系的通常叫做客戶端�；谶@個簡單的模型，就可以進入網(wǎng)絡(luò)編程。
Java對這個模型的支持有很多種Api.而這里我只想介紹有關(guān)Socket的編程接口。對于Java而言已經(jīng)簡化了Socket的編程接口。首先我們來討論有關(guān)提供固定位置的服務(wù)方是如何建立的。Java提供了ServerSocket來對其進行支持。事實上當(dāng)你創(chuàng)建該類的一個實力對象并提供一個端口資源你就建立了一個固定位置可以讓其他計算機來訪問你。
ServerSocket server=new ServerSocket（6789）；
這里稍微要注意的是端口的分配必須是唯一的。因為端口是為了唯一標(biāo)識每臺計算機唯一服務(wù)的。另外端口號是從0~65535之間的，前1024個端口已經(jīng)被Tcp/Ip 作為保留端口，因此你所分配的端口只能是1024個之后的。
好了。我們有了固定位置�，F(xiàn)在所需要的就是一根連接線了。該連接線由客戶方首先提出要求。因此Java同樣提供了一個Socket對象來對其進行支持。只要客戶方創(chuàng)建一個Socket的實例對象進行支持就可以了。
Socket client=new Socket（InetAddress.getLocalHost（），5678）；
客戶機必須知道有關(guān)服務(wù)器的IP地址。對于著一點Java也提供了一個相關(guān)的類InetAddress 該對象的實例必須通過它的靜態(tài)方法來提供。它的靜態(tài)方法主要提供了得到本機IP 和通過名字或IP直接得到InetAddress的方法。
好了，上面的方法基本可以建立一條連線讓兩臺計算機相互交流了�？墒菙�(shù)據(jù)是如何傳輸?shù)哪兀渴聦嵣螴/O操作總是和網(wǎng)絡(luò)編程息息相關(guān)的。因為底層的網(wǎng)絡(luò)是繼續(xù)數(shù)據(jù)的。除非遠程調(diào)用，處理問題的核心在執(zhí)行上。
否則數(shù)據(jù)的交互還是依賴于IO操作的。所以你也必須導(dǎo)入Java.io這個包。Java的IO操作也不復(fù)雜。它提供了針對于字節(jié)流和Unicode的讀者和寫者，然后也提供了一個緩沖用于數(shù)據(jù)的讀寫。
BufferedReader in=new BufferedReader（new InputStreamReader（server.getInputStream（）））；
PrintWriter out=new PrintWriter（server.getOutputStream（））；
上面兩句就是建立緩沖并把原始的字節(jié)流轉(zhuǎn)變?yōu)閁nicode可以操作。而原始的字節(jié)流來源于Socket的兩個方法，getInputStream（）和getOutputStream（）方，分別用來得到輸入和輸出。那么現(xiàn)在有了基本的模型和基本的操作工具，我們可以做一個簡單的Socket例程了服務(wù)方：
import Java。io。*;
import Java。net。*;
public class MyServer
{
public static void main
(String[] args) throws IOException
{
ServerSocket server=new
ServerSocket(5678);
Socket client=server.accept();
BufferedReader
in=new BufferedReader(new
InputStreamReader
(client.getInputStream()));
PrintWriter out=new
PrintWriter(client.getOutputStream());
while(true)
{
String str=in.readLine();
System.out.println(str);
out.println("has receive...");
out.flush();
if(str.equals("end"))
break;
}
client。close();
}
}
這個程序的主要目的在于服務(wù)器不斷接收客戶機所寫入的信息只到�？蛻魴C發(fā)送"End"字符串就退出程序。并且服務(wù)器也會做出"Receive"為回應(yīng)。告知客戶機已接收到消息�？蛻魴C代碼：
import Java.net.*;
import Java.io.*;
public class Client{
static Socket server;
public static void
main(String[] args)
throws Exception
{
server=new Socket
(InetAddress.getLocalHost()，5678);
BufferedReader in=new BufferedReader(new
InputStreamReader(server。getInputStream()));
PrintWriter out=new
PrintWriter(server.getOutputStream());
BufferedReader wt=new BufferedReader(new
InputStreamReader(System.in));
while(true)
{
String str=wt.readLine();
out.println(str);
out.flush();
if(str.equals("end"))
{
break;
}
System.out.println(in.readLine());
}
server.close();
}
}
|
