我正在使用 netty 构建一个应用程序。在应用程序中,我需要处理传入和传出的消息。要求是应用程序将发送的任何消息都应由特定处理程序处理,并且进入应用程序的任何消息应由另一个特定处理程序处理。但是,我希望在两个处理程序之间交换消息,以便能够跟踪发送的消息响应,因为请求消息也将发送到应用程序。
请知道如何实现这样的要求。这个问题可能听起来不相关,但这就是我得到的问题,而且我还不是一个网络极客。我读到的一些关于它的资料让我选择了它。
谢谢你的建议。
最佳答案
如果可以的话,我会将此功能外包给其他层。 也许您可以提供更多详细信息,您只需要跟踪消息吗? 当您发送消息时,您希望得到回复吗? 您能否唯一标识正在发送和接收的消息?
基本上,我会有另一个层,当您发送和接收消息时,它总是会收到通知。
+--------------------------------------------------------------+
| |
| MessageLoggerHandler |
| |
+--------------------------------------------------------------+
^ +
+ |
+---------------------------+ +--------------v------------+
| | | |
|MessageReaderInboundHandler| |MesageWriterOutboundHandler|
| | | |
+---------------------------+ +---------------------------+
^ +
+ |
+-------------------------------------------------v------------+
| |
| NETTY I/O |
| |
+--------------------------------------------------------------+
关于java - Netty 消息处理程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15474041/