// 性能測(cè)試代碼示例
@SpringBootTest
class WebContainerPerformanceTest {
    
    @Test
    void testConcurrentPerformance() {
        // 模擬1000并發(fā)用戶持續(xù)請(qǐng)求30秒
        LoadTest loadTest = LoadTest.configure()
            .threads(1000)
            .duration(30, TimeUnit.SECONDS)
            .build();
            
        // Tomcat測(cè)試結(jié)果
        TomcatResult tomcatResult = loadTest.runWithTomcat();
        
        // Undertow測(cè)試結(jié)果  
        UndertowResult undertowResult = loadTest.runWithUndertow();
        
        // 結(jié)果對(duì)比
        System.out.println("QPS - Tomcat: " + tomcatResult.getQps());
        System.out.println("QPS - Undertow: " + undertowResult.getQps());
        System.out.println("平均響應(yīng)時(shí)間 - Tomcat: " + tomcatResult.getAvgResponseTime());
        System.out.println("平均響應(yīng)時(shí)間 - Undertow: " + undertowResult.getAvgResponseTime());
    }
}

// Undertow的內(nèi)存管理示例
publicclass UndertowMemoryManagement {
    
    // 使用直接緩沖區(qū)處理請(qǐng)求
    public void handleRequest(HttpServerExchange exchange) {
        // 獲取直接緩沖區(qū)
        ByteBuffer buffer = exchange.getConnection().getBufferPool().allocate();
        
        try {
            // 直接操作緩沖區(qū)，避免拷貝
            readRequestData(exchange, buffer);
            processRequest(buffer);
            writeResponse(exchange, buffer);
        } finally {
            // 釋放緩沖區(qū)
            exchange.getConnection().getBufferPool().free(buffer);
        }
    }
    
    // Tomcat通常需要多次內(nèi)存拷貝
    public void tomcatHandleRequest(Request request, Response response) {
        // 從輸入流讀取數(shù)據(jù)（內(nèi)存拷貝）
        byte[] inputData = readInputStream(request.getInputStream());
        
        // 處理數(shù)據(jù)（可能再次拷貝）
        byte[] outputData = processData(inputData);
        
        // 寫入輸出流（又一次拷貝）
        response.getOutputStream().write(outputData);
    }
}

# Undertow配置示例
server:
undertow:
    # 線程池配置
    threads:
      worker:16
      io:4
    # 緩沖區(qū)配置
    buffer-size:1024
    direct-buffers:true
    # 連接配置
    max-connections:10000
    max-http-post-size:10485760

# Tomcat配置示例
server:
tomcat:
    # 連接器配置
    max-connections:10000
    max-threads:200
    min-spare-threads:10
    # 其他配置
    max-http-post-size:10485760
    connection-timeout:20000

// XNIO工作線程模型示例
publicclass XNIOWorkerModel {
    
    public void demonstrateWorkerModel() {
        // 創(chuàng)建Worker實(shí)例
        XnioWorker worker = Xnio.getInstance().createWorker(
            OptionMap.create(Options.THREAD_DAEMON, true)
        );
        
        // IO線程處理網(wǎng)絡(luò)事件
        worker.getIoThread().execute(() -> {
            // 處理IO就緒事件
            handleIOReadyEvents();
        });
        
        // 工作線程處理業(yè)務(wù)邏輯
        worker.getWorkerThreadPool().execute(() -> {
            // 執(zhí)行業(yè)務(wù)處理
            executeBusinessLogic();
        });
    }
}

@Configuration
publicclass UndertowConfig {
    
    @Bean
    public UndertowServletWebServerFactory undertowServletWebServerFactory() {
        UndertowServletWebServerFactory factory = new UndertowServletWebServerFactory();
        
        factory.addBuilderCustomizers(builder -> {
            // 配置HTTP/2
            builder.setServerOption(UndertowOptions.ENABLE_HTTP2, true);
            
            // 配置緩沖區(qū)
            builder.setSocketOption(Options.RECEIVE_BUFFER, 1024 * 16);
            builder.setSocketOption(Options.SEND_BUFFER, 1024 * 64);
            
            // 配置線程池
            builder.setIoThreads(Runtime.getRuntime().availableProcessors());
            builder.setWorkerThreads(200);
            
            // 配置連接數(shù)限制
            builder.setServerOption(UndertowOptions.MAX_CONNECTIONS, 10000);
        });
        
        return factory;
    }
}

public class CustomHandler implements HttpHandler {
    
    privatefinal HttpHandler next;
    
    public CustomHandler(HttpHandler next) {
        this.next = next;
    }
    
    @Override
    public void handleRequest(HttpServerExchange exchange) throws Exception {
        long startTime = System.currentTimeMillis();
        
        try {
            // 前置處理：認(rèn)證、日志等
            preHandle(exchange);
            
            // 調(diào)用下一個(gè)處理器
            next.handleRequest(exchange);
            
        } finally {
            // 后置處理：統(tǒng)計(jì)、清理等
            postHandle(exchange, startTime);
        }
    }
    
    private void preHandle(HttpServerExchange exchange) {
        // 認(rèn)證檢查
        if (!checkAuthentication(exchange)) {
            exchange.setStatusCode(401);
            exchange.endExchange();
            return;
        }
        
        // 請(qǐng)求日志記錄
        logRequest(exchange);
    }
}

# 生產(chǎn)環(huán)境Undertow優(yōu)化配置
server:
undertow:
    # IO線程數(shù)（通常為CPU核心數(shù)）
    io-threads:8
    # 工作線程數(shù)（根據(jù)業(yè)務(wù)調(diào)整）
    worker-threads:200
    # 直接緩沖區(qū)
    direct-buffers:true
    buffer-size:16384
    # 連接配置
    max-connections:10000
    max-http-post-size:10485760
    # 優(yōu)雅關(guān)閉
    no-request-timeout:60000
    drain-wait-time:20000
    
# JVM優(yōu)化配合
port:8080
compression:
    enabled:true
    mime-types:text/html,text/xml,text/plain,application/json

<!-- 排除Tomcat -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <exclusions>
        <exclusion>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<!-- 引入U(xiǎn)ndertow -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-undertow</artifactId>
</dependency>