我想将 Quickfixj 及其所有内置功能实现到使用 Spring-Integration 的项目中。我曾以为我可以将这个库包装为 Spring-Integration 的端点对象之一。但是,我很难理解是否应该使用 channel 适配器或网关,或者是否应该使用其他东西。我如何让 Quickfixj 或任何其他类型的服务器设置独立工作并将消息传递到 channel 中?
Quickfixj 已经提供了我监听 TCP 端口、解析和验证消息等所需的所有功能。我只需要通过 channel 将接收到的消息输出到更大的系统。
最佳答案
这应该很简单,Spring Integration 提供了Messaging Gateway将常规 Java 代码与集成流程集成。
只需提供一个接口(interface),框架就会创建实现。
当您收到 QuickFixJ 消息时,只需调用网关即可。
您可能希望将 QuickFixJ 消息映射到 spring-messaging
Message<?>
(有效负载、 header ),或者您可以简单地将 QuickFixJ 消息作为 Message<?>
的有效负载发送- 这实际上取决于您的要求。
关于java - 如何将像 Quickfixj 这样的 TCP 服务器实现集成到 Spring-Integration 项目中?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55737853/