一种分布式环境协调消费队列方法和装置
Abstract:
本申请实施例提供了一种分布式环境协调消费队列方法和装置,涉及分布式技术领域。所述方法包括:针对一待消费的队列分片,基于租赁协议获取的所述队列分片的状态数据;根据所述状态数据,判断是否有其他客户端在消费所述队列分片;如果确定没有其他客户端在消费所述队列分片,则更新所述队列分片的状态数据,并获取所述队列分片当前的消费进度;根据当前的消费进度继续消费所述队列分片,并将所述队列分片新的消费进度进行记录。本申请可以在负载均衡、某个客户端宕掉等情况下,在当前客户端A抢占其他客户端正在消费的队列分片时,队列分片的消费进度可以无缝传递到当前客户端中,避免部分数据的重复消费,使消费结果更精确。
Public/Granted literature
Patent Agency Ranking
0/0