您如何将像 Quickfixj 这样的 TCP 服务器实现集成到 Spring-Integration 项目中?

How would you integrate a TCP server implementation like Quickfixj into Spring-Integration project?

我想将 Quickfixj 及其所有内置功能实施到使用 Spring-Integration 的项目中。我原以为我可以将这个库包装为 Spring-Integration 的端点对象之一。但是,我很难理解我是否应该使用通道适配器或网关,或者我是否应该使用其他东西。我如何让 Quickfixj 或任何其他类型的服务器设置独立工作并将消息传递到频道?

Quickfixj 已经提供了监听 TCP 端口、解析和验证消息等所需的所有功能。我只需要通过通道将接收到的消息输出到更大的系统。

应该很简单,Spring 集成提供 Messaging Gateway 从常规 Java 代码与集成流程集成。

只需提供一个接口,框架就会创建实现。

当您收到 QuickFixJ 消息时,只需调用网关即可。

您可能希望将 QuickFixJ 消息映射到 spring-messaging Message<?>(有效负载,headers),或者您可以简单地发送 QuickFixJ 消息作为 Message<?> - 这真的取决于您的要求。