delay-queue:JDK实现的本地delayQueue和基于分布式Redis的两种分布式-源码

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