基础概念
在开始写代码之前,我们需要理解几个核心概念：
（图片来源网络，侵删）
- Socket (套接字)：你可以把它想象成一个“网络插头”，客户端通过这个插头连接到服务器（一个网络地址和端口），然后就可以通过这个插头进行数据的收发。
- IP 地址：网络中设备的唯一地址，
0.0.1(代表本机) 或服务器的公网 IP。 - 端口号：服务器上应用程序的“门牌号”，一个服务器可以同时运行多个网络服务，每个服务都监听一个不同的端口号，客户端需要知道这个端口号才能连接到正确的服务。
- 客户端/服务器模型：
- 服务器：在指定的 IP 和端口上监听 客户端的连接请求，它被动地等待连接。
- 客户端：主动发起连接 请求到服务器的 IP 和端口，连接成功后，就可以与服务器进行双向通信。
简单的 Socket 客户端示例
这是一个最基础的客户端,它连接到一个服务器，发送一条消息，然后接收一条消息并打印出来，最后关闭连接。
假设有一个简单的回显服务器在 0.0.1 的 8888 端口上运行，它会发回客户端发送的任何消息。
SimpleClient.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class SimpleClient {
public static void main(String[] args) {
// 服务器的 IP 地址和端口号
String serverHost = "127.0.0.1";
int serverPort = 8888;
// try-with-resources 语句，可以自动关闭资源
try (Socket socket = new Socket(serverHost, serverPort);
// 获取输出流，用于向服务器发送数据
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// 获取输入流，用于从服务器接收数据
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
System.out.println("成功连接到服务器 " + serverHost + ":" + serverPort);
// 1. 发送数据到服务器
String messageToSend = "你好，服务器！";
out.println(messageToSend);
System.out.println("已发送: " + messageToSend);
// 2. 从服务器接收数据
String responseFromServer = in.readLine();
System.out.println("服务器回复: " + responseFromServer);
} catch (UnknownHostException e) {
// IP 地址无法解析
System.err.println("找不到主机: " + serverHost);
e.printStackTrace();
} catch (IOException e) {
// 如果发生 I/O 错误（连接被拒绝）
System.err.println("I/O 错误: 无法连接到 " + serverHost + ":" + serverPort);
e.printStackTrace();
}
}
}
代码详解
-
new Socket(serverHost, serverPort):- 这是客户端的核心,这行代码会尝试创建一个 Socket 并连接到指定的服务器。
- 如果连接成功,程序才会继续执行，如果服务器不存在、端口错误或防火墙阻止，会抛出
IOException。 - 注意：这步是阻塞 的，意味着程序会在这里等待，直到连接建立或失败。
-
PrintWriter out = ...:
（图片来源网络，侵删）socket.getOutputStream()获取一个字节输出流。new PrintWriter(...)将其包装成一个字符打印流，使用PrintWriter可以方便地使用println(),print(),printf()等方法，并且可以自动刷新缓冲区（当autoFlush参数为true时）。out.println("你好，服务器！")会将字符串发送到服务器。
-
BufferedReader in = ...:socket.getInputStream()获取一个字节输入流。new InputStreamReader(...)将其转换为字符流。new BufferedReader(...)包装成缓冲字符流，这样可以高效地按行读取文本。in.readLine()会读取服务器发送过来的一行文本（以换行符\n，这步也是阻塞 的，程序会等待服务器发送数据。
-
try-with-resources:- 我们将
Socket,PrintWriter, 和BufferedReader都放在try语句中，这样无论代码是否成功执行，当try块结束时，这些资源都会被自动关闭，避免了资源泄漏，这是一个非常好的编程习惯。
- 我们将
交互式 Socket 客户端
上面的示例是一次性的发送和接收,在实际应用中，客户端通常需要持续与服务器交互，比如一个聊天客户端，这通常需要使用多线程来处理发送和接收，因为 in.readLine() 是阻塞的，如果只用一个线程，当等待服务器回复时，客户端就无法发送新的消息了。
下面是一个更完整的交互式客户端示例。
（图片来源网络，侵删）
InteractiveClient.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class InteractiveClient {
public static void main(String[] args) {
String serverHost = "127.0.0.1";
int serverPort = 8888;
try (Socket socket = new Socket(serverHost, serverPort);
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
// 用于从控制台读取用户输入
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in))) {
System.out.println("已连接到服务器，输入 'exit' 退出。");
// 启动一个线程来持续监听服务器消息
Thread listenerThread = new Thread(new ServerListener(in));
listenerThread.start();
String userInput;
// 循环读取用户输入
while (true) {
System.out.print("请输入消息: ");
userInput = stdIn.readLine();
if ("exit".equalsIgnoreCase(userInput)) {
break; // 用户输入 exit，退出循环
}
// 发送消息到服务器
out.println(userInput);
}
System.out.println("客户端正在关闭...");
} catch (UnknownHostException e) {
System.err.println("找不到主机: " + serverHost);
} catch (IOException e) {
System.err.println("I/O 错误: " + e.getMessage());
}
}
}
// 一个单独的线程，用于监听和打印来自服务器的消息
class ServerListener implements Runnable {
private BufferedReader in;
public ServerListener(BufferedReader in) {
this.in = in;
}
@Override
public void run() {
try {
String serverResponse;
// 持续读取服务器发送的每一行
while ((serverResponse = in.readLine()) != null) {
// 打印到控制台，为了区分，可以加个前缀
System.out.println("[服务器] " + serverResponse);
}
} catch (IOException e) {
// 如果连接断开，会抛出异常
System.out.println("与服务器断开连接。");
}
}
}
交互式客户端的工作原理
-
主线程：
- 负责建立连接。
- 进入一个
while循环，使用BufferedReader stdIn读取用户在控制台输入的内容。 - 将用户输入的内容通过
out.println()发送到服务器。 - 如果用户输入
exit，则退出循环，关闭资源。
-
ServerListener线程：- 在主线程启动后,立即创建并启动一个
ServerListener线程。 - 这个线程的唯一任务就是运行一个
while循环，不断调用in.readLine()来读取服务器的消息。 - 当它收到消息后,就打印到控制台。
- 这样,发送 和 接收 操作就在两个独立的线程中同时进行，互不阻塞，用户可以随时发送新消息，也能实时看到服务器的回复。
- 在主线程启动后,立即创建并启动一个
如何运行和测试
要运行客户端,你需要一个配套的服务器，你可以自己写一个简单的 Java 服务器，或者使用一些现成的工具，Netcat (nc)。
使用 Netcat 作为测试服务器
-
安装 Netcat:
- Windows: 可以从 netcat-for-windows 下载。
- macOS / Linux: 通常已经预装，在终端输入
nc -h检查。 - WSL (Windows Subsystem for Linux): 同样，通常已预装。
-
启动服务器:
- 打开一个终端。
- 运行以下命令,让它监听本机的
8888端口：# -l 表示监听模式 # -p 指定端口号 nc -l -p 8888
- 这个终端就等待客户端连接了,你输入的任何内容，它都会发回（回显）。
-
运行 Java 客户端:
- 打开另一个终端。
- 编译并运行你的 Java 客户端代码：
javac InteractiveClient.java java InteractiveClient
-
观察交互:
- 客户端终端会显示 "已连接到服务器..."。
- 在客户端终端输入 "你好"，然后按回车。
- 在服务器（Netcat）终端，你会看到 "你好"。
- 在客户端终端,你会看到 "[服务器] 你好"。
- 在客户端终端输入 "exit" 并回车，客户端程序会退出。
关键注意事项
- 阻塞：
socket.connect(),in.readLine()等都是阻塞操作，在简单的程序中没问题，但在复杂的 GUI 应用或需要高并发的场景下，必须使用多线程或异步 I/O (如 NIO)。 - 异常处理：网络是不可靠的，必须妥善处理
IOException和UnknownHostException。 - 资源关闭：务必关闭所有打开的流和 Socket。
try-with-resources是最好的方式。 - 编码：上面的例子使用的是平台默认的字符编码，为了确保跨平台兼容性，最好明确指定编码，
new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8)。 - 缓冲：
BufferedReader和BufferedWriter（或PrintWriter）能极大地提高 I/O 性能，强烈建议使用。
希望这份详细的指南能帮助你理解和使用 Java Socket 客户端！
