接受者如何处理 QuickFIX/J 中的消息

How does the acceptor handle messages in QuickFIX/J

我正在尝试构建一个由 Broker(客户端)-Router(接受器)-Market(客户端)组成的交易模拟器。 QuickFIX/J 上的文档非常稀疏。我想详细了解一下:

通常如何处理消息以及接受者是否有任何开箱即用的路由器table?

实际上,我想通过接受器(路由器)在经纪人和市场之间进行通信。我知道没有现成的基于标签的通信解决方案,所以我必须为此实现一些协议,但我首先需要对消息服务有广泛的了解。我已经阅读并查看了文档,但对我来说似乎有点抽象。我想清楚地知道,客户端如何使用上述方法处理进出接受器的消息,反之亦然。

此外,如果有任何 classes/Objects/methods 是消息处理及其实现的关键。

quickFiX 也使用阻塞、非阻塞或异步套接字吗?

*ps 我已经创建了 2 个客户端和 1 个接受器,并且运行良好

**我不懂语言,所以 quickFix 库的其他端口中的任何解释都会有所帮助

这里是各种回调的解释:https://github.com/quickfix-j/quickfixj#creating-a-quickfixj-application

基本上你需要在你的应用程序中实现这些方法,并且可以根据你想要的标签做任何你想做的事情。 向特定会话发送消息就像调用

一样简单
Session.sendToTarget

https://github.com/quickfix-j/quickfixj#sending-messages

如果您觉得文档中缺少某些内容,请打开拉取请求(首选)或问题。

QFJ 使用 MINA 库进行通信,其底层使用 Java NIO(非阻塞 IO)。但是,您可以通过同步写入选项使用某种阻塞。请参阅 SocketSynchronousWrites 配置选项。