java - Netty 消息处理程序

标签 java netty

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

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

谢谢你的建议。

最佳答案

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

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

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

关于java - Netty 消息处理程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15474041/

相关文章:

java - Netty - 如何将 ChunkedWriteHandler 与 HttpContentCompressor 结合起来

java - 流媒体上传/下载

java - MySql 批量插入

java - 动态内容的 BaseAdaptor 用法

使用 scala 插件在 Intellij/maven 中配置 1.7 时的 Java 6 类

java - 添加 Firebase Admin 6.12.2 后 Netty 无法处理请求

java - 如何使用 Netty deflator 压缩发送到浏览器的响应

java - 使用 Netty 收到的消息是否可能出现故障或受到限制?

java - 如何将GraphiQL与Spring-Boot集成?

java - 保护 Raspberry Pi 上 Tomcat 上的 Web 服务