Нетти клиент несколько запросов

Question

Во-первых, я объясню ситуацию и логику, которую я пытаюсь реализовать:

• У меня есть несколько потоков, каждый положил результат его работы, какой-то объект называется Result в очередь QueueToSend

• NettyClient Мои пробегов в потоке и принимает Result от QueueToSend каждый 1 milisecond и должны подключаться к серверу и отправить сообщение, которое создается из Result. Мне также нужно, чтобы эти соединения были асинхронными. Поэтому мне нужен список Result, который должен быть известен NettyHandler, чтобы отправить правильное сообщение и обработать правый результат, а затем снова отправить ответ.

Так что я инициализировать NettyClient самозагрузки

bootstrap = new ClientBootstrap(
       new NioClientSocketChannelFactory(
         Executors.newCachedThreadPool(), 
         Executors.newCachedThreadPool())); 

и устанавливает трубопровод один раз при запуске приложения. Затем каждый milisecond я беру Result объект из QueueToSend и подключиться к серверу

ChannelFuture future = bootstrap.connect(new InetSocketAddress(host,port); 
ResultConcurrentHashMap.put(future.getChannel().getId(), result); 

Я решил использовать статический ConcurrentHashMap для сохранения каждого результата объекта, взятый из QueueToSend, ассоциированного с каналом.

Первая проблема имеет место в NettyHandler в методе channelConnected, когда я пытаюсь принять Result объект, связанный с каналом от ResultConcurrentHashMap.

@Override 
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) { 
     Channel channel = ctx.getPipeline.getChannel(); 
     Result result = ResultConcurrentHashMap.get(channel.getId()); 
} 

Но иногда result равно нулю (1 из 50), даже подумал, что это должно быть в ResultConcurrentHashMap. Я думаю, что это произойдет, причину того, что channelConnected события происходит до NettyClient пробегов этого кода:

ResultConcurrentHashMap.put(future.getChannel().getId(), result); 

Может быть, это не будет выглядеть, если я бег NettyServer и NettyClient не на локальном и другое, но удалено, он будет принимать moretime к estabilish соединения , Но мне нужно решение для этой проблемы.

Другая проблема заключается в том, что я отправляю сообщения каждые 1 миллисекунду асинхронно, и я полагаю, что сообщения могут быть смешанными, и сервер не может их правильно прочитать. Если я запускаю их один за другим, это будет нормально:

future.getChannel().getCloseFuture().awaitUninterruptibly(); 

Но мне нужно asynchromus посылать и обрабатывать правильные результаты, ассоциированные с каналом и отправки ответов. Что мне следует реализовать?

Answer 1

ChannelFutures выполняются асинхронно до того, как события будут запущены. Например, будущее канала будет завершено до запуска события, связанного с каналом.

Итак, вы должны зарегистрировать прослушиватель канала после вызова bootstrap.connect() и написать свой код в прослушивателе для инициализации HashMap, тогда он будет виден обработчику.

 ChannelFuture channelFuture = bootstrap.connect(remoteAddress, localAddress); 

     channelFuture.addListener(new ChannelFutureListener() { 
      @Override 
      public void operationComplete(ChannelFuture future) throws Exception { 
       resultConcurrentHashMap.put(future.getChannel().getId(), result); 
      } 
     });