我正在研究一个需要多台服务器相互连接并交换数据的系统。我想在每个服务器中创建一个服务器套接字,接受新的传入连接,但同时启动一些与其他服务器的出站连接。
建立连接后,无论是入站还是出站,我都希望使用它而不区分谁是发起者。TCP连接是对称的,毕竟一旦建立...
有没有办法用内蒂做到这一点?[我是新手...查看ServerBootstrap,我不明白如何打开出站连接并"附加"它,以便我在ServerBootstrap中指定的处理程序为所有连接提供服务。
当然,我只能打开与所有服务器的传出连接,但我会发现每两个服务器之间只有一个连接会更优雅。
您是否考虑过额外的引导程序?
Bootstrap outboundBootstrap = new Bootstrap();
outboundBootstrap.group(workerGroup)
.channel(EpollSocketChannel.class)
.handler(new MyInit());
然后打开连接:
InetSocketAddress address =..;ChannelFuture future = outboundBootstrap.connect(address);