一种分布式消息队列的存储方法、装置、设备及可读介质

    公开(公告)号:CN113438281A

    公开(公告)日:2021-09-24

    申请号:CN202110627991.6

    申请日:2021-06-05

    Inventor: 孙俊逸

    Abstract: 本发明公开了一种分布式消息队列的存储方法,包括在分布式消息队列中任意一个节点执行以下步骤:响应于接收到消息处理请求,获取消息处理请求的主题,并判断本节点是否为主题的主节点;若是本节点为主题的主节点,将消息处理请求加入优先队列;对优先队列中的消息处理请求进行处理,并向主题的其他主节点发送请求处理响应;以及响应于接收到所有其他主节点返回的请求处理完成标识,向主题的从节点发送数据同步请求。本发明还公开了一种分布式消息队列的存储装置、计算机设备和可读存储介质。本发明通过分布式消息队列节点内部建立交互机制,降低集群的运维成本、人力成本、管理成本,保障业务的稳定运行。

    一种数据库数据传输方法、装置、设备及可读存储介质

    公开(公告)号:CN111814435A

    公开(公告)日:2020-10-23

    申请号:CN202010710074.X

    申请日:2020-07-22

    Inventor: 陶钰昕 孙俊逸

    Abstract: 本发明公开了一种数据库数据传输方法、装置、设备及计算机可读存储介质,该方法包括:获取用于执行数据库数据传输任务的第一任务文件;将第一任务文件转换为与内存计算系统相匹配的第二任务文件;将第二任务文件发送给内存计算系统,以便内存计算系统利用第二任务文件执行数据库数据传输任务;该方法在将第一任务文件转换为第二任务文件后,将第二任务文件发送给内存计算系统,以便内存计算系统利用第二任务文件执行数据库数据传输任务。通过采用计算效率更高的内存计算系统,可以提高数据库之间的数据传输速度,减少数据传输所需的时间。

    一种分布式消息队列的存储方法、装置、设备及可读介质

    公开(公告)号:CN113438281B

    公开(公告)日:2023-02-28

    申请号:CN202110627991.6

    申请日:2021-06-05

    Inventor: 孙俊逸

    Abstract: 本发明公开了一种分布式消息队列的存储方法,包括在分布式消息队列中任意一个节点执行以下步骤:响应于接收到消息处理请求,获取消息处理请求的主题,并判断本节点是否为主题的主节点;若是本节点为主题的主节点,将消息处理请求加入优先队列;对优先队列中的消息处理请求进行处理,并向主题的其他主节点发送请求处理响应;以及响应于接收到所有其他主节点返回的请求处理完成标识,向主题的从节点发送数据同步请求。本发明还公开了一种分布式消息队列的存储装置、计算机设备和可读存储介质。本发明通过分布式消息队列节点内部建立交互机制,降低集群的运维成本、人力成本、管理成本,保障业务的稳定运行。

    一种消息队列缓存自动删除方法、装置、设备、存储介质

    公开(公告)号:CN113886106A

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

    申请号:CN202111231230.5

    申请日:2021-10-22

    Inventor: 孙俊逸

    Abstract: 本发明提供一种消息队列缓存自动删除方法、装置、设备、存储介质,获取集群内主题的配置及分布信息,并依据主题状态分发主题删除请求,并生成删除队列;在接收到主题删除请求后,进行节点内实际数据块的解析,获取实际的待删除列表并将待删除列表加入删除队列;依次获取删除队列,依据列表进行数据块删除。通过设置常驻删除进程,实时解析主题消息消费状态,并在各个节点下发处理任务,通过节点内数据状态解析,实现主题缓存数据的实时删除,降低集群存储资源压力,提升集群资源利用率,减少集群存储资源不足的运维问题。

Patent Agency Ranking