[go: up one dir, main page]

CN111489258A - 数据处理系统、方法、电子设备及存储介质 - Google Patents

数据处理系统、方法、电子设备及存储介质 Download PDF

Info

Publication number
CN111489258A
CN111489258A CN202010246223.1A CN202010246223A CN111489258A CN 111489258 A CN111489258 A CN 111489258A CN 202010246223 A CN202010246223 A CN 202010246223A CN 111489258 A CN111489258 A CN 111489258A
Authority
CN
China
Prior art keywords
data
target
transaction
transaction data
processing device
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
Application number
CN202010246223.1A
Other languages
English (en)
Inventor
郭国峰
张凯
祝磊
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shenzhen Huayun Information System Co ltd
Original Assignee
Shenzhen Huayun Information System Co ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Shenzhen Huayun Information System Co ltd filed Critical Shenzhen Huayun Information System Co ltd
Priority to CN202010246223.1A priority Critical patent/CN111489258A/zh
Publication of CN111489258A publication Critical patent/CN111489258A/zh
Pending legal-status Critical Current

Links

Images

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/54—Interprogram communication
    • G06F9/542—Event management; Broadcasting; Multicasting; Notifications
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/06—Asset management; Financial planning or analysis
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/55—Push-based network services

Landscapes

  • Engineering & Computer Science (AREA)
  • Business, Economics & Management (AREA)
  • Theoretical Computer Science (AREA)
  • Accounting & Taxation (AREA)
  • Finance (AREA)
  • General Physics & Mathematics (AREA)
  • Development Economics (AREA)
  • Physics & Mathematics (AREA)
  • Technology Law (AREA)
  • Strategic Management (AREA)
  • Marketing (AREA)
  • Economics (AREA)
  • General Business, Economics & Management (AREA)
  • Software Systems (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Game Theory and Decision Science (AREA)
  • Human Resources & Organizations (AREA)
  • Operations Research (AREA)
  • Multimedia (AREA)
  • Signal Processing (AREA)
  • General Engineering & Computer Science (AREA)
  • Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)

Abstract

本发明实施例提供了一种数据处理系统、方法、电子设备及存储介质，所述系统包括：多台数据源设备、数据处理设备以及多台服务器；多台所述数据源设备，通过中间设备接收目标机构广播的交易数据；所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备；所述数据处理设备，接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。

Description

数据处理系统、方法、电子设备及存储介质
技术领域
本发明实施例涉及数据处理技术领域，尤其涉及一种数据处理系统、方法、电子设备及存储介质。
背景技术
金融市场，包括货币市场和资本市场，是资金融通市场。所谓资金融通，是指在经济运行过程中，资金供求双方运用各种金融工具调节资金盈余的活动，是所有金融交易活动的总称，在金融交易市场上进行交易的是各种金融工具，例如股票、债券、储蓄存单等。金融从业者时刻关注金融交易行情数据，其承载着众多金融交易市场中的信息，在股票、债券、期货、期权等证券市场上随处可见。
量化交易是金融交易市场中常见的一种交易模式，这种交易模式建立在数学模型的基础上，从庞大的历史数据中选出能带来收益的“大概率”事件，以此来制定较优的投资策略，并以这种投资策略作为依据进行交易。量化交易的重点在于投资策略以及接收到金融交易行情数据的时机，如果可以越早接收到金融交易行情数据，量化交易者便可以越早进行投资策略的执行，如此获取金融交易行情数据的时机是分秒必争的。
相关技术中，金融交易行情数据是由各大交易所发出来的关于各级市场相关的数据，交易所通过中间设备(例如交换机、网卡、服务器等)将金融交易行情数据广播至数据源设备，再由数据源设备将金融交易行情数据推送至量化交易者服务器，如图1所示，SW为中间设备交换机，MDGW为数据源设备。在不同数据链路中，由于受网络延迟的不同、数据途径的路径不同、中间设备转发数据的运行状态不同等因素的影响，造成金融交易行情数据的时延不同，不同量化交易者接收金融交易行情数据的顺序存在差异，对量化交易者执行投资策略存在影响。
发明内容
为了解决上述由于受网络延迟的不同、数据途径的路径不同、中间设备转发数据的运行状态不同等因素的影响，造成金融交易行情数据的时延不同，不同量化交易者接收金融交易行情数据的顺序存在差异，对量化交易者执行投资策略存在影响的技术问题，本发明实施例提供了一种数据处理系统、方法、电子设备及存储介质。具体技术方案如下：
在本发明实施例的第一方面，首先提供了一种数据处理系统，所述系统包括：多台数据源设备、数据处理设备以及多台服务器；
多台所述数据源设备，通过中间设备接收目标机构广播的交易数据；
所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备；
所述数据处理设备，接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
在一个可选的实施方式中，所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否为首次接收；
若所述交易数据为首次接收，所述数据处理设备，则确定所述交易数据为目标交易数据。
在一个可选的实施方式中，所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否为首次接收，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，解析所述交易数据中携带的数据标识；
所述数据处理设备，判断所述数据标识是否与已存储的数据标识一致；
若所述交易数据为首次接收，所述数据处理设备，则确定所述交易数据为目标交易数据，包括：
若所述数据标识与已存储的数据标识未一致，所述数据处理设备，则确定所述交易数据为目标交易数据，并存储所述数据标识。
在一个可选的实施方式中，所述系统还包括：
若所述数据标识与已存储的数据标识一致，所述数据处理设备，则删除所述交易数据。
在一个可选的实施方式中，所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否已推送至多台所述服务器；
若所述交易数据未推送至多台所述服务器，所述数据处理设备，则确定所述交易数据为目标交易数据。
在一个可选的实施方式中，所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否已推送至多台所述服务器，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否存在服务器数据推送列表中；
若所述交易数据未推送至多台所述服务器，所述数据处理设备，则确定所述交易数据为目标交易数据，包括：
若所述交易数据未在服务器数据推送列表中，所述数据处理设备，则确定所述交易数据为目标交易数据，并将所述交易数据存储至服务器数据推送列表中。
在一个可选的实施方式中，所述系统还包括：
若所述交易数据存在服务器数据推送列表中，所述数据处理设备，则删除所述交易数据。
在一个可选的实施方式中，所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备，包括：
所述数据处理设备，获取金融交易行情拓扑图；
所述数据处理设备，根据所述金融交易行情拓扑图从多台所述数据源设备中确定至少两台目标数据源设备。
在本发明实施例的第二方面，还提供了一种数据处理方法，所述方法包括：
从多台数据源设备中确定至少两台目标数据源设备；
接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
从任一所述目标数据源设备发送的交易数据中确定目标交易数据；
将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
在本发明实施例的第三方面，还提供了一种电子设备，包括处理器、通信接口、存储器和通信总线，其中，处理器，通信接口，存储器通过通信总线完成相互间的通信；
存储器，用于存放计算机程序；
处理器，用于执行存储器上所存放的程序时，实现上述任一所述的数据处理方法。
在本发明实施例的第四方面，还提供了一种存储介质，所述存储介质中存储有指令，当其在计算机上运行时，使得计算机执行上述任一所述的数据处理方法。
在本发明实施例的第五方面，还提供了一种包含指令的计算机程序产品，当其在计算机上运行时，使得计算机执行上述任一所述的数据处理方法。
本发明实施例提供的技术方案，通过数据处理设备接收任一目标数据源设备发送的交易数据，从该交易数据中确定目标交易数据，其中该目标交易数据包括时延最低的交易数据，并将目标交易数据推送至多台服务器。如此本发明实施例通过数据处理设备确定时延最低的交易数据，并推送至多台服务器，不同量化交易者接收金融交易行情数据的顺序并无差异，避免了对量化交易者执行投资策略的影响。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本发明的实施例，并与说明书一起用于解释本发明的原理。
为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，对于本领域普通技术人员而言，在不付出创造性劳动性的前提下，还可以根据这些附图获得其他的附图。
图1为本发明实施例中示出的一种金融交易行情拓扑图示意图；
图2为本发明实施例中示出的一种数据处理方法的交互流程示意图；
图3为本发明实施例中示出的另一种金融交易行情拓扑图示意图；
图4为本发明实施例中示出的另一种金融交易行情拓扑图示意图；
图5为本发明实施例中示出的另一种数据处理方法的交互流程示意图；
图6为本发明实施例中示出的一种金融交易行情数据示意图；
图7为本发明实施例中示出的一种数据处理装置的结构示意图；
图8为本发明实施例中示出的一种电子设备的结构示意图。
具体实施方式
为使本发明实施例的目的、技术方案和优点更加清楚，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明的一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例，都属于本发明保护的范围。
本发明实施例提供了一种数据处理系统，该系统包括多台数据源设备、一台数据处理设备以及多台服务器，基于该数据处理系统，如图2所示，为本发明实施例提供的一种数据处理方法的交互流程示意图，该方法具体可以包括以下步骤：
S201，多台所述数据源设备，通过中间设备接收目标机构广播的交易数据；
在本发明实施例中，金融交易行情数据是由各大交易所发出来的关于各级市场相关的数据，交易所通过中间设备(例如交换机、网卡、服务器等)将金融交易行情数据广播至数据源设备。
因此，本发明实施例中多台数据源设备，可以通过中间设备(例如交换机、网卡、服务器等)接收目标机构(例如交易所)广播的交易数据(即金融交易行情数据)。
例如，对于数据源设备而言，可以通过中间设备接收深交所广播的金融交易行情数据，意味着数据源设备的交易数据可以来自于深交所的金融交易行情数据；对于数据源设备而言，也可以通过中间设备接收上交所广播的金融交易行情数据，意味着数据源设备的交易数据也可以来自于上交所的金融交易行情数据，本发明实施例对此不作限定。
相应的本发明实施例中，如果数据源设备的交易数据来自于深交所的金融交易行情数据，则数据源设备可以是MDGW(深交所行情网关)，如果数据源设备的交易数据来自于上交所的金融交易行情数据，则数据源设备可以是VDE(上交所行情网关)，数据源设备可以因数据源设备的数据来源不同而不同，本发明实施例对此不作限定。
S202，所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备；
为了可以将时延最低的金融交易行情数据推送至量化交易者服务器，需要确定接入本发明实施例中数据处理设备的目标数据源设备，通过数据处理设备确定时延最低的金融交易行情数据。
具体地，本发明实施例数据处理设备，可以获取金融交易行情拓扑图，根据该金融交易行情拓扑图，从多台所述数据源设备中确定至少两台目标数据源设备。例如，如图3所示，为本发明实施例示出的一种金融交易行情拓扑图，数据处理设备根据该金融交易行情拓扑图，从多台所述数据源设备中确定至少两台目标数据源设备，SW为中间设备交换机，MDGW为数据源设备。
其中，本发明实施例中数据处理设备和目标数据源设备之间可以通过交换机、分光器、集线器等方式进行数据传输。例如，如图4所示，本发明实施例中数据处理设备利用分光器或者集线器等进行旁路接入目标数据源设备，这种方式可以把在复杂网络中转发的众多金融交易行情数据进行优选，排除掉在某个时刻某个金融交易行情数据因为网络拥堵、服务器繁忙或是设备故障灯原因导致的时延较大的情况。
S203，所述数据处理设备，接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
对于上述确定的任一目标数据源设备，本发明实施例所述数据处理设备，接收该目标数据源设备发送的金融交易行情数据。
例如，对于目标数据源设备MDGW_a，本发明实施例所述数据处理设备，接收该目标数据源设备MDGW_a发送的金融交易行情数据，对于目标数据源设备MDGW_b，本发明实施例所述数据处理设备，接收该目标数据源设备MDGW_b发送的金融交易行情数据。
S204，所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
对于上述任一目标数据源设备发送的金融交易行情数据，本发明实施例所述数据处理设备，从其中确定目标金融交易行情数据，并将该目标金融交易行情数据推送至多台服务器。
具体地，本发明实施例所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，判断该金融交易行情数据是否为首次接收，如果该金融交易行情数据为首次接收，则表明该金融交易行情数据通过该目标数据源设备优先到达本发明实施例中数据处理设备，即为时延最低的金融交易行情数据，此时可以确定该金融交易行情数据为目标金融交易行情数据。
其中，所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，解析金融交易行情数据中携带的数据标识，判断该数据标识是否与已存储的数据标识一致，如果该数据标识与已存储的数据标识未一致，则表明该金融交易行情数据通过该目标数据源设备优先到达本发明实施例中数据处理设备，即为时延最低的金融交易行情数据，此时可以确定该金融交易行情数据为目标金融交易行情数据，并存储该数据标识；
如果该数据标识与已存储的数据标识一致，数据处理设备，则可以删除该金融交易行情数据，意味着在该金融交易行情数据之前，与该金融交易行情数据一致的金融交易行情数据已到达本发明实施例中数据处理设备。
例如，本发明实施例中数据处理设备，可以接收目标数据源设备MDGW_a发送的金融交易行情数据1，解析该金融交易行情数据1中携带的ID，金融交易行情数据1中携带的ID与已存储的ID未一致，表明该金融交易行情数据1通过目标数据源设备MDGW_a首次到达本发明实施例中数据处理设备，即时延最低的金融交易行情数据1，可以确定该金融交易行情数据1为目标金融交易行情数据，并存储该金融交易行情数据1中携带的ID；
而对于目标数据源设备MDGW_b发送的金融交易行情数据1，由于受网络延迟、数据途径的路径、中间设备转发数据的运行状态等因素的影响，暂时未到达本发明实施例中数据处理设备，后续本发明实施例中数据处理设备，在接收到MDGW_b发送的金融交易行情数据1的情况下，解析该金融交易行情数据1中携带的ID，金融交易行情数据1中携带的ID与已存储的ID一致(上述步骤已存储该金融交易行情数据1中携带的ID)，相较于目标数据源设备MDGW_a发送的金融交易行情数据1，到达本发明实施例中数据处理设备的时刻较晚，可以删除该目标数据源设备MDGW_b发送的金融交易行情数据1；
本发明实施例中数据处理设备，接收MDGW_b发送的金融交易行情数据2，解析该MDGW_b发送的金融交易行情数据2中携带的ID，与已存储的ID未一致，表明该金融交易行情数据2通过目标数据源设备MDGW_a首次到达本发明实施例中数据处理设备，即时延最低的金融交易行情数据2，可以确定该金融交易行情数据2为目标金融交易行情数据，并存储该金融交易行情数据2中携带的ID；
而对于目标数据源设备MDGW_a发送的金融交易行情数据2，由于受网络延迟、数据途径的路径、中间设备转发数据的运行状态等因素的影响，暂时未到达本发明实施例，后续本发明实施例中数据处理设备，在接收到MDGW_a发送的金融交易行情数据2的情况下，解析该金融交易行情数据2中携带的的ID，金融交易行情数据2中携带的ID与已存储的ID一致((上述步骤已存储该金融交易行情数据2中携带的ID))，相较于目标数据源设备MDGW_b发送的金融交易行情数据2，到达本发明实施例中数据处理设备的时刻较晚，可以删除该目标数据源设备MDGW_a发送的金融交易行情数据2。
另外，对于本发明实施例中存储的数据标识，可以判断该数据标识对应的金融交易行情数据的接收次数是否与目标数据源设备数量一致，如果该数据标识对应的金融交易行情数据的接收次数与目标数据源设备数量一致，可以删除该数据标识，以此节省存储资源。
例如，本发明实施例中存在3台目标数据源设备，对于同一金融交易行情数据A，这3台目标数据源设备都会传输至本发明实施例中数据处理设备，区别在于到达本发明实施例中数据处理设备的时刻可能不一致，当金融交易行情数据A通过目标数据源设备1首次到达本发明实施例中数据处理设备时，可以认为是时延最低的金融交易行情数据(即目标金融交易行情数据)，可以将该金融交易行情数据A推送至多台服务器，此时金融交易行情数据A的接收次数为1，且已经存储金融交易行情数据A中携带的ID；
后续该金融交易行情数据A通过目标数据源设备2、目标数据源设备3到达本发明实施例中数据处理设备，此时会依次删除目标数据源设备2以及目标数据源设备3发送的金融交易行情数据A，累计金融交易行情数据A的接收次数，当金融交易行情数据A的接收次数为3时，与目标数据源设备数量3一致，可以删除已存储的目标数据源设备1发送的金融交易行情数据A中携带的ID。
通过上述对本发明实施例提供的技术方案的描述，通过数据处理设备接收任一目标数据源设备发送的交易数据，从该交易数据中确定目标交易数据，其中该目标交易数据包括时延最低的交易数据，并将目标交易数据推送至多台服务器。如此本发明实施例通过数据处理设备确定时延最低的交易数据，并推送至多台服务器，不同量化交易者接收金融交易行情数据的顺序并无差异，避免了对量化交易者执行投资策略的影响。
如图5所示，为本发明实施例提供的另一种数据处理方法的交互流程示意图，该方法具体可以包括以下步骤：
S501，多台所述数据源设备，通过中间设备接收目标机构广播的交易数据；
在本发明实施例中，本步骤与上述步骤S201类似，本发明实施例在此不再一一赘述。
S502，所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备；
在本发明实施例中，本步骤与上述步骤S202类似，本发明实施例在此不再一一赘述。
S503，所述数据处理设备，接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
在本发明实施例中，本步骤与上述步骤S203类似，本发明实施例在此不再一一赘述。
S504，所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否已推送至多台所述服务器；
所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，判断该金融交易行情数据是否已推送至多台服务器。
具体地，所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，判断该金融交易行情数据是否存在服务器数据推送列表中。
例如，本发明实施例所述数据处理设备，可以预先建立服务器数据推送列表，对于已推送至多台服务器的金融交易行情数据，存储至该服务器数据推送列表中，后续对于任一目标数据源设备发送的金融交易行情数据，本发明实施例所述数据处理设备，判断该金融交易行情数据是否存在服务器数据推送列表中。
S504，若所述交易数据未推送至多台所述服务器，所述数据处理设备，则确定所述交易数据为目标交易数据，将所述目标交易数据推送至多台服务器，其中，所述目标交易数据包括时延最低的所述交易数据。
所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，如果未推送至多台服务器，则确定该金融交易行情数据为目标数据，将该目标数据推送至多台服务器。
具体地，所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，如果该金融交易行情数据未在服务器数据推送列表中，则表明该金融交易行情数据通过该目标数据源设备优先到达本发明实施例中数据处理设备，即为时延最低的金融交易行情数据，此时可以确定该金融交易行情数据为目标金融交易行情数据，并在服务器数据推送列表中存储该金融交易行情数据。
所述数据处理设备，对于上述任一目标数据源设备发送的金融交易行情数据，如果该金融交易行情数据存在于服务器数据推送列表中，则删除该目标数据源设备发送的金融交易行情数据。
例如，本发明实施例所述数据处理设备，接收目标数据源设备MDGW_a发送的金融交易行情数据1，该目标数据源设备MDGW_a发送的金融交易行情数据1未存在于服务器数据推送列表中，表明该金融交易行情数据1通过目标数据源设备MDGW_a首次到达本发明实施例中数据处理设备，即时延最低的金融交易行情数据1，可以确定该金融交易行情数据1为目标金融交易行情数据，并存储至服务器数据推送列表中；
而对于MDGW_b发送的金融交易行情数据1，由于受网络延迟、数据途径的路径、中间设备转发数据的运行状态等因素的影响，暂时未到达本发明实施例，后续本发明实施例中数据处理设备，在接收到MDGW_b发送的金融交易行情数据1的情况下，该目标数据源设备MDGW_b发送的金融交易行情数据1存在于服务器数据推送列表中，相较于目标数据源设备MDGW_a发送的金融交易行情数据1，达到本发明实施例的时刻较晚，可以删除该目标数据源设备MDGW_b发送的金融交易行情数据1；
本发明实施例中数据处理设备，可以接收MDGW_b发送的金融交易行情数据2，未存在于服务器数据推送列表中，表明该金融交易行情数据2通过目标数据源设备MDGW_b首次到达本发明实施例中数据处理设备，即时延最低的金融交易行情数据2，可以确定该金融交易行情数据2为目标金融交易行情数据，并存储至服务器数据推送列表中；
而后续数据处理设备，接收到目标数据源设备MDGW_a发送的金融交易行情数据2，此时目标数据源设备MDGW_a发送的金融交易行情数据2存在于服务器数据推送列表中，相较于目标数据源设备MDGW_b发送的金融交易行情数据2，到达本发明实施例中数据处理设备的时刻较晚，可以删除该目标数据源设备MDGW_a发送的金融交易行情数据2。
另外，服务器数据推送列表中存储的金融交易行情数据，数据处理设备，可以判断该金融交易行情数据的接收次数是否与目标数据源设备数量一致，如果该金融交易行情数据的接收次数与目标数据源设备数量一致，可以删除该金融交易行情数据，以此节省存储资源。
例如，本发明实施例中存在3台目标数据源设备，对于同一金融交易行情数据A，这3台目标数据源设备都会传输至本发明实施例，区别在于到达本发明实施例的时刻可能不一致，当金融交易行情数据A通过目标数据源设备1首次到达本发明实施例中数据处理设备时，可以认为是时延最低的金融交易行情数据(即目标金融交易行情数据)，数据处理设备，可以将该金融交易行情数据A推送至多台服务器，此时金融交易行情数据A的接收次数为1，且在服务器数据推送列表中已经存储金融交易行情数据A；
后续该金融交易行情数据A通过目标数据源设备2、目标数据源设备3到达本发明实施例中数据处理设备，此时数据处理设备，会依次删除目标数据源设备2、目标数据源设备3发送的金融交易行情数据A，累计金融交易行情数据A的接收次数，当金融交易行情数据A的接收次数为3时，与目标数据源设备数量3一致，数据处理设备，可以删除服务器数据推送列表中已经存储的金融交易行情数据A。
对于本发明实施例中所述的金融交易行情数据，可以如图6所示，目标数据源设备发送的金融交易行情数据包括了消息头、频道代码、消息记录号等多个消息字段，其中消息记录号就是本发明实施例所关注的序号ID。
在此，本发明实施例从单侧的角度描述数据处理设备所执行的步骤：从多台数据源设备中确定至少两台目标数据源设备；接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；从任一所述目标数据源设备发送的交易数据中确定目标交易数据；将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。其中，对于数据处理设备执行的步骤，可以参考上述实施例。
与上述方法实施例相对应，本发明实施例还提供了一种数据处理装置，如图7所示，该装置可以包括：设备确定模块710、数据接收模块720、数据确定模块730、数据推送模块740。
设备确定模块710，用于从多台数据源设备中确定至少两台目标数据源设备；
数据接收模块720，用于接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
数据确定模块730，用于从任一所述目标数据源设备发送的交易数据中确定目标交易数据；
数据推送模块740，用于将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
本发明实施例还提供了一种电子设备，如图8所示，包括处理器81、通信接口82、存储器83和通信总线84，其中，处理器81，通信接口82，存储器83通过通信总线84完成相互间的通信，
存储器83，用于存放计算机程序；
处理器81，用于执行存储器83上所存放的程序时，实现如下步骤：
从多台数据源设备中确定至少两台目标数据源设备；接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；从任一所述目标数据源设备发送的交易数据中确定目标交易数据；将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
上述电子设备提到的通信总线可以是外设部件互连标准(Peripheral ComponentInterconnect，简称PCI)总线或扩展工业标准结构(Extended Industry StandardArchitecture，简称EISA)总线等。该通信总线可以分为地址总线、数据总线、控制总线等。为便于表示，图中仅用一条粗线表示，但并不表示仅有一根总线或一种类型的总线。
通信接口用于上述电子设备与其他设备之间的通信。
存储器可以包括随机存取存储器(Random Access Memory，简称RAM)，也可以包括非易失性存储器(non-volatile memory)，例如至少一个磁盘存储器。可选的，存储器还可以是至少一个位于远离前述处理器的存储装置。
上述的处理器可以是通用处理器，包括中央处理器(Central Processing Unit，简称CPU)、网络处理器(Network Processor，简称NP)等；还可以是数字信号处理器(Digital Signal Processing，简称DSP)、专用集成电路(Application SpecificIntegrated Circuit，简称ASIC)、现场可编程门阵列(Field－Programmable Gate Array，简称FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件。
在本发明提供的又一实施例中，还提供了一种存储介质，该存储介质中存储有指令，当其在计算机上运行时，使得计算机执行上述实施例中任一所述的数据处理方法。
在本发明提供的又一实施例中，还提供了一种包含指令的计算机程序产品，当其在计算机上运行时，使得计算机执行上述实施例中任一所述的数据处理方法。
在上述实施例中，可以全部或部分地通过软件、硬件、固件或者其任意组合来实现。当使用软件实现时，可以全部或部分地以计算机程序产品的形式实现。所述计算机程序产品包括一个或多个计算机指令。在计算机上加载和执行所述计算机程序指令时，全部或部分地产生按照本发明实施例所述的流程或功能。所述计算机可以是通用计算机、专用计算机、计算机网络、或者其他可编程装置。所述计算机指令可以存储在存储介质中，或者从一个存储介质向另一个存储介质传输，例如，所述计算机指令可以从一个网站站点、计算机、服务器或数据中心通过有线(例如同轴电缆、光纤、数字用户线(DSL))或无线(例如红外、无线、微波等)方式向另一个网站站点、计算机、服务器或数据中心进行传输。所述存储介质可以是计算机能够存取的任何可用介质或者是包含一个或多个可用介质集成的服务器、数据中心等数据存储设备。所述可用介质可以是磁性介质，(例如，软盘、硬盘、磁带)、光介质(例如，DVD)、或者半导体介质(例如固态硬盘Solid State Disk(SSD))等。
需要说明的是，在本文中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
本说明书中的各个实施例均采用相关的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于系统实施例而言，由于其基本相似于方法实施例，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。
以上所述仅为本发明的较佳实施例而已，并非用于限定本发明的保护范围。凡在本发明的精神和原则之内所作的任何修改、等同替换、改进等，均包含在本发明的保护范围内。

Claims (10)

1.一种数据处理系统，其特征在于，所述系统包括：多台数据源设备、数据处理设备以及多台服务器；
多台所述数据源设备，通过中间设备接收目标机构广播的交易数据；
所述数据处理设备，从多台所述数据源设备中确定至少两台目标数据源设备；
所述数据处理设备，接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
2.根据权利要求1所述的系统，其特征在于，所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否为首次接收；
若所述交易数据为首次接收，所述数据处理设备，则确定所述交易数据为目标交易数据。
3.根据权利要求2所述的系统，其特征在于，所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否为首次接收，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，解析所述交易数据中携带的数据标识；
所述数据处理设备，判断所述数据标识是否与已存储的数据标识一致；
若所述交易数据为首次接收，所述数据处理设备，则确定所述交易数据为目标交易数据，包括：
若所述数据标识与已存储的数据标识未一致，所述数据处理设备，则确定所述交易数据为目标交易数据，并存储所述数据标识。
4.根据权利要求3所述的系统，其特征在于，所述系统还包括：
若所述数据标识与已存储的数据标识一致，所述数据处理设备，则删除所述交易数据。
5.根据权利要求1所述的系统，其特征在于，所述数据处理设备，从任一所述目标数据源设备发送的交易数据中确定目标交易数据，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否已推送至多台所述服务器；
若所述交易数据未推送至多台所述服务器，所述数据处理设备，则确定所述交易数据为目标交易数据。
6.根据权利要求5所述的系统，其特征在于，所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否已推送至多台所述服务器，包括：
所述数据处理设备，对于任一所述目标数据源设备发送的交易数据，判断所述交易数据是否存在服务器数据推送列表中；
若所述交易数据未推送至多台所述服务器，所述数据处理设备，则确定所述交易数据为目标交易数据，包括：
若所述交易数据未在服务器数据推送列表中，所述数据处理设备，则确定所述交易数据为目标交易数据，并将所述交易数据存储至服务器数据推送列表中。
7.根据权利要求6所述的系统，其特征在于，所述系统还包括：
若所述交易数据存在服务器数据推送列表中，所述数据处理设备，则删除所述交易数据。
8.一种数据处理方法，其特征在于，应用于数据处理设备，所述方法包括：
从多台数据源设备中确定至少两台目标数据源设备；
接收任一所述目标数据源设备发送的交易数据，其中，所述交易数据包括金融交易行情数据；
从任一所述目标数据源设备发送的交易数据中确定目标交易数据；
将所述目标交易数据推送至多台所述服务器，其中，所述目标数据包括时延最低的所述交易数据。
9.一种电子设备，其特征在于，包括处理器、通信接口、存储器和通信总线，其中，处理器，通信接口，存储器通过通信总线完成相互间的通信；
存储器，用于存放计算机程序；
处理器，用于执行存储器上所存放的程序时，实现权利要求8中所述的方法步骤。
10.一种存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如权利要求8中所述的方法。
CN202010246223.1A 2020-03-31 2020-03-31 数据处理系统、方法、电子设备及存储介质 Pending CN111489258A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202010246223.1A CN111489258A (zh) 2020-03-31 2020-03-31 数据处理系统、方法、电子设备及存储介质

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202010246223.1A CN111489258A (zh) 2020-03-31 2020-03-31 数据处理系统、方法、电子设备及存储介质

Publications (1)

Publication Number Publication Date
CN111489258A true CN111489258A (zh) 2020-08-04

Family

ID=71791630

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202010246223.1A Pending CN111489258A (zh) 2020-03-31 2020-03-31 数据处理系统、方法、电子设备及存储介质

Country Status (1)

Country Link
CN (1) CN111489258A (zh)

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108769141A (zh) * 2018-05-09 2018-11-06 深圳市深弈科技有限公司 一种多源实时交易行情数据接收与归并处理的方法
CN109274747A (zh) * 2018-09-29 2019-01-25 上海中畅信息科技有限公司 行情网关系统及其处理方法
CN110611624A (zh) * 2018-06-15 2019-12-24 上海仪电（集团）有限公司中央研究院 一种基于fpga的海量行情数据加速系统及加速方法
CN110634071A (zh) * 2019-09-06 2019-12-31 北京神州同道智能信息技术有限公司 一种基于自动量化交易平台的全市场多品种智能金融资管系统
US20200081750A1 (en) * 2018-09-06 2020-03-12 The Toronto-Dominion Bank Devices and methods for providing notifications

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108769141A (zh) * 2018-05-09 2018-11-06 深圳市深弈科技有限公司 一种多源实时交易行情数据接收与归并处理的方法
CN110611624A (zh) * 2018-06-15 2019-12-24 上海仪电（集团）有限公司中央研究院 一种基于fpga的海量行情数据加速系统及加速方法
US20200081750A1 (en) * 2018-09-06 2020-03-12 The Toronto-Dominion Bank Devices and methods for providing notifications
CN109274747A (zh) * 2018-09-29 2019-01-25 上海中畅信息科技有限公司 行情网关系统及其处理方法
CN110634071A (zh) * 2019-09-06 2019-12-31 北京神州同道智能信息技术有限公司 一种基于自动量化交易平台的全市场多品种智能金融资管系统

Similar Documents

Publication Publication Date Title
US11776055B2 (en) Transactionally deterministic high speed financial exchange having improved, efficiency, communication, customization, performance, access, trading opportunities, credit controls, and fault tolerance
US8706606B2 (en) Automated trading system
US12190382B2 (en) Transactionally deterministic high speed financial exchange having improved, efficiency, communication, customization, performance, access, trading opportunities, credit controls, and fault tolerance
US11688011B2 (en) Transactionally deterministic high speed financial exchange having improved, efficiency, communication, customization, performance, access, trading opportunities, credit controls, and fault tolerance
US20230351502A1 (en) On-demand auction
US20250278518A1 (en) Federated personally identifiable information (pii) service
CN110415027A (zh) 一种大数据行情平台系统
CN113112358B (zh) 基于区块链的决策方法及装置和电子设备
US11699184B2 (en) Context based filtering within subsets of network nodes implementing a trading system
WO2021218827A1 (zh) 跨境汇款
US12260454B2 (en) Pipelined credit checking
CN114841795A (zh) 一种业务处理方法、装置、电子设备及计算机可读介质
CN115293913A (zh) 商业汇票承兑人拒付款风险预警方法及装置
CN111489258A (zh) 数据处理系统、方法、电子设备及存储介质
CN113079110B (zh) 消息处理方法、装置、设备及存储介质
US20210383469A1 (en) Currency trading method based on blockchain and electronic device
CN115375298A (zh) 一种考虑业务类型的收付处理方法、系统、终端和介质
US20250390952A1 (en) Method, apparatus and system for equalizing latencies in publication of event data to multiple client devices
TWI874161B (zh) 彙整金融商品交易行情的現場可程式化邏輯閘陣列
TWI795645B (zh) 基於區塊鏈的貨幣交易方法、裝置及電子設備
US11263164B1 (en) Multiple field programmable gate array (FPGA) based multi-legged order transaction processing system and method thereof
WO2025018993A1 (en) Method, apparatus and system for publishing market data updates using a reprogrammable hardware device and software
TW201905812A (zh) 外匯交易管理系統及其管理方法
KR20250147176A (ko) 자산 거래가 수행되는 자산 시장의 정보를 제공하는 방법 및 장치
CN115619550A (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
CB02 Change of applicant information
CB02 Change of applicant information

Address after: 9th Floor, Block A, Shenzhen National Engineering Laboratory Building, No. 20, Gaoxin South 7th Road, High-tech Zone Community, Yuehai Street, Nanshan District, Shenzhen, Guangdong 518000

Applicant after: Shenzhen Huayun Information System Technology Co.,Ltd.

Address before: No. 904, block a, national engineering laboratory building, Gaoxin South 7th road digital technology park, Yuehai street, Nanshan District, Shenzhen, Guangdong 518000

Applicant before: Shenzhen Huayun Information System Co.,Ltd.

RJ01 Rejection of invention patent application after publication
RJ01 Rejection of invention patent application after publication

Application publication date: 20200804