资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/SpringCloud（第 009 篇）简单 Quartz 微服务，不支持分布式

SpringCloud（第 009 篇）简单 Quartz 微服务，不支持分布式

awkj / 3240人阅读

摘要：添加任务成功运行任务名称添加定时任务服务定时任务服务。触发器计划列表添加测试任务类测试任务类被任务调度后执行该任务类。声明一个静态变量保存添加启动类简单微服务，不支持分布式。

SpringCloud（第 009 篇）简单 Quartz 微服务，不支持分布式

-

一、大致介绍 
</>复制代码 
  1. 1、本章节仅仅只是为了测试 Quartz 在微服务中的使用情况；
  2. 2、其实若只是简单的实现任务调用而言的话，SpringBoot 的 Schedule 这个注解即可满足需求，但是注意该注解不支持分布式；
  3. 3、注意：配置文件中的 mysql 数据库链接配置大家就各自配置自己的哈；
二、实现步骤 2.1 添加 maven 引用包 
</>复制代码 
  3.     4.0.0
  4.     springms-simple-quartz
  5.     1.0-SNAPSHOT
  6.     jar
  7.     
  8.     
  9.         com.springms.cloud
  10.         springms-spring-cloud
  11.         1.0-SNAPSHOT
  12.     
  13.     
  14.     
  15.         
  16.         
  17.             org.springframework.boot
  18.             spring-boot-starter-data-jpa
  19.         
  20.         
  21.         
  22.             org.springframework.boot
  23.             spring-boot-starter-web
  24.         
  25.         
  26.         
  27.             mysql
  28.             mysql-connector-java
  29.         
  30.                
  31.         
  32.         
  33.             org.quartz-scheduler
  34.             quartz
  35.             2.3.0
  36.         
  37.         
  38.             org.quartz-scheduler
  39.             quartz-jobs
  40.             2.3.0
  41.         
  42.         
  43.             org.springframework
  44.             spring-context-support
  45.         
  46.
2.2 添加应用配置文件（springms-simple-quartz/src/main/resources/application.properties） 
</>复制代码 
  1. ################################################################################
  2. # mysql com.springms.cloud-test
  3. spring.datasource.driverClassName=com.mysql.jdbc.Driver
  4. spring.datasource.url=jdbc:mysql://ip:port/hmilyylimh
  5. spring.datasource.username=username
  6. spring.datasource.password=password
  7. spring.datasource.jpa.hibernate.ddl-auto=update
  8. spring.datasource.jpa.show-sql=true
  9. ################################################################################
  10. # embedded servlet container
  11. server.port=8390
  12. # sessionTimeout in seconds
  13. server.sessionTimeout=30000
2.3 添加Spring上下文配置文件（springms-simple-quartz/src/main/resources/applicationContext.xml） 
</>复制代码 
  3.     
  4.     
  5.         
  6.             
  7.                 classpath:application.properties
  8.             
  9.         
  10.         
  11.     
  12.     
  13.     
  14.     
  15.     
  16.         
  17.         
  18.         
  19.         
  20.         
  21.             
  22.             
  23.         
  24.             run
  25.         
  26.     
  27.     
  28.     
  29.         
  30.         
  31.         
  32.             
  33.         
  34.         
  35.             0/10 * * * * ?
  36.         
  37.     
  38.     
  39.     
  40.         
  41.             
  42.                 
  43.             
  44.         
  45.     
  46.     
  47.
2.4 添加任务调度对象类（springms-simple-quartz/src/main/java/com/springms/cloud/domain/ScheduleJob.java） 
</>复制代码 
  1. package com.springms.cloud.domain;
  2. /**
  3.  * 任务调度对象。
  4.  *
  5.  * @author hmilyylimh
  6.  *
  7.  * @version 0.0.1
  8.  *
  9.  * @date 17/9/18
  10.  *
  11.  */
  12. public class ScheduleJob {
  13.     
  14.     private String jobName;
  15.     private String jobGroup;
  16.     private String desc;
  17.     private String jobStatus;
  18.     private String cronExpression;
  19.     
  20.     public String getJobName() {
  21.         return jobName;
  22.     }
  23.     public void setJobName(String jobName) {
  24.         this.jobName = jobName;
  25.     }
  26.     public String getJobGroup() {
  27.         return jobGroup;
  28.     }
  29.     public void setJobGroup(String jobGroup) {
  30.         this.jobGroup = jobGroup;
  31.     }
  32.     public String getDesc() {
  33.         return desc;
  34.     }
  35.     public void setDesc(String desc) {
  36.         this.desc = desc;
  37.     }
  38.     public String getJobStatus() {
  39.         return jobStatus;
  40.     }
  41.     public void setJobStatus(String jobStatus) {
  42.         this.jobStatus = jobStatus;
  43.     }
  44.     public String getCronExpression() {
  45.         return cronExpression;
  46.     }
  47.     public void setCronExpression(String cronExpression) {
  48.         this.cronExpression = cronExpression;
  49.     }
  50. }
