如何在Netty通道中调度HttpRequest？

public class HttpServer {
    public static void main(String[] args) throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline pipeline = ch.pipeline();
                            pipeline.addLast(new HttpRequestDecoder());
                            pipeline.addLast(new HttpResponseEncoder());
                            pipeline.addLast(new HttpServerHandler());
                        }
                    });

            ChannelFuture future = bootstrap.bind(8080).sync();
            future.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

public class HttpServerHandler extends SimpleChannelInboundHandler<HttpRequest> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, HttpRequest request) throws Exception {
        // 根据request的URI进行路由和调度
        String uri = request.uri();
        if ("/api/user".equals(uri)) {
            // 处理用户相关的请求
            handleUserRequest(ctx, request);
        } else if ("/api/product".equals(uri)) {
            // 处理产品相关的请求
            handleProductRequest(ctx, request);
        } else {
            // 未知的请求
            sendErrorResponse(ctx, HttpResponseStatus.NOT_FOUND);
        }
    }

    private void handleUserRequest(ChannelHandlerContext ctx, HttpRequest request) {
        // 处理用户请求的逻辑
        // ...
        // 发送响应
        sendResponse(ctx, HttpResponseStatus.OK, "User request handled successfully");
    }

    private void handleProductRequest(ChannelHandlerContext ctx, HttpRequest request) {
        // 处理产品请求的逻辑
        // ...
        // 发送响应
        sendResponse(ctx, HttpResponseStatus.OK, "Product request handled successfully");
    }

    private void sendErrorResponse(ChannelHandlerContext ctx, HttpResponseStatus status) {
        FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, status);
        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
    }

    private void sendResponse(ChannelHandlerContext ctx, HttpResponseStatus status, String content) {
        FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, status,
                Unpooled.copiedBuffer(content, CharsetUtil.UTF_8));
        response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain; charset=UTF-8");
        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
    }
}