消息处理的方法、装置、电子设备和存储介质

    公开(公告)号:CN116132523A

    公开(公告)日:2023-05-16

    申请号:CN202310027533.8

    申请日:2023-01-09

    发明人: 罗蕾 胡江 陈大平

    摘要: 本发明公开了消息处理的方法、装置、电子设备和存储介质,涉及大数据分析技术领域。该方法的一具体实施方式包括:响应于当前时间不属于禁发时间段,从禁发队列中读取预设数量的待处理消息,获取各待推送消息中的优先级标识,以将各待推送消息存储至优先级标识对应的消息队列;获取各待处理消息的处理时间信息,响应于处理时间信息不满足预设条件,基于处理时间信息和预设的标准时间信息,计算操作等待时间,以等待在操作等待时间后,从禁发队列中读取预设数量的待处理消息。该实施方式能够解决在推送消息数量较多时,延迟推送的消息会大量积累,此时如果同时进行消息推送,很容易导致系统压力过大,导致系统无法平稳运行的问题。

    一种数据库迁移方法、装置、设备、存储介质及产品

    公开(公告)号:CN118467499A

    公开(公告)日:2024-08-09

    申请号:CN202410510354.4

    申请日:2024-04-26

    摘要: 本发明公开了一种数据库迁移方法、装置、设备、存储介质及产品,涉及大数据技术领域。该数据库迁移方法包括:响应于接收到的携带待更新数据的数据更新指令,获取待更新数据在源数据库中对应的目标数据库表标识;基于目标数据库表标识在源数据库和目标数据库中进行待更新数据的同步更新;在待更新数据对应的数据保留有效期内,根据目标数据库和源数据库中待更新数据所属待更新数据库表的数据一致性情况确定对应的数据迁移成功情况。通过基于待更新数据在源数据库中对应的目标数据库表标识,分别对源数据库和目标数据库进行同步更新,并在到达数据保留有效期后完成源数据库和目标数据库的数据同步,实现了数据库的不停业切换,应用场景广泛。

    消息处理方法、装置、服务端、用户端、系统、介质及产品

    公开(公告)号:CN118277130A

    公开(公告)日:2024-07-02

    申请号:CN202410484687.4

    申请日:2024-04-22

    摘要: 本发明公开了一种消息处理方法、装置、服务端、用户端、系统、介质及产品。本发明涉及数据处理技术领域。该方法包括:获取用户端对于目标组件的离线消息的当前消息请求,其中携带上一次消息请求对应的第一时间戳;访问第一数据库以查询目标组件的离线消息最新一次更新对应的第二时间戳;在第一时间戳和第二时间戳不同的情况下访问第二数据库,将查询到的待发送至用户端的离线消息以及第二时间戳发送至用户端。通过在每次消息请求中携带上一次消息请求所确定的离线消息有更新的时间戳,在其与离线消息最新一次更新的时间戳不同时确定离线消息发生更新并访问离线消息数据库,可减少不必要的查询,降低数据库访问压力,提高组件离线消息的处理效率。

    一种扩容方法、装置、电子设备及计算机可读介质

    公开(公告)号:CN114281880A

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

    申请号:CN202111629225.X

    申请日:2021-12-28

    摘要: 本发明公开了一种扩容方法、装置、电子设备及计算机可读介质,涉及大数据数据存储技术领域。该方法的一具体实施方式包括:查找原始数据库集群存储的大Key数据,将所述大Key数据导出到本地文件,导出成功后,删除所述原始数据库集群的大Key数据;对所述原始数据库集群进行扩容,在扩容过程中,将所述原始数据库集群存储的非大Key数据迁移到扩容后的新数据库集群;确定所述新数据库集群的非大Key数据与所述原始数据库集群的非大Key数据相一致,将所述本地文件的大Key数据导入至所述新数据库集群。该实施方式实现了大Key数据的单独处理,避免了由于大Key数据导致的超时失败,保证了扩容过程的安全可控和平稳运行。

    一种消息推送方法、装置、设备及存储介质

    公开(公告)号:CN113296980A

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

    申请号:CN202110558273.8

    申请日:2021-05-21

    IPC分类号: G06F9/54 G06F9/50

    摘要: 本发明公开了一种消息推送方法、装置、设备及存储介质,涉及互联网技术领域。该方法包括:获取待推送消息的数量、历史推送速度和预期资源利用率;若所述待推送消息的数量大于阈值,则根据所述预期资源利用率和所述历史推送速度确定当前推送速度;以所述当前推送速度向终端推送所述待推送消息,通过本发明的技术方案,能够根据终端的历史推送速度和预期资源利用率调整消息推送速度,使终端的资源利用率稳定达到预期,使硬件资源得到充分利用,避免硬件资源的浪费。