delay-queue
local delayQueue implemented by JDK & two kinds of distributed delayQueue based redis
1. 基本介绍
RedisSynDelayQueue
基于redis,并发情况下会加分布式锁,单线程场景(syn=false)性能较好, 并发场景性能较差
若在并发场景下,设置syn=false,会导致消息重复消费、消息丢失的情况
支持delay时间的动态调整
RedisConcurrentDelayQueue:star:
基于redis,支持在无分布式锁的情况下进行并发消费
autoAck为true时,吞吐量性能极好,autoAck为false,吞吐量会稍有下降
支持delay时间的动态调整
autoAck为false时,必须在处理完消息后手动调用ack方法,否则会导致应用重启后重新开始消费
JDKDe
1