1 ServerSocket類
創建一個ServerSocket類,同時在運行該語句的計算機的指定端口處建立一個監聽服務,如:
ServerSocket MyListener=new ServerSocket(600);
這里指定提供監聽服務的端口是600,一台計算機可以同時提供多個服務,這些不同的服務之間通過端口號來區別,不同的端口號上提供不同的服務。為了隨時監聽可能的Client請求,執行如下的語句:
Socket LinkSocket=MyListener.accept();
該語句調用了ServerSocket對象的accept()方法,這個方法的執行將使Server端的程序處於等待狀態,程序將一直阻塞直到捕捉到一個來自Client端的請求,並返回一個用於與該Client通信的Socket對象Link-Socket。此后Server程序只要向這個Socket對象讀寫數據,就可以實現向遠端的Client讀寫數據。結束監聽時,關閉ServerSocket對象:
Mylistener.close();
2 Socket類
當Client程序需要從Server端獲取信息及其他服務時,應創建一個Socket對象:
Socket MySocket=new Socket(“ServerComputerName”,600);
Socket類的構造函數有兩個參數,第一個參數是欲連接到的Server計算機的主機地址,第二個參數是該Server機上提供服務的端口號。
Socket對象建立成功之后,就可以在Client和Server之間建立一個連接,並通過這個連接在兩個端點之間傳遞數據。利用Socket類的方法getOutputStream()和getInputStream()分別獲得向Socket讀寫數據的輸入/輸出流,最后將從Server端讀取的數據重新返還到Server端。
當Server和Client端的通信結束時,可以調用Socket類的close()方法關閉Socket,拆除連接。
ServerSocket 一般僅用於設置端口號和監聽,真正進行通信的是服務器端的Socket與客戶端的Socket,在ServerSocket 進行accept之后,就將主動權轉讓了。
1. 服務器端程序設計
在服務器端,利用ServerSocket類的構造函數ServerSocket(int port)創建一個ServerSocket類的對象,port參數傳遞端口,這個端口就是服務器監聽連接請求的端口,如果在這時出現錯誤將拋出IOException異常對象,否則將創建ServerSocket對象並開始准備接收連接請求。
服務程序從調用ServerSocket的accept()方法開始,直到連接建立。在建立連接后,accept()返回一個最近創建的Socket對象,該Socket對象綁定了客戶程序的IP地址或端口號。
2.客戶端程序設計
當客戶程序需要與服務器程序通信時,需在客戶機創建一個Socket對象。Socket類有構造函數Socket(InetAddress addr,int port)和Socket(String host,intport),兩個構造函數都創建了一個基於Socket的連接服務器端流套接字的流套接字。對於第一個InetAd-dress子類對象通過addr參數獲得服務器主機的IP地址,對於第二個函數host參數包被分配到InetAddress對象中,如果沒有IP地址與host參數相一致,那么將拋出UnknownHostException異常對象。兩個函數都通過參數port獲得服務器的端口號。假設已經建立連接了,網絡API將在客戶端基於Socket的流套接字中捆綁客戶程序的IP地址和任意一個端口號,否則兩個函數都會拋出一個IOException對象。
如果創建了一個Socket對象,那么它可通過get-InputStream()方法從服務程序獲得輸入流讀傳送來的信息,也可通過調用getOutputStream()方法獲得輸出流來發送消息。在讀寫活動完成之后,客戶程序調用close()方法關閉流和流套接字。
附小程序加以說明:
服務器端代碼:
1 import java.io.IOException; 2 import java.io.OutputStream; 3 import java.net.ServerSocket; 4 import java.net.Socket; 5 6 7 8 public class Myserver { 9 10 //建立ServerSocket,並設置其端口號 11 private ServerSocket ss; 12 13 public static final int port=8962; 14 15 public Myserver(){ 16 17 try{ 18 19 ss=new ServerSocket(port); 20 21 }catch(IOException e){ 22 23 e.printStackTrace(); 24 } 25 26 } 27 public void setConnection() throws IOException{ 28 //建立服務器端的Socket 29 Socket s; 30 OutputStream os; 31 try{ //ServerSocke.accept()t返回一個Socket對象 32 33 s=ss.accept(); 34 os=s.getOutputStream(); 35 os.write("hello".getBytes()); 36 os.close(); 37 s.close(); 38 }catch(IOException e){ 39 40 e.printStackTrace(); 41 } 42 43 } 44 45 public static void main(String[] args) throws IOException { 46 47 Myserver ms=new Myserver(); 48 ms.setConnection(); 49 50 } 51 52 }
客戶端代碼:
1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.net.Socket; 6 7 8 9 public class Myclient { 10 public static final String IP="172.16.221.134"; 11 public static final int port=8962; 12 private Socket s; 13 14 public Myclient() throws IOException{ 15 try{ 16 s=new Socket(IP,port); 17 18 }catch(IOException e){ 19 20 e.printStackTrace(); 21 } 22 } 23 24 public void setConnection()throws IOException{ 25 26 InputStream is; 27 28 try{ 29 is=s.getInputStream(); 30 BufferedReader br=new BufferedReader(new InputStreamReader(is)); 31 32 System.out.println(br.readLine()); 33 34 }catch(IOException e){ 35 36 e.printStackTrace(); 37 } 38 39 40 } 41 public static void main(String args[]) throws IOException{ 42 43 Myclient mc=new Myclient(); 44 mc.setConnection(); 45 46 } 47 }
參考原文:http://www.cnblogs.com/mareymarey111/archive/2011/12/08/2280253.html