Обработка ответа от сервера в клиенте Netty

Question

Я пишу приложение JavaFX, используя Netty для реализации настраиваемого протокола. Нет состояния сеанса, но я хотел бы сопоставить ответ сервера с конкретным исходящим запросом (и вернуть результат в правильный JavaFX Task.) До сих пор я не смог сделать это в клиентском коде, потому что ответ Future это ChannelFuture<Void>.

future = tcpBoostrap.connect(address, 3333).sync(); 
final Channel channel = future.awaitUninterruptibly().channel(); 

ChannelFuture responseFuture = channel.writeAndFlush(requestBuilder.build()); 
responseFuture.addListener(new ChannelFutureListener() { 
    @Override 
    public void operationComplete(ChannelFuture channelFuture) throws Exception { 
     if (channelFuture.isSuccess()) { 
      logger.debug("completed operation: {}", channelFuture.toString()); 
     } 
    } 
}); 

Я попытался глядя том, как настроить PipeLine каким-то образом установить ChannelHandlers, что бы поделиться информацией в общей переменной контекста, но я не мог найти что-нибудь существенное.

Может ли кто-нибудь предложить идиоматическое место, где я могу заполнить задачу пользовательского интерфейса, которую я могу «заполнить» ответом в Netty?

Answer 1

Netty не может делать такую ​​работу за вас, так как не может понять механизм сопряжения. На стороне клиента вам необходимо реализовать ChannelHandler и передать инициализатор методу .handler(handler). См. Netty TimeClient example. В обработчике channelRead метод обрабатывает ответ с сервера, десериализует его и в соответствии с механизмом, специфичным для вашей пары приложений, с ранее созданным Future и завершает его. Future не обязательно должен быть Netty будущего, поскольку эта часть полностью исключена из обработки Netty.

Для сопряжения Я предполагаю, что вы используете некоторый идентификатор, который вы отправляете на сервер, и сервер отправляет тот же идентификатор клиенту. Поэтому в таком случае достаточно Map<Long, Future<?>>.