App-Platform 仓库的 action 存在随机报错，使用 FIT 框架需要增加日志定位

[CodeCasterX]

如图，上层业务在跑门禁时，会随机报错，当前经过排查，需要在框架层增加相关日志来辅助定位

[CodeCasterX]

以下为来自 Claude 的分析，分析的很有道理：

---

问题分析：

这是一个典型的 竞态条件（Race Condition） 问题，涉及到多线程并发访问和资源生命周期管理。

问题发生的流程：

1. 请求处理开始：HttpClassicRequestAssembler.handleHttpRequest() 被调用，创建了 NettyHttpServerRequest 对象
2. 异步执行：请求被提交到线程池异步处理（netty-request-assembler-thread-4）
3. 请求处理完成：异步线程中的 doHttpRequest() 方法执行完毕，在 finally 块中调用了 request.removeExecuteThread()，随后 NettyHttpServerRequest 被关闭（从日志可以看到 "Netty http request closed"）
4. 内容到达：与此同时，Netty worker 线程（netty-worker-group-thread-4）收到了 HTTP 内容数据，调用 handleHttpContent() 方法
5. 冲突发生：当尝试调用 receiveHttpContent() 时，发现请求已经被关闭，抛出 IOException: The netty http server request has already been closed

根本原因：

对于 GET 请求，通常没有请求体，但 HTTP 协议仍然会发送 LastHttpContent 来标志请求结束。 在你的代码中：

• 异步处理线程很快完成了请求处理并关闭了资源
• 但 Netty 仍在接收协议层面的 LastHttpContent
• 当 LastHttpContent 到达时，请求对象已经被关闭

可能的解决方案：

1. 延迟关闭策略

不要在请求处理完成时立即关闭 NettyHttpServerRequest，而是等待所有 HTTP 内容接收完毕后再关闭：

private void doHttpRequest(ChannelHandlerContext ctx, NettyHttpServerRequest request) {
    request.setExecuteThread(Thread.currentThread());
    try (HttpClassicServerRequest classicRequest = HttpClassicServerRequest.create(this.server, request);
         NettyHttpServerResponse response = new NettyHttpServerResponse(ctx, request);
         HttpClassicServerResponse classicResponse = HttpClassicServerResponse.create(this.server, response)) {
        
        // 处理请求逻辑
        HttpHandler handler = this.server.httpDispatcher().dispatch(classicRequest, classicResponse);
        classicRequest.attributes().set(PATH_PATTERN.key(), handler.pathPattern());
        classicRequest.attributes().set(HTTP_HANDLER.key(), handler);
        HttpServerFilterChain filterChain = new DefaultHttpServerFilterChain(handler);
        this.doFilterChain(filterChain, classicRequest, classicResponse);
        
    } catch (Exception cause) {
        this.exceptionCaught(ctx, cause, request);
    } finally {
        request.removeExecuteThread();
        // 不要在这里关闭 NettyHttpServerRequest，让它在 receiveLastHttpContent 时自然关闭
    }
}

2. 添加状态检查

在 receiveHttpContent 方法中添加更智能的状态检查：

private void receiveHttpContent(ChannelHandlerContext ctx, NettyHttpServerRequest serverRequest,
        HttpContent content) {
    try {
        if (content instanceof LastHttpContent) {
            if (!serverRequest.isClosed()) {  // 添加状态检查
                serverRequest.receiveLastHttpContent(cast(content));
            }
            clearRequest(ctx);
        } else {
            if (!serverRequest.isClosed()) {  // 添加状态检查
                serverRequest.receiveHttpContent(content);
            }
        }
    } catch (IOException e) {
        // 对于已关闭的请求，记录警告而不是抛出异常
        log.warn("Failed to receive http content for closed request: {}", e.getMessage());
    }
}

3. 改进生命周期管理

考虑将 NettyHttpServerRequest 的关闭时机推迟到 clearRequest() 方法中，确保所有内容都接收完毕。
建议优先尝试方案2，因为它能够优雅地处理这种竞态条件，而不会影响正常的请求处理流程。