Java中的Socket类是java.net包下的核心类，基于TCP协议实现可靠的端到端网络通信，是Java网络编程的基础组件，能够支撑各类需要网络数据交互的应用场景开发。
Socket类的核心能力
Socket类主要面向客户端开发，配合ServerSocket类（服务端）可以实现完整的网络通信流程，核心能力包括以下几个方面：
- 建立可靠的TCP连接：通过三次握手与服务端建立稳定连接，保证数据传输的可靠性
- 双向数据传输：支持客户端向服务端发送数据，也支持接收服务端返回的数据
- 多类型数据交互：可以传输字符串、字节流、文件等多种格式的数据
- 连接生命周期管理：支持主动关闭连接、设置超时时间等操作
基础使用场景与代码示例
1. 简单客户端与服务端通信
首先实现服务端代码，使用ServerSocket监听指定端口，等待客户端连接：
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class SimpleServer {
public static void main(String[] args) {
int port = 8888;
try (ServerSocket serverSocket = new ServerSocket(port)) {
System.out.println("服务端启动，监听端口：" + port);
// 等待客户端连接，阻塞方法
Socket clientSocket = serverSocket.accept();
System.out.println("客户端已连接，地址：" + clientSocket.getInetAddress());
// 获取输入流，读取客户端发送的数据
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
// 获取输出流，向客户端发送数据
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
String clientMsg = in.readLine();
System.out.println("收到客户端消息：" + clientMsg);
// 向客户端返回响应
out.println("服务端已收到你的消息：" + clientMsg);
// 关闭客户端连接
clientSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
接下来是客户端代码，使用Socket类连接服务端并交互数据：
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class SimpleClient {
public static void main(String[] args) {
String serverHost = "127.0.0.1";
int serverPort = 8888;
try (Socket socket = new Socket(serverHost, serverPort)) {
System.out.println("已连接到服务端：" + serverHost + ":" + serverPort);
// 获取输出流，向服务端发送数据
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// 获取输入流，读取服务端返回的数据
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
// 向服务端发送消息
String sendMsg = "Hello, Server!";
out.println(sendMsg);
System.out.println("向服务端发送消息：" + sendMsg);
// 读取服务端响应
String serverResponse = in.readLine();
System.out.println("收到服务端响应：" + serverResponse);
} catch (IOException e) {
e.printStackTrace();
}
}
}
2. 基于Socket的文件传输
Socket也可以实现文件传输，核心思路是将文件转换为字节流，通过Socket的输出流发送，接收端再通过输入流读取字节流并还原为文件：
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
public class FileClient {
public static void main(String[] args) {
String serverHost = "127.0.0.1";
int serverPort = 8888;
File file = new File("test.txt");
try (Socket socket = new Socket(serverHost, serverPort);
FileInputStream fis = new FileInputStream(file);
OutputStream os = socket.getOutputStream()) {
// 先发送文件名长度、文件名、文件长度，方便服务端解析
byte[] fileNameBytes = file.getName().getBytes();
// 发送文件名长度
os.write(fileNameBytes.length);
// 发送文件名
os.write(fileNameBytes);
// 发送文件长度
os.write(longToBytes(file.length()));
// 发送文件内容
byte[] buffer = new byte[1024];
int len;
while ((len = fis.read(buffer)) != -1) {
os.write(buffer, 0, len);
}
System.out.println("文件发送完成");
} catch (IOException e) {
e.printStackTrace();
}
}
// long转字节数组的辅助方法
private static byte[] longToBytes(long value) {
byte[] result = new byte[8];
for (int i = 0; i < 8; i++) {
result[i] = (byte) (value >> (i * 8));
}
return result;
}
}
Socket类的常用方法
Socket类提供了多个实用方法，方便开发者管理连接和获取数据：
| 方法名 | 作用说明 |
|---|---|
| getInputStream() | 返回该Socket连接的输入流，用于读取对方发送的数据 |
| getOutputStream() | 返回该Socket连接的输出流，用于向对方发送数据 |
| getInetAddress() | 获取连接的对端IP地址 |
| getPort() | 获取连接的对端端口号 |
| setSoTimeout(int timeout) | 设置读取数据的超时时间，单位为毫秒，超时后抛出SocketTimeoutException |
| close() | 关闭Socket连接，释放相关资源 |
使用注意事项
在使用Socket类进行网络编程时，需要注意以下几点：
- 所有的IO操作都要处理IOException异常，避免程序崩溃
- 使用完Socket后要及时调用close()方法关闭连接，避免资源泄露，推荐使用try-with-resources语法自动关闭
- TCP是面向流的协议，没有消息边界，如果需要传输结构化数据，需要自定义消息格式，比如添加长度前缀、分隔符等
- 生产环境中需要考虑连接异常、断线重连、并发处理等问题，不能仅使用单线程的简单实现