-
公开(公告)号:CN113438281A
公开(公告)日:2021-09-24
申请号:CN202110627991.6
申请日:2021-06-05
Applicant: 济南浪潮数据技术有限公司
Inventor: 孙俊逸
Abstract: 本发明公开了一种分布式消息队列的存储方法,包括在分布式消息队列中任意一个节点执行以下步骤:响应于接收到消息处理请求,获取消息处理请求的主题,并判断本节点是否为主题的主节点;若是本节点为主题的主节点,将消息处理请求加入优先队列;对优先队列中的消息处理请求进行处理,并向主题的其他主节点发送请求处理响应;以及响应于接收到所有其他主节点返回的请求处理完成标识,向主题的从节点发送数据同步请求。本发明还公开了一种分布式消息队列的存储装置、计算机设备和可读存储介质。本发明通过分布式消息队列节点内部建立交互机制,降低集群的运维成本、人力成本、管理成本,保障业务的稳定运行。
-
公开(公告)号:CN111814435A
公开(公告)日:2020-10-23
申请号:CN202010710074.X
申请日:2020-07-22
Applicant: 济南浪潮数据技术有限公司
IPC: G06F40/151 , G06F16/28 , G06F16/25 , G06F16/182
Abstract: 本发明公开了一种数据库数据传输方法、装置、设备及计算机可读存储介质,该方法包括:获取用于执行数据库数据传输任务的第一任务文件;将第一任务文件转换为与内存计算系统相匹配的第二任务文件;将第二任务文件发送给内存计算系统,以便内存计算系统利用第二任务文件执行数据库数据传输任务;该方法在将第一任务文件转换为第二任务文件后,将第二任务文件发送给内存计算系统,以便内存计算系统利用第二任务文件执行数据库数据传输任务。通过采用计算效率更高的内存计算系统,可以提高数据库之间的数据传输速度,减少数据传输所需的时间。
-
公开(公告)号:CN113438281B
公开(公告)日:2023-02-28
申请号:CN202110627991.6
申请日:2021-06-05
Applicant: 济南浪潮数据技术有限公司
Inventor: 孙俊逸
IPC: H04L67/1097 , H04L67/1095 , H04L41/0631 , H04L67/55
Abstract: 本发明公开了一种分布式消息队列的存储方法,包括在分布式消息队列中任意一个节点执行以下步骤:响应于接收到消息处理请求,获取消息处理请求的主题,并判断本节点是否为主题的主节点;若是本节点为主题的主节点,将消息处理请求加入优先队列;对优先队列中的消息处理请求进行处理,并向主题的其他主节点发送请求处理响应;以及响应于接收到所有其他主节点返回的请求处理完成标识,向主题的从节点发送数据同步请求。本发明还公开了一种分布式消息队列的存储装置、计算机设备和可读存储介质。本发明通过分布式消息队列节点内部建立交互机制,降低集群的运维成本、人力成本、管理成本,保障业务的稳定运行。
-
公开(公告)号:CN113886106A
公开(公告)日:2022-01-04
申请号:CN202111231230.5
申请日:2021-10-22
Applicant: 济南浪潮数据技术有限公司
Inventor: 孙俊逸
Abstract: 本发明提供一种消息队列缓存自动删除方法、装置、设备、存储介质,获取集群内主题的配置及分布信息,并依据主题状态分发主题删除请求,并生成删除队列;在接收到主题删除请求后,进行节点内实际数据块的解析,获取实际的待删除列表并将待删除列表加入删除队列;依次获取删除队列,依据列表进行数据块删除。通过设置常驻删除进程,实时解析主题消息消费状态,并在各个节点下发处理任务,通过节点内数据状态解析,实现主题缓存数据的实时删除,降低集群存储资源压力,提升集群资源利用率,减少集群存储资源不足的运维问题。