具有同步请求响应的Netty客户端

Question

我正在尝试创建一个基于网络的网络客户端。我根据网络站点中给出的示例编写了代码。但问题是，响应是由客户端处理程序处理的

我做的一件事是在HttpTarget中创建一个setResponse()方法

因此，基本上我想同步进行，即在HttpSnoopClient中发送一个请求(channel.writeandFlush(req))，然后等待，直到HttpSnoopCLientHandler收到响应

谁能告诉我一个好方法。提前致谢！

Answer 1

当您为每个连接创建一个新的HttpSnoopClientHandler时，我会考虑将HttpSnoopClientHandler转换为ChannelDuplexHandler。在write方法中，您可以存储对传出超文本传输协议请求的引用。当收到响应时，您可以使用（Channel、Request、响应）调用setResponse方法。这应该提供足够的上下文，以便您可以正确处理响应。

如果您的客户端是纯请求/响应，不单独发出不相关的请求，并且您希望应用程序线程按顺序处理响应，则可以使用 SynchronousQueue 来协调响应，并允许主线程继续。或者，您的回调可以在内部处理响应。

您还可以扩展这种技术来使用HTTP管道。HTTP管道保证响应按照发出请求的顺序返回。在HttpSnoopClientHandler中，您维护一个请求队列。当每个响应被返回时，您将它与队列前面的请求进行匹配。

Answer 2

我有一个类似的用例，我必须阻止并发请求，直到一个资源的请求完成。我实现了一个ConcurrentHashMap

频道阅读-

if(map.contains(reqKey)){
    map.add(reqKey, list.add(ctx))
    //do nothing with AUTO_READ = false and do not initiate any ctx.* methods
}else{
    //firstRequest
    map.add(reqKey, new ArrayList<CTX>(){{ add(ctx);}})
    //continue with request execution
    //cache response and raise event on completion
}

用户事件触发-

onCompletionEvent {

    ctxList = map.get(reqKey).clone();
    map.remove(reqKey);
    for(blockedCtx : ctxList){
        //respond back with cached response to each blockedCtx
    }

}

@norman-maurer，你能对此发表你的看法吗！！！