Java内置HttpServer调用stop(delay)未立即停止问题咨询

问题现象 #

使用Java内置HttpServer时，调用stop(delay)方法（如stop(10)），即便当前没有正在处理的请求，也会阻塞满整个delay时长，不符合Javadoc中“无请求时立即停止，仅给正在执行的请求留出完成时间”的描述。

原因剖析 #

查看OpenJDK中HttpServerImpl的源码实现，stop(delay)的核心逻辑如下：

1. 关闭监听套接字，拒绝新请求
2. 循环检查当前活跃请求数（numCurrentExchanges），每隔100ms轮询一次，直到活跃请求数为0或达到delay超时
3. 关闭所有剩余连接，等待Dispatcher线程退出

问题出在：即便请求已处理完成，可能由于线程同步延迟、连接复用导致的空闲连接未及时清理，或者默认Executor的线程调度延迟，导致numCurrentExchanges未能及时降到0，从而触发了满时长的轮询等待。

解决方案 #

通过自定义ExecutorService来管理请求处理线程，实现更精准的优雅关闭：

修改后的代码示例 #

package test;

import com.sun.net.httpserver.HttpServer;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.LocalDateTime;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class Test {
  public static void main(String[] args) throws IOException, InterruptedException {
    // 自定义ExecutorService，用于管理请求处理线程
    ExecutorService executor = Executors.newCachedThreadPool();
    
    var httpServer = HttpServer.create();
    httpServer.setExecutor(executor); // 设置自定义Executor
    httpServer.createContext("/", exchange -> {
      exchange.sendResponseHeaders(200, -1);
      exchange.close();
    });
    httpServer.bind(new InetSocketAddress("127.0.0.1", 0), 0);
    httpServer.start();

    var httpClient = HttpClient.newHttpClient();
    var host = httpServer.getAddress().getAddress().getHostAddress();
    var port = httpServer.getAddress().getPort();

    var httpRequest = HttpRequest.newBuilder()
        .uri(URI.create("http://" + host + ":" + port + "/"))
        .GET()
        .build();

    var httpResponse = httpClient.send(httpRequest, HttpResponse.BodyHandlers.ofByteArray());
    System.out.println(httpResponse.statusCode());

    System.out.println(LocalDateTime.now() + " Stopping server");
    
    // 优雅关闭Executor：等待所有正在处理的请求完成
    executor.shutdown();
    if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
        // 超时后强制终止未完成的任务
        executor.shutdownNow();
    }
    // 此时已无活跃请求，调用stop(0)立即停止服务器
    httpServer.stop(0);
    
    System.out.println(LocalDateTime.now() + " Server stopped");
  }
}

逻辑说明 #

1. 自定义Executor：替代HttpServer默认的线程池，让我们能主动控制线程的生命周期
2. Executor优雅关闭：
   • executor.shutdown()：拒绝新任务提交，但允许已提交的任务执行完成
   • executor.awaitTermination(10, TimeUnit.SECONDS)：等待最多10秒，直到所有任务执行完毕
   • 超时后调用executor.shutdownNow()：强制终止剩余任务
3. 立即停止服务器：当确认所有请求处理线程已完成后，调用stop(0)立即关闭服务器，避免不必要的阻塞

验证结果 #

修改后的代码执行时，stop(0)会在所有请求完成后立即执行，不会阻塞10秒，同时保证了生产环境中正在处理的请求有足够时间完成。

内容的提问来源于stack exchange，提问作者vbezhenar