-
公开(公告)号:CN116418896B
公开(公告)日:2023-08-22
申请号:CN202310675911.3
申请日:2023-06-08
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式技术(长沙)有限公司
摘要: 本发明涉及计算机技术领域,提供一种基于定时器的任务执行方法、装置、设备及介质,能够在消息发送端向分布式主备高可用消息接收端集群中的每个接收节点同步下发消息的过程中,时钟驱动源集群按照预设发送间隔持续向每个接收节点同步发送时间片消息,每个接收节点基于预设发送间隔及时间片消息构建逻辑时钟,并根据逻辑时钟及消息发送端下发的消息执行对应的任务,通过引入时钟驱动源集群作为定时器,使分布式主备高可用集群在执行任务时能够保持一致性。
-
公开(公告)号:CN116455997A
公开(公告)日:2023-07-18
申请号:CN202310689199.2
申请日:2023-06-12
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式技术(长沙)有限公司
IPC分类号: H04L69/22 , H04L69/24 , H04L51/06 , H04L51/18 , H04L51/214
摘要: 本发明涉及大数据技术领域,提供一种STEP行情多路转发方法、装置、设备及介质,能够获取下发STEP协议格式的原始行情消息的行情网关作为目标发送方,及获取转发原始行情消息后用于消费消息的行情消费方作为目标接收方,利用原始行情消息中的原始校验和、原始消息体长度、原始发送方ID、原始接收方ID,及目标发送方ID、目标接收方ID、目标消息体长度进行计算得到目标校验和,计算时只关注变动的字段,降低了计算量,提升了计算效率,基于目标校验和、目标发送方ID、目标接收方ID及目标消息体长度对原始行情消息进行转换得到目标行情消息并转发,能够有效降低STEP行情多路转发时的时延,提升转发效率。
-
公开(公告)号:CN116418896A
公开(公告)日:2023-07-11
申请号:CN202310675911.3
申请日:2023-06-08
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式技术(长沙)有限公司
摘要: 本发明涉及计算机技术领域,提供一种基于定时器的任务执行方法、装置、设备及介质,能够在消息发送端向分布式主备高可用消息接收端集群中的每个接收节点同步下发消息的过程中,时钟驱动源集群按照预设发送间隔持续向每个接收节点同步发送时间片消息,每个接收节点基于预设发送间隔及时间片消息构建逻辑时钟,并根据逻辑时钟及消息发送端下发的消息执行对应的任务,通过引入时钟驱动源集群作为定时器,使分布式主备高可用集群在执行任务时能够保持一致性。
-
公开(公告)号:CN116455997B
公开(公告)日:2023-08-22
申请号:CN202310689199.2
申请日:2023-06-12
申请人: 深圳华锐分布式技术股份有限公司 , 华锐分布式技术(长沙)有限公司
IPC分类号: H04L69/22 , H04L69/24 , H04L51/06 , H04L51/18 , H04L51/214
摘要: 本发明涉及大数据技术领域,提供一种STEP行情多路转发方法、装置、设备及介质,能够获取下发STEP协议格式的原始行情消息的行情网关作为目标发送方,及获取转发原始行情消息后用于消费消息的行情消费方作为目标接收方,利用原始行情消息中的原始校验和、原始消息体长度、原始发送方ID、原始接收方ID,及目标发送方ID、目标接收方ID、目标消息体长度进行计算得到目标校验和,计算时只关注变动的字段,降低了计算量,提升了计算效率,基于目标校验和、目标发送方ID、目标接收方ID及目标消息体长度对原始行情消息进行转换得到目标行情消息并转发,能够有效降低STEP行情多路转发时的时延,提升转发效率。
-
公开(公告)号:CN115168056A
公开(公告)日:2022-10-11
申请号:CN202211069820.7
申请日:2022-09-02
申请人: 深圳华锐分布式技术股份有限公司
摘要: 本发明公开了基于资源配置的信息处理方法、装置、设备及介质,方法包括:根据配置信息对管理服务器的系统资源进行分配从而确定每一处理线程对应的递交线程,通过递交线程获取客户端反馈的递交对接参数,将接收到的交易数据分别输入所述处理线程进行处理以对处理线程内的初始数据进行更新,根据各递交线程的递交对接参数从更新后的初始数据中获取与递交对接参数对应的快照信息,通过递交线程将快照信息递交至各递交线程对接的客户端。本发明属于大数据处理的技术领域,上述方法通过处理线程对接收到的交易数据进行存储,通过递交线程获取与递交对接参数对应的快照信息,从而根据客户需求获取相应快照信息进行反馈,从而更全面地察看交易数据信息。
-
公开(公告)号:CN111274050B
公开(公告)日:2024-04-30
申请号:CN202010057742.3
申请日:2020-01-19
申请人: 深圳华锐分布式技术股份有限公司
IPC分类号: G06F9/54
摘要: 本申请涉及一种业务数据转发方法、装置、计算机设备和存储介质。所述方法包括:确定与本地对接的多于一条的数据传输线路;确定数据传输线路的运行状态,并接收处于良好状态的数据传输线路所传输的业务数据;对接收到的业务数据添加相应的数据标识;当添加的所述数据标识首次出现时,直接将接收到的业务数据发送至业务数据消费系统;发送的业务数据用于指示业务数据消费系统基于业务数据进行业务处理;当添加的数据标识重复出现时,丢弃与重复出现的数据标识对应的业务数据。采用本方法能够提升业务数据处理准确性。
-
公开(公告)号: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接口,将待下发快照下发至对快照数据发起实时订阅请求的客户端,并利用异步缓存线程对待下发快照进行旁路缓存,一方面优先对快照数据及时进行实时下发,另一方面通过缓存技术进行快照存储,以便后续下发时直接从缓存中获取快照,提升行情快照的下发效率,当接收到任意客户端发起的快照订阅请求时,基于缓存进行滤重处理得到滤重结果,根据滤重结果生成对任意客户端的快照下发策略并更新下发滤重记录,避免快照重复下发。
-
公开(公告)号:CN115168056B
公开(公告)日:2022-12-02
申请号:CN202211069820.7
申请日:2022-09-02
申请人: 深圳华锐分布式技术股份有限公司
摘要: 本发明公开了基于资源配置的信息处理方法、装置、设备及介质,方法包括:根据配置信息对管理服务器的系统资源进行分配从而确定每一处理线程对应的递交线程,通过递交线程获取客户端反馈的递交对接参数,将接收到的交易数据分别输入所述处理线程进行处理以对处理线程内的初始数据进行更新,根据各递交线程的递交对接参数从更新后的初始数据中获取与递交对接参数对应的快照信息,通过递交线程将快照信息递交至各递交线程对接的客户端。本发明属于大数据处理的技术领域,上述方法通过处理线程对接收到的交易数据进行存储,通过递交线程获取与递交对接参数对应的快照信息,从而根据客户需求获取相应快照信息进行反馈,从而更全面地察看交易数据信息。
-
公开(公告)号:CN115082246A
公开(公告)日:2022-09-20
申请号:CN202210980007.9
申请日:2022-08-16
申请人: 深圳华锐分布式技术股份有限公司
摘要: 本发明涉及大数据技术领域,提供一种ETF基金净值指标计算方法、装置、设备及介质,其方法包括:根据每只股票的逐笔成交数据及逐笔委托数据实时构建每只股票的剩余未成交订单队列;确定目标ETF基金所包含的每只子股票;获取每只子股票的剩余未成交订单队列作为每只子股票的目标队列;根据每只子股票的目标队列计算目标ETF基金的净值指标队列。本发明能够利用逐笔成交数据及逐笔委托数据实时计算ETF基金净值指标,发布频率更高,并且通过逐笔构建ETF基金净值指标的方式,能够形成ETF基金的净值指标队列,进而提供更加全面的委托分布情况,提高了行情深度,进而能够提供更加全面的股票交易决策依据。
-
-
-
-
-
-
-
-
-