Java Socket編程：初識TCP Socket

作者：晴天豬 2012-03-19 11:41:30

Java為TCP協議提供了兩個類，分別在客戶端編程和服務器端編程中使用它們。在應用程序開始通信之前，需要先創建一個連接，由客戶端程序發起；而服務器端的程序需要一直監聽著主機的特定端口號，等待客戶端的連接。在客戶端中我們只需要使用Socket實例，而服務端要同時處理ServerSocket實例和Socket實例;二者并且都使用OutputStream和InpuStream來發送和接收數據。

學習一種知識***的方式就是使用它，通過前面的筆記，我們已經知道如何獲取主機的地址信息，現在我們通過一個簡單的程序來初步學習傳輸層使用了TCP協議的Socket編程。

TCP服務器端

在Socket編程中，服務器端遠比客戶端要復雜得多。服務器端的工作就是建立一個通信終端，被動的等待客戶端的連接。下面這個服務器端程序的示例的作用是：監聽從控制臺輸入獲取的端口號，并且將客戶端發送過來的消息，再發送回去。

import java.net.*;  
 import java.text.MessageFormat;  
 import java.io.*;  
   
 public class TCPEchoServer {  
   
     private static final int BUFSIZE = 32;  
   
     /**  
      * @param args  
　　  */ 
     public static void main(String[] args) throws IOException {  
         // TODO Auto-generated method stub  
 　　　　 // 從控制臺獲取需要監聽的端口號  
         if (args.length != 1)  
             throw new IllegalArgumentException("Parameter(s):<Port>");  
         // 獲取端口號  
         int servPort = Integer.parseInt(args[0]);  
         // 實例化一個ServerSocket對象實例  
         ServerSocket servSocket = new ServerSocket(servPort);  
         System.out.println(MessageFormat.format("開始啟動監聽，端口號:{0}", args[0]));  
   
         // 初始接收數據的總字節數  
         int recvMsgSize;  
         // 接收數據的緩沖區  
         byte[] receiveBuf = new byte[BUFSIZE];  
   
         // 循環迭代，監聽端口號,處理新的連接請求  
         while (true) {  
             // 阻塞等待，每接收到一個請求就創建一個新的連接實例  
             Socket clntSocket = servSocket.accept();  
             // 獲取連接的客戶端的 SocketAddress  
             SocketAddress clientAddress = clntSocket.getRemoteSocketAddress();  
             // 打印輸出連接客戶端地址信息  
             System.out.println("Handling client at" + clientAddress);  
             // 從客戶端接收數據的對象  
             InputStream in = clntSocket.getInputStream();  
             // 向客戶端發送數據的對象  
             OutputStream out = clntSocket.getOutputStream();  
             // 讀取客戶端發送的數據后，再發送到客戶端  
             while ((recvMsgSize = in.read(receiveBuf)) != -1) {  
                 out.write(receiveBuf, 0, recvMsgSize);  
             }  
             // 客戶端關閉連接時，關閉連接  
             System.out.println(" 客戶端關閉連接");  
             clntSocket.close();  
         }  
   
     }  
   
 }

TCP客戶端

在Socket編程中，首先客戶端需要向服務器端發送，然后被動的等待服務器端的響應。下面的示例中：我們向服務器端發送信息，等待服務器端發送的消息，并打印顯示出來。

import java.io.*;  
 import java.net.Socket;  
 import java.net.SocketException;  
   
 public class TCPEchoClient {  
   
     /**  
      * @param args  
      * @throws IOException  
 　　  */ 
     public static void main(String[] args) throws IOException {  
         // TODO Auto-generated method stub  
 　　　　 // 判斷從控制臺接受的參數是否正確  
         if ((args.length < 2) || (args.length > 3))  
             throw new IllegalArgumentException(  
                     "Parameter(s):<Server><Word>[<Port>]]");  
         // 獲取服務器地址  
         String server = args[0];  
         // 獲取需要發送的信息  
         byte[] data = args[1].getBytes();  
         // 如果有三個從參數那么就獲取發送信息的端口號，默認端口號為8099  
         int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099;  
         // 根據服務器地址和端口號實例化一個Socket實例  
         Socket socket = new Socket(server, servPort);  
         System.out.println("Connected to server...sending echo string");  
         // 返回此套接字的輸入流，即從服務器接受的數據對象  
         InputStream in = socket.getInputStream();  
         // 返回此套接字的輸出流，即向服務器發送的數據對象  
         OutputStream out = socket.getOutputStream();  
         // 向服務器發送從控制臺接收的數據  
         out.write(data);  
         // 接收數據的計數器，將寫入數據的初始偏移量  
         int totalBytesRcvd = 0;  
         // 初始化接收數據的總字節數  
         int bytesRcvd;  
         while (totalBytesRcvd < data.length) {  
             // 服務器關閉連接，則返回 -1,read方法返回接收數據的總字節數  
             if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length  
                     - totalBytesRcvd)) == -1)  
                 throw new SocketException("與服務器的連接已關閉");  
             totalBytesRcvd += bytesRcvd;  
         }  
         // 打印服務器發送來的數據  
         System.out.println("Received:" + new String(data));  
         // 關閉連接  
         socket.close();  
   
     }  
   
 }