在 Netty 服务器上,如何创建出站连接,然后像使用传入连接一样继续使用它们



我正在研究一个需要多台服务器相互连接并交换数据的系统。我想在每个服务器中创建一个服务器套接字,接受新的传入连接,但同时启动一些与其他服务器的出站连接。

建立连接后,无论是入站还是出站,我都希望使用它而不区分谁是发起者。TCP连接是对称的,毕竟一旦建立...

有没有办法用内蒂做到这一点?[我是新手...查看ServerBootstrap,我不明白如何打开出站连接并"附加"它,以便我在ServerBootstrap中指定的处理程序为所有连接提供服务。

当然,我只能打开与所有服务器的传出连接,但我会发现每两个服务器之间只有一个连接会更优雅。

您是否考虑过额外的引导程序?

Bootstrap outboundBootstrap = new Bootstrap();
outboundBootstrap.group(workerGroup)
            .channel(EpollSocketChannel.class)
            .handler(new MyInit());

然后打开连接:

InetSocketAddress address =..;ChannelFuture future = outboundBootstrap.connect(address);

最新更新