Reactor网络中字节缓冲区分配器

Question

有没有一种方法可以在请求处理程序中获得反应堆网络中使用的字节缓冲区分配器？类似于如何在纯Netty中执行final ByteBufAllocator ByteBufAllocator=ctx.alloc()；？

HttpServer.create()
        .host("0.0.0.0")
        .port(8080)
        .route(routes -> {
          routes.ws("/ws", (in, out) ->  
            // how to get the allocator here?
          });
        })

Answer 1

您可以从WebSocketOutbound或HttpServerResponse访问ByteBuFalLocator，如下所示：

HttpServer.create()
        .host("0.0.0.0")
        .port(8080)
        .route(routes -> routes
                .ws("/ws", (in, out) -> {
                    ByteBufAllocator alloc = out.alloc();
                    // ...
                })
                .get("/path", (request, response) -> {
                    ByteBufAllocator alloc = response.alloc();
                    // ...
                })
        );