公开(公告)号：CN115079926A

公开(公告)日：2022-09-20

申请号：CN202110258335.3

申请日：2021-03-10

申请人： 腾讯科技(深圳)有限公司

发明人： 涂诗云 ,  刘德志 ,  鲍明宇 ,  魏巍 ,  帅攀 ,  吕昊俣 ,  费强 ,  陈宁国 ,  郭俊杰 ,  战波

IPC分类号： G06F3/06

摘要： 本发明公开了一种消息队列的再平衡方法、装置、设备及存储介质，该方法包括：获取消息队列中各个源存储节点的存储空间信息，消息队列中的数据以数据段的形式分段存储在各个源存储节点中；根据源存储节点的存储空间信息，确定各个源存储节点中的待迁移数据；将各个源存储节点中的待迁移数据并发迁移至目标存储节点；将各个源存储节点中的待迁移数据清除。本申请实施例能够将分段存储的待迁移数据并发地迁移至目标存储节点，提高了数据迁移效率；在扩容资源较为缺乏的情况下，利用存储压力较小的存储节点进行再平衡，提高存储节点的利用率，可广泛应用于数据处理技术领域。

公开(公告)号：CN113064707B

公开(公告)日：2023-01-13

申请号：CN202110348539.6

申请日：2021-03-31

申请人： 腾讯科技(深圳)有限公司(CN)

发明人： 鲍明宇 ,  刘德志 ,  帅攀 ,  魏巍 ,  吕昊俣 ,  涂诗云 ,  陈宁国 ,  费强 ,  战波 ,  郭俊杰

IPC分类号： G06F9/48 ,  G06F9/50 ,  G06F9/54

摘要： 本申请公开了消息处理方法、装置及设备，方法包括：接收第一客户端发送的消息延迟请求，消息延迟请求包括消息类型、延迟消息集合和延迟消息集合中每个延迟消息对应的延迟时间；将延迟消息集合发送给消息系统；在消息类型为目标存储消息的情况下，根据每个延迟消息对应的恢复时间和存储系统中至少一个存储单元对应的恢复时间段，从至少一个存储单元中确定每个延迟消息对应的目标存储单元；将每个延迟消息转储于所述对应的目标存储单元；若目标存储单元对应的恢复时间段满足预设条件，由至少一个恢复系统将目标存储单元中的延迟消息恢复至消息系统。利用本申请实施例提供的技术方案至少可以实现大量延迟消息的高效处理。

公开(公告)号：CN113064707A

公开(公告)日：2021-07-02

申请号：CN202110348539.6

申请日：2021-03-31

申请人： 腾讯科技(深圳)有限公司

发明人： 鲍明宇 ,  刘德志 ,  帅攀 ,  魏巍 ,  吕昊俣 ,  涂诗云 ,  陈宁国 ,  费强 ,  战波 ,  郭俊杰

IPC分类号： G06F9/48 ,  G06F9/50 ,  G06F9/54

摘要： 本申请公开了消息处理方法、装置及设备，方法包括：接收第一客户端发送的消息延迟请求，消息延迟请求包括消息类型、延迟消息集合和延迟消息集合中每个延迟消息对应的延迟时间；将延迟消息集合发送给消息系统；在消息类型为目标存储消息的情况下，根据每个延迟消息对应的恢复时间和存储系统中至少一个存储单元对应的恢复时间段，从至少一个存储单元中确定每个延迟消息对应的目标存储单元；将每个延迟消息转储于所述对应的目标存储单元；若目标存储单元对应的恢复时间段满足预设条件，由至少一个恢复系统将目标存储单元中的延迟消息恢复至消息系统。利用本申请实施例提供的技术方案至少可以实现大量延迟消息的高效处理。