使用Netty4和Apache Camel的全双工TCP连接

Question

对于我正在做的一个IoT项目，我正在研究我们的“套接字处理程序”的下一个增强版本，它已经有5年多的历史了，并且已经演变成一个巨大的野兽，除了处理与IoT设备的套接字连接之外，还在线程处理方面也变得非常棘手。

对于我的完全重写，我将Apache Camel作为路由和转换工具包，并了解这如何帮助我们将处理步骤拆分为微服务，通过消息队列松散耦合。

然而，有一件事我很难理解，那就是我如何实现以下逻辑“Apache Camel way”：IoT设备发送一个初始消息，其中包含它的id、一些额外的报头和消息有效负载。除了提取消息有效负载并将其路由到通道之外，我还需要使用设备id来检查以设备Id命名的消息队列，以查找必须通过接收初始消息的同一套接字连接转到设备的任何命令。

虽然似乎Camel中包含的Netty4可以处理同步双工通信，但我不明白如何在Camel Netty4组件中实现上述逻辑。Camel路由似乎只有一种方式。

有没有一种正确的方法来做这件事，或者我应该忘记使用camel来做这件事，而只使用Netty4 bare？

Answer 1

在camel路由结束后，exchange的主体和头部将作为响应返回给请求者。