Java Socket編程(3)初識TCP Socket

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

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

1.TCP服務器端

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

import java.net.*;
import java.text.MessageFormat;
import java.io.*;

public class TCPEchoServer {

    private static final int BUFSIZE = 32;

    /**
     * @param args
11　　  */
    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();
        }

    }

}

 

2.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();

    }

}

首先運行服務器端,監聽8099端口:

 

接着運行客戶端程序，並且向服務器端發送消息:

 

再次查看我們的服務器端控制台，我們可以看到前面客戶端連接的地址信息:

 

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

作者:晴天豬

出處:http://www.cnblogs.com/IPrograming 

本文版權歸作者和博客園共有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接，否則保留追究法律責任的權利。