Java - Socket 類及示例

Sockets 使用 TCP 提供兩臺計算機之間的通訊機制。客戶端程式在其通訊端建立一個套接字，並嘗試將該套接字連線到伺服器。

連線建立後，伺服器在其通訊端建立一個套接字物件。客戶端和伺服器現在可以透過寫入和讀取套接字進行通訊。

java.net.Socket 類表示套接字，java.net.ServerSocket 類為伺服器程式提供了一種機制，用於監聽客戶端並與它們建立連線。

連線建立後，可以使用 I/O 流進行通訊。每個套接字都有 OutputStream 和 InputStream。客戶端的 OutputStream 連線到伺服器的 InputStream，客戶端的 InputStream 連線到伺服器的 OutputStream。

Java Socket 類表示客戶端和伺服器用來相互通訊的套接字。客戶端透過例項化一個 Socket 物件來獲取它，而伺服器從 accept() 方法的返回值獲取 Socket 物件。

宣告

public class Socket
   extends Object
      implements Closeable

建構函式

當 Socket 建構函式返回時，它不僅例項化一個 Socket 物件，而且實際上還嘗試連線到指定的伺服器和埠。

方法

這裡列出 Socket 類中一些感興趣的方法。請注意，客戶端和伺服器都有一個 Socket 物件，因此這些方法可以由客戶端和伺服器呼叫。

客戶端示例

下面的 GreetingClient 是一個客戶端程式，它使用套接字連線到伺服器，傳送問候語，然後等待響應。

示例

package com.tutorialspoint;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class GreetingClient {

   public static void main(String [] args) {
      String serverName = args[0];
      int port = Integer.parseInt(args[1]);
      try {
         System.out.println("Connecting to " + serverName + " on port " + port);
         Socket client = new Socket(serverName, port);
         
         System.out.println("Just connected to " + client.getRemoteSocketAddress());
         OutputStream outToServer = client.getOutputStream();
         DataOutputStream out = new DataOutputStream(outToServer);
         
         out.writeUTF("Hello from " + client.getLocalSocketAddress());
         InputStream inFromServer = client.getInputStream();
         DataInputStream in = new DataInputStream(inFromServer);
         
         System.out.println("Server says " + in.readUTF());
         client.close();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

下面的 GreetingServer 程式是一個伺服器應用程式示例，它使用 Socket 類監聽指定埠號上的客戶端（埠號由命令列引數指定）。

package com.tutorialspoint;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;

public class GreetingServer extends Thread {
   private ServerSocket serverSocket;
   
   public GreetingServer(int port) throws IOException {
      serverSocket = new ServerSocket(port);
      serverSocket.setSoTimeout(10000);
   }

   public void run() {
      while(true) {
         try {
            System.out.println("Waiting for client on port " + 
               serverSocket.getLocalPort() + "...");
            Socket server = serverSocket.accept();
            
            System.out.println("Just connected to " + server.getRemoteSocketAddress());
            DataInputStream in = new DataInputStream(server.getInputStream());
            
            System.out.println(in.readUTF());
            DataOutputStream out = new DataOutputStream(server.getOutputStream());
            out.writeUTF("Thank you for connecting to " + server.getLocalSocketAddress()
               + "\nGoodbye!");
            server.close();
            
         } catch (SocketTimeoutException s) {
            System.out.println("Socket timed out!");
            break;
         } catch (IOException e) {
            e.printStackTrace();
            break;
         }
      }
   }
   
   public static void main(String [] args) {
      int port = Integer.parseInt(args[0]);
      try {
         Thread t = new GreetingServer(port);
         t.start();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

編譯客戶端和伺服器，然後按如下方式啟動伺服器：

$ java GreetingServer 6066
Waiting for client on port 6066...
Just connected to /127.0.0.1:49462
Hello from /127.0.0.1:49462
Waiting for client on port 6066...

按如下方式檢查客戶端程式：

輸出

$ java GreetingClient localhost 6066
Connecting to localhost on port 6066
Just connected to localhost/127.0.0.1:6066
Server says Thank you for connecting to /127.0.0.1:6066
Goodbye!