Java 网络通信基于 Socket（套接字） 编程，分为两大类：

协议	类	特点
TCP	Socket, ServerSocket	面向连接、可靠、数据顺序、有流控制
UDP	DatagramSocket, DatagramPacket	无连接、不可靠、快速、无序、面向数据报

1、Java UDP 通信核心接口介绍

你这个程序使用的是 UDP 协议，使用类有：

DatagramSocket：用于发送和接收数据包（Socket 实例）

DatagramPacket：用于封装发送或接收的数据内容

1、DatagramSocket 类

这个类代表一个 UDP 套接字（Socket），可以发送或接收 DatagramPacket。

DatagramSocket socket = new DatagramSocket();         // 客户端：系统自动分配本地端口
DatagramSocket socket = new DatagramSocket(port);     // 服务器：绑定到指定端口

方法	说明
send(DatagramPacket p)	发送一个数据报
receive(DatagramPacket p)	接收一个数据报（阻塞）
close()	关闭套接字，释放端口

UDP 是无连接的通信，所以只需要发送和接收数据报，不需要建立连接。

2、DatagramPacket 类

这个类是一个 数据包容器，既可以用于发送数据，也可以用于接收数据。

发送端构造方法：

DatagramPacket packet = new DatagramPacket(byte[] buf, int length, InetAddress address, int port);

参数	说明
buf	要发送的数据字节数组
length	字节数组长度
address	目标主机地址（InetAddress.getByName(“127.0.0.1”)）
port	目标端口号

接收端构造方法：

DatagramPacket packet = new DatagramPacket(byte[] buf, int length);

参数	说明
buf	用来接收数据的字节数组
length	缓冲区大小

常用方法：

方法	说明
getData()	获取数据字节数组（包含整个缓冲区）
getLength()	获取实际接收到的数据长度
getSocketAddress()	获取发送方的地址和端口
getAddress() / getPort()	获取 IP 地址 / 端口号

3、UDP客户端与UDP服务器通信例子

下面是简单清晰的 UDP 客户端与服务器通信例子：

UdpEchoServer.java（服务器）

package thread;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;public class UdpEchoServer {public static void main(String[] args) throws IOException {// 创建 DatagramSocket，绑定端口 9090DatagramSocket socket = new DatagramSocket(9090);System.out.println("服务器已启动，监听端口 9090...");while (true) {// 接收客户端发来的数据包byte[] buffer = new byte[1024]; // 缓冲区DatagramPacket receivePacket = new DatagramPacket(buffer, buffer.length);socket.receive(receivePacket);  // 阻塞接收// 读取数据内容String message = new String(receivePacket.getData(), 0, receivePacket.getLength());System.out.println("收到客户端消息：" + message);// 构造响应内容（原样返回加上后缀）String response = "回显：" + message;byte[] responseData = response.getBytes();// 构造响应数据包，目标为收到的客户端地址和端口DatagramPacket responsePacket = new DatagramPacket(responseData,responseData.length,receivePacket.getAddress(),receivePacket.getPort());// 发送响应数据包socket.send(responsePacket);}}
}

UdpEchoClient.java（客户端）

package thread;import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UdpEchoClient {public static void main(String[] args) throws IOException {// 创建 DatagramSocket，系统自动分配端口DatagramSocket socket = new DatagramSocket();// 服务器地址和端口InetAddress serverAddress = InetAddress.getByName("127.0.0.1");int serverPort = 9090;Scanner scanner = new Scanner(System.in);System.out.println("请输入内容，输入 exit 退出：");while (true) {System.out.print(">> ");String input = scanner.nextLine();if ("exit".equalsIgnoreCase(input)) {break;}// 构造发送数据包byte[] data = input.getBytes();DatagramPacket sendPacket = new DatagramPacket(data, data.length, serverAddress, serverPort);socket.send(sendPacket);// 接收服务器响应byte[] buffer = new byte[1024];DatagramPacket receivePacket = new DatagramPacket(buffer, buffer.length);socket.receive(receivePacket);// 打印响应String response = new String(receivePacket.getData(), 0, receivePacket.getLength());System.out.println("来自服务器：" + response);}socket.close();}
}

2、Java TCP 通信核心接口介绍

Java 中使用 TCP 协议 通信的主要类有：

Socket：表示客户端或服务端通信时的“套接字”

ServerSocket：服务端专用，用于监听客户端连接请求

1、ServerSocket 类

ServerSocket 是服务端用来监听某个端口的类，接收到连接请求后会生成 Socket 进行数据通信。

构造方法：

ServerSocket serverSocket = new ServerSocket(port); // 监听指定端口

常用方法：

方法	说明
accept()	接收客户端连接，返回一个 Socket，阻塞方法
close()	关闭监听，释放端口资源

说明： accept() 是阻塞的，直到有客户端连接才会继续执行。

2、Socket 类

Socket 表示客户端套接字，也用于服务端与某个客户端通信的 Socket 实例。

构造方法（客户端使用）

ServerSocket serverSocket = new ServerSocket(port); // 监听指定端口

常用方法：

方法	说明
getInputStream()	获取输入流，用于读取数据（来自对方）
getOutputStream()	获取输出流，用于发送数据（给对方）
close()	关闭连接

3、输入输出流常见包装类

包装类组合	用途
InputStreamReader + BufferedReader	读取字符串（按行读取）
OutputStream + PrintWriter	发送字符串（可自动 flush）

4、TCP 客户端与 TCP 服务器通信例子

TCP 服务器（TcpEchoServer.java）

package thread;import java.io.*;
import java.net.*;public class TcpEchoServer {public static void main(String[] args) throws IOException {// 1. 创建 ServerSocket，监听端口 9090ServerSocket serverSocket = new ServerSocket(9090);System.out.println("TCP服务器启动，监听端口 9090...");// 2. 等待客户端连接（阻塞）Socket clientSocket = serverSocket.accept();System.out.println("客户端已连接：" + clientSocket.getRemoteSocketAddress());// 3. 获取输入输出流BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true); // 自动刷新// 4. 循环读取客户端消息并回显String message;while ((message = reader.readLine()) != null) {System.out.println("客户端说：" + message);writer.println("回显：" + message);}// 5. 关闭连接reader.close();writer.close();clientSocket.close();serverSocket.close();}
}

TCP 客户端（TcpEchoClient.java）

package thread;import java.io.*;
import java.net.*;
import java.util.Scanner;public class TcpEchoClient {public static void main(String[] args) throws IOException {// 1. 创建 Socket，连接到服务器Socket socket = new Socket("127.0.0.1", 9090);System.out.println("已连接到服务器！");// 2. 获取输入输出流BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));PrintWriter writer = new PrintWriter(socket.getOutputStream(), true); // 自动刷新Scanner scanner = new Scanner(System.in);System.out.println("请输入要发送的内容，输入 exit 退出：");// 3. 发送和接收消息while (true) {System.out.print(">> ");String input = scanner.nextLine();if ("exit".equalsIgnoreCase(input)) {break;}writer.println(input); // 发送数据String response = reader.readLine(); // 接收响应System.out.println("服务器回复：" + response);}// 4. 关闭连接socket.close();}
}