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!