我正在使用 netty 构建一个应用程序。在应用程序中,我需要处理传入和传出消息。要求是应用程序将发送的任何消息都应由特定的处理程序处理,并且进入应用程序的任何消息都应由另一个特定的处理程序处理。但是我想在两个处理程序之间交换消息以便能够跟踪发送的消息响应,因为请求消息也将被发送到应用程序。
请任何想法实现这样的要求。这个问题听起来可能不相关,但这就是我得到的,我还不是一个网络极客。我读到的关于它的一点点让我选择了它。
感谢您的意见。
如果可以的话,我会将此功能外包给其他层。也许您可以提供更多详细信息,您只需要跟踪消息吗?当您发送消息时,您期望得到响应吗?您能否唯一标识正在发送和接收的消息?
基本上我会有另一个层,当您发送和接收消息时总是会收到通知。
+--------------------------------------------------------------+
| |
| MessageLoggerHandler |
| |
+--------------------------------------------------------------+
^ +
+ |
+---------------------------+ +--------------v------------+
| | | |
|MessageReaderInboundHandler| |MesageWriterOutboundHandler|
| | | |
+---------------------------+ +---------------------------+
^ +
+ |
+-------------------------------------------------v------------+
| |
| NETTY I/O |
| |
+--------------------------------------------------------------+