Java服务器监听骨架采用volatile布尔变量控制循环生命周期，通过shutdown方法设标志位并关闭socket实现优雅关闭，结合中断机制、异常判断及JVM shutdown hook确保资源安全释放。
在 Java 中编写服务器监听骨架时，常用 while (true) 无限循环配合退出条件实现持续接收请求，同时支持优雅关闭。关键不是“停不下来”，而是“想停时能安全停”。
用 volatile 布尔变量控制循环生命周期
这是最常用、线程安全且轻量的方式。主线程通过修改一个 volatile 标志位通知监听循环退出，避免指令重排序和缓存不一致问题。
- 声明
private volatile boolean running = true;作为开关 - 循环体写成
while (running) { /* 接收/处理连接 */ } - 提供
shutdown()方法：设running = false;，并视情况调用serverSocket.close()中断阻塞
利用阻塞方法的中断机制主动退出
像 ServerSocket#accept() 这类阻塞调用，调用 socket.close() 或线程 interrupt() 会触发 IOException（如 SocketClosedException 或 ClosedByInterruptException），可借此跳出循环。
- 在
catch (IOException e)中检查!running，决定是否继续循环 - 不要忽略异常，更不要生吞；区分是主动关闭还是网络异常
- 示例：若
e instanceof SocketException && "Socket closed".equals(e.getMessage())，大概率是 shutdown 触发的，可直接 break
结合 shutdown hook 实现进程级兜底关闭
防止程序被 kill -15 杀掉时监听未释放资源。注册 JVM 关闭钩子，在进程退出前执行清理逻辑。
立即学习“Java免费学习笔记（深入）”；
- 调用
Runtime.getRuntime().addShutdownHook(new Thread(this::shutdown)); - 确保
shutdown()是幂等的（重复调用无副作用） - 钩子里不要做耗时操作（如等待所有客户端处理完），避免阻塞 JVM 退出
完整骨架示例（精简版）
// 注意：实际项目建议用 NIO（如 Netty）或 Spring Boot 内嵌容器
public class SimpleTcpServer {
private final ServerSocket serverSocket;
private volatile boolean running = true;
<pre class="brush:php;toolbar:false;">public SimpleTcpServer(int port) throws IOException {
this.serverSocket = new ServerSocket(port);
}
public void start() {
Thread monitor = new Thread(this::listenLoop, "server-listener");
monitor.start();
}
private void listenLoop() {
while (running) {
try (Socket client = serverSocket.accept()) {
// 处理单个连接（建议丢给线程池）
handleClient(client);
} catch (IOException e) {
if (!running) {
// 主动关闭导致的异常，正常退出
break;
}
// 其他 IO 异常（如端口被占、系统限制），可记录日志后 continue
System.err.println("Accept failed: " + e.getMessage());
}
}
closeQuietly(serverSocket);
}
public void shutdown() {
running = false;
closeQuietly(serverSocket);
}
private void closeQuietly(Closeable closeable) {
if (closeable != null) {
try {
closeable.close();
} catch (IOException ignored) {}
}
}
private void handleClient(Socket client) {
// 示例：简单回显
try (var in = new BufferedReader(new InputStreamReader(client.getInputStream()));
var out = new PrintWriter(client.getOutputStream(), true)) {
String line;
while ((line = in.readLine()) != null && running) {
out.println("ECHO: " + line);
}
} catch (IOException e) {
if (running) System.err.println("Client error: " + e.getMessage());
}
}}
