一、基于Socket的java網絡編程
1、什么是Socket?
所謂socket通常也稱作"套接字",用于描述IP地址和端口，是一個通信鏈的句柄。應用程序通常通過"套接字"向網絡發出請求或者應答網絡請求。
2、Socket通訊的過程
Server端Listen(監聽)某個端口是否有連接請求，Client端向Server 端發出Connect(連接)請求，Server端向Client端發回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。
對于一個功能齊全的Socket，都要包含以下基本結構，其工作過程包含以下四個基本的步驟：
（1） 創建Socket；
（2） 打開連接到Socket的輸入/出流；
（3） 按照一定的協議對Socket進行讀/寫操作；
（4） 關閉Socket.（在實際應用中，并未使用到顯示的close，雖然很多文章都推薦如此，不過在我的程序中，可能因為程序本身比較簡單，要求不高，所以并未造成什么影響。）
3、創建Socket
java在包java.net中提供了兩個類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務端。這是兩個封裝得非常好的類，使用很方便。其構造方法如下：
Socket(InetAddress address, int port); Socket(InetAddress address, int port, boolean stream); Socket(String host, int prot); Socket(String host, int prot, boolean stream); Socket(SocketImpl impl) Socket(String host, int port, InetAddress localAddr, int localPort) Socket(InetAddress address, int port, InetAddress localAddr, int localPort) ServerSocket(int port); ServerSocket(int port, int backlog); ServerSocket(int port, int backlog, InetAddress bindAddr)
其中address、host和port分別是雙向連接中另一方的IP地址、主機名和端 口號，stream指明socket是流socket還是數據報socket，localPort表示本地主機的端口號，localAddr和 bindAddr是本地機器的地址（ServerSocket的主機地址），impl是socket的父類，既可以用來創建serverSocket又可 以用來創建Socket。count則表示服務端所能支持的最大連接數。
例如：
Socket client = new Socket("127.0.01.", 80); ServerSocket server = new ServerSocket(80);
注：
在選擇端口時，必須小心。每一個端口提供一種特定的服務，只有給出正確的端口，才 能獲得相應的服務。0~1023的端口號為系統所保留，例如http服務的端口號為80,telnet服務的端口號為21,ftp服務的端口號為23, 所以我們在選擇端口號時，最好選擇一個大于1023的數以防止發生沖突。
在創建socket時如果發生錯誤，將產生IOException，在程序中必須對之作出處理。所以在創建Socket或ServerSocket是必須捕獲或拋出例外。
4、簡單的Client/Server程序
①客戶端程序：
import java.io.*; import java.net.*; public class TalkClient { public static void main(String args[]) { try{ Socket socket=new Socket("127.0.0.1",4700); //向本機的4700端口發出客戶請求 BufferedReader sin=new BufferedReader(new InputStreamReader(System.in)); //由系統標準輸入設備構造BufferedReader對象 PrintWriter os=new PrintWriter(socket.getOutputStream()); //由Socket對象得到輸出流，并構造PrintWriter對象 BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream())); //由Socket對象得到輸入流，并構造相應的BufferedReader對象 String readline; readline=sin.readLine(); //從系統標準輸入讀入一字符串 while(!readline.equals("bye")){ //若從標準輸入讀入的字符串為 "bye"則停止循環 os.println(readline); //將從系統標準輸入讀入的字符串輸出到Server os.flush(); //刷新輸出流，使Server馬上收到該字符串 System.out.println("Client:"+readline); //在系統標準輸出上打印讀入的字符串 System.out.println("Server:"+is.readLine()); //從Server讀入一字符串，并打印到標準輸出上 readline=sin.readLine(); //從系統標準輸入讀入一字符串 } //繼續循環 os.close(); //關閉Socket輸出流 is.close(); //關閉Socket輸入流 socket.close(); //關閉Socket }catch(Exception e) { System.out.println("Error"+e); //出錯，則打印出錯信息 } } }
②：服務端程序：
import java.io.*; import java.net.*; import java.applet.Applet; public class TalkServer{ public static void main(String args[]) { try{ ServerSocket server=null; try{ server=new ServerSocket(4700); //創建一個ServerSocket在端口4700監聽客戶請求 }catch(Exception e) { System.out.println("can not listen to:"+e); //出錯，打印出錯信息 } Socket socket=null; try{ socket=server.accept(); //使用accept()阻塞等待客戶請求，有客戶 //請求到來則產生一個Socket對象，并繼續執行 }catch(Exception e) { System.out.println("Error."+e); //出錯，打印出錯信息 } String line; BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream())); //由Socket對象得到輸入流，并構造相應的BufferedReader對象 PrintWriter os=newPrintWriter(socket.getOutputStream()); //由Socket對象得到輸出流，并構造PrintWriter對象 BufferedReader sin=new BufferedReader(new InputStreamReader(System.in)); //由系統標準輸入設備構造BufferedReader對象 System.out.println("Client:"+is.readLine()); //在標準輸出上打印從客戶端讀入的字符串 line=sin.readLine(); //從標準輸入讀入一字符串 while(!line.equals("bye")){ //如果該字符串為 "bye"，則停止循環 os.println(line); //向客戶端輸出該字符串 os.flush(); //刷新輸出流，使Client馬上收到該字符串 System.out.println("Server:"+line); //在系統標準輸出上打印讀入的字符串 System.out.println("Client:"+is.readLine()); //從Client讀入一字符串，并打印到標準輸出上 line=sin.readLine(); //從系統標準輸入讀入一字符串 } //繼續循環 os.close(); //關閉Socket輸出流 is.close(); //關閉Socket輸入流 socket.close(); //關閉Socket server.close(); //關閉ServerSocket }catch(Exception e){ System.out.println("Error:"+e); //出錯，打印出錯信息 } } }
文章列表
留言列表
