当前位置：首页 > news >正文

QuickFIX扩展开发实战：自定义消息类型与协议扩展完整教程

news 2026/5/16 9:02:58

QuickFIX扩展开发实战：自定义消息类型与协议扩展完整教程

【免费下载链接】quickfixQuickFIX C++ Fix Engine Library项目地址: https://gitcode.com/gh_mirrors/qu/quickfix

QuickFIX是一款功能强大的C++ FIX引擎库，为金融交易系统提供可靠的协议支持。本教程将带您深入了解如何扩展QuickFIX，创建自定义消息类型和协议扩展，让您的交易系统更具灵活性和适应性。无论您是金融科技开发者还是对FIX协议感兴趣的技术人员，这篇完整指南都能帮助您快速掌握扩展开发的核心技巧。

了解QuickFIX的消息处理机制

在开始扩展开发之前，我们需要先了解QuickFIX的消息处理机制。QuickFIX使用MessageCracker类来解析和分发不同类型的FIX消息。这个类在多个头文件中定义，涵盖了不同版本的FIX协议：

src/C++/fix40/MessageCracker.h
src/C++/fix41/MessageCracker.h
src/C++/fix42/MessageCracker.h
src/C++/fix43/MessageCracker.h
src/C++/fix44/MessageCracker.h
src/C++/fix50/MessageCracker.h
src/C++/fix50sp1/MessageCracker.h
src/C++/fix50sp2/MessageCracker.h
src/C++/fixt11/MessageCracker.h

这些类共同构成了QuickFIX的消息处理系统，允许开发者根据不同的FIX版本处理特定的消息类型。

数据字典：QuickFIX的核心配置

数据字典（DataDictionary）是QuickFIX的核心组件，它定义了FIX协议的结构和规则。通过数据字典，QuickFIX能够验证消息的格式和内容，确保交易消息的正确性。

数据字典的基本结构

数据字典通常以XML格式存储，包含以下主要部分：

字段定义（Fields）：定义所有可能的消息字段
消息定义（Messages）：定义各种消息类型及其包含的字段
组件定义（Components）：可重用的字段组合
组定义（Groups）：可重复的字段序列

在代码中使用数据字典

在QuickFIX中，DataDictionary类负责加载和解析这些XML配置文件。您可以在src/C++/DataDictionary.h中找到该类的定义。以下是使用数据字典的基本步骤：

创建DataDictionary对象并加载XML文件
使用数据字典验证消息格式
在消息处理过程中引用数据字典信息

自定义消息类型开发步骤

1. 扩展数据字典

首先，您需要创建一个自定义的XML数据字典文件，定义新的消息类型和字段。可以参考现有的字典文件，如：

spec/FIX44.xml
spec/FIX50.xml

在新的XML文件中，添加您的自定义消息类型定义。例如：

<message name="CustomOrder" msgtype="D" msgcat="app"> <field name="ClOrdID" required="Y"/> <field name="Symbol" required="Y"/> <field name="Side" required="Y"/> <field name="OrderQty" required="Y"/> <field name="Price" required="N"/> <field name="CustomField" required="N" number="10000"/> </message>

2. 生成代码

QuickFIX提供了代码生成工具，可以根据数据字典自动生成C++类。虽然我们没有找到generate.sh脚本，但可以通过查看项目结构了解代码生成过程。通常，代码生成步骤如下：

准备自定义的XML数据字典
使用QuickFIX的代码生成工具处理XML文件
生成消息类和字段定义

生成的代码将包含新消息类型的类定义，您可以在项目中使用这些类来创建和解析自定义消息。

3. 实现消息处理逻辑

创建自定义消息处理类，继承自MessageCracker，并实现新消息类型的处理方法：

#include "quickfix/MessageCracker.h" class MyMessageCracker : public FIX::MessageCracker { public: void onMessage(const CustomOrder& message, const FIX::SessionID& sessionID) { // 处理自定义消息的逻辑 FIX::ClOrdID clOrdID; message.get(clOrdID); FIX::Symbol symbol; message.get(symbol); // 处理其他字段... } };

4. 集成到应用程序

将自定义消息处理类集成到您的QuickFIX应用程序中：

#include "Application.h" #include "MyMessageCracker.h" class MyApplication : public FIX::Application, public MyMessageCracker { // 实现应用程序逻辑... void fromApp(const FIX::Message& message, const FIX::SessionID& sessionID) throw(FIX::FieldNotFound, FIX::IncorrectDataFormat, FIX::IncorrectTagValue, FIX::UnsupportedMessageType) { crack(message, sessionID); } };

协议扩展的高级技巧

使用数据字典提供者

QuickFIX提供了DataDictionaryProvider类，允许您为不同的FIX版本和应用程序版本管理多个数据字典。您可以在src/C++/DataDictionaryProvider.h中找到该类的定义。

FIX::DataDictionaryProvider provider; provider.addTransportDataDictionary(FIX::BeginString_FIX44, "path/to/FIX44.xml"); provider.addApplicationDataDictionary(FIX::ApplVerID_FIX50SP2, "path/to/custom_dict.xml");

会话设置配置

在会话配置文件中，您可以指定使用的数据字典：

[SESSION] BeginString=FIX.4.4 SenderCompID=YOUR_COMP_ID TargetCompID=COUNTERPARTY_COMP_ID UseDataDictionary=Y DataDictionary=path/to/custom_dict.xml

这些设置在src/C++/SessionSettings.h中有定义。

处理重复组

对于包含重复组的复杂消息，QuickFIX提供了Group类来简化处理。您可以在src/C++/Group.h中找到相关定义。

// 假设CustomOrder消息包含一个OrderQtyGroup组 FIX::Group group(1000, 1001); // 组标签和字段标签 message.getGroup(1, group); // 获取第一个组实例 FIX::OrderQty qty; group.get(qty);

实战示例：扩展FIX协议支持自定义订单类型

让我们通过一个实际示例来巩固所学知识。我们将创建一个支持算法交易的自定义订单消息。

1. 定义自定义消息

在自定义数据字典中添加：

<message name="AlgorithmicOrder" msgtype="A" msgcat="app"> <field name="ClOrdID" required="Y"/> <field name="Symbol" required="Y"/> <field name="Side" required="Y"/> <field name="OrderQty" required="Y"/> <field name="AlgorithmType" required="Y" number="10001"/> <field name="AlgorithmParameters" required="N" number="10002"/> </message>

2. 创建消息处理类

#include "quickfix/MessageCracker.h" #include "AlgorithmicOrder.h" // 生成的消息类 class AlgoOrderHandler : public FIX::MessageCracker { public: void onMessage(const AlgorithmicOrder& message, const FIX::SessionID& sessionID) { FIX::ClOrdID clOrdID; message.get(clOrdID); FIX::AlgorithmType algoType; message.get(algoType); // 根据算法类型执行相应的订单处理逻辑 if (algoType == "TWAP") { processTWAPOrder(message); } else if (algoType == "VWAP") { processVWAPOrder(message); } } private: void processTWAPOrder(const AlgorithmicOrder& message) { // TWAP算法订单处理逻辑 } void processVWAPOrder(const AlgorithmicOrder& message) { // VWAP算法订单处理逻辑 } };

3. 配置和使用自定义消息

在应用程序中配置并使用新的消息类型：

#include "MyApplication.h" #include "AlgoOrderHandler.h" int main(int argc, char** argv) { try { FIX::SessionSettings settings(argv[1]); MyApplication application; FIX::FileStoreFactory storeFactory(settings); FIX::FileLogFactory logFactory(settings); FIX::SocketAcceptor acceptor(application, storeFactory, settings, logFactory); acceptor.start(); std::cout << "Acceptor started" << std::endl; // 等待用户输入退出 std::cin.get(); acceptor.stop(); return 0; } catch (std::exception& e) { std::cout << "Exception: " << e.what() << std::endl; return 1; } }