延时队列方式

你的名字 2023-03-13 09:23 19阅读 0赞

**一、（定期轮询或者无限循环）实现延迟任务（数据库、缓存、Map、List、线程、线程池等）**  
待续…

import java.time.Instant;
    import java.time.LocalDateTime;
    import java.util.HashMap;
    import java.util.Iterator;
    import java.util.Map;
    
    public class DelayTask { 
    
        // 存放定时任务
        private static Map<String, Long> TASK_MAP = new HashMap<>();
    
        public static void main(String[] args) { 
            // 添加定时任务 延迟 3s
            TASK_MAP.put("task", Instant.now().plusSeconds(3).toEpochMilli());
            // 调用延迟任务
            loopTask();
        }
    
        /** * 实现延迟任务 */
        public static void loopTask() { 
            while (true) { 
                Iterator it = TASK_MAP.entrySet().iterator();
                while (it.hasNext()) { 
                    Map.Entry entry = (Map.Entry) it.next();
                    // 有任务需要执行
                    if (System.currentTimeMillis() >= Long.valueOf(entry.getValue().toString())) { 
                        // 延迟任务 业务逻辑执行
                        System.out.println("任务执行, 时间：" + LocalDateTime.now());
                        // 删除任务
                        TASK_MAP.remove(entry.getKey());
                    }
                }
            }
        }
    
    }

**二、（DelayQueue和ScheduledExecutorService）JAVA API 实现延迟任务**  
待续…

**三、Timer与TimerTask 实现延迟任务**

import java.time.LocalDateTime;
    import java.util.Timer;
    import java.util.TimerTask;
    
    public class TimerJob { 
    
        public static void main(String[] args) { 
            //定时3秒,调用关闭方法
            Timer timer = new Timer();
            timer.schedule(new TimerTask() { 
                @Override
                public void run() { 
                    System.out.println("任务执行, 时间：" + LocalDateTime.now());
                } }, 10000);
        }
    }

**四、Netty提供的HashedWheelTimer工具类 实现延迟任务**  
待续…

**五、时间轮(kafka) 实现延迟任务**  
待续…

**六、RabbitMQ死信队列 实现延迟任务**  
待续…

**七、RabbitMQ 延迟消息插件 rabbitmq-delayed-message-exchange 实现延迟任务**  
待续…

**八、Quartz 实现延时任务**  
待续…

**九、Redis Zset 实现延时任务**  
待续…

**十、Redis 键空间通知的方式 实现延时任务**  
待续…

**十一、Koala 实现延时任务**  
待续…

**十二、JCronTab 实现延时任务**  
待续…

**十三、SchedulerX（阿里） 实现延时任务**

参考：[SchedulerX定时任务代码实现][SchedulerX]

**十四、Spring Scheduled 实现延时任务**

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.scheduling.annotation.EnableScheduling;
    
    @SpringBootApplication
    @EnableScheduling
    public class FaceaddApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(FaceaddApplication.class, args);
        }
    
    }

import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Service;
    
    import java.time.LocalDateTime;
    
    /** * @author nick */
    @Service
    public class ScheduleJobs { 
    
        @Scheduled(fixedDelay = 2 * 1000)
        public void fixedDelayJob() { 
            System.out.println("任务执行, 时间：" + LocalDateTime.now());
        }
    }

**十五、有赞延迟队列**

待续…

[SchedulerX]: https://blog.csdn.net/qq_32447301/article/details/106064053