devbox
笔触狂放9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

redis延时任务以及其他实现方式_java操作redis实现延时任务

作者：笔触狂放9 | 2024-02-21 18:41:53

赞

踩

java操作redis实现延时任务

使用场景

  • 生成订单30分钟未支付，则自动取消

  • 生成订单60秒后,给用户发短信

方案分析

1)数据库轮询
该方案通常是在小型项目中使用，即通过一个线程定时的去扫描数据库，通过订单时间来判断是否有超时的订单，然后进行update或delete等操作（使用调度quartz实现）

<dependency>
  <groupId>org.quartz-scheduler</groupId>
  <artifactId>quartz</artifactId>
  <version>2.2.2</version>
</dependency>

  • 1
  • 2
  • 3
  • 4
  • 5
package com.rjzheng.delay1;

import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;

import org.quartz.impl.StdSchedulerFactory;


public class MyJob implements Job {
    public void execute(JobExecutionContext context)
        throws JobExecutionException {
        System.out.println("要去数据库扫描啦。。。");
    }

    public static void main(String[] args) throws Exception {
        // 创建任务
        JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
                                        .withIdentity("job1", "group1").build();

        // 创建触发器 每3秒钟执行一次
        Trigger trigger = TriggerBuilder.newTrigger()
                                        .withIdentity("trigger1", "group3")
                                        .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                                                                           .withIntervalInSeconds(3)
                                                                           .repeatForever())
                                        .build();

        Scheduler scheduler = new StdSchedulerFactory().getScheduler();

        // 将任务及其触发器放入调度器
        scheduler.scheduleJob(jobDetail, trigger);

        // 调度器开始调度任务
        scheduler.start();
    }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45

运行代码，可发现每隔3秒，输出如下

要去数据库扫描啦。。。

  • 1

优缺点
优点:

  • 简单易行，支持集群操作

缺点:

  • 对服务器内存消耗大
  • 存在延迟，比如你每隔3分钟扫描一次，那最坏的延迟时间就是3分钟
  • 假设你的订单有几千万条，每隔几分钟这样扫描一次，数据库损耗极大

2)JDK的延迟队列
该方案是利用JDK自带的DelayQueue来实现，这是一个无界阻塞队列，该队列只有在延迟期满的时候才能从中获取元素，放入DelayQueue中的对象，是必须实现Delayed接口的。
在这里插入图片描述

  • Poll():获取并移除队列的超时元素，没有则返回空
  • take():获取并移除队列的超时元素，如果没有则wait当前线程，直到有元素满足超时条件，返回结果
package com.rjzheng.delay2;

import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;


public class OrderDelay implements Delayed {
    private String orderId;
    private long timeout;

    OrderDelay(String orderId, long timeout) {
        this.orderId = orderId;

        this.timeout = timeout + System.nanoTime();
    }

    public int compareTo(Delayed other) {
        if (other == this) {

            return 0;
        }

        OrderDelay t = (OrderDelay) other;

        long d = (getDelay(TimeUnit.NANOSECONDS) -
            t.getDelay(TimeUnit.NANOSECONDS));

        return (d == 0) ? 0 : ((d < 0) ? (-1) : 1);
    }

    // 返回距离你自定义的超时时间还有多少
    public long getDelay(TimeUnit unit) {
        return unit.convert(timeout - System.nanoTime(), TimeUnit.NANOSECONDS);
    }

    void print() {
        System.out.println(orderId + "编号的订单要删除啦。。。。");
    }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
package com.rjzheng.delay2;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.TimeUnit;
public class DelayQueueDemo
{
    public static void main(String[] args)
    {
        // TODO Auto-generated method stub  
        List < String > list = new ArrayList < String > ();
        list.add("00000001");
        list.add("00000002");
        list.add("00000003");
        list.add("00000004");
        list.add("00000005");
        DelayQueue < OrderDelay > queue = newDelayQueue < OrderDelay > ();
        long start = System.currentTimeMillis();
        for(int i = 0; i < 5; i++)
        {
            //延迟三秒取出
            queue.put(new OrderDelay(list.get(i), TimeUnit.NANOSECONDS.convert(3, TimeUnit.SECONDS)));
            try
            {
                queue.take().print();
                System.out.println("After " + (System.currentTimeMillis() - start) + " MilliSeconds");
            }
            catch(InterruptedException e)
            {
                // TODO Auto-generated catch block  
                e.printStackTrace();
            }
        }
    }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
00000001编号的订单要删除啦。。。。

After 3003 MilliSeconds

00000002编号的订单要删除啦。。。。

After 6006 MilliSeconds

00000003编号的订单要删除啦。。。。

After 9006 MilliSeconds

00000004编号的订单要删除啦。。。。

After 12008 MilliSeconds

00000005编号的订单要删除啦。。。。

After 15009 MilliSeconds

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19

可以看到都是延迟3秒，订单被删除

优缺点
优点:

  • 效率高,任务触发时间延迟低。

缺点:

  • 服务器重启后，数据全部消失，怕宕机
  • 集群扩展相当麻烦 因为内存条件限制的原因，比如下单未付款的订单数太多，那么很容易就出现OOM异常
  • 代码复杂度较高

3)时间轮算法
在这里插入图片描述

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.24.Final</version>
</dependency>

  • 1
  • 2
  • 3
  • 4
  • 5
package com.rjzheng.delay3;
import io.netty.util.HashedWheelTimer;
import io.netty.util.Timeout;
import io.netty.util.Timer;
import io.netty.util.TimerTask;
import java.util.concurrent.TimeUnit;
public class HashedWheelTimerTest
{
    static class MyTimerTask implements TimerTask
    {
        boolean flag;
        public MyTimerTask(boolean flag)
        {
            this.flag = flag;
        }
        public void run(Timeout timeout) throws Exception
        {
            // TODO Auto-generated method stub
            System.out.println("要去数据库删除订单了。。。。");
            this.flag = false;
        }
    }
    public static void main(String[] argv)
    {
        MyTimerTask timerTask = new MyTimerTask(true);
        Timer timer = new HashedWheelTimer();
        timer.newTimeout(timerTask, 5, TimeUnit.SECONDS);
        int i = 1;
        while(timerTask.flag)
        {
            try
            {
                Thread.sleep(1000);
            }
            catch(InterruptedException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(i + "秒过去了");
            i++;
        }
    }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
1秒过去了

2秒过去了

3秒过去了

4秒过去了

5秒过去了

要去数据库删除订单了。。。。

6秒过去了

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13

优缺点
优点:

  • 效率高,任务触发时间延迟时间比delayQueue低，代码复杂度比delayQueue低。

缺点:

  • 服务器重启后，数据全部消失，怕宕机
  • 集群扩展相当麻烦
  • 因为内存条件限制的原因，比如下单未付款的订单数太多，那么很容易就出现OOM异常

4)redis缓存
利用redis的zset,zset是一个有序集合，每一个元素(member)都关联了一个score,通过score排序来取集合中的值

  • 添加元素:ZADD key score member [[score member] [score member] …]
  • 按顺序查询元素:ZRANGE key start stop [WITHSCORES]
  • 查询元素：score:ZSCORE key member
  • 移除元素:ZREM key member [member …]

redis操作：

# 添加单个元素
redis> ZADD page_rank 10 google.com

(integer) 1


# 添加多个元素
redis> ZADD page_rank 9 baidu.com 8 bing.com

(integer) 2

redis> ZRANGE page_rank 0 -1 WITHSCORES

1) "bing.com"
2) "8"
3) "baidu.com"
4) "9"
5) "google.com"
6) "10"

# 查询元素的score值

redis> ZSCORE page_rank bing.com
"8"

# 移除单个元素
 
redis> ZREM page_rank google.com

(integer) 1

redis> ZRANGE page_rank 0 -1 WITHSCORES

1) "bing.com"
2) "8"
3) "baidu.com"
4) "9"

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37

在这里插入图片描述

package com.rjzheng.delay4;
import java.util.Calendar;
import java.util.Set;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Tuple;
public class AppTest
{
 private static final String ADDR = "127.0.0.1";
 private static final int PORT = 6379;
 private static JedisPool jedisPool = new JedisPool(ADDR, PORT);
 public static Jedis getJedis()
  {
   return jedisPool.getResource();
  }
  //生产者,生成5个订单放进去
 public void productionDelayMessage()
  {
   for(int i = 0; i < 5; i++)
   {
    //延迟3秒
    Calendar cal1 = Calendar.getInstance();
    cal1.add(Calendar.SECOND, 3);
    int second3later = (int)(cal1.getTimeInMillis() / 1000);
    AppTest.getJedis().zadd("OrderId", second3later, "OID0000001" + i);
    System.out.println(System.currentTimeMillis() + "ms:redis生成了一个订单任务：订单ID为" + "OID0000001" + i);
   }
  }
  //消费者，取订单
 public void consumerDelayMessage()
 {
  Jedis jedis = AppTest.getJedis();
  while(true)
  {
   Set < Tuple > items = jedis.zrangeWithScores("OrderId", 0, 1);
   if(items == null || items.isEmpty())
   {
    System.out.println("当前没有等待的任务");
    try
    {
     Thread.sleep(500);
    }
    catch(InterruptedException e)
    {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
    continue;
   }
   int score = (int)((Tuple) items.toArray()[0]).getScore();
   Calendar cal = Calendar.getInstance();
   int nowSecond = (int)(cal.getTimeInMillis() / 1000);
   if(nowSecond >= score){
    String orderId = ((Tuple) items.toArray()[0]).getElement();
    Long num =jedis.zrem("OrderId", orderId);
    <--对ZREM的返回值进行判断，只有大于0的时候，才消费数据!>
   if(num != null && num > 0){
    System.out.println(System.currentTimeMillis() + "ms:redis消费了一个任务：消费的订单OrderId为" + orderId);
    }
   }
  }
 }
 public static void main(String[] args)
 {
  AppTest appTest = new AppTest();
  appTest.productionDelayMessage();
  appTest.consumerDelayMessage();
 }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69

上测试代码

package com.rjzheng.delay4;
import java.util.concurrent.CountDownLatch;
public class ThreadTest
{
 private static final int threadNum = 10;
 private static CountDownLatch cdl = newCountDownLatch(threadNum);
 static class DelayMessage implements Runnable
 {
  public void run()
  {
   try
   {
    cdl.await();
   }
   catch(InterruptedException e)
   {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   AppTest appTest = new AppTest();
   appTest.consumerDelayMessage();
  }
 }
 public static void main(String[] args)
 {
  AppTest appTest = new AppTest();
  appTest.productionDelayMessage();
  for(int i = 0; i < threadNum; i++)
  {
   new Thread(new DelayMessage()).start();
   cdl.countDown();
  }
 }
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/笔触狂放9/article/detail/125751
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号