CN117788152A - 金融行情数据处理方法、装置、设备及存储介质 - Google Patents
金融行情数据处理方法、装置、设备及存储介质 Download PDFInfo
- Publication number
- CN117788152A CN117788152A CN202311575583.6A CN202311575583A CN117788152A CN 117788152 A CN117788152 A CN 117788152A CN 202311575583 A CN202311575583 A CN 202311575583A CN 117788152 A CN117788152 A CN 117788152A
- Authority
- CN
- China
- Prior art keywords
- target
- decision message
- data
- financial
- transaction decision
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Landscapes
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
本公开涉及一种金融行情数据处理方法、装置、设备及存储介质。本公开通过接收金融行情数据包;对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;获取目标数据处理器中的第二交易决策报文;基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。通过FPGA数据处理器和中央处理器协同对金融行情数据进行解析得到交易决策报文,可以提高对金融行情数据的分析处理速度和处理效率。
Description
技术领域
本公开涉及数据处理技术领域,尤其涉及一种金融行情数据处理方法、装置、设备及存储介质。
背景技术
金融交易领域的高频交易(High-Frequency Trading)是超低时延的一个重要应用领域,也是对性能追求最为极致的领域。金融机构和交易所需要在微秒甚至纳秒级别进行交易,以获取市场优势。因此,对于交易平台和网络基础设施来说,金融行情数据的处理速度至关重要。
目前,相关技术通常通过中央处理器(Central Processing Unit,CPU)对金融行情数据进行分析处理,将分析处理后的数据发送至网卡,再由网卡将分析处理后的数据发送给金融交易平台,对金融行情数据分析处理的耗时较长,处理速度慢,效率较低,因此,亟需一种高速的金融行情数据处理方法来满足当前需求。
发明内容
为了解决上述技术问题,本公开提供了一种金融行情数据处理方法,应用于现场可编程逻辑门阵列FPGA数据处理器,方法包括:
接收金融行情数据包;
对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;
将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;
获取目标数据处理器中的第二交易决策报文;
基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;
将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。
本公开的第一方面提供了一种金融行情数据处理装置,应用于现场可编程逻辑门阵列FPGA数据处理器,装置包括:
接收模块,用于接收金融行情数据包;
解析模块,用于对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;
第一发送模块,用于将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;
获取模块,用于获取目标数据处理器中的第二交易决策报文;
生成模块,用于基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;
第二发送模块,用于将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。
本公开的第二方面提供了一种计算机设备,包括:
FPGA数据处理器和存储器,其中,存储器中存储有计算机程序,当计算机程序被处理器执行时,可以实现上述第一方面的金融行情数据处理方法。
本公开的第四方面提供了一种计算机可读存储介质,存储介质中存储有计算机程序,当计算机程序被处理器执行时,可以实现上述第一方面的金融行情数据处理方法。
本公开提供的技术方案与现有技术相比具有如下优点:
本公开通过接收金融行情数据包;对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;获取目标数据处理器中的第二交易决策报文;基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。通过FPGA数据处理器和中央处理器协同对金融行情数据进行解析得到交易决策报文,合理利用FPGA数据处理器和中央处理器的计算资源,可以缩短金融行情数据的分析处理时长,提高对金融行情数据的分析处理速度和处理效率。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本公开的实施例,并与说明书一起用于解释本公开的原理。
为了更清楚地说明本公开实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,对于本领域普通技术人员而言,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。
图1是本公开实施例提供的一种金融行情数据处理方法的流程图;
图2是本公开实施例提供的另一种金融行情数据处理方法的流程图;
图3是本公开实施例提供的一种FPGA数据处理器数据传输的结构示意图;
图4是本公开实施例提供的一种金融行情数据处理装置的结构示意图;
图5是本公开实施例提供的一种计算机设备的结构示意图。
具体实施方式
为了能够更清楚地理解本公开的上述目的、特征和优点,下面将对本公开的方案进行进一步描述。需要说明的是,在不冲突的情况下,本公开的实施例及实施例中的特征可以相互组合。
在下面的描述中阐述了很多具体细节以便于充分理解本公开,但本公开还可以采用其他不同于在此描述的方式来实施;显然,说明书中的实施例只是本公开的一部分实施例,而不是全部的实施例。
应当理解,本公开的方法实施方式中记载的各个步骤可以按照不同的顺序执行,和/或并行执行。此外,方法实施方式可以包括附加的步骤和/或省略执行示出的步骤。本公开的范围在此方面不受限制。
需要说明的是,在本文中,诸如“第一”和“第二”等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
需要注意,本公开中提及的“一个”、“多个”的修饰是示意性而非限制性的,本领域技术人员应当理解,除非在上下文另有明确指出,否则应该理解为“一个或多个”。
本公开实施例提供的金融行情数据处理方法,可以由一种计算机设备中的FPGA(Field Programmable Gate Array,现场可编程逻辑门阵列)数据处理器来执行,FPGA数据处理器可以在中央处理器之外单独设置,也可以集成在网卡中。FPGA是作为专用集成电路(ASIC)领域中的一种半定制电路而出现的,既解决了定制电路的不足,又克服了原有可编程器件门电路数有限的缺点。
计算机设备可以被理解为任意一种具有处理能力和计算能力的设备,该设备可以包括但不限于诸如智能手机、笔记本电脑、平板电脑(PAD)等的移动终端,以及诸如数字TV、台式计算机、智能家居设备等的固定电子设备。
为了更好的理解本公开实施例的发明构思,下面结合示例性的实施例对本公开实施例的技术方案进行说明。
图1是本公开实施例提供的一种金融行情数据处理方法的流程图,如图1所示,本实施例提供的金融行情数据处理方法包括如下步骤:
步骤110、接收金融行情数据包。
本公开实施例中,计算机设备中设有FPGA数据处理器,FPGA数据处理器可以接收金融行情服务器发送的金融行情数据包。
金融行情数据包可以理解为包括金融行情数据的数据报文,金融行情数据可以理解为金融领域的历史交易数据,例如某年某月某日某时,合约a以200元的价格卖出了100手。
步骤120、对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文。
本公开实施例中,在接收到金融行情数据包之后,FPGA数据处理器可以对金融行情数据包进行分解,提取金融行情数据包中的金融行情数据,然后对金融行情数据进行解析,生成第一交易决策报文。
交易决策报文可以理解为指导金融交易系统进行金融操作的数据,例如可以包括合约标识、交易时间、买入价、买入量、卖出价、卖出量等数据,金融交易系统可以包括交易所等平台。
在一些实施例中,对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文,可以包括步骤1201-1203:
步骤1201、确定FPGA数据处理器的第一预设解析策略所需的行情数据的第一目标数据类型。
本公开实施例中,FPGA数据处理器可以根据FPGA数据处理器的第一预设解析策略,确定第一预设解析策略所需的行情数据的第一目标数据类型。
第一预设解析策略可以理解为FPGA数据处理器预先设置的行情数据的解析方法。
数据类型可以包括不同的数据格式、订阅、非订阅、不同的行业、不同的金融市场等数据类型,不同的行业可以包括金融业、制造业等,不同的金融市场可以包括股票、国债、期货等。
第一预设解析策略以及第一预设解析策略所需的行情数据所属的第一目标数据类型可以根据需要进行设置,这里不作限定。
步骤1202、从金融行情数据中提取第一目标数据类型对应的第一解析行情数据。
本公开实施例中,FPGA数据处理器可以从金融行情数据中提取第一目标数据类型对应的第一解析行情数据,即对金融行情数据进行解析、解码,将第一预设解析策略不关心的数据进行过滤,保留下第一预设解析策略所需的第一目标数据类型对应的数据。例如,当第一目标数据类型为数据格式A的数据时,可以从金融行情数据中提取数据格式A对应的第一解析行情数据。
步骤1203、基于第一解析行情数据进行交易策略计算,生成第一交易决策报文。
本公开实施例中,FPGA数据处理器可以基于第一解析行情数据进行交易策略计算,生成第一交易决策报文。
步骤130、将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文。
本公开实施例中,在接收到金融行情数据包之后,FPGA数据处理器可以将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文。
其中,目标数据处理器可以包括计算机设备中的中央处理器(CentralProcessing Unit,CPU)。
在一些实施例中,FPGA数据处理器可以基于直接内存访问(Direct MemoryAccess,DMA)方式,将金融行情数据包中的金融行情数据写入目标数据处理器中的目标内存空间中,以使目标数据处理器对目标内存空间中的金融行情数据进行解析生成第二交易决策报文。
直接内存访问可以理解为一种可以直接访问设备内存中的数据的数据访问方式。
在一些实施例中,将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,可以包括步骤1301-1303:
步骤1301、确定目标数据处理器的第二预设解析策略所需的行情数据所属的第二目标数据类型。
本公开实施例中,FPGA数据处理器可以根据目标数据处理器的第二预设解析策略,确定第二预设解析策略所需的行情数据所属的第二目标数据类型。
第二预设解析策略可以理解为目标数据处理器预先设置的行情数据的解析方法。
第二预设解析策略以及第二预设解析策略所需的行情数据所属的第二目标数据类型可以根据需要进行设置,这里不作限定。
步骤1302、从金融行情数据中提取到第二目标数据类型对应的第二解析行情数据。
本公开实施例中,FPGA数据处理器可以基于第二目标数据类型,从金融行情数据中提取到第二目标数据类型对应的第二解析行情数据,即对金融行情数据进行解析、解码,将第二预设解析策略不关心的数据进行过滤,保留下第二预设解析策略所需的第二目标数据类型对应的数据。例如,当第二目标数据类型为数据格式B的数据时,可以对金融行情数据进行解析,得到数据格式B对应的第二解析行情数据。
步骤1303、将第二解析行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器基于第二解析行情数据进行交易策略计算,生成第二交易决策报文。
本公开实施例中,FPGA数据处理器可以将第二解析行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器基于第二解析行情数据进行交易策略计算,生成第二交易决策报文。
步骤140、获取目标数据处理器中的第二交易决策报文。
本公开实施例中,FPGA数据处理器可以获取目标数据处理器中的第二交易决策报文。
在一些实施例中,响应于目标数据处理器生成第二交易决策报文,FPGA数据处理器可以基于直接内存访问方式,从目标数据处理器中的目标内存空间中读取第二交易决策报文。
步骤150、基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文。
本公开实施例中,在获得第一交易决策报文和第二交易决策报文之后,FPGA数据处理器中的第一策略模块可以基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文。
在一些实施例中,FPGA数据处理器中的第一策略模块可以计算第一交易决策报文产生的第一收益和第二交易决策报文产生的第二收益;
在第一收益大于第二收益时,可以将第一交易决策报文确定为目标交易决策报文;
在第二收益大于第一收益时,可以将第二交易决策报文确定为目标交易决策报文;
在第一收益等于第二收益时,可以将第一交易决策报文和/或第二交易决策报文确定为目标交易决策报文。
步骤160、将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。
本公开实施例中,在生成目标交易决策报文之后,FPGA数据处理器可以将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。
金融操作可以包括交易时间、买入、卖出等操作。例如,当交易决策报文包括10点1分时刻以201元的价格买入200手合约a,则金融交易系统可以在10点1分时刻以201元的价格买入200手合约a。
在一些实施例中,将目标交易决策报文发送至金融交易系统,可以包括步骤1601-1603:
步骤1601、获取金融交易系统的目标通信地址。
本公开实施例中,FPGA数据处理器可以获取金融交易系统的目标通信地址。例如,可以从FPGA数据处理器的存储空间中获取金融交易系统的目标通信地址。目标通信地址可以包括金融交易系统的IP地址、MAC地址、端口号等。
步骤1602、将目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,得到交易决策报文包。
本公开实施例中,FPGA数据处理器的源通信地址可以包括FPGA数据处理器的IP地址、MAC地址、端口号等。
FPGA数据处理器可以将目标交易决策报文、金融交易系统的目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包,然后将交易决策报文包发送至数据收发模块。
步骤1603、将交易决策报文包发送至目标通信地址,以使金融交易系统基于交易决策报文包中的目标交易决策报文进行金融操作。
本公开实施例中,FPGA数据处理器可以将交易决策报文包发送至目标通信地址,以使金融交易系统基于交易决策报文包中的目标交易决策报文进行金融操作。
本公开实施例,通过接收金融行情数据包;对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;获取目标数据处理器中的第二交易决策报文;基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。通过FPGA数据处理器和中央处理器协同对金融行情数据进行解析得到交易决策报文,合理利用FPGA数据处理器和中央处理器的计算资源,可以缩短金融行情数据的分析处理时长,提高对金融行情数据的分析处理速度和处理效率。
图2是本公开实施例提供的一种金融行情数据处理方法的流程图,如图2所示,本实施例提供的金融行情数据处理方法包括如下步骤:
步骤210、接收金融行情数据包。
步骤220、基于预设的过滤规则,将金融行情数据包中与金融行情无关的数据进行过滤,得到金融行情数据。
本公开实施例中,在接收到金融行情数据包之后,FPGA数据处理器中的解包模块可以基于预设的过滤规则,将金融行情数据包中与金融行情无关的数据进行过滤,得到金融行情数据。
由此,可以进一步提高对金融行情数据的处理速度。
其中,与金融行情无关的数据可以包括数据包属性数据和地址数据中的至少一种,数据包属性数据可以包括数据包长度等属性数据,地址数据可以包括源IP地址、源端口号、源MAC地址、目标IP地址、目标端口号、目标MAC地址等地址数据。
步骤230、对金融行情数据进行解析,生成第一交易决策报文。
步骤240、将金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文。
步骤250、获取目标数据处理器中的第二交易决策报文。
步骤260、基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文。
步骤270、获取金融交易系统的目标通信地址。
本公开实施例中,FPGA数据处理器可以获取金融交易系统的目标通信地址。例如,可以从FPGA数据处理器的存储空间中获取金融交易系统的目标通信地址。目标通信地址可以包括金融交易系统的IP地址、MAC地址、端口号等。
步骤280、将目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,得到交易决策报文包。
本公开实施例中,FPGA数据处理器的源通信地址可以包括FPGA数据处理器的IP地址、MAC地址、端口号等。
FPGA数据处理器可以将目标交易决策报文、金融交易系统的目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包,然后将交易决策报文包发送至数据收发模块。
在一些实施例中,将目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包,可以包括步骤2801-2803:
步骤2801、获取金融交易系统的数据属性要求。
本公开实施例中,金融交易系统的数据属性要求可以包括数据格式要求、数据长度要求等。
FPGA数据处理器可以获取金融交易系统的数据属性要求。例如,可以从FPGA数据处理器的存储空间中获取金融交易系统的数据属性要求。
步骤2802、基于数据属性要求,对目标交易决策报文进行转换,得到满足数据属性要求的目标交易决策报文。
本公开实施例中,FPGA数据处理器可以基于金融交易系统的数据属性要求,对目标交易决策报文进行转换,得到满足数据属性要求的目标交易决策报文。
步骤2803、将满足数据属性要求的目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包。
本公开实施例中,FPGA数据处理器可以将满足金融交易系统的数据属性要求的目标交易决策报文、金融交易系统的目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包。
步骤290、将交易决策报文包发送至目标通信地址,以使金融交易系统基于交易决策报文包中的目标交易决策报文进行金融操作。
本公开实施例中,FPGA数据处理器可以将交易决策报文包发送至目标通信地址,以使金融交易系统基于交易决策报文包中的目标交易决策报文交易决策报文进行金融操作。
由此,可以通过FPGA数据处理器和中央处理器协同对金融行情数据进行解析得到交易决策报文,合理利用FPGA数据处理器和中央处理器的计算资源,可以缩短金融行情数据的分析处理时长,提高对金融行情数据的分析处理速度和处理效率。
在本公开的一些实施例中,FPGA数据处理器可以基于各个数据处理动作的镜像数据,生成FPGA数据处理器的各个数据处理动作对应的日志数据,并对日志数据进行存储,以便对FPGA数据处理器中的各个数据处理过程进行记录。
图3是本公开实施例提供的一种数据传输的结构示意图。如图3所示,包括金融行情服务器310、FPGA数据处理器320、目标数据处理器330、金融交易系统340,该FPGA数据处理器320可以被理解为上述计算机设备中的部分功能模块,FPGA数据处理器320内部可以包括第一数据收发模块321、解包模块322、行情解析模块323、第二数据收发模块324、第一策略模块325、报单模块326、组包模块327、,目标数据处理器330可以被理解为上述计算机设备中的部分功能模块,例如目标数据处理器可以为中央处理器CPU,目标数据处理器330内部可以包括第二策略模块331。
第一数据收发模块可以收发数据,与网卡相似,也可以称作媒体存取控制位址MAC(Media Access Control Address)模块,数据收发模块可以接收金融行情服务器发送的金融行情数据包,然后将金融行情数据包发送给解包模块,解包模块可以基于预设的过滤规则,将金融行情数据包中与金融行情无关的数据进行过滤,得到金融行情数据,然后将金融行情数据发送给行情解析模块,行情解析模块可以确定FPGA数据处理器的第一预设解析策略所需的行情数据的第一目标数据类型,从金融行情数据中提取第一目标数据类型对应的第一解析行情数据,然后将第一解析行情数据发送给第一策略模块,第一策略模块可以基于第一解析行情数据进行交易策略计算,生成第一交易决策报文,行情解析模块可以确定目标数据处理器的第二预设解析策略所需的行情数据所属的第二目标数据类型,从金融行情数据中提取到第二目标数据类型对应的第二解析行情数据,将第二解析行情数据发送至第二数据收发模块,第二数据收发模块可以基于直接内存访问DMA方式,将第二解析行情数据发送至目标数据处理器中的第二策略模块,第二策略模块可以基于第二解析行情数据进行交易策略计算,生成第二交易决策报文并将第二交易决策报文存储至目标内存空间中,第一策略模块可以响应于目标数据处理器生成第二交易决策报文,基于直接内存访问方式,从第二策略模块中的目标内存空间中读取第二交易决策报文,第一策略模块在得到第一交易决策报文和第二交易决策报文之后,可以基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文,并将目标交易决策报文发送至报单模块,报单模块可以基于金融交易系统的数据属性要求,对目标交易决策报文进行转换,得到满足数据属性要求的目标交易决策报文,然后将满足数据属性要求的目标交易决策报文发送给组包模块,组包模块可以将满足金融交易系统的数据属性要求的目标交易决策报文、金融交易系统的目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包,然后将交易决策报文包发送给第一数据收发模块,第一数据收发模块接收到交易决策报文包后,可以将交易决策报文包发送至金融交易系统,金融交易系统可以基于交易决策报文包中的目标交易决策报文进行金融操作。
由此,可以通过FPGA数据处理器和中央处理器协同对金融行情数据进行解析得到交易决策报文,合理利用FPGA数据处理器和中央处理器的计算资源,可以缩短金融行情数据的分析处理时长,提高对金融行情数据的分析处理速度和处理效率。
在一些实施例中,上述FPGA数据处理器320还可以包括日志模块,日志模块可以基于目标接口(例如AXI-stream接口)接入FPGA数据处理器中的其他各数据处理模块,可以基于各个数据处理模块的数据处理动作的镜像数据,生成FPGA数据处理器的各个数据处理模块的数据处理动作对应的日志数据,并对日志数据进行存储,以便对FPGA数据处理器中的各个数据处理模块的数据处理过程进行记录。
在本公开的一些实施例中,上述FPGA数据处理器中的各个模块之间可以AXI-stream格式的数据进行数据传输。AXI-stream格式为一种高速传输的数据格式,可以提高数据的传输速度。
图4是本公开实施例提供的一种金融行情数据处理装置的结构示意图,该装置可以被理解为上述计算机设备中的部分功能模块。如图所示,该金融行情数据处理装置400包括:
接收模块,用于接收金融行情数据包;
解析模块,用于对金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;
第一发送模块,用于将金融行情数据包中的金融行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器对金融行情数据进行解析生成第二交易决策报文;
获取模块,用于获取目标数据处理器中的第二交易决策报文;
生成模块,用于基于第一交易决策报文和第二交易决策报文,生成目标交易决策报文;
第二发送模块,用于将目标交易决策报文发送至金融交易系统,以使金融交易系统基于目标交易决策报文进行金融操作。
可选的,上述金融行情数据处理装置包括:
过滤模块,用于基于预设的过滤规则,将金融行情数据包中与金融行情无关的数据进行过滤,得到金融行情数据。
可选的,上述解析模块包括:
第一确定子模块,用于确定FPGA数据处理器的第一预设解析策略所需的行情数据的第一目标数据类型;
第一解析子模块,用于从金融行情数据中提取第一目标数据类型对应的第一解析行情数据;
第二解析子模块,用于基于第一解析行情数据进行交易策略计算,生成第一交易决策报文。
可选的,上述第二发送模块包括:
第二确定子模块,用于确定目标数据处理器的第二预设解析策略所需的行情数据所属的第二目标数据类型;
第三解析子模块,用于从金融行情数据中提取第二目标数据类型对应的第二解析行情数据;
第一发送子模块,用于将第二解析行情数据发送至FPGA数据处理器之外的目标数据处理器,以使目标数据处理器基于第二解析行情数据进行交易策略计算,生成第二交易决策报文。
可选的,上述生成模块包括:
计算子模块,用于计算第一交易决策报文产生的第一收益和第二交易决策报文产生的第二收益;
第三确定子模块,用于在第一收益大于第二收益时,将第一交易决策报文确定为目标交易决策报文;
第四确定子模块,用于在第二收益大于第一收益时,将第二交易决策报文确定为目标交易决策报文;
第五确定子模块,用于在第一收益等于第二收益时,将第一交易决策报文和/或第二交易决策报文确定为目标交易决策报文。
可选的,上述第二发送模块包括:
获取子模块,用于获取金融交易系统的目标通信地址;
打包子模块,用于将目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,得到交易决策报文包;
第二发送子模块,用于将交易决策报文包发送至目标通信地址,以使金融交易系统基于交易决策报文包中的目标交易决策报文进行金融操作。
可选的,上述打包子模块包括:
获取单元,用于获取金融交易系统的数据属性要求;
转换单元,用于基于数据属性要求,对交易决策报文进行转换,得到满足数据属性要求的目标交易决策报文;
打包单元,用于将满足数据属性要求的目标交易决策报文、目标通信地址和FPGA数据处理器的源通信地址进行打包,生成交易决策报文包。
可选的,上述第一发送模块包括:
写入子模块,用于基于直接内存访问方式,将金融行情数据包中的金融行情数据写入目标数据处理器中的目标内存空间中,以使目标数据处理器对内存空间中的金融行情数据进行解析生成第二交易决策报文;
可选的,上述获取模块包括:
读取子模块,用于响应于目标数据处理器生成第二交易决策报文,基于直接内存访问方式,从目标数据处理器中的目标内存空间中读取第二交易决策报文。
本公开实施例提供的金融行情数据处理装置可以实现上述任一实施例的方法,其执行方式和有益效果类似,在这里不再赘述。
本公开实施例还提供一种计算机设备,该计算机设备包括FPGA数据处理器和存储器,其中,存储器中存储有计算机程序,当该计算机程序被该FPGA数据处理器执行时可以实现上述任一实施例的方法,其执行方式和有益效果类似,在这里不再赘述。
图5是本公开实施例提供的一种计算机设备的结构示意图,如图5所示,计算机设备500可以包括FPGA数据处理器510和存储器520,其中,存储器520中存储有计算机程序521,当该计算机程序521被该FPGA数据处理器510执行时可以实现上述任一实施例提供的方法,其执行方式和有益效果类似,在这里不再赘述。
当然,为了简化,图5中仅示出了该计算机设备500中与本发明有关的组件中的一些,省略了诸如总线、输入/输出接口、输入装置和输出装置等的组件。除此之外,根据具体应用情况,计算机设备500还可以包括任何其他适当的组件。
本公开实施例提供了一种计算机可读存储介质,该存储介质中存储有计算机程序,当该计算机程序被处理器执行时,可以实现上述任一实施例的方法,其执行方式和有益效果类似,在这里不再赘述。
上述计算机可读存储介质可以采用一个或多个可读介质的任意组合。可读介质可以是可读信号介质或者可读存储介质。可读存储介质例如可以包括但不限于电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。
上述计算机程序可以以一种或多种程序设计语言的任意组合来编写用于执行本公开实施例操作的程序代码,所述程序设计语言包括面向对象的程序设计语言,诸如Java、C++等,还包括常规的过程式程序设计语言,诸如“C”语言或类似的程序设计语言。程序代码可以完全地在用户计算机设备上执行、部分地在用户设备上执行、作为一个独立的软件包执行、部分在用户计算机设备上部分在远程计算机设备上执行、或者完全在远程计算机设备或服务器上执行。
以上描述仅为本公开的较佳实施例以及对所运用技术原理的说明。本领域技术人员应当理解,本公开中所涉及的公开范围,并不限于上述技术特征的特定组合而成的技术方案,同时也应涵盖在不脱离上述公开构思的情况下,由上述技术特征或其等同特征进行任意组合而形成的其它技术方案。例如上述特征与本公开中公开的(但不限于)具有类似功能的技术特征进行互相替换而形成的技术方案。
此外,虽然采用特定次序描绘了各操作,但是这不应当理解为要求这些操作以所示出的特定次序或以顺序次序执行来执行。在一定环境下,多任务和并行处理可能是有利的。同样地,虽然在上面论述中包含了若干具体实现细节,但是这些不应当被解释为对本公开的范围的限制。在单独的实施例的上下文中描述的某些特征还可以组合地实现在单个实施例中。相反地,在单个实施例的上下文中描述的各种特征也可以单独地或以任何合适的子组合的方式实现在多个实施例中。
以上所述仅是本公开的具体实施方式,使本领域技术人员能够理解或实现本公开。对这些实施例的多种修改对本领域的技术人员来说将是显而易见的,本文中所定义的一般原理可以在不脱离本公开的精神或范围的情况下,在其它实施例中实现。因此,本公开将不会被限制于本文所述的这些实施例,而是要符合与本文所公开的原理和新颖特点相一致的最宽的范围。
Claims (11)
1.一种金融行情数据处理方法,其特征在于,应用于现场可编程逻辑门阵列FPGA数据处理器,所述方法包括:
接收金融行情数据包;
对所述金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;
将所述金融行情数据包中的金融行情数据发送至所述FPGA数据处理器之外的目标数据处理器,以使所述目标数据处理器对所述金融行情数据进行解析生成第二交易决策报文;
获取所述目标数据处理器中的第二交易决策报文;
基于所述第一交易决策报文和所述第二交易决策报文,生成目标交易决策报文;
将所述目标交易决策报文发送至金融交易系统,以使所述金融交易系统基于所述目标交易决策报文进行金融操作。
2.根据权利要求1所述的方法,其特征在于,所述接收金融行情数据包之后,所述方法还包括:
基于预设的过滤规则,将所述金融行情数据包中与金融行情无关的数据进行过滤,得到金融行情数据。
3.根据权利要求1所述的方法,其特征在于,所述对所述金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文,包括:
确定所述FPGA数据处理器的第一预设解析策略所需的行情数据的第一目标数据类型;
从所述金融行情数据中提取所述第一目标数据类型对应的第一解析行情数据;
基于所述第一解析行情数据进行交易策略计算,生成第一交易决策报文。
4.根据权利要求1所述的方法,其特征在于,所述将所述金融行情数据包中的金融行情数据发送至所述FPGA数据处理器之外的目标数据处理器,包括:
确定所述目标数据处理器的第二预设解析策略所需的行情数据所属的第二目标数据类型;
从所述金融行情数据中提取所述第二目标数据类型对应的第二解析行情数据;
将所述第二解析行情数据发送至所述FPGA数据处理器之外的目标数据处理器,以使所述目标数据处理器基于所述第二解析行情数据进行交易策略计算,生成第二交易决策报文。
5.根据权利要求1所述的方法,其特征在于,所述基于所述第一交易决策报文和所述第二交易决策报文,生成目标交易决策报文,包括:
计算所述第一交易决策报文产生的第一收益和所述第二交易决策报文产生的第二收益;
在所述第一收益大于所述第二收益时,将所述第一交易决策报文确定为目标交易决策报文;
在所述第二收益大于所述第一收益时,将所述第二交易决策报文确定为目标交易决策报文;
在所述第一收益等于所述第二收益时,将所述第一交易决策报文和/或所述第二交易决策报文确定为目标交易决策报文。
6.根据权利要求1所述的方法,其特征在于,所述将所述目标交易决策报文发送至金融交易系统,包括:
获取所述金融交易系统的目标通信地址;
将所述目标交易决策报文、所述目标通信地址和所述FPGA数据处理器的源通信地址进行打包,得到交易决策报文包;
将所述交易决策报文包发送至所述目标通信地址,以使所述金融交易系统基于所述交易决策报文包中的目标交易决策报文进行金融操作。
7.根据权利要求6所述的方法,其特征在于,所述将所述目标交易决策报文、所述目标通信地址和所述FPGA数据处理器的源通信地址进行打包,得到交易决策报文包,包括:
获取所述金融交易系统的数据属性要求;
基于所述数据属性要求,对所述交易决策报文进行转换,得到满足所述数据属性要求的目标交易决策报文;
将满足所述数据属性要求的目标交易决策报文、所述目标通信地址和所述FPGA数据处理器的源通信地址进行打包,生成交易决策报文包。
8.根据权利要求1所述的方法,其特征在于,所述将所述金融行情数据包中的金融行情数据发送至所述FPGA数据处理器之外的目标数据处理器,包括:
基于直接内存访问方式,将所述金融行情数据包中的金融行情数据写入所述目标数据处理器中的目标内存空间中,以使所述目标数据处理器对所述内存空间中的金融行情数据进行解析生成第二交易决策报文;
所述获取所述目标数据处理器中的第二交易决策报文,包括:
响应于所述目标数据处理器生成第二交易决策报文,基于直接内存访问方式,从所述目标数据处理器中的目标内存空间中读取所述第二交易决策报文。
9.一种金融行情数据处理装置,其特征在于,应用于现场可编程逻辑门阵列FPGA数据处理器,所述装置包括:
接收模块,用于接收金融行情数据包;
解析模块,用于对所述金融行情数据包中的金融行情数据进行解析,生成第一交易决策报文;
第一发送模块,用于将所述金融行情数据包中的金融行情数据发送至所述FPGA数据处理器之外的目标数据处理器,以使所述目标数据处理器对所述金融行情数据进行解析生成第二交易决策报文;
获取模块,用于获取所述目标数据处理器中的第二交易决策报文;
生成模块,用于基于所述第一交易决策报文和所述第二交易决策报文,生成目标交易决策报文;
第二发送模块,用于将所述目标交易决策报文发送至金融交易系统,以使所述金融交易系统基于所述目标交易决策报文进行金融操作。
10.一种计算机设备,其特征在于,包括:
FPGA数据处理器和存储器,其中,所述存储器中存储有计算机程序,当所述计算机程序被所述FPGA数据处理器执行时,实现如权利要求1-8中任一项所述的金融行情数据处理方法。
11.一种计算机可读存储介质,其特征在于,所述存储介质中存储有计算机程序,当所述计算机程序被处理器执行时,实现如权利要求1-8中任一项所述的金融行情数据处理方法。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202311575583.6A CN117788152A (zh) | 2023-11-23 | 2023-11-23 | 金融行情数据处理方法、装置、设备及存储介质 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202311575583.6A CN117788152A (zh) | 2023-11-23 | 2023-11-23 | 金融行情数据处理方法、装置、设备及存储介质 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN117788152A true CN117788152A (zh) | 2024-03-29 |
Family
ID=90378803
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202311575583.6A Pending CN117788152A (zh) | 2023-11-23 | 2023-11-23 | 金融行情数据处理方法、装置、设备及存储介质 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN117788152A (zh) |
Citations (11)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20150127515A1 (en) * | 2013-11-07 | 2015-05-07 | Chicago Mercantile Exchange Inc. | Transactionally Deterministic High Speed Financial Exchange Having Improved, Efficiency, Communication, Customization, Performance, Access, Trading Opportunities, Credit Controls, and Fault Tolerance |
CN105989538A (zh) * | 2015-07-28 | 2016-10-05 | 盛立金融软件开发(杭州)有限公司 | 一种金融产品自动交易系统及自动交易方法 |
CN107451091A (zh) * | 2017-08-02 | 2017-12-08 | 上海金融期货信息技术有限公司 | 基于fpga‑cpu混合架构的高速信息交互系统 |
CN108230149A (zh) * | 2017-12-13 | 2018-06-29 | 武汉旷腾信息技术有限公司 | 基于soc fpga的加速金融交易系统及方法 |
CN109859052A (zh) * | 2019-01-16 | 2019-06-07 | 平安科技(深圳)有限公司 | 一种投资策略的智能推荐方法、装置、存储介质和服务器 |
CN110517136A (zh) * | 2019-07-30 | 2019-11-29 | 上海兮通信息科技有限公司 | 一种证券行情加速处理方法及系统 |
CN112487337A (zh) * | 2020-12-10 | 2021-03-12 | 盛立金融软件开发(杭州)有限公司 | 一种行情数据交互装置、方法及设备 |
CN112634041A (zh) * | 2020-12-28 | 2021-04-09 | 深圳华云信息系统有限公司 | 基于fpga的金融交易方法、装置及系统 |
CN115114222A (zh) * | 2022-08-30 | 2022-09-27 | 珠海星云智联科技有限公司 | 行情快照分发方法及相关装置 |
CN115168280A (zh) * | 2022-08-30 | 2022-10-11 | 珠海星云智联科技有限公司 | 行情快照的处理方法及相关装置 |
US20230153906A1 (en) * | 2021-11-16 | 2023-05-18 | Rebellions Inc. | Apparatus for high frequency trading and method of operating thereof |
-
2023
- 2023-11-23 CN CN202311575583.6A patent/CN117788152A/zh active Pending
Patent Citations (11)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20150127515A1 (en) * | 2013-11-07 | 2015-05-07 | Chicago Mercantile Exchange Inc. | Transactionally Deterministic High Speed Financial Exchange Having Improved, Efficiency, Communication, Customization, Performance, Access, Trading Opportunities, Credit Controls, and Fault Tolerance |
CN105989538A (zh) * | 2015-07-28 | 2016-10-05 | 盛立金融软件开发(杭州)有限公司 | 一种金融产品自动交易系统及自动交易方法 |
CN107451091A (zh) * | 2017-08-02 | 2017-12-08 | 上海金融期货信息技术有限公司 | 基于fpga‑cpu混合架构的高速信息交互系统 |
CN108230149A (zh) * | 2017-12-13 | 2018-06-29 | 武汉旷腾信息技术有限公司 | 基于soc fpga的加速金融交易系统及方法 |
CN109859052A (zh) * | 2019-01-16 | 2019-06-07 | 平安科技(深圳)有限公司 | 一种投资策略的智能推荐方法、装置、存储介质和服务器 |
CN110517136A (zh) * | 2019-07-30 | 2019-11-29 | 上海兮通信息科技有限公司 | 一种证券行情加速处理方法及系统 |
CN112487337A (zh) * | 2020-12-10 | 2021-03-12 | 盛立金融软件开发(杭州)有限公司 | 一种行情数据交互装置、方法及设备 |
CN112634041A (zh) * | 2020-12-28 | 2021-04-09 | 深圳华云信息系统有限公司 | 基于fpga的金融交易方法、装置及系统 |
US20230153906A1 (en) * | 2021-11-16 | 2023-05-18 | Rebellions Inc. | Apparatus for high frequency trading and method of operating thereof |
CN115114222A (zh) * | 2022-08-30 | 2022-09-27 | 珠海星云智联科技有限公司 | 行情快照分发方法及相关装置 |
CN115168280A (zh) * | 2022-08-30 | 2022-10-11 | 珠海星云智联科技有限公司 | 行情快照的处理方法及相关装置 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN112395098B (zh) | 应用程序接口调用方法、装置、存储介质和电子设备 | |
CN114500640B (zh) | 报文生成方法及发送方法、装置、电子设备和介质 | |
CN111475532B (zh) | 数据处理的优化方法及装置、存储介质、终端 | |
CN112214334A (zh) | 微服务调用方法、装置、电子设备及计算机可读存储介质 | |
TW201926173A (zh) | 資源轉移的驗證方法、裝置和電子支付驗證方法、裝置 | |
CN110990746A (zh) | 页面加载方法、装置、系统、存储介质、电子设备 | |
CN111738763B (zh) | 策略处理方法、装置、设备及存储介质 | |
CN116016628A (zh) | 一种api网关埋点分析方法及装置 | |
CN115330540A (zh) | 一种处理交易数据的方法和装置 | |
CN117788152A (zh) | 金融行情数据处理方法、装置、设备及存储介质 | |
CN113283991A (zh) | 一种区块链上交易数据的处理方法及装置 | |
CN109120509B (zh) | 一种信息收集的方法及装置 | |
CN117931794A (zh) | 算子框架、数据处理方法、装置和计算机存储介质 | |
US20250069279A1 (en) | Image processing method and apparatus, and electronic device and storage medium | |
CN111861742A (zh) | 一种fpga平台及一种数据处理系统 | |
CN116775575A (zh) | 一种文件合并方法、装置、电子设备及存储介质 | |
CN117880008A (zh) | 基于网关的业务请求处理方法、装置、设备及存储介质 | |
CN112148782B (zh) | 市场数据接入方法及装置 | |
CN117788153A (zh) | 金融行情数据处理方法、装置、设备及存储介质 | |
CN108984221B (zh) | 一种多平台用户行为日志的采集方法和装置 | |
CN111639936B (zh) | 交易信息的获取方法、装置、电子设备及可读存储介质 | |
CN115358761A (zh) | 售后处理方法和装置、售后处理设备及存储介质 | |
CN110134843B (zh) | 一种目标文件的生成方法以及装置 | |
JP2023526462A (ja) | 情報を処理するための方法及び装置 | |
CN110995754A (zh) | 一种数据报文索引的管理方法和装置以及设备 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
RJ01 | Rejection of invention patent application after publication |
Application publication date: 20240329 |