java - Netty 消息处理程序

Question

我正在使用 netty 构建一个应用程序。在应用程序中，我需要处理传入和传出的消息。要求是应用程序将发送的任何消息都应由特定处理程序处理，并且进入应用程序的任何消息应由另一个特定处理程序处理。但是，我希望在两个处理程序之间交换消息，以便能够跟踪发送的消息响应，因为请求消息也将发送到应用程序。

请知道如何实现这样的要求。这个问题可能听起来不相关，但这就是我得到的问题，而且我还不是一个网络极客。我读到的一些关于它的资料让我选择了它。

谢谢你的建议。

Answer 1

如果可以的话，我会将此功能外包给其他层。也许您可以提供更多详细信息，您只需要跟踪消息吗？当您发送消息时，您希望得到回复吗？您能否唯一标识正在发送和接收的消息？

基本上，我会有另一个层，当您发送和接收消息时，它总是会收到通知。

 +--------------------------------------------------------------+
 |                                                              |
 |                      MessageLoggerHandler                    |
 |                                                              |
 +--------------------------------------------------------------+
              ^                                    +
              +                                    |
 +---------------------------+      +--------------v------------+
 |                           |      |                           |
 |MessageReaderInboundHandler|      |MesageWriterOutboundHandler|
 |                           |      |                           |
 +---------------------------+      +---------------------------+
              ^                                    +
              +                                    |
 +-------------------------------------------------v------------+
 |                                                              |
 |                          NETTY I/O                           |
 |                                                              |
 +--------------------------------------------------------------+