SpringBoot整合Quartz-动态读取任务执行(2.2.1)

举报
西魏陶渊明 发表于 2022/09/25 05:37:49 2022/09/25
【摘要】 本次使用redis作为数据库,存储定时任务类 redis的连接不是重点,重点是解析序列化处理过的任务数组和Quartz如何添加任务 1. JobEntity 用来保存执行任务类 public...

本次使用redis作为数据库,存储定时任务类
redis的连接不是重点,重点是解析序列化处理过的任务数组和Quartz如何添加任务

1. JobEntity 用来保存执行任务类

public class JobEntity implements Serializable {
    //cron表达式
    private String cronExpression;
    //组名
    private String jobGroup = Scheduler.DEFAULT_GROUP;
    
    private String jobName;

    private String className; // 执行任务的类(完整路径  包含包名)

    private String methodName;//执行任务的方法名

    set ...
    get ...
}

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

2.任务类

public class Test {
    public void xun(){
        System.out.println("--------定时任务2-------");
    }
}
public class Test2 {
    public void test(){
        System.out.println("--------定时任务1-------");
    }
}

  
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

3.存入redis

public void start2() {
        Gson gson = new Gson();
        JobEntity jobEntity = new JobEntity();
        jobEntity.setMethodName("test");
        jobEntity.setJobName("MyJob2");
        jobEntity.setClassName("zebra.shjf.schedule.Test2");
        jobEntity.setCronExpression("0/1 * * * * ?");
        jobEntity.setJobGroup("MyGroup2");

        JobEntity jobEntity2 = new JobEntity();
        jobEntity2.setMethodName("xun");
        jobEntity2.setJobName("MyJob");
        jobEntity2.setClassName("zebra.shjf.schedule.Test");
        jobEntity2.setCronExpression("0/1 * * * * ?");
        jobEntity2.setJobGroup("MyGroup");

        ArrayList<JobEntity> list = new ArrayList<JobEntity>();
        list.add(jobEntity);
        list.add(jobEntity2);
        jedis.set("jobEntity", gson.toJson(list));
    }
 127.0.0.1:6379> get "jobEntity"
    "[{\"cronExpression\":\"0/1 * * * * ?\",\"jobGroup\":\"MyGroup2\",\"jobName\":\"MyJob2\",\"className\":\"zebra.shjf.schedule.Test2\",\"methodName\":\"test\"},{\"cronExpression\":\"0/1 * * * * ?\",\"jobGroup\":\"MyGroup\",\"jobName\":\"MyJob\",\"className\":\"zebra.shjf.schedule.Test\",\"methodName\":\"xun\"}]"

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

3.重点解析(注释解释)

   @Test
    public void start3() throws Exception {
        //准备添加从redis中得到的实体类,目的是遍历,然后添加到定时容器中,去执行
        ArrayList<JobEntity>arrayList=new ArrayList<JobEntity>();

        Gson gson = new Gson();
        //从redis中得到json数组对象
        String str = jedis.get("jobEntity");
        //json解析器
        JsonParser parser = new JsonParser();
        //解析出json元素,jsonElement对象中有一些方法判断是对象还是数组,各对应不同的处理
        JsonElement jsonElement = parser.parse(str);

        //如果是json数组就转换为jsonArray
        JsonArray jsonArray = null;
        if (jsonElement.isJsonArray()) {
            jsonArray = jsonElement.getAsJsonArray();
        }
        //遍历
        Iterator it= jsonArray.iterator();
        while (it.hasNext()){
            JsonElement e = (JsonElement)it.next();
            //把获得的数组中每一个对象,重新添加到数组中
            arrayList.add(gson.fromJson(e,JobEntity.class));
        }
        //容器
        Scheduler scheduler=null;
        //遍历数组
        for(JobEntity jobEntity:arrayList){
            //遍历获得每个job对象
            JobDetail jobDetail = JobBuilder.newJob(ScheduledTasks.class).withIdentity(jobEntity.getJobName(), jobEntity.getJobGroup()).//
                    usingJobData("className", jobEntity.getClassName())
                    .usingJobData("methodName", jobEntity.getMethodName()).build();
            //jobDetail.getJobDataMap().put("test", jobEntity);
            //为每个任务动态构建表达式
            CronScheduleBuilder cron = CronScheduleBuilder.cronSchedule(jobEntity.getCronExpression());
            //构建触发器
            CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobEntity.getJobName(), jobEntity.getJobGroup()).withSchedule(cron).build();

            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            scheduler = schedulerFactory.getScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
        }
        scheduler.start();

        Thread thread = new Thread();
        thread.sleep(10000);

    }
    

  
 
  • 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

文章来源: springlearn.blog.csdn.net,作者:西魏陶渊明,版权归原作者所有,如需转载,请联系作者。

原文链接:springlearn.blog.csdn.net/article/details/53858275

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。