行情快照下发方法、装置、设备及介质

    公开(公告)号:CN116483747B

    公开(公告)日:2023-09-08

    申请号:CN202310758698.2

    申请日:2023-06-26

    IPC分类号: G06F12/0877 G06Q40/06

    摘要: 本发明涉及大数据技术领域,提供一种行情快照下发方法、装置、设备及介质,能够对交易所下发的快照数据进行格式规范化处理得到待下发快照,在缓存前先对快照格式进行规范化处理,使快照下发时无需改动下游客户端API接口,将待下发快照下发至对快照数据发起实时订阅请求的客户端,并利用异步缓存线程对待下发快照进行旁路缓存,一方面优先对快照数据及时进行实时下发,另一方面通过缓存技术进行快照存储,以便后续下发时直接从缓存中获取快照,提升行情快照的下发效率,当接收到任意客户端发起的快照订阅请求时,基于缓存进行滤重处理得到滤重结果,根据滤重结果生成对任意客户端的快照下发策略并更新下发滤重记录,避免快照重复下发。

    行情快照下发方法、装置、设备及介质

    公开(公告)号:CN116483747A

    公开(公告)日:2023-07-25

    申请号:CN202310758698.2

    申请日:2023-06-26

    IPC分类号: G06F12/0877 G06Q40/06

    摘要: 本发明涉及大数据技术领域,提供一种行情快照下发方法、装置、设备及介质,能够对交易所下发的快照数据进行格式规范化处理得到待下发快照,在缓存前先对快照格式进行规范化处理,使快照下发时无需改动下游客户端API接口,将待下发快照下发至对快照数据发起实时订阅请求的客户端,并利用异步缓存线程对待下发快照进行旁路缓存,一方面优先对快照数据及时进行实时下发,另一方面通过缓存技术进行快照存储,以便后续下发时直接从缓存中获取快照,提升行情快照的下发效率,当接收到任意客户端发起的快照订阅请求时,基于缓存进行滤重处理得到滤重结果,根据滤重结果生成对任意客户端的快照下发策略并更新下发滤重记录,避免快照重复下发。

    请求调度方法、装置、设备及介质

    公开(公告)号:CN115277859B

    公开(公告)日:2022-12-06

    申请号:CN202211189676.0

    申请日:2022-09-28

    IPC分类号: H04L67/60 H04L47/625

    摘要: 本发明涉及互联网技术领域,提供一种请求调度方法、装置、设备及介质,其方法包括:在进行请求调度时,依次遍历客户端数组中的每个客户端;在遍历当前客户端时轮询当前客户端对应的全局数组中的每个元素,直至轮询到有元素对应的索引队列不为空的目标索引队列,将处于队头的目标元素所指向的请求队列确定为目标队列,停止对当前客户端的轮询,从目标队列中获取请求添加至待执行队列,继续遍历下一客户端,在遍历过程中,并发执行待执行队列中的每个请求。利用本发明能够基于构建的客户端数组、请求队列及全局数组对请求进行遍历轮询,使服务端调度请求时能够无差别化对待不同请求类型,具有更高的请求并发量、请求执行吞吐量及处理效率。

    请求调度方法、装置、设备及介质

    公开(公告)号:CN115277859A

    公开(公告)日:2022-11-01

    申请号:CN202211189676.0

    申请日:2022-09-28

    IPC分类号: H04L67/60 H04L47/625

    摘要: 本发明涉及互联网技术领域,提供一种请求调度方法、装置、设备及介质,其方法包括:在进行请求调度时,依次遍历客户端数组中的每个客户端;在遍历当前客户端时轮询当前客户端对应的全局数组中的每个元素,直至轮询到有元素对应的索引队列不为空的目标索引队列,将处于队头的目标元素所指向的请求队列确定为目标队列,停止对当前客户端的轮询,从目标队列中获取请求添加至待执行队列,继续遍历下一客户端,在遍历过程中,并发执行待执行队列中的每个请求。利用本发明能够基于构建的客户端数组、请求队列及全局数组对请求进行遍历轮询,使服务端调度请求时能够无差别化对待不同请求类型,具有更高的请求并发量、请求执行吞吐量及处理效率。

    基于期货行情K线的交易方法、装置、设备及介质

    公开(公告)号:CN116630048A

    公开(公告)日:2023-08-22

    申请号:CN202310676689.9

    申请日:2023-06-08

    IPC分类号: G06Q40/04 G06Q30/0201

    摘要: 本发明涉及大数据技术领域,提供一种基于期货行情K线的交易方法、装置、设备及介质,能够解析CTP期货行情数据得到当前行情信息,利用当前行情信息中的当前市场及当前代码段在交易时间段映射表中进行匹配得到当前交易时间段,进一步利用当前行情信息及当前交易时间段在K线时间映射表中进行匹配得到当前K线时间,并利用从K线缓存中获取的上一个K线状态、当前K线时间及当前行情信息计算当前K线状态,由于使用了K线缓存机制,能够有效计算各个行情品种的期货K线,且能够实现跨天处理,使计算的K线更加准确,将当前K线状态输入至当前量化交易模型得到当前交易策略,以利用计算得到的期货行情K线辅助进行更加合理有效的交易。

    应用层网络数据传输方法、装置、设备及介质

    公开(公告)号:CN115297062A

    公开(公告)日:2022-11-04

    申请号:CN202211197907.2

    申请日:2022-09-29

    IPC分类号: H04L47/36 H04L69/329

    摘要: 本发明涉及大数据技术领域,提供一种应用层网络数据传输方法、装置、设备及介质,其方法包括:在应用层遍历待传输数据,并在遍历过程中对最小数据结构单元进行计数,当计数值达到目标数量时,利用遍历到的最小数据结构单元进行封装得到当前数据包,清空计数值以等待下一轮遍历,从剩余的最小数据结构单元中消耗一个最小数据结构单元添加至当前数据包,并对初始剩余量进行减1操作得到当前剩余量;当遍历完成时,传输当前封装得到的所有数据包。本发明能够在网络数据传输过程中,在应用层将大数据包拆分成独立的小数据包,防止在传输过程中由于单个数据包过大对网络占用产生不利影响,保证数据能够被完整传输,同时降低了接收端的数据解析压力。

    基于资源配置的信息处理方法、装置、设备及介质

    公开(公告)号:CN115168056A

    公开(公告)日:2022-10-11

    申请号:CN202211069820.7

    申请日:2022-09-02

    摘要: 本发明公开了基于资源配置的信息处理方法、装置、设备及介质,方法包括:根据配置信息对管理服务器的系统资源进行分配从而确定每一处理线程对应的递交线程,通过递交线程获取客户端反馈的递交对接参数,将接收到的交易数据分别输入所述处理线程进行处理以对处理线程内的初始数据进行更新,根据各递交线程的递交对接参数从更新后的初始数据中获取与递交对接参数对应的快照信息,通过递交线程将快照信息递交至各递交线程对接的客户端。本发明属于大数据处理的技术领域,上述方法通过处理线程对接收到的交易数据进行存储,通过递交线程获取与递交对接参数对应的快照信息,从而根据客户需求获取相应快照信息进行反馈,从而更全面地察看交易数据信息。