事實上網絡編程簡單的理解就是兩台計算機相互通訊數據而已.對於程序員而言,去掌握一種編程接口並使用一種編程模型相對就會顯得簡單的多了.Java SDK提供一些相對簡單的Api來完成這些工作.Socket就是其中之一.對於Java而言.這些Api存在與Java.Net 這個包裡面.因此只要導入這個包就可以准備網絡編程了.
網絡編程的基本模型就是客戶機到服務器模型.簡單的說就是兩個進程之間相互通訊,然後其中一個必須提供一個固定的位置,而另一個則只需要知道這個固定的位置.並去建立兩者之間的聯系..然後完成數據的通訊就可以了.這裡提供固定位置的通常稱為服務器,而建立聯系的通常叫做客戶端.基於這個簡單的模型,就可以進入網絡編程啦.
Java對這個模型的支持有很多種Api.而這裡我只想介紹有關Socket的編程接口.對於Java而言已經簡化了Socket的編程接口.首先我們來討論有關提供固定位置的服務方是如何建立的.Java提供了ServerSocket來對其進行支持.事實上當你創建該類的一個實力對象並提供一個端口資源你就建立了一個固定位置可以讓其他計算機來訪問你.ServerSocket server=new ServerSocket(6789);這裡稍微要注意的是端口的分配必須是唯一的.因為端口是為了唯一標識每台計算機唯一服務的.另外端口號是從0~65535之間的,前1024個端口已經被Tcp/Ip 作為保留端口,因此你所分配的端口只能是1024個之後的.好了.我們有了固定位置.現在所需要的就是一根連接線了.該連接線由客戶方首先提出要求.因此Java同樣提供了一個Socket對象來對其進行支持.只要客戶方創建一個Socket的實例對象進行支持就可以了.Socket clIEnt=new Socket(InetAddress.getLocalHost(),5678);客戶機必須知道有關服務器的IP地址.對於著一點Java也提供了一個相關的類InetAddress 該對象的實例必須通過它的靜態方法來提供.它的靜態方法主要提供了得到本機IP 和通過名字或IP直接得到InetAddress的方法.
好了.上面的方法基本可以建立一條連線讓兩台計算機相互交流了.可是數據是如何傳輸的呢?事實上I/O操作總是和網絡編程息息相關的.因為底層的網絡是繼續數據的.除非遠程調用,處理問題的核心在執行上.否則數據的交互還是依賴於IO操作的.所以你也必須導入java.io這個包.Java的IO操作也不復雜.它提供了針對於字節流和Unicode的讀者和寫者,然後也提供了一個緩沖用於數據的讀寫.
BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
PrintWriter out=new PrintWriter(server.getOutputStream());
上面兩句就是建立緩沖並把原始的字節流轉變為Unicode可以操作.而原始的字節流來源於Socket的兩個方法.getInputStream()和getOutputStream()方.分別用來得到輸入和輸出.那麼現在有了基本的模型和基本的操作工具.我們可以做一個簡單的Socket例程了.
服務方: import Java.io.*; 這個程序的主要目的在於服務器不斷接收客戶機所寫入的信息只到.客戶機發送"End"字符串就退出程序.並且服務器也會做出"Receive"為回應.告知客戶機已接收到消息.
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();
}
}
客戶機代碼: import Java.Net.*; 客戶機代碼則是接受客戶鍵盤輸入,並把該信息輸出,然後輸出"End"用來做退出標識.
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();
}
}
這個程序只是簡單的兩台計算機之間的通訊.如果是多個客戶同時訪問一個服務器呢?你可以試著再運行一個客戶端,結果是會拋出異常的.那麼多個客戶端如何實現呢?
import Java.io.*;
import Java.Net.*;
public class MyServer {
public static void main(String[] args) throws IOException{
ServerSocket server=new ServerSocket(5678);
while(true){
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();
}
}
}
這裡僅僅只是加了一個外層的While循環.這個循環的目的就是當一個客戶進來就為它分配一個Socket直到這個客戶完成一次和服務器的交互,這裡也就是接受到客戶的"End"消息.那麼現在就實現了多客戶之間的交互了.但是.問題又來了.這樣做雖然解決了多客戶,可是是排隊執行的.也就是說當一個客戶和服務器完成一次通訊之後下一個客戶才可以進來和服務器交互.無法做到同時服務.那麼要如何才能同時達到既能相互之間交流又能同時交流呢?很顯然這是一個並行執行的問題了.所以線程是最好的解決方案. import Java.Net.*;
import Java.io.*;
public class MultiUser extends Thread{
private Socket clIEnt;
public MultiUser(Socket c){
this.clIEnt=c;
}
public void run(){
try{
BufferedReader in=new BufferedReader(new InputStreamReader(clIEnt.getInputStream()));
PrintWriter out=new PrintWriter(clIEnt.getOutputStream());
//Mutil User but can't parallel
while(true){
String str=in.readLine();
System.out.println(str);
out.println("has receive....");
out.flush();
if(str.equals("end"))
break;
}
clIEnt.close();
}catch(IOException ex){
}finally{
}
}
public static void main(String[] args)throws IOException{
ServerSocket server=new ServerSocket(5678);
while(true){
//transfer location change Single User or Multi User
MultiUser mu=new MultiUser(server.accept());
mu.start();
}
}
}
我的類直接從Thread類繼承了下來.並且通過構造函數傳遞引用和客戶Socket建立了聯系.這樣每個線程就有了.一個通訊管道.同樣我們可以填寫run方法.把之前的操作交給線程來完成.這樣多客戶並行的Socket就建立起來了.