2.5 添加QuartzJobFactory（springms-simple-quartz/src/main/java/com/springms/cloud/service/QuartzJobFactory.java） 
</>复制代码 
  1. package com.springms.cloud.service;
  2. import com.springms.cloud.domain.ScheduleJob;
  3. import org.quartz.DisallowConcurrentExecution;
  4. import org.quartz.Job;
  5. import org.quartz.JobExecutionContext;
  6. import org.quartz.JobExecutionException;
  7. @DisallowConcurrentExecution
  8. public class QuartzJobFactory implements Job {
  9.     @Override
  10.     public void execute(JobExecutionContext context) throws JobExecutionException {
  11.         System.out.println("任务成功运行");
  12.         ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");
  13.         System.out.println("任务名称 = [" + scheduleJob.getJobName() + "]");
  14.     }
  15. }
2.6 添加定时任务服务（springms-simple-quartz/src/main/java/com/springms/cloud/service/ScheduleJobService.java） 
</>复制代码 
  1. package com.springms.cloud.service;
  2. import java.util.ArrayList;
  3. import java.util.List;
  4. import java.util.Set;
  5. import com.springms.cloud.task.TestTask;
  6. import com.springms.cloud.util.SpringApplicationContextUtil;
  7. import com.springms.cloud.domain.ScheduleJob;
  8. import org.quartz.CronTrigger;
  9. import org.quartz.JobKey;
  10. import org.quartz.Scheduler;
  11. import org.quartz.SchedulerException;
  12. import org.quartz.Trigger;
  13. import org.quartz.impl.matchers.GroupMatcher;
  14. import org.slf4j.Logger;
  15. import org.slf4j.LoggerFactory;
  16. import org.springframework.scheduling.quartz.SchedulerFactoryBean;
  17. /**
  18.  * 定时任务服务。
  19.  *
  20.  * @author hmilyylimh
  21.  *
  22.  * @version 0.0.1
  23.  *
  24.  * @date 17/9/18
  25.  *
  26.  */
  27. public class ScheduleJobService {
  28.     
  29.     private static final Logger Logger = LoggerFactory.getLogger(TestTask.class);
  30.     
  31.     public void getScheduleJob(){
  32.          
  33.         try {
  34.             SchedulerFactoryBean schedulerFactoryBean = SpringApplicationContextUtil.getBean("scheduler");
  35.             Scheduler scheduler = schedulerFactoryBean.getScheduler();
  36.             GroupMatcher matcher = GroupMatcher.anyJobGroup();
  37.             Set jobKeys = scheduler.getJobKeys(matcher);        
  38.             List jobList = new ArrayList();
  39.             for (JobKey jobKey : jobKeys) {
  40.                 List triggers = scheduler.getTriggersOfJob(jobKey);
  41.                 for (Trigger trigger : triggers) {
  42.                     ScheduleJob job = new ScheduleJob();
  43.                     job.setJobName(jobKey.getName());
  44.                     job.setJobGroup(jobKey.getGroup());
  45.                     job.setDesc("触发器:" + trigger.getKey());
  46.                     Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
  47.                     job.setJobStatus(triggerState.name());
  48.                     if (trigger instanceof CronTrigger) {
  49.                         CronTrigger cronTrigger = (CronTrigger) trigger;
  50.                         String cronExpression = cronTrigger.getCronExpression();
  51.                         job.setCronExpression(cronExpression);
  52.                     }
  53.                     jobList.add(job);                                       
  54.                 }
  55.             }
  56.             
  57.             for (ScheduleJob job : jobList) {
  58.                 Logger.info("计划列表,name:{},group:{},desc:{},status:{}",job.getJobName(),job.getJobGroup(),job.getDesc(),job.getJobStatus());
  59.             }
  60.             
  61.         } catch (SchedulerException e) {
  62.             Logger.error("SchedulerException", e);
  63.         }
  64.     }
  65. }
2.7 添加测试任务类（springms-simple-quartz/src/main/java/com/springms/cloud/task/TestTask.java） 
</>复制代码 
  1. package com.springms.cloud.task;
  2. import org.slf4j.Logger;
  3. import org.slf4j.LoggerFactory;
  4. /**
  5.  * 测试任务类（被任务调度后执行该任务类）。
  6.  *
  7.  * @author hmilyylimh
  8.  *
  9.  * @version 0.0.1
  10.  *
  11.  * @date 17/9/18
  12.  *
  13.  */
  14. public class TestTask {
  15.     
  16.     /** 日志对象 */
  17.     private static final Logger LOG = LoggerFactory.getLogger(TestTask.class);
  18.     
  19.     public void run() {
  20.         if (LOG.isInfoEnabled()) {
  21.             LOG.info("测试任务线程开始执行");
  22.             
  23.             //new ScheduleJobService().getScheduleJob();
  24.         }
  25.     }
  26. }
2.8 添加 Spring 上下文工具类（springms-simple-quartz/src/main/java/com/springms/cloud/util/SpringApplicationContextUtil.java） 
</>复制代码 
  1. package com.springms.cloud.util;
  2. import org.springframework.beans.BeansException;
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.ApplicationContextAware;
  5. import org.springframework.stereotype.Component;
  6. /**
  7.  * Spring 上下文工具类。
  8.  *
  9.  * @author hmilyylimh
  10.  *
  11.  * @version 0.0.1
  12.  *
  13.  * @date 17/9/18
  14.  *
  15.  */
  16. @Component
  17. public class SpringApplicationContextUtil implements ApplicationContextAware{
  18.     
  19.     // 声明一个静态变量保存   
  20.     private static ApplicationContext applicationContext;
  21.     public void setApplicationContext(ApplicationContext applicationContext)
  22.             throws BeansException {
  23.         SpringApplicationContextUtil.applicationContext=applicationContext;
  24.     }
  25.     
  26.     public static ApplicationContext getContext(){
  27.         
  28.         return applicationContext;   
  29.     }  
  30.     
  31.     @SuppressWarnings("unchecked")
  32.     public static  T getBean(String name) throws BeansException {
  33.                return (T) applicationContext.getBean(name);
  34.      }
  35. }
2.9 添加 Quartz 启动类（springms-simple-quartz/src/main/java/com/springms/cloud/SimpleQuartzApplication.java） 
</>复制代码 
  1. package com.springms.cloud;
  2. import org.slf4j.Logger;
  3. import org.slf4j.LoggerFactory;
  4. import org.springframework.beans.factory.annotation.Value;
  5. import org.springframework.boot.SpringApplication;
  6. import org.springframework.boot.context.embedded.EmbeddedServletContainerFactory;
  7. import org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainerFactory;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.ComponentScan;
  10. import org.springframework.context.annotation.Configuration;
  11. import org.springframework.context.annotation.ImportResource;
  12. import java.util.concurrent.TimeUnit;
  13. /**
  14.  * 简单 Quartz 微服务，不支持分布式。
  15.  *
  16.  * 其实若只是简单的实现任务调用而言的话，SpringBoot 的 Schedule 这个注解即可满足需求，但是注意该注解不支持分布式；
  17.  *
  18.  * @author hmilyylimh
  19.  *
  20.  * @version 0.0.1
  21.  *
  22.  * @date 2017/9/18
  23.  *
  24.  */
  25. @ComponentScan
  26. @Configuration
  27. @ImportResource("applicationContext.xml")
  28. public class SimpleQuartzApplication {
  29.     
  30.     private static final Logger Logger = LoggerFactory.getLogger(SimpleQuartzApplication.class);
  31.     
  32.     @Value("${server.port}")
  33.     private int port;
  34.     @Value("${server.sessionTimeout}")
  35.     private int sessionTimeout;    
  36.     public static void main(String[] args) {
  37.         Logger.info("简单Quartz微服务入口函数编码-" +System.getProperty("file.encoding"));
  38.                 
  39.         SpringApplication.run(SimpleQuartzApplication.class, args);
  40.         System.out.println("【【【【【【 简单Quartz微服务 】】】】】】已启动.");
  41.     }
  42.     
  43.     @Bean
  44.     public EmbeddedServletContainerFactory servletContainer() {
  45.         TomcatEmbeddedServletContainerFactory factory = new TomcatEmbeddedServletContainerFactory();
  46.         factory.setPort(port);
  47.         factory.setSessionTimeout(sessionTimeout, TimeUnit.SECONDS);
  48.         return factory;
  49.     }
  50. }
三、测试 
</>复制代码 
  1. /****************************************************************************************
  2.  一、简单Quartz微服务：
  3.  1、添加 Quartz 相关配置文件；
  4.  2、启动 springms-simple-quartz 模块服务，启动1个端口；
  5.  3、然后查看日志， TestTask 类的日志不断被定时打印出来；
  6.  总结：其实若只是简单的实现任务调用而言的话，SpringBoot 的 Schedule 这个注解即可满足需求，但是注意该注解不支持分布式；
  7.  ****************************************************************************************/
四、下载地址

https://gitee.com/ylimhhmily/SpringCloudTutorial.git

SpringCloudTutorial交流QQ群: 235322432

SpringCloudTutorial交流微信群: 微信沟通群二维码图片链接

欢迎关注，您的肯定是对我最大的支持!!!

云服务器 GPU云服务器 用阿里云服务器微信不支持访问 第1篇 第2篇 第3篇

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/70459.html

相关文章

  • SpringCloud（第 054 篇）简单 Quartz-Cluster 微服务，采用注解配置 Q

    摘要：加载配置文件失败加载配置文件失败添加定时调度任务定时调度任务添加定时调度任务定时调度任务执行的张表入数据库添加启动类简单微服务，采用注解配置分布式集群。 SpringCloud（第 054 篇）简单 Quartz-Cluster 微服务，采用注解配置 Quartz 分布式集群 - 一、大致介绍 1、因网友提到有没有采用注解式配置的Quartz例子，因此本人就贴上了这样一个样例； 2、至...

    isLishude 评论0 收藏0

  • SpringCloud（第 010 篇）简单 Quartz-Cluster 支持集群分布式且支持动态

    摘要：通过再添加其他的元素可在中放置多个触发器。停止触发器重启触发器停止触发器移除触发器添加调度的任务类调度的任务。执行的张表入数据库添加启动类简单微服务，支持集群分布式，并支持动态修改任务的执行时间。 SpringCloud（第 010 篇）简单 Quartz-Cluster 微服务，支持集群分布式，并支持动态修改 Quartz 任务的 cronExpression 执行时间 - 一、大致...

    xiyang 评论0 收藏0

  • SpringCloud（第 046 篇）注解式Schedule配置定时任务，不支持任务调度

    摘要：当前时间打印当前时间定时任务触发，操作多个添加数据，事务中任一异常，都可以正常导致数据回滚。当前时间当前时间添加微服务启动类注解式配置定时任务，不支持任务调度。 SpringCloud（第 046 篇）注解式Schedule配置定时任务，不支持任务调度 - 一、大致介绍 1、很多时候我们需要隔一定的时间去执行某个任务，为了实现这样的需求通常最普通的方式就是利用多线程来实现； 2、但是有...

    masturbator 评论0 收藏0

  • SpringCloud+quartz 定时提醒系统

    摘要：定时提醒系统之前通过做了一个定时查询系统，前几天通过编写了个升级版，功能和之前的差不多，现在来看看吧。将参数传递到类中创建事件成功，执行时间为创建时间后想要修改的话就需要这么写在实现类里面注入不了那么可以这么做这个就是模块的部分介绍了。 SpringCloud+quartz 定时提醒系统 之前通过Springboot做了一个定时查询系统，前几天通过SpringCloud编写了个升级版，...

    awokezhou 评论0 收藏0

发表评论

登陆后可评论

0条评论

awkj

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<