Reactor-Netty中HttpServerResponse带Body时trailerHeaders失效问题

问题现象 #

当调用send系列方法（如sendString）发送响应Body时，预先设置的trailerHeaders无法传递给客户端；但注释掉send方法后，trailer头能正常返回给客户端。

复现代码与验证结果 #

带send方法的服务器代码 #

DisposableServer server =
        HttpServer.create()
                .port(8083)
                .protocol(HttpProtocol.H2C)
                .handle((request, response) -> {
                    return response
                            .status(200)
                            .header(HttpHeaderNames.TRAILER, "grpc-status")
                            .chunkedTransfer(true)
                            .trailerHeaders(s -> {
                                s.add("grpc-status", "0");
                            })
                            .sendString(Mono.just("d"));
                })
                .bindNow();

server.onDispose()
        .block();

请求命令及无trailer返回结果 #

curl -X POST http://localhost:8083/api.Ping/GetPing  --http2-prior-knowledge -H 'Content-Type: application/grpc' --data-binary "@myfile.dat"  -v
....
> content-length: 48
>
* We are completely uploaded and fine
* Connection state changed (MAX_CONCURRENT_STREAMS == 4294967295)!
< HTTP/2 200
< trailer: grpc-status
< content-length: 1
<
* Connection #0 to host localhost left intact
d

此时客户端未收到grpc-status trailer头。

注释send方法后的服务器代码 #

public static void server() {
    DisposableServer server =
            HttpServer.create()
                    .port(8083)
                    .protocol(HttpProtocol.H2C)
                    .handle((request, response) -> {
                        return response
                                .status(200)
                                .header(HttpHeaderNames.TRAILER, "grpc-status")
                                .chunkedTransfer(true)
                                .trailerHeaders(s -> {
                                    s.add("grpc-status", "0");
                                });
//                                .sendString(Mono.just("d"));
                    })
                    .bindNow();

    server.onDispose()
            .block();
}

请求及trailer正常返回结果 #

> content-length: 48
>
* We are completely uploaded and fine
* Connection state changed (MAX_CONCURRENT_STREAMS == 4294967295)!
< HTTP/2 200
< trailer: grpc-status
<
< grpc-status: 0
* Connection #0 to host localhost left intact

原因分析 #

核心问题在于chunkedTransfer(true)与send方法的冲突：
当调用sendString(Mono.just("d"))时，Reactor-Netty会自动计算内容长度并添加Content-Length头，这会覆盖chunkedTransfer(true)的配置。在HTTP/2协议中，若响应存在Content-Length，则不会启用分块传输，而trailer头依赖分块传输（或HTTP/2流结束帧）才能被正确传递。

解决方案 #

要让trailer在携带Body时生效，需确保响应使用分块传输，避免Reactor-Netty自动添加Content-Length头，以下是几种可行方案：

方案1：流式发送内容，避免提前确定长度 #

将固定内容的Mono改为Flux发送，触发分块传输逻辑：

.sendString(Flux.just("d"))

或使用ByteBufFlux传递内容：

.send(ByteBufFlux.fromString(Mono.just("d")))

方案2：显式清除Content-Length头 #

在响应配置中手动清除自动生成的Content-Length，强制启用分块传输：

return response
        .status(200)
        .header(HttpHeaderNames.TRAILER, "grpc-status")
        .header(HttpHeaderNames.CONTENT_LENGTH, null) // 清除自动添加的Content-Length
        .chunkedTransfer(true)
        .trailerHeaders(s -> {
            s.add("grpc-status", "0");
        })
        .sendString(Mono.just("d"));

方案3：使用sendObject构建完整响应 #

通过sendObject直接传递包含trailer的响应对象，确保Body与trailer协同处理：

HttpHeaders headers = new HttpHeaders();
headers.add(HttpHeaderNames.TRAILER, "grpc-status");

HttpResponseStatus status = HttpResponseStatus.OK;
ByteBuf body = ByteBufAllocator.DEFAULT.buffer().writeBytes("d".getBytes());

HttpHeaders trailers = new HttpHeaders();
trailers.add("grpc-status", "0");

return response.sendObject(new DefaultHttpResponse(status, headers), body, trailers);

验证效果 #

修改后再次执行curl请求，可看到grpc-status trailer头正常出现在响应末尾：

< HTTP/2 200
< trailer: grpc-status
< transfer-encoding: chunked
<
d
< grpc-status: 0

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