我正在尝试构建一个由经纪人(客户端)-路由器(接受者)-市场(客户端)组成的交易模拟器。 QuickFIX / J上的文档非常稀疏。我想详细了解:
一般如何处理消息,以及接收者是否有现成的路由器表?
有效地,我想通过接受者(路由器)在经纪人和市场之间进行沟通。我知道没有基于标签的通信的现成解决方案,因此我必须为此实现一些协议,但是我首先需要对消息传递服务有广泛的了解。我已经阅读并查看了文档,但对我来说似乎有点抽象。我想简单地知道,客户端如何使用上述方法处理往返于接收者的消息,反之亦然。
此外,如果有任何类/对象/方法在消息处理及其以简单术语的实现中很关键。
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
配置选项。