-
公开(公告)号: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接口,将待下发快照下发至对快照数据发起实时订阅请求的客户端,并利用异步缓存线程对待下发快照进行旁路缓存,一方面优先对快照数据及时进行实时下发,另一方面通过缓存技术进行快照存储,以便后续下发时直接从缓存中获取快照,提升行情快照的下发效率,当接收到任意客户端发起的快照订阅请求时,基于缓存进行滤重处理得到滤重结果,根据滤重结果生成对任意客户端的快照下发策略并更新下发滤重记录,避免快照重复下发。
-
公开(公告)号:CN115269709B
公开(公告)日:2022-12-30
申请号:CN202211208194.5
申请日:2022-09-30
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式(北京)技术有限公司
IPC分类号: G06F16/25 , G06F16/2457 , G06F16/953 , G06Q40/00
摘要: 本发明涉及大数据技术领域,提供一种基于行情数据的查询及回放方法、装置、设备及介质,其方法包括:确定向服务端发起的针对行情数据的每个请求的类型;将每个请求中的查询请求写入发送队列;获取每个请求中的回放请求的请求代码数目;根据所述请求代码数目对所述回放请求进行拆分,得到多个子请求并写入发送队列;将发送队列中的每个子请求异步发送至服务端;当接收到服务端根据每个请求返回的请求结果时,从中提取回放请求对应的目标结果;根据行情时间对目标结果进行触发式反馈。本发明能够通过对查询与回放请求的拆分,使得服务端无差别化处理查询和回放请求,实现资源的有效利用,同时实现高效且高并发的行情数据查询及回放。
-
公开(公告)号: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
摘要: 本发明涉及互联网技术领域,提供一种请求调度方法、装置、设备及介质,其方法包括:在进行请求调度时,依次遍历客户端数组中的每个客户端;在遍历当前客户端时轮询当前客户端对应的全局数组中的每个元素,直至轮询到有元素对应的索引队列不为空的目标索引队列,将处于队头的目标元素所指向的请求队列确定为目标队列,停止对当前客户端的轮询,从目标队列中获取请求添加至待执行队列,继续遍历下一客户端,在遍历过程中,并发执行待执行队列中的每个请求。利用本发明能够基于构建的客户端数组、请求队列及全局数组对请求进行遍历轮询,使服务端调度请求时能够无差别化对待不同请求类型,具有更高的请求并发量、请求执行吞吐量及处理效率。
-
公开(公告)号:CN115269709A
公开(公告)日:2022-11-01
申请号:CN202211208194.5
申请日:2022-09-30
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式(北京)技术有限公司
IPC分类号: G06F16/25 , G06F16/2457 , G06F16/953 , G06Q40/00
摘要: 本发明涉及大数据技术领域,提供一种基于行情数据的查询及回放方法、装置、设备及介质,其方法包括:确定向服务端发起的针对行情数据的每个请求的类型;将每个请求中的查询请求写入发送队列;获取每个请求中的回放请求的请求代码数目;根据所述请求代码数目对所述回放请求进行拆分,得到多个子请求并写入发送队列;将发送队列中的每个子请求异步发送至服务端;当接收到服务端根据每个请求返回的请求结果时,从中提取回放请求对应的目标结果;根据行情时间对目标结果进行触发式反馈。本发明能够通过对查询与回放请求的拆分,使得服务端无差别化处理查询和回放请求,实现资源的有效利用,同时实现高效且高并发的行情数据查询及回放。
-
公开(公告)号: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
申请人: 深圳华锐分布式技术股份有限公司
摘要: 本发明公开了基于资源配置的信息处理方法、装置、设备及介质,方法包括:根据配置信息对管理服务器的系统资源进行分配从而确定每一处理线程对应的递交线程,通过递交线程获取客户端反馈的递交对接参数,将接收到的交易数据分别输入所述处理线程进行处理以对处理线程内的初始数据进行更新,根据各递交线程的递交对接参数从更新后的初始数据中获取与递交对接参数对应的快照信息,通过递交线程将快照信息递交至各递交线程对接的客户端。本发明属于大数据处理的技术领域,上述方法通过处理线程对接收到的交易数据进行存储,通过递交线程获取与递交对接参数对应的快照信息,从而根据客户需求获取相应快照信息进行反馈,从而更全面地察看交易数据信息。
-
公开(公告)号:CN114666165A
公开(公告)日:2022-06-24
申请号:CN202210548383.0
申请日:2022-05-20
申请人: 深圳华锐分布式技术股份有限公司
IPC分类号: H04L9/40 , H04L67/01 , H04L67/1004 , H04L67/5651 , G06F16/953
摘要: 本发明涉及互联网领域,提供一种查询请求响应方法、装置、设备及介质,能够通过Nginx加密发送目标查询请求,以实现Nginx负载均衡,并提高数据传输的安全性,并且,通过对所述目标查询请求执行第一校验及第二校验,进一步保证了目标查询请求的有效性,在反馈查询结果时对数据进行拆分及压缩,得到多个小包,并以小包形式将查询结果发送至客户端,避免由于带宽限制影响查询结果的响应速度,提高了对目标查询请求的响应效率。
-
-
-
-
-
-
-
-
-