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

标签 java spring-integration quickfixj

我想将 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/

相关文章:

java - Spring @value 未设置属性

java - 在嵌套 HashMap 中搜索字符串数组项

activemq - spring 集成是否支持带有 ActiveMq 的 AMQP

java - 如何创建 LIFO 队列 channel

java - QuickFIX/J - 故障转移策略

快速修复/J : Sending message when logged out

java - 显示所选文件

java - 返回 List<Object> 的房间查询会卡住应用程序

java - 监听竞争消费者队列的多个测试应用程序上下文导致间歇性测试失败

java - 如何根据 QuickFix/J 中的 Fix 字典验证 FIX 消息?