如何在Netty Reactor HTTP Server响应中正确发送Mono<ResponseEntity>作为JSON

<dependency>
    <groupId>io.projectreactor.netty</groupId>
    <artifactId>reactor-netty</artifactId>
    <version>VERSION</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

import org.springframework.http.ResponseEntity;
import org.springframework.web.reactive.function.server.HandlerFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;

public class MyHandler {
    public Mono<ServerResponse> handleRequest(ServerRequest request) {
        Mono<ResponseEntity> responseMono = // 构建你的响应Mono<ResponseEntity>，可以使用WebClient等方式获取数据
        return responseMono.flatMap(responseEntity -> ServerResponse.ok().bodyValue(responseEntity));
    }

    public RouterFunction<ServerResponse> routes() {
        return RouterFunctions.route()
                .GET("/api/endpoint", this::handleRequest)
                .build();
    }
}

import io.netty.channel.ChannelOption;
import io.netty.handler.codec.http.HttpHeaderNames;
import io.netty.handler.codec.http.HttpHeaderValues;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
import io.netty.handler.timeout.ReadTimeoutHandler;
import io.netty.handler.timeout.WriteTimeoutHandler;
import org.springframework.http.MediaType;
import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter;
import org.springframework.web.reactive.function.server.RouterFunction;
import reactor.netty.http.server.HttpServer;

import java.time.Duration;

public class NettyServer {
    public static void main(String[] args) throws Exception {
        RouterFunction<ServerResponse> router = new MyHandler().routes();
        ReactorHttpHandlerAdapter handlerAdapter = new ReactorHttpHandlerAdapter(RouterFunctions.toHttpHandler(router));

        HttpServer server = HttpServer.create()
                .port(8080)
                .tcpConfiguration(tcpServer -> tcpServer
                        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
                        .doOnConnection(conn -> conn
                                .addHandlerLast(new ReadTimeoutHandler(10))
                                .addHandlerLast(new WriteTimeoutHandler(10))
                        )
                )
                .secure(sslContextSpec -> sslContextSpec.sslContext(
                        SslContextBuilder.forServer(ClassLoader.getSystemResource("server.crt").openStream(),
                                ClassLoader.getSystemResource("server.pem").openStream(), "password")
                                .trustManager(InsecureTrustManagerFactory.INSTANCE)
                ))
                .handle(handlerAdapter);

        server.bindUntilJavaShutdown(Duration.ofSeconds(30), disposableServer -> {
            System.out.println("Netty server started on port " + disposableServer.port());
        });
    }
}