一种实现消息队列自动重推的处理方法
公开
摘要
本发明公开了一种基于实现消息队列自动重推的处理方法,具体步骤如下:在发送数据到消息队列前,将消息唯一标识(ID)存入到数据库或者缓存中间件中,设置分值作为自动重推的时间戳;消息接收方收到消息之后,使用通过连接数据库、删除缓存中间件的数据的方式,将消息唯一标识(ID)删除,表示消息已接收;使用自动任务定时查询数据库或查询缓存中间件读取未被消息接收方的数据,并进行消息数据反查,最终实现消息补推。如果尝试多次推送之后仍未能推送完毕,则放弃补推,保存消息到数据库中。本发明完善地解决了“消息队列无法保证消息绝不丢失”的情况,在实际应用中可解决消息数据丢失后需要人工介入的问题。
基本信息
专利标题 :
一种实现消息队列自动重推的处理方法
专利标题(英):
暂无
公开(公告)号 :
CN114528153A
申请号 :
CN202111669756.1
公开(公告)日 :
2022-05-24
申请日 :
2021-12-30
授权号 :
暂无
授权日 :
暂无
发明人 :
郑奕凯
申请人 :
天翼电子商务有限公司
申请人地址 :
北京市西城区阜成门外大街31号4层429D
代理机构 :
代理人 :
优先权 :
CN202111669756.1
主分类号 :
G06F11/14
IPC分类号 :
G06F11/14 G06F16/22 G06F16/23 G06F16/2458 G06F9/54
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F11/00
错误检测;错误校正;监控
G06F11/07
响应错误的产生,例如,容错
G06F11/14
用运算中的冗余作数据的错误检测或校正,例如,通过采用导致相同结果的不同运算序列
法律状态
2022-05-24 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载