基于Redis实现的延迟消息队列

[{"title":"（ 22 个子文件 24KB ） 基于Redis实现的延迟消息队列","children":[{"title":"delay-queue-master","children":[{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"yangwenjie","children":[{"title":"delayqueue","children":[{"title":"test","children":[{"title":"TestAll.java <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"application.yaml <span style='color:#111;'> 156B </span>","children":null,"spread":false},{"title":"log4j.properties <span style='color:#111;'> 694B </span>","children":null,"spread":false},{"title":"redis.yaml <span style='color:#111;'> 1.11KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"yangwenjie","children":[{"title":"delayqueue","children":[{"title":"utils","children":[{"title":"SnowflakeIdUtil.java <span style='color:#111;'> 438B </span>","children":null,"spread":false},{"title":"RedissonUtils.java <span style='color:#111;'> 4.68KB </span>","children":null,"spread":false},{"title":"SnowflakeIdWorker.java <span style='color:#111;'> 5.54KB </span>","children":null,"spread":false}],"spread":true},{"title":"dto","children":[{"title":"Result.java <span style='color:#111;'> 1.48KB </span>","children":null,"spread":false}],"spread":true},{"title":"core","children":[{"title":"DelayQueueJob.java <span style='color:#111;'> 1.87KB </span>","children":null,"spread":false},{"title":"ScoredSortedItem.java <span style='color:#111;'> 1.11KB </span>","children":null,"spread":false},{"title":"DelayBucketHandler.java <span style='color:#111;'> 2.46KB </span>","children":null,"spread":false},{"title":"DelayQueueJobPool.java <span style='color:#111;'> 1.15KB </span>","children":null,"spread":false},{"title":"DelayBucket.java <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false},{"title":"DelayQueue.java <span style='color:#111;'> 3.17KB </span>","children":null,"spread":false},{"title":"ReadyQueue.java <span style='color:#111;'> 845B </span>","children":null,"spread":false}],"spread":true},{"title":"exception","children":[{"title":"GlobalExceptionHandler.java <span style='color:#111;'> 744B </span>","children":null,"spread":false}],"spread":true},{"title":"web","children":[{"title":"DelayQueueController.java <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false}],"spread":true},{"title":"DelayQueueApp.java <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"listener","children":[{"title":"ApplicationStartup.java <span style='color:#111;'> 893B </span>","children":null,"spread":false}],"spread":false},{"title":"Swagger2.java <span style='color:#111;'> 1.37KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 3.83KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 3.77KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]