我有一个客户端正在发送多个请求。每个请求都将发送到不同的服务器。所以,200个请求被发送到200个不同的服务器。
我已经为不同的连接创建了一个偶数循环组,它具有不同的引导。
我应该使用200个通道处理200个请求还是使用一个通道。下面是我的代码,我现在使用的是单通道:
public HttpClientDemo(int serverPort)
{
this.serverPort = serverPort;
this.pipelineFactory = new HTTPClientInitializer();
this.workerGroup = new NioEventLoopGroup();
}
public void connect(String address, int timeout) {
connectAsync(address).syncUninterruptibly();
}
private ChannelFuture connectAsync(final String address)
{
return new Bootstrap()
.group(workerGroup)
.channel(NioSocketChannel.class)
.handler(pipelineFactory).connect(address,serverPort).addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) {
if(future.isSuccess())
{
log.info("Client is able to connect to: " + address);
}
else
{
log.error("Client not able to connect to: " + address + " " + future.cause());
}
}
});
}
1条答案
按热度按时间xmakbtuz1#
每个通道都连接到不同的端点和不同的服务器,这意味着您将需要不同的通道。