基于Springbootredis实现延时队列

　　什么是延迟队列？
　　首先，队列这种数据结构相信大家都不陌生，它是一种先进先出的数据结构。普通队列中的元素是有序的，先进入队列中的元素会被优先取出进行消费；
　　延时队列相比于普通队列最大的区别就体现在其延时的属性上，普通队列的元素是先进先出，按入队顺序进行处理，而延时队列中的元素在入队时会指定一个延迟时间，表示其希望能够在经过该指定时间后处理。从某种意义上来讲，延迟队列的结构并不像一个队列，而更像是一种以时间为权重的有序堆结构。应用场景下单成功后，X分钟内没有支付，自动取消订单外卖场景，快要超时时给外卖小哥发送提醒通知预定的会议开始前X分钟提醒等等方案JDK中DelayQueue相关APIQuartzRedisZset（本文）MQ等等实现
　　本文使用RedisZset来实现延迟队列。
　　zset是Redis提供的最具特色的数据类型之一，首先它是一个set，这保证了内部value值的唯一性，其次它给每个value添加了一个score（分值）属性，通过对分值的排序实现了有序化。比如用zset结构来存储学生的成绩，value值代表学生的ID，score则是的考试成绩。我们可以对成绩按分数进行排序从而得到学生的的名次。
　　1、pom。xmldependencygroupIdorg。springframework。bootgroupIdspringbootstarterdataredisartifactIddependency
　　application。ymlspring：redis：host：localhostport：6379password：xxxdatabase：1
　　2、延迟任务对象定义publicinterfaceRedisDelayTask｛任务IDreturnStringgetId（）；队列中的值returnStringgetValue（）；延迟时间（单位：s）returnlonggetDelayTime（）；任务执行voidexecute（）；｝抽象任务publicabstractclassAbstractRedisDelayTaskimplementsRedisDelayTask｛protectedStringid；protectedStringvalue；privatelongdelayTime；publicAbstractRedisDelayTask（Stringid，Stringvalue，longdelayTime）｛this。idid；this。valuevalue；this。delayTimedelayTime；｝OverridepublicStringgetId（）｛returnid；｝publicvoidsetId（Stringid）｛this。idid；｝OverridepublicStringgetValue（）｛returnvalue；｝publicvoidsetValue（Stringvalue）｛this。valuevalue；｝OverridepubliclonggetDelayTime（）｛returndelayTime；｝publicvoidsetDelayTime（longdelayTime）｛this。delayTimedelayTime；｝OverridepublicStringtoString（）｛returnRedisDelayTask｛idid，valuevalue，delayTimedelayTime｝；｝｝
　　3、通知类任务定义publicclassNoticeTaskextendsAbstractRedisDelayTask｛privatefinalstaticLoggerLOGGERLoggerFactory。getLogger（NoticeTask。class）；publicNoticeTask（Stringid，Stringvalue，longdelayTime）｛super（id，value，delayTime）；｝Overridepublicvoidexecute（）｛LOGGER。info（taskexecute，｛｝，this）；｝｝
　　4、任务管理ComponentpublicclassRedisDelayQueueManagerimplementsInitializingBean｛AutowiredprivateStringRedisTemplateredisTemplate；任务列表privateMapString，RedisDelayTasktasksnewConcurrentHashMap（）；添加延迟任务到队列paramtaskpublicvoidaddTask（RedisDelayTasktask）｛longdelayedTimeSystem。currentTimeMillis（）TimeUnit。MILLISECONDS。convert（task。getDelayTime（），TimeUnit。SECONDS）；booleanrredisTemplate。opsForZSet（）。add（task。getId（），task。getValue（），delayedTime）；if（r）｛tasks。put（task。getId（），task）；｝｝检查并执行任务privatevoidcheckAndExecuteTask（）｛while（true）｛SetStringtaskIdstasks。keySet（）；for（StringtaskId：taskIds）｛score就是任务要执行的时间点，如果当前时间，说明任务该执行了SetZSetOperations。TypedTupleStringtuplesredisTemplate。opsForZSet（）。rangeByScoreWithScores（taskId，0，System。currentTimeMillis（））；if（！CollectionUtils。isEmpty（tuples））｛for（ZSetOperations。TypedTupleStringtuple：tuples）｛移除并执行任务RedisDelayTasktasktasks。remove（taskId）；if（task！null）｛task。execute（）；从队列中删除redisTemplate。opsForZSet（）。remove（taskId，tuple。getValue（））；｝｝｝｝｝｝OverridepublicvoidafterPropertiesSet（）throwsException｛新起一个线程执行任务newThread（（）｛checkAndExecuteTask（）；｝，redisdelaytask）。start（）；｝｝
　　5、测试RunWith（SpringRunner。class）SpringBootTest（classesRedisApplication。class）publicclassRedisDelayTaskTest｛AutowiredprivateRedisDelayQueueManagerredisDelayQueueManager；TestpublicvoidaddTask（）throwsIOException｛NoticeTasktasknewNoticeTask（noticetask，noticetaskvalue，5）；redisDelayQueueManager。addTask（task）；NoticeTasktask2newNoticeTask（noticetask2，noticetaskvalue2，10）；redisDelayQueueManager。addTask（task2）；System。in。read（）；｝｝
　　执行结果如下：2022012217：27：53。428INFO86506〔main〕io。lettuce。core。KqueueProvider：Startingwithoutoptionalkqueuelibrary
　　2022012217：27：58。140INFO86506〔edisdelaytask〕c。springboot。demo。redis。task。NoticeTask：taskexecute，RedisDelayTask｛idnoticetask，valuenoticetaskvalue，delayTime5｝
　　2022012217：28：03。925INFO86506〔edisdelaytask〕c。springboot。demo。redis。task。NoticeTask：taskexecute，RedisDelayTask｛idnoticetask2，valuenoticetaskvalue2，delayTime10｝