shortlink幂等
2024-07-13 17:25:34 0 举报
shortlink幂等
作者其他创作
大纲/内容
Y
结束
设置预消费标识的value=1
Y,曾尝试消费失败,但未删除标识
stream未收到ack,会认为消费失败,重新向发送该消息
N,key已存在
N,已完成消费
消息id作为key放入redis(setIfAbsent)
N,发生异常
删除redis中的预消费标识,并抛出异常
从stream中移除该消息
value=0
执行消费逻辑
Y,从未消费过,或消费失败,标识被删除/过期
收藏
0 条评论
下一页