重新连接，同时与netty 4保持状态

Question

我正在使用netty 4，并利用ChannelPipeline将协议状态管理等内容与编解码器分开（例如）。这真的很好用——我喜欢管道的单线程（如果需要的话）特性。

我还想管理断开/重新连接。

但是，当“断开连接”时，我想保留那些本来会发送给断开连接的人的消息。我希望这样做的同时仍然使用netty特性（即在持久化之前仍然使用管道中的处理程序进行编码等）。

不过，显然，这个（逻辑）管道的寿命超过了一个通道的寿命（当重新连接发生时，我将使用登录消息中发送的会话名称，并将所有状态拉回到新通道的管道中）。

显然，我可以在网络之外完成这一切——但我仍然希望在断开连接的情况下继续使用管道进行编码等。目前我所能想到的就是使用某种“/dev/null/”风格（自定义）的通道，当我们断开连接时，它会删除所有内容，在断开连接时适当重建管道（我们会在这个“假”死消息通道中切换）并重新连接，和一个自定义的EventExecutorGroup，以保持线程良好（即固定到'逻辑会话'状态-因此在通道之间移动）。这似乎有点'呃'：）

有没有任何一种现有的模式，我没有看到记录在案，用于处理断开之间的时间

Answer 1

听起来你们是在努力确保“尽力而为”地交付给客户。我处理类似的事情。

在上游，您需要一个带有队列和通道组的接收器。当客户端连接时，这些接收器之一被创建并被添加到通道组中。添加消息时，它们会同时添加到队列中并写入通道组。组中的每个连接都会接收这些消息。

在重新连接时，您（神奇地）将新客户端映射回接收器，并（神奇地）确定其在队列中的位置，然后从队列中发送增量，并将其添加到组中。“神奇”的部分由你决定。

您确实需要担心这段代码中的并发，并且需要担心接收器的手动垃圾回收机制。

我是番石榴的超级粉丝，喜欢TTL和LRU缓存，我在这里使用过它们。

更新：

根据下面的说明，您要求动态构建管道并重用处理程序。管道处理程序可以重用，所以这个序列图应该基本上满足您的需要。

该图中不包括的是写入处理程序的外部html" target="_blank">进程。当ctx被分离并且连接向下流关闭时，您需要在有状态处理程序中处理对客户端的缓冲。我认为你可以实验的确切机制。

希望这有帮助。