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
2022-02-15 16:57:51 15KB redis delay-queue distributed-queue Java
1