admin 管理员组

文章数量: 1086019

I am new to netty and I am stuck at a point. I am using netty as a reverse proxy and here is my channel pipeline.

streamChannel.pipeline()
                                                .addLast(new Http2StreamFrameToHttpObjectCodec(true))
                                                .addLast(new BandwidthHandler(transactionStrategy))
                                                .addLast(new ProxyRequestCodec(transactionStrategy, sslSession))
                                                .addLast(new TransactionHandler(transactionStrategy, connectionCtx))
                                                .addLast(new ObjectAggregator(aggregationStrategy, MAX_AGGREGATED_CONTENT_LENGTH,protocol))
                                                .addLast(new AggregatedProxyRequestDecoder(connectionCtx))
                                                .addLast(new AuthenticationHandler(authenticationStrategy))
                                                .addLast(new RouteHandler(routingStrategy, fChannel))
                                                .addLast(new RequestFilter(filteringStrategy, fChannel))
                                                .addLast(new AppSpecificHandler(proxyConfig.appHandlers(), connectionCtx))
                                                .addLast(new RequestModifier(modificationStrategy))
                                                .addLast(new FlowControlHandler())
                                                .addLast(new ConnectionHandler(connectionCtx, backendPort))
                                                .addLast(new RequestForwarder(connectionCtx))
                                                .addLast(new ExceptionHandler(connectionCtx));

These handlers are present inside the Http2MultiplexHandler because these handlers were used in http1 and updating the whole business logic to http2 frames was a major change. Now the issue I am facing is that the connection handler does not connect to backend host unless the it receives a FullHttpRequest that is if I remove ObjectAggregator from the pipeline, the future returned from bootstrap.connect(host, port) doesn't resolve until I get a connection timeout exception. Below is the connection handler code.

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    if (msg instanceof ProxyRequest proxyRequest) {
        connectToBackend(ctx, proxyRequest);
        return;
    }

    fireNextHandlerRead(ctx, msg);
}
private void connectToBackend(ChannelHandlerContext ctx, ProxyRequest proxyRequest) throws InterruptedException {
    var host = proxyRequest.hostName();
    var bChannel = connectionCtx.bChannelPool().acquire(host);

    if (bChannel.isConnected()) {
        connectionCtx.bChannel(bChannel);
        fireNextHandlerRead(ctx, proxyRequest);
        return;
    }
    var connectFuture = bChannel.connect(host, backendPort);
    connectFuture
            .addListener(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE)
            .addListener(future -> {
                if (!future.isSuccess()) return;
                connectionCtx.bChannel(bChannel);
                fireNextHandlerRead(ctx, proxyRequest);
            });
}

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    if (msg instanceof ProxyRequest proxyRequest) {
        connectToBackend(ctx, proxyRequest);
        return;
    }

    fireNextHandlerRead(ctx, msg);
}
private void connectToBackend(ChannelHandlerContext ctx, ProxyRequest proxyRequest) throws InterruptedException {
    var host = proxyRequest.hostName();
    var bChannel = connectionCtx.bChannelPool().acquire(host);

    if (bChannel.isConnected()) {
        connectionCtx.bChannel(bChannel);
        fireNextHandlerRead(ctx, proxyRequest);
        return;
    }
    var connectFuture = bChannel.connect(host, backendPort);
    connectFuture
            .addListener(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE)
            .addListener(future -> {
                if (!future.isSuccess()) return;
                connectionCtx.bChannel(bChannel);
                fireNextHandlerRead(ctx, proxyRequest);
            });
}

Below is the connect from BackendChannel

public ChannelFuture connect(String host, int port) {
    var connectFuture = bootstrap.connect(host, port);
    channelOpt = Optional.of(connectFuture.channel());
    return connectFuture;
}

I am pretty sure it has nothing to do with the fullHttpRequest, because the same logic works in a standalone http1 pipeline. Any help would be greatly appriciated.

本文标签：

Error[2]: Invalid argument supplied for foreach(), File: /www/wwwroot/roclinux.cn/tmp/view_template_quzhiwa_htm_read.htm, Line: 58
File: /www/wwwroot/roclinux.cn/tmp/route_read.php, Line: 205, include(/www/wwwroot/roclinux.cn/tmp/view_template_quzhiwa_htm_read.htm)
File: /www/wwwroot/roclinux.cn/tmp/index.inc.php, Line: 129, include(/www/wwwroot/roclinux.cn/tmp/route_read.php)
File: /www/wwwroot/roclinux.cn/index.php, Line: 29, include(/www/wwwroot/roclinux.cn/tmp/index.inc.php)

版权声明：本文标题：reverse proxy - bootstrap.coonect doesn't resolve the future unless I pass a FullHttpRequest in netty - Stack Overflow 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.roclinux.cn/p/1744055285a2525739.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。