Java為T(mén)CP協(xié)議提供了兩個(gè)類(lèi)，分別在客戶(hù)端編程和服務(wù)器端編程中使用它們。在應(yīng)用程序開(kāi)始通信之前，需要先創(chuàng)建一個(gè)連接，由客戶(hù)端程序發(fā)起；而服務(wù)器端的程序需要一直監(jiān)聽(tīng)著主機(jī)的特定端口號(hào)，等待客戶(hù)端的連接。在客戶(hù)端中我們只需要使用Socket實(shí)例，而服務(wù)端要同時(shí)處理ServerSocket實(shí)例和Socket實(shí)例;二者并且都使用OutputStream和InpuStream來(lái)發(fā)送和接收數(shù)據(jù)。

學(xué)習(xí)一種知識(shí)***的方式就是使用它，通過(guò)前面的筆記，我們已經(jīng)知道如何獲取主機(jī)的地址信息，現(xiàn)在我們通過(guò)一個(gè)簡(jiǎn)單的程序來(lái)初步學(xué)習(xí)傳輸層使用了TCP協(xié)議的Socket編程。

TCP服務(wù)器端

在Socket編程中，服務(wù)器端遠(yuǎn)比客戶(hù)端要復(fù)雜得多。服務(wù)器端的工作就是建立一個(gè)通信終端，被動(dòng)的等待客戶(hù)端的連接。下面這個(gè)服務(wù)器端程序的示例的作用是：監(jiān)聽(tīng)從控制臺(tái)輸入獲取的端口號(hào)，并且將客戶(hù)端發(fā)送過(guò)來(lái)的消息，再發(fā)送回去。

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  
 　　　　 // 從控制臺(tái)獲取需要監(jiān)聽(tīng)的端口號(hào)  
         if (args.length != 1)  
             throw new IllegalArgumentException("Parameter(s):<Port>");  
         // 獲取端口號(hào)  
         int servPort = Integer.parseInt(args[0]);  
         // 實(shí)例化一個(gè)ServerSocket對(duì)象實(shí)例  
         ServerSocket servSocket = new ServerSocket(servPort);  
         System.out.println(MessageFormat.format("開(kāi)始啟動(dòng)監(jiān)聽(tīng)，端口號(hào):{0}", args[0]));  
   
         // 初始接收數(shù)據(jù)的總字節(jié)數(shù)  
         int recvMsgSize;  
         // 接收數(shù)據(jù)的緩沖區(qū)  
         byte[] receiveBuf = new byte[BUFSIZE];  
   
         // 循環(huán)迭代，監(jiān)聽(tīng)端口號(hào),處理新的連接請(qǐng)求  
         while (true) {  
             // 阻塞等待，每接收到一個(gè)請(qǐng)求就創(chuàng)建一個(gè)新的連接實(shí)例  
             Socket clntSocket = servSocket.accept();  
             // 獲取連接的客戶(hù)端的 SocketAddress  
             SocketAddress clientAddress = clntSocket.getRemoteSocketAddress();  
             // 打印輸出連接客戶(hù)端地址信息  
             System.out.println("Handling client at" + clientAddress);  
             // 從客戶(hù)端接收數(shù)據(jù)的對(duì)象  
             InputStream in = clntSocket.getInputStream();  
             // 向客戶(hù)端發(fā)送數(shù)據(jù)的對(duì)象  
             OutputStream out = clntSocket.getOutputStream();  
             // 讀取客戶(hù)端發(fā)送的數(shù)據(jù)后，再發(fā)送到客戶(hù)端  
             while ((recvMsgSize = in.read(receiveBuf)) != -1) {  
                 out.write(receiveBuf, 0, recvMsgSize);  
             }  
             // 客戶(hù)端關(guān)閉連接時(shí)，關(guān)閉連接  
             System.out.println(" 客戶(hù)端關(guān)閉連接");  
             clntSocket.close();  
         }  
   
     }  
   
 } 

TCP客戶(hù)端

在Socket編程中，首先客戶(hù)端需要向服務(wù)器端發(fā)送，然后被動(dòng)的等待服務(wù)器端的響應(yīng)。下面的示例中：我們向服務(wù)器端發(fā)送信息，等待服務(wù)器端發(fā)送的消息，并打印顯示出來(lái)。

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  
 　　　　 // 判斷從控制臺(tái)接受的參數(shù)是否正確  
         if ((args.length < 2) || (args.length > 3))  
             throw new IllegalArgumentException(  
                     "Parameter(s):<Server><Word>[<Port>]]");  
         // 獲取服務(wù)器地址  
         String server = args[0];  
         // 獲取需要發(fā)送的信息  
         byte[] data = args[1].getBytes();  
         // 如果有三個(gè)從參數(shù)那么就獲取發(fā)送信息的端口號(hào)，默認(rèn)端口號(hào)為8099  
         int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099;  
         // 根據(jù)服務(wù)器地址和端口號(hào)實(shí)例化一個(gè)Socket實(shí)例  
         Socket socket = new Socket(server, servPort);  
         System.out.println("Connected to server...sending echo string");  
         // 返回此套接字的輸入流，即從服務(wù)器接受的數(shù)據(jù)對(duì)象  
         InputStream in = socket.getInputStream();  
         // 返回此套接字的輸出流，即向服務(wù)器發(fā)送的數(shù)據(jù)對(duì)象  
         OutputStream out = socket.getOutputStream();  
         // 向服務(wù)器發(fā)送從控制臺(tái)接收的數(shù)據(jù)  
         out.write(data);  
         // 接收數(shù)據(jù)的計(jì)數(shù)器，將寫(xiě)入數(shù)據(jù)的初始偏移量  
         int totalBytesRcvd = 0;  
         // 初始化接收數(shù)據(jù)的總字節(jié)數(shù)  
         int bytesRcvd;  
         while (totalBytesRcvd < data.length) {  
             // 服務(wù)器關(guān)閉連接，則返回 -1,read方法返回接收數(shù)據(jù)的總字節(jié)數(shù)  
             if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length  
                     - totalBytesRcvd)) == -1)  
                 throw new SocketException("與服務(wù)器的連接已關(guān)閉");  
             totalBytesRcvd += bytesRcvd;  
         }  
         // 打印服務(wù)器發(fā)送來(lái)的數(shù)據(jù)  
         System.out.println("Received:" + new String(data));  
         // 關(guān)閉連接  
         socket.close();  
   
     }  
   
 } 

首先運(yùn)行服務(wù)器端,監(jiān)聽(tīng)8099端口：

接著運(yùn)行客戶(hù)端程序，并且向服務(wù)器端發(fā)送消息：

再次查看我們的服務(wù)器端控制臺(tái)，我們可以看到前面客戶(hù)端連接的地址信息：

參考資料：《TCP/IP Socket in Java》

原文鏈接：http://www.cnblogs.com/IPrograming 

【編輯推薦】

1. Java Socket編程：如何識(shí)別網(wǎng)絡(luò)主機(jī)
2. Java Socket編程：基本的術(shù)語(yǔ)和概念
3. Java集合類(lèi)ArrayList循環(huán)中刪除特定元素
4. Java集合框架總結(jié)：Set接口的使用
5. Java的位移運(yùn)算巧方法