Java - Socket 类

Socket 使用 TCP 提供两台计算机之间的通信机制。客户端程序在其通信端创建一个 Socket，并尝试将该 Socket 连接到服务器。

连接建立后，服务器在其通信端创建一个 Socket 对象。客户端和服务器现在可以通过写入和读取 Socket 来进行通信。

java.net.Socket 类

java.net.Socket 类表示一个 Socket，java.net.ServerSocket 类为服务器程序提供了一种机制来监听客户端并与它们建立连接。

连接建立后，可以使用 I/O 流 进行通信。每个 Socket 都有一个 OutputStream 和一个 InputStream。客户端的 OutputStream 连接到服务器的 InputStream，客户端的 InputStream 连接到服务器的 OutputStream。

Java Socket 类表示客户端和服务器用来相互通信的 Socket。客户端通过实例化一个 Socket 对象来获取，而服务器从 accept() 方法的返回值中获取 Socket 对象。

Socket 类声明

public class Socket
   extends Object
      implements Closeable

Socket 类构造函数

Socket 构造函数返回时，它不仅仅是实例化一个 Socket 对象，它实际上会尝试连接到指定的服务器和端口。

Socket 类方法

这里列出了一些 Socket 类中值得关注的方法。请注意，客户端和服务器都有一个 Socket 对象，因此这些方法可以由客户端和服务器调用。

Java 中 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();
      }
   }
}

示例：Socket 服务器

下面的 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!