1

我构建了一个上游 Netty 管道,其中管道中的一个早期上游处理程序(我们将其称为 CometDecoder)必须向下游侧相应的 CometEncoder 发送一个空的长轮询请求,当且仅当剩余的上游处理程序不发送通过 CometEncoder 向下游发出实质性请求,以响应接收到的请求。

在此处输入图像描述

原因是这个遗留服务器期望长轮询请求始终处于打开状态,并且并非来自服务器的每个响应都会引发来自客户端的后续请求。

Netty 中似乎有一个 ChannelSink 用作管道中的终端下游处理程序。如果有一个类似的结构允许我们连接到终端 UPSTREAM 处理程序并检查中间上游处理程序之一是否已发送消息的状态,那就太好了。Netty中有这样的东西吗?

那些不得不在 Netty 中处理 Comet 编程的人发现的任何其他方法?

4

0 回答 0