一种数据传输中基于时间轴的行情数据一致性保护方法

摘要

本发明涉及信息数据传输技术领域，具体是一种数据传输中基于时间轴的行情数据一致性保护方法，其特征在于A系统接收到的若干只股票行情其时间分别为t1,t2,……tk，根据这样的数据源计算出的指数行情时间为TA，TA=h(t1,t2,……tk)，B系统也会根据接收到的股票行情的时间计算出指数行情的时间TB，两者在向下游进行发布的时候，通过各自的一致性保护模块进行交互，使得输出的指数行情结果一致，并映射在时间轴上的同样位置T，所述的一致性保护模块由行情交互模块、结果对比模块和映射模块构成。本发明适用于在证券市场中，指数行情双源双发的大规模计算场合，提供了一种安全可靠，快速稳定并维持输出中指数行情一致性的一种方法。

主权项

一种数据传输中基于时间轴的行情数据一致性保护方法，其特征在于A系统接收到的若干只股票行情其时间分别为t1,t2,……tk，根据这样的数据源计算出的指数行情时间为TA，TA＝h(t1,t2,……tk)，B系统也会根据接收到的股票行情的时间计算出指数行情的时间TB，两者在向下游进行发布的时候，通过各自的一致性保护模块进行交互，使得输出的指数行情结果一致，并映射在时间轴上的同样位置T，所述的一致性保护模块由行情交互模块、结果对比模块和映射模块构成，操作方法为：a)指数计算主系统计算出指数行情之后，向一致性保护模块M发送启动消息；b)一致性保护模块M收到指数计算主系统发送的消息之后，开始启动，此时A系统的一致性保护模块MA和B系统的一致性保护模块MB都获取到了本机的计算结果T时刻A系统计算出的指数值I(Ta),指数值的映射因子v(a)和T时刻B系统计算出的指数值I(Tb),指数值的映射因子v(b)，v的计算如下公式所示：其中，T_last是上一回合计算的指数行情所属的时间，公式中k为共k只证券参与指数计算，tk为第k只证券的时间戳，v取指数行情中每只股票的时间戳与上一回合的指数行情时间戳的标准差，v越大代表指数中的所有股票的成交时间总体上距离上次的T越远，就代表指数行情越新；c)行情交互模块与另一台服务器进行交互，接收另一台指数计算服务器的计算结果，同时发送本地的指数行情结果；实现A系统的一致性保护模块MA和B系统的一致性保护模块MB两个模块的数据交换功能，本步骤的结果是A系统的一致性保护模块MA和B系统的一致性保护模块MB都会获得指数值I(Ta),映射因子v(a)和指数值I(Tb),映射因子v(b)；d)结果对比模块按照指数行情的对比准则进行指数行情比对；根据两个计算结果的各个参数进行比较，如果有不同，则需要同步；e)映射模块根据比对的结果进行指数行情映射，实际上的逻辑就是M的功能，M的模块的功能如下公式描述：$I\left(T\right)=g\left(I\right(Ta),I(Tb\left)\right)=\left\{\begin{array}{c}I\left(Ta\right),va>vb\\ I\left(Tb\right),va<vb\end{array}\right.;$A系统的一致性保护模块MA在计算出自己的指数结果I(Ta)和映射因子va之后，会获取到B系统的结果I(Tb)和v(b)，根据映射因子的大小决定选取I(Ta)和I(Tb)中较新的值，决定最终的结果I(T)从而映射到时间轴上的T点，同样B系统的一致性保护模块MB也会进行同样的过程，得出结果I(T)映射到T，这样两者发出的结果映射到时间轴上便是一致的，根据两个不同映射因子v(a)和映射因子v(b)选取指数值I(Ta)和指数值I(Tb)得到一致的结果I(T)的过程；从而映射到时间轴上统一的一个时间点，结束后通知指数计算系统向外发布；f)指数计算系统将此回合映射后的指数行情发送到市场，进行下一回合的运算；指数行情时间点的确定是将映射到时间轴上很多不同的点的股票行情，确定映射到一个点的指数行情的过程；而一致性保护模块的工作任务是将两个映射在时间轴上不同的指数行情数据，按照一定的规则进行合并，变为映射到时间轴上相同的数据，向市场发布。