`
liujiekasini0312
  • 浏览: 147659 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

定时任务-quartz的使用，实现可页面化管理 标签： quartz

 
阅读更多
定时任务-quartz的使用，实现可页面化管理
使用spring+quartz实现定时任务的页面化管理。主要特点：
1.时间表达式等信息配置在数据库中，从而实现页面化管理。
2.可以手动执行或者停止单个任务，也可以使一个任务加入或者移出自动运行列表。

下面开始介绍用法，在这之前先说明框架的版本。spring3.2.4+quartz1.6.0
一.配置文件
只需要在spring的配置文件中加入：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. <beanid="scheduler"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
  2. </bean>
  3. <beanid="jobManager"class="com.temobi.quartz.JobManager">
  4. </bean>

说明：scheduler对象是spring管理定时任务的对象。
jobManager是我们自定义加载定时任务列表的对象，此对象加载所有任务列表后，将他们加入到自动运行列表。
二.jobManager代码：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. publicclassJobManagerimplementsInitializingBean{
  2. privatestaticfinalLoglog=LogFactory.getLog(JobManager.class);
  3. @Autowired
  4. TaskJobServicetaskJobService;
  5. @Autowired
  6. QuartzManagerquartzManager;
  7. @Override
  8. publicvoidafterPropertiesSet()throwsException{
  9. loadAllJob();
  10. }
  11. privatevoidloadAllJob(){
  12. List<TaskJob>list=taskJobService.getTaskList();
  13. quartzManager.enableCronSchedule(list);
  14. }
  16. }


说明：
1.实现spring中InitializingBean接口，并覆盖afterPropertiesSet方法，则该方法会在应用启动的时候而且其他servlet执行完成之后执行，此处用来加载所有定时任务，并加入定时任务自动运行列表。
2.quartzManager是我们自定义的定时任务管理类，用来实现我们文章开头说的功能。
三.QuartzManager代码
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassQuartzManager{
  3. @Autowired
  4. Schedulerscheduler;
  6. privatestaticfinalLoglog=LogFactory.getLog(QuartzManager.class);
  7. publicvoidenableCronSchedule(List<TaskJob>list){
  8. for(TaskJobtask:list){
  9. SchedulingJobjob=newSchedulingJob();
  10. job.setJobId(task.getId());
  11. job.setJobName(task.getJobName());
  12. //job.setMemos(task.getNote());
  13. job.setCronExpression(task.getJobCronExpression());
  14. try{
  15. StringclassName=task.getJobClass().trim();
  16. Classclazz=Class.forName(className);
  17. job.setStateFulljobExecuteClass(clazz);
  18. }catch(Exceptione){
  19. e.printStackTrace();
  20. continue;
  21. }
  22. JobDataMapparamsMap=newJobDataMap();
  23. paramsMap.put("jobName",task.getJobName());
  25. if(task.getParamsKey1()!=null&&task.getParamsValue1()!=null){
  26. paramsMap.put(task.getParamsKey1(),task.getParamsValue1());
  27. }
  28. if(task.getParamsKey2()!=null&&task.getParamsValue2()!=null){
  29. paramsMap.put(task.getParamsKey2(),task.getParamsValue2());
  30. }
  31. if(task.getParamsKey3()!=null&&task.getParamsValue3()!=null){
  32. paramsMap.put(task.getParamsKey3(),task.getParamsValue3());
  33. }
  34. enableCronSchedule(job,paramsMap,true);
  36. log.info("系统结束初始化任务："+task.getId()+":"+task.getJobName()+":"+task.getJobId());
  37. }
  38. }
  39. /**
  40. *启动一个自定义的job
  41. *
  42. *@paramschedulingJob
  43. *自定义的job
  44. *@paramparamsMap
  45. *传递给job执行的数据
  46. *@paramisStateFull
  47. *是否是一个同步定时任务，true：同步，false：异步
  48. *@return成功则返回true，否则返回false
  49. */
  50. publicbooleanenableCronSchedule(SchedulingJobschedulingJob,JobDataMapparamsMap,booleanisStateFull){
  51. if(schedulingJob==null){
  52. returnfalse;
  53. }
  54. try{
  55. //scheduler=(Scheduler)ApplicationHelper.getBean("scheduler");
  56. CronTriggertrigger=(CronTrigger)scheduler.getTrigger(schedulingJob.getTriggerName(),
  57. schedulingJob.getJobGroup());
  58. if(null==trigger){//如果不存在该trigger则创建一个
  59. JobDetailjobDetail=null;
  60. if(isStateFull){
  61. jobDetail=newJobDetail(schedulingJob.getJobId(),schedulingJob.getJobGroup(),
  62. schedulingJob.getStateFulljobExecuteClass());
  63. }else{
  64. jobDetail=newJobDetail(schedulingJob.getJobId(),schedulingJob.getJobGroup(),
  65. schedulingJob.getJobExecuteClass());
  66. }
  67. jobDetail.setJobDataMap(paramsMap);
  68. trigger=newCronTrigger(schedulingJob.getTriggerName(),schedulingJob.getJobGroup(),
  69. schedulingJob.getCronExpression());
  70. scheduler.scheduleJob(jobDetail,trigger);
  71. }else{
  72. //Trigger已存在，那么更新相应的定时设置
  73. trigger.setCronExpression(schedulingJob.getCronExpression());
  74. scheduler.rescheduleJob(trigger.getName(),trigger.getGroup(),trigger);
  75. }
  76. }catch(Exceptione){
  77. e.printStackTrace();
  78. returnfalse;
  79. }
  80. returntrue;
  81. }
  83. /**
  84. *禁用一个job
  85. *
  86. *@paramjobId
  87. *需要被禁用的job的ID
  88. *@paramjobGroupId
  89. *需要被警用的jobGroupId
  90. *@return成功则返回true，否则返回false
  91. */
  92. publicbooleandisableSchedule(StringjobId){
  93. if(jobId.equals("")){
  94. returnfalse;
  95. }
  96. try{
  97. StringjobGroupId="DEFAULT";
  98. Triggertrigger=getJobTrigger(jobId,jobGroupId);
  99. if(null!=trigger){
  100. scheduler.deleteJob(jobId,jobGroupId);
  101. }
  102. }catch(SchedulerExceptione){
  103. e.printStackTrace();
  104. returnfalse;
  105. }
  106. returntrue;
  107. }
  109. /**
  110. *得到job的详细信息
  111. *
  112. *@paramjobId
  113. *job的ID
  114. *@paramjobGroupId
  115. *job的组ID
  116. *@returnjob的详细信息,如果job不存在则返回null
  117. */
  118. publicJobDetailgetJobDetail(StringjobId,StringjobGroupId){
  119. if(jobId.equals("")||jobGroupId.equals("")||null==jobId||jobGroupId==null){
  120. returnnull;
  121. }
  122. try{
  123. returnscheduler.getJobDetail(jobId,jobGroupId);
  124. }catch(SchedulerExceptione){
  125. e.printStackTrace();
  126. returnnull;
  127. }
  128. }
  130. /**
  131. *得到job对应的Trigger
  132. *
  133. *@paramjobId
  134. *job的ID
  135. *@paramjobGroupId
  136. *job的组ID
  137. *@returnjob的Trigger,如果Trigger不存在则返回null
  138. */
  139. publicTriggergetJobTrigger(StringjobId,StringjobGroupId){
  140. if(jobId.equals("")||jobGroupId.equals("")||null==jobId||jobGroupId==null){
  141. returnnull;
  142. }
  143. try{
  144. returnscheduler.getTrigger(jobId+"Trigger",jobGroupId);
  145. }catch(SchedulerExceptione){
  146. e.printStackTrace();
  147. returnnull;
  148. }
  149. }
  151. }


说明：
1.主要方法有三个，启动一个任务，禁用一个任务，启动多个任务。启动即加入自动运行列表，禁用即移出自动运行列表。
2.TaskJob是一个任务对象，和数据库表结构相对应，后面给出数据库设计。
3.程序中有类似，
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. paramsMap.put(task.getParamsKey1(),task.getParamsValue1());
这样的代码，意思是假如你：如果你在数据库的ParamsKey1值为"username",ParamsValue1的值为"zhangsang".那么你在具体的job中给定变量名为"username"的变量并给出set/get方法，就可以得到值"zhangsang",此功能适用于给定时任务配置固定参数，并且参数名字随便你定。我们这里给了三个备用的，你也可以扩展，步骤就是数据库加一个字段，在上面的程序中paramsMap放入这个字段，当然你也可以不用参数。你数据库没有配置任何值，表示该定时任务没有固定参数。
4.SchedulingJob是一个定时任务执行参数的bean。即 将Taskjob对象的值经过处理转换成SchedulingJob对象，然后用SchedulingJob对象的值调用定时任务的API。
SchedulingJob对象主要做的事就是，TriggerName和JobGroup分别给出默认值。根据className生成StateFulljobExecuteClass的Class对象。
四。SchedulingJob代码：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. publicclassSchedulingJob{
  2. publicstaticfinalintJS_ENABLED=0;//任务启用状态
  3. publicstaticfinalintJS_DISABLED=1;//任务禁用状态
  4. publicstaticfinalintJS_DELETE=2;//任务已删除状态
  6. privateStringjobId;//任务的Id，一般为所定义Bean的ID
  7. privateStringjobName;//任务的描述
  8. privateStringjobGroup;//任务所属组的名称
  9. privateintjobStatus;//任务的状态，0：启用；1：禁用；2：已删除
  10. privateStringcronExpression;//定时任务运行时间表达式
  11. privateStringmemos;//任务描述
  12. privateClass<?>stateFulljobExecuteClass;//同步的执行类，需要从StatefulMethodInvokingJob继承
  13. privateClass<?>jobExecuteClass;//异步的执行类，需要从MethodInvokingJob继承
  14. /**
  15. *得到该job的Trigger名字
  16. *@return
  17. */
  18. publicStringgetTriggerName(){
  19. returnthis.getJobId()+"Trigger";
  20. }
  21. publicStringgetJobId(){
  22. returnjobId;
  23. }
  24. publicvoidsetJobId(StringjobId){
  25. this.jobId=jobId;
  26. }
  27. publicStringgetJobName(){
  28. returnjobName;
  29. }
  30. publicvoidsetJobName(StringjobName){
  31. this.jobName=jobName;
  32. }
  33. publicStringgetJobGroup(){
  34. if(jobGroup==null){
  35. jobGroup=Scheduler.DEFAULT_GROUP;
  36. }
  37. returnjobGroup;
  38. }
  39. publicvoidsetJobGroup(StringjobGroup){
  40. this.jobGroup=jobGroup;
  41. }
  42. publicintgetJobStatus(){
  43. returnjobStatus;
  44. }
  45. publicvoidsetJobStatus(intjobStatus){
  46. this.jobStatus=jobStatus;
  47. }
  48. publicStringgetCronExpression(){
  49. returncronExpression;
  50. }
  51. publicvoidsetCronExpression(StringcronExpression){
  52. this.cronExpression=cronExpression;
  53. }
  54. publicStringgetMemos(){
  55. returnmemos;
  56. }
  57. publicvoidsetMemos(Stringmemos){
  58. this.memos=memos;
  59. }
  60. publicClass<?>getStateFulljobExecuteClass(){
  61. returnstateFulljobExecuteClass;
  62. }
  63. publicvoidsetStateFulljobExecuteClass(Class<?>stateFulljobExecuteClass){
  64. this.stateFulljobExecuteClass=stateFulljobExecuteClass;
  65. }
  66. publicClass<?>getJobExecuteClass(){
  67. returnjobExecuteClass;
  68. }
  69. publicvoidsetJobExecuteClass(Class<?>jobExecuteClass){
  70. this.jobExecuteClass=jobExecuteClass;
  71. }
  72. publicstaticintgetJS_ENABLED(){
  73. returnJS_ENABLED;
  74. }
  75. publicstaticintgetJS_DISABLED(){
  76. returnJS_DISABLED;
  77. }
  78. publicstaticintgetJS_DELETE(){
  79. returnJS_DELETE;
  80. }
  82. }

五。具体JOB实现
只要继承QuartzJobBean类，覆盖executeInternal方法即可。在job中可能通过get方法的方式得到jobDetail对象中JobDataMap(详见QuartzManager类)中同名参数值。示例代码。
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassContentJobextendsQuartzJobBean{
  3. @Autowired
  4. TaskJobServicetaskJobService;
  5. privateStringbeginDate;
  6. privateStringendDate;
  8. /**
  9. *手动执行任务
  10. *@paramrequest
  11. */
  12. @RequestMapping("/contentJobManual.do")
  13. publicvoidmanual(HttpServletRequestrequest){
  14. StringstartDate=request.getParameter("startDate");
  15. StringendDate=request.getParameter("endDate");
  16. TaskJobServicetaskJobService=(TaskJobService)ApplicationHelper.getBean("taskJobService");
  17. Map<String,String>param=newHashMap<String,String>();
  18. SimpleDateFormatsdf=newSimpleDateFormat("yyyy-MM-dd");
  19. Stringtoday=sdf.format(newDate());
  20. if(StringUtils.isEmpty(startDate)){
  21. param.put("beginDate",today);
  22. }else{
  23. param.put("beginDate",startDate);
  24. }
  25. if(StringUtils.isEmpty(endDate)){
  26. param.put("endDate",today);
  27. }else{
  28. param.put("endDate",endDate);
  29. }
  30. taskJobService.callStatisticContent(param);
  31. }
  33. @Override
  34. publicvoidexecuteInternal(JobExecutionContextcontext){
  35. TaskJobServicetaskJobService=(TaskJobService)ApplicationHelper.getBean("taskJobService");
  36. Map<String,String>param=newHashMap<String,String>();
  37. SimpleDateFormatsdf=newSimpleDateFormat("yyyy-MM-dd");
  38. Stringtoday=sdf.format(newDate());
  39. if(StringUtils.isEmpty(beginDate)){
  40. param.put("beginDate",today);
  41. }else{
  42. param.put("beginDate",beginDate);
  43. }
  44. if(StringUtils.isEmpty(endDate)){
  45. param.put("endDate",today);
  46. }else{
  47. param.put("endDate",endDate);
  48. }
  49. taskJobService.callStatisticContent(param);
  50. }
  52. publicStringgetBeginDate(){
  53. returnbeginDate;
  54. }
  56. publicvoidsetBeginDate(StringbeginDate){
  57. this.beginDate=beginDate;
  58. }
  60. publicStringgetEndDate(){
  61. returnendDate;
  62. }
  63. publicvoidsetEndDate(StringendDate){
  64. this.endDate=endDate;
  65. }

六。手动执行一个任务。可以将该job类声明成一个@Controller。另外写一个方法如上例中的manual方法。
扩展：目前还不能将自动运行的方法和手动执行的方法（即executeInternal方法和manual方法）写成一个。因为自动运行的方法不是一个action类，它不在web环境中，是通过反射实现的。如果把executeInternal这个方法强行配置成具有web功能的方法（即类上面加@Controller，方法上面加@RequestMapping("/contentJobManual.do")）也是不行的，因为该方法没有HttpServletRequest对象，获取不了参数。除非你的定时任务没有参数。当然你也不能修改该方法的参数类型，因为他是覆盖QuartzJobBean的方法。
七。数据库设计。
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. IDVARCHAR2(60)N
  2. JOB_CLASSVARCHAR2(255)N
  3. JOB_NAMEVARCHAR2(60)N
  4. JOB_CRON_EXPRESSIONVARCHAR2(60)N
  5. JOB_SERVICE_BEANVARCHAR2(60)Y
  6. PARAMS_KEY1VARCHAR2(60)Y
  7. PARAMS_VALUE1VARCHAR2(60)Y
  8. PARAMS_KEY2VARCHAR2(60)Y
  9. PARAMS_VALUE2VARCHAR2(60)Y
  10. PARAMS_KEY3VARCHAR2(60)Y
  11. PARAMS_VALUE3VARCHAR2(60)Y
  12. NOTEVARCHAR2(255)Y
  13. JOB_STATUSVARCHAR2(1)Y
  14. UPDATETIMEDATEY
  15. JOB_AUTORUNVARCHAR2(1)Y
  16. JOB_GROUPVARCHAR2(60)Y

说明：JOB_STATUS表示是否有效任务，JOB_AUTORUN表示是否自动运行，JOB_SERVICE_BEAN表示手动执行的请求URL，JOB_CLASS表示JOB类的全路径，JOB_GROUP表示任务属于哪个组，方便对任务的分组管理（批量启动，禁止等），区别于quartz的API所要求的同名参数，其实也可以把这个值传给API。其它字段比较好理解。该表对应的bean是taskjob。
八。页面管理。
主要功能是将一个任务加入或者移出自动运行队列（通过quartzManager对象）。和任务的增删查改。示例代码如下：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassTaskJobAction{
  3. privatestaticfinalLoglog=LogFactory.getLog(TaskJobAction.class);
  4. @Autowired
  5. TaskJobServicetaskJobService;
  6. @Autowired
  7. QuartzManagerquartzManager;
  9. @RequestMapping("/enableTask.do")
  10. publicvoidenableTask(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  11. StringparameterStr="";
  12. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  13. parameterStr=StringUtils.trim(parameterStr);
  14. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  15. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  16. Stringid=p.get("id");
  17. if(!StringUtils.isEmpty(id)){
  18. TaskJobtask=taskJobService.getTaskById(id);
  19. List<TaskJob>list=newArrayList<TaskJob>();
  20. list.add(task);
  21. quartzManager.enableCronSchedule(list);
  23. task.setJobEnabled("Y");
  24. taskJobService.update(task);//将任务设置成自动运行状态
  25. }
  27. }
  28. @RequestMapping("/disableTask.do")
  29. publicvoiddisableTask(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  30. StringparameterStr="";
  31. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  32. parameterStr=StringUtils.trim(parameterStr);
  33. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  34. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  35. Stringid=p.get("id");
  36. if(!StringUtils.isEmpty(id)){
  37. TaskJobtask=taskJobService.getTaskById(id);
  38. quartzManager.disableSchedule(task.getJobId());
  40. task.setJobEnabled("N");
  41. taskJobService.update(task);//将任务设置成非运行状态
  42. }
  44. }
  45. @RequestMapping("/add.do")
  46. publicvoidadd(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  47. StringparameterStr="";
  48. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  49. parameterStr=StringUtils.trim(parameterStr);
  50. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  51. Stringjobjson=p.get("jobjson");
  52. jobjson=URLDecoder.decode(jobjson,"utf-8");
  53. TaskJobtask=JsonUtil.toObject(jobjson,TaskJob.class);
  54. StringjobName=URLDecoder.decode(task.getJobName(),"utf-8");
  55. task.setJobName(jobName);
  56. if(!StringUtils.isEmpty(jobjson)){
  57. taskJobService.insert(task);
  58. }
  60. }
  62. @RequestMapping("/update.do")
  63. publicvoidupdate(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  64. StringparameterStr="";
  65. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  66. parameterStr=StringUtils.trim(parameterStr);
  67. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  68. Stringjobjson=p.get("jobjson");
  69. jobjson=URLDecoder.decode(jobjson,"utf-8");
  70. TaskJobtask=JsonUtil.toObject(jobjson,TaskJob.class);
  71. StringjobName=URLDecoder.decode(task.getJobName(),"utf-8");
  72. task.setJobName(jobName);
  73. if(!StringUtils.isEmpty(jobjson)){
  74. taskJobService.update(task);
  75. }
  77. }
  79. @RequestMapping("/delete.do")
  80. publicvoiddelete(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  81. StringparameterStr="";
  82. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  83. parameterStr=StringUtils.trim(parameterStr);
  84. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  85. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  86. StringidStr=p.get("idStr");
  87. if(!StringUtils.isEmpty(idStr)){
  88. taskJobService.delete(idStr);
  89. }
  91. }
  92. @ResponseBody
  93. @RequestMapping("/taskList.do")
  94. publicRecordResultBeanlist(HttpServletRequestrequest,HttpServletResponseresponse,@RequestParam("pageSize")intpageSize,
  95. @RequestParam("startIndex")intstartIndex)throwsIOException{
  96. intpageNum=startIndex/pageSize+1;
  97. StringstartDate=request.getParameter("startDate");
  98. StringendDate=request.getParameter("endDate");
  99. StringjobName=request.getParameter("jobName");
  100. if(!StringUtils.isEmpty(jobName)){
  101. jobName=URLDecoder.decode(jobName,"UTF-8");
  102. jobName=URLDecoder.decode(jobName,"UTF-8");
  103. }
  104. RecordResultBeanresultBean=newRecordResultBean();
  105. try{
  107. Pagerpager=newPager(pageNum,pageSize);
  108. Map<String,Object>map=newHashMap<String,Object>();
  109. map.put("jobName",jobName);
  110. pager.setKeys(map);
  111. pager=taskJobService.findPage(pager);
  112. if(pager==null||pager.getTotalCount()==0){
  113. resultBean.setResult(false);
  115. }else{
  116. resultBean.setResult(true);
  117. resultBean.setBean(pager);
  118. }
  120. }catch(Exceptionex){
  121. log.warn(JDKStackTrace.getJDKStrack(ex));
  122. }
  124. returnresultBean;
  125. }
定时任务-quartz的使用，实现可页面化管理
使用spring+quartz实现定时任务的页面化管理。主要特点：
1.时间表达式等信息配置在数据库中，从而实现页面化管理。
2.可以手动执行或者停止单个任务，也可以使一个任务加入或者移出自动运行列表。

下面开始介绍用法，在这之前先说明框架的版本。spring3.2.4+quartz1.6.0
一.配置文件
只需要在spring的配置文件中加入：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. <beanid="scheduler"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
  2. </bean>
  3. <beanid="jobManager"class="com.temobi.quartz.JobManager">
  4. </bean>

说明：scheduler对象是spring管理定时任务的对象。
jobManager是我们自定义加载定时任务列表的对象，此对象加载所有任务列表后，将他们加入到自动运行列表。
二.jobManager代码：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. publicclassJobManagerimplementsInitializingBean{
  2. privatestaticfinalLoglog=LogFactory.getLog(JobManager.class);
  3. @Autowired
  4. TaskJobServicetaskJobService;
  5. @Autowired
  6. QuartzManagerquartzManager;
  7. @Override
  8. publicvoidafterPropertiesSet()throwsException{
  9. loadAllJob();
  10. }
  11. privatevoidloadAllJob(){
  12. List<TaskJob>list=taskJobService.getTaskList();
  13. quartzManager.enableCronSchedule(list);
  14. }
  16. }


说明：
1.实现spring中InitializingBean接口，并覆盖afterPropertiesSet方法，则该方法会在应用启动的时候而且其他servlet执行完成之后执行，此处用来加载所有定时任务，并加入定时任务自动运行列表。
2.quartzManager是我们自定义的定时任务管理类，用来实现我们文章开头说的功能。
三.QuartzManager代码
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassQuartzManager{
  3. @Autowired
  4. Schedulerscheduler;
  6. privatestaticfinalLoglog=LogFactory.getLog(QuartzManager.class);
  7. publicvoidenableCronSchedule(List<TaskJob>list){
  8. for(TaskJobtask:list){
  9. SchedulingJobjob=newSchedulingJob();
  10. job.setJobId(task.getId());
  11. job.setJobName(task.getJobName());
  12. //job.setMemos(task.getNote());
  13. job.setCronExpression(task.getJobCronExpression());
  14. try{
  15. StringclassName=task.getJobClass().trim();
  16. Classclazz=Class.forName(className);
  17. job.setStateFulljobExecuteClass(clazz);
  18. }catch(Exceptione){
  19. e.printStackTrace();
  20. continue;
  21. }
  22. JobDataMapparamsMap=newJobDataMap();
  23. paramsMap.put("jobName",task.getJobName());
  25. if(task.getParamsKey1()!=null&&task.getParamsValue1()!=null){
  26. paramsMap.put(task.getParamsKey1(),task.getParamsValue1());
  27. }
  28. if(task.getParamsKey2()!=null&&task.getParamsValue2()!=null){
  29. paramsMap.put(task.getParamsKey2(),task.getParamsValue2());
  30. }
  31. if(task.getParamsKey3()!=null&&task.getParamsValue3()!=null){
  32. paramsMap.put(task.getParamsKey3(),task.getParamsValue3());
  33. }
  34. enableCronSchedule(job,paramsMap,true);
  36. log.info("系统结束初始化任务："+task.getId()+":"+task.getJobName()+":"+task.getJobId());
  37. }
  38. }
  39. /**
  40. *启动一个自定义的job
  41. *
  42. *@paramschedulingJob
  43. *自定义的job
  44. *@paramparamsMap
  45. *传递给job执行的数据
  46. *@paramisStateFull
  47. *是否是一个同步定时任务，true：同步，false：异步
  48. *@return成功则返回true，否则返回false
  49. */
  50. publicbooleanenableCronSchedule(SchedulingJobschedulingJob,JobDataMapparamsMap,booleanisStateFull){
  51. if(schedulingJob==null){
  52. returnfalse;
  53. }
  54. try{
  55. //scheduler=(Scheduler)ApplicationHelper.getBean("scheduler");
  56. CronTriggertrigger=(CronTrigger)scheduler.getTrigger(schedulingJob.getTriggerName(),
  57. schedulingJob.getJobGroup());
  58. if(null==trigger){//如果不存在该trigger则创建一个
  59. JobDetailjobDetail=null;
  60. if(isStateFull){
  61. jobDetail=newJobDetail(schedulingJob.getJobId(),schedulingJob.getJobGroup(),
  62. schedulingJob.getStateFulljobExecuteClass());
  63. }else{
  64. jobDetail=newJobDetail(schedulingJob.getJobId(),schedulingJob.getJobGroup(),
  65. schedulingJob.getJobExecuteClass());
  66. }
  67. jobDetail.setJobDataMap(paramsMap);
  68. trigger=newCronTrigger(schedulingJob.getTriggerName(),schedulingJob.getJobGroup(),
  69. schedulingJob.getCronExpression());
  70. scheduler.scheduleJob(jobDetail,trigger);
  71. }else{
  72. //Trigger已存在，那么更新相应的定时设置
  73. trigger.setCronExpression(schedulingJob.getCronExpression());
  74. scheduler.rescheduleJob(trigger.getName(),trigger.getGroup(),trigger);
  75. }
  76. }catch(Exceptione){
  77. e.printStackTrace();
  78. returnfalse;
  79. }
  80. returntrue;
  81. }
  83. /**
  84. *禁用一个job
  85. *
  86. *@paramjobId
  87. *需要被禁用的job的ID
  88. *@paramjobGroupId
  89. *需要被警用的jobGroupId
  90. *@return成功则返回true，否则返回false
  91. */
  92. publicbooleandisableSchedule(StringjobId){
  93. if(jobId.equals("")){
  94. returnfalse;
  95. }
  96. try{
  97. StringjobGroupId="DEFAULT";
  98. Triggertrigger=getJobTrigger(jobId,jobGroupId);
  99. if(null!=trigger){
  100. scheduler.deleteJob(jobId,jobGroupId);
  101. }
  102. }catch(SchedulerExceptione){
  103. e.printStackTrace();
  104. returnfalse;
  105. }
  106. returntrue;
  107. }
  109. /**
  110. *得到job的详细信息
  111. *
  112. *@paramjobId
  113. *job的ID
  114. *@paramjobGroupId
  115. *job的组ID
  116. *@returnjob的详细信息,如果job不存在则返回null
  117. */
  118. publicJobDetailgetJobDetail(StringjobId,StringjobGroupId){
  119. if(jobId.equals("")||jobGroupId.equals("")||null==jobId||jobGroupId==null){
  120. returnnull;
  121. }
  122. try{
  123. returnscheduler.getJobDetail(jobId,jobGroupId);
  124. }catch(SchedulerExceptione){
  125. e.printStackTrace();
  126. returnnull;
  127. }
  128. }
  130. /**
  131. *得到job对应的Trigger
  132. *
  133. *@paramjobId
  134. *job的ID
  135. *@paramjobGroupId
  136. *job的组ID
  137. *@returnjob的Trigger,如果Trigger不存在则返回null
  138. */
  139. publicTriggergetJobTrigger(StringjobId,StringjobGroupId){
  140. if(jobId.equals("")||jobGroupId.equals("")||null==jobId||jobGroupId==null){
  141. returnnull;
  142. }
  143. try{
  144. returnscheduler.getTrigger(jobId+"Trigger",jobGroupId);
  145. }catch(SchedulerExceptione){
  146. e.printStackTrace();
  147. returnnull;
  148. }
  149. }
  151. }


说明：
1.主要方法有三个，启动一个任务，禁用一个任务，启动多个任务。启动即加入自动运行列表，禁用即移出自动运行列表。
2.TaskJob是一个任务对象，和数据库表结构相对应，后面给出数据库设计。
3.程序中有类似，
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. paramsMap.put(task.getParamsKey1(),task.getParamsValue1());
这样的代码，意思是假如你：如果你在数据库的ParamsKey1值为"username",ParamsValue1的值为"zhangsang".那么你在具体的job中给定变量名为"username"的变量并给出set/get方法，就可以得到值"zhangsang",此功能适用于给定时任务配置固定参数，并且参数名字随便你定。我们这里给了三个备用的，你也可以扩展，步骤就是数据库加一个字段，在上面的程序中paramsMap放入这个字段，当然你也可以不用参数。你数据库没有配置任何值，表示该定时任务没有固定参数。
4.SchedulingJob是一个定时任务执行参数的bean。即 将Taskjob对象的值经过处理转换成SchedulingJob对象，然后用SchedulingJob对象的值调用定时任务的API。
SchedulingJob对象主要做的事就是，TriggerName和JobGroup分别给出默认值。根据className生成StateFulljobExecuteClass的Class对象。
四。SchedulingJob代码：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. publicclassSchedulingJob{
  2. publicstaticfinalintJS_ENABLED=0;//任务启用状态
  3. publicstaticfinalintJS_DISABLED=1;//任务禁用状态
  4. publicstaticfinalintJS_DELETE=2;//任务已删除状态
  6. privateStringjobId;//任务的Id，一般为所定义Bean的ID
  7. privateStringjobName;//任务的描述
  8. privateStringjobGroup;//任务所属组的名称
  9. privateintjobStatus;//任务的状态，0：启用；1：禁用；2：已删除
  10. privateStringcronExpression;//定时任务运行时间表达式
  11. privateStringmemos;//任务描述
  12. privateClass<?>stateFulljobExecuteClass;//同步的执行类，需要从StatefulMethodInvokingJob继承
  13. privateClass<?>jobExecuteClass;//异步的执行类，需要从MethodInvokingJob继承
  14. /**
  15. *得到该job的Trigger名字
  16. *@return
  17. */
  18. publicStringgetTriggerName(){
  19. returnthis.getJobId()+"Trigger";
  20. }
  21. publicStringgetJobId(){
  22. returnjobId;
  23. }
  24. publicvoidsetJobId(StringjobId){
  25. this.jobId=jobId;
  26. }
  27. publicStringgetJobName(){
  28. returnjobName;
  29. }
  30. publicvoidsetJobName(StringjobName){
  31. this.jobName=jobName;
  32. }
  33. publicStringgetJobGroup(){
  34. if(jobGroup==null){
  35. jobGroup=Scheduler.DEFAULT_GROUP;
  36. }
  37. returnjobGroup;
  38. }
  39. publicvoidsetJobGroup(StringjobGroup){
  40. this.jobGroup=jobGroup;
  41. }
  42. publicintgetJobStatus(){
  43. returnjobStatus;
  44. }
  45. publicvoidsetJobStatus(intjobStatus){
  46. this.jobStatus=jobStatus;
  47. }
  48. publicStringgetCronExpression(){
  49. returncronExpression;
  50. }
  51. publicvoidsetCronExpression(StringcronExpression){
  52. this.cronExpression=cronExpression;
  53. }
  54. publicStringgetMemos(){
  55. returnmemos;
  56. }
  57. publicvoidsetMemos(Stringmemos){
  58. this.memos=memos;
  59. }
  60. publicClass<?>getStateFulljobExecuteClass(){
  61. returnstateFulljobExecuteClass;
  62. }
  63. publicvoidsetStateFulljobExecuteClass(Class<?>stateFulljobExecuteClass){
  64. this.stateFulljobExecuteClass=stateFulljobExecuteClass;
  65. }
  66. publicClass<?>getJobExecuteClass(){
  67. returnjobExecuteClass;
  68. }
  69. publicvoidsetJobExecuteClass(Class<?>jobExecuteClass){
  70. this.jobExecuteClass=jobExecuteClass;
  71. }
  72. publicstaticintgetJS_ENABLED(){
  73. returnJS_ENABLED;
  74. }
  75. publicstaticintgetJS_DISABLED(){
  76. returnJS_DISABLED;
  77. }
  78. publicstaticintgetJS_DELETE(){
  79. returnJS_DELETE;
  80. }
  82. }

五。具体JOB实现
只要继承QuartzJobBean类，覆盖executeInternal方法即可。在job中可能通过get方法的方式得到jobDetail对象中JobDataMap(详见QuartzManager类)中同名参数值。示例代码。
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassContentJobextendsQuartzJobBean{
  3. @Autowired
  4. TaskJobServicetaskJobService;
  5. privateStringbeginDate;
  6. privateStringendDate;
  8. /**
  9. *手动执行任务
  10. *@paramrequest
  11. */
  12. @RequestMapping("/contentJobManual.do")
  13. publicvoidmanual(HttpServletRequestrequest){
  14. StringstartDate=request.getParameter("startDate");
  15. StringendDate=request.getParameter("endDate");
  16. TaskJobServicetaskJobService=(TaskJobService)ApplicationHelper.getBean("taskJobService");
  17. Map<String,String>param=newHashMap<String,String>();
  18. SimpleDateFormatsdf=newSimpleDateFormat("yyyy-MM-dd");
  19. Stringtoday=sdf.format(newDate());
  20. if(StringUtils.isEmpty(startDate)){
  21. param.put("beginDate",today);
  22. }else{
  23. param.put("beginDate",startDate);
  24. }
  25. if(StringUtils.isEmpty(endDate)){
  26. param.put("endDate",today);
  27. }else{
  28. param.put("endDate",endDate);
  29. }
  30. taskJobService.callStatisticContent(param);
  31. }
  33. @Override
  34. publicvoidexecuteInternal(JobExecutionContextcontext){
  35. TaskJobServicetaskJobService=(TaskJobService)ApplicationHelper.getBean("taskJobService");
  36. Map<String,String>param=newHashMap<String,String>();
  37. SimpleDateFormatsdf=newSimpleDateFormat("yyyy-MM-dd");
  38. Stringtoday=sdf.format(newDate());
  39. if(StringUtils.isEmpty(beginDate)){
  40. param.put("beginDate",today);
  41. }else{
  42. param.put("beginDate",beginDate);
  43. }
  44. if(StringUtils.isEmpty(endDate)){
  45. param.put("endDate",today);
  46. }else{
  47. param.put("endDate",endDate);
  48. }
  49. taskJobService.callStatisticContent(param);
  50. }
  52. publicStringgetBeginDate(){
  53. returnbeginDate;
  54. }
  56. publicvoidsetBeginDate(StringbeginDate){
  57. this.beginDate=beginDate;
  58. }
  60. publicStringgetEndDate(){
  61. returnendDate;
  62. }
  63. publicvoidsetEndDate(StringendDate){
  64. this.endDate=endDate;
  65. }

六。手动执行一个任务。可以将该job类声明成一个@Controller。另外写一个方法如上例中的manual方法。
扩展：目前还不能将自动运行的方法和手动执行的方法（即executeInternal方法和manual方法）写成一个。因为自动运行的方法不是一个action类，它不在web环境中，是通过反射实现的。如果把executeInternal这个方法强行配置成具有web功能的方法（即类上面加@Controller，方法上面加@RequestMapping("/contentJobManual.do")）也是不行的，因为该方法没有HttpServletRequest对象，获取不了参数。除非你的定时任务没有参数。当然你也不能修改该方法的参数类型，因为他是覆盖QuartzJobBean的方法。
七。数据库设计。
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. IDVARCHAR2(60)N
  2. JOB_CLASSVARCHAR2(255)N
  3. JOB_NAMEVARCHAR2(60)N
  4. JOB_CRON_EXPRESSIONVARCHAR2(60)N
  5. JOB_SERVICE_BEANVARCHAR2(60)Y
  6. PARAMS_KEY1VARCHAR2(60)Y
  7. PARAMS_VALUE1VARCHAR2(60)Y
  8. PARAMS_KEY2VARCHAR2(60)Y
  9. PARAMS_VALUE2VARCHAR2(60)Y
  10. PARAMS_KEY3VARCHAR2(60)Y
  11. PARAMS_VALUE3VARCHAR2(60)Y
  12. NOTEVARCHAR2(255)Y
  13. JOB_STATUSVARCHAR2(1)Y
  14. UPDATETIMEDATEY
  15. JOB_AUTORUNVARCHAR2(1)Y
  16. JOB_GROUPVARCHAR2(60)Y

说明：JOB_STATUS表示是否有效任务，JOB_AUTORUN表示是否自动运行，JOB_SERVICE_BEAN表示手动执行的请求URL，JOB_CLASS表示JOB类的全路径，JOB_GROUP表示任务属于哪个组，方便对任务的分组管理（批量启动，禁止等），区别于quartz的API所要求的同名参数，其实也可以把这个值传给API。其它字段比较好理解。该表对应的bean是taskjob。
八。页面管理。
主要功能是将一个任务加入或者移出自动运行队列（通过quartzManager对象）。和任务的增删查改。示例代码如下：
[java]view plaincopy
print?在CODE上查看代码片派生到我的代码片
  1. @Controller
  2. publicclassTaskJobAction{
  3. privatestaticfinalLoglog=LogFactory.getLog(TaskJobAction.class);
  4. @Autowired
  5. TaskJobServicetaskJobService;
  6. @Autowired
  7. QuartzManagerquartzManager;
  9. @RequestMapping("/enableTask.do")
  10. publicvoidenableTask(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  11. StringparameterStr="";
  12. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  13. parameterStr=StringUtils.trim(parameterStr);
  14. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  15. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  16. Stringid=p.get("id");
  17. if(!StringUtils.isEmpty(id)){
  18. TaskJobtask=taskJobService.getTaskById(id);
  19. List<TaskJob>list=newArrayList<TaskJob>();
  20. list.add(task);
  21. quartzManager.enableCronSchedule(list);
  23. task.setJobEnabled("Y");
  24. taskJobService.update(task);//将任务设置成自动运行状态
  25. }
  27. }
  28. @RequestMapping("/disableTask.do")
  29. publicvoiddisableTask(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  30. StringparameterStr="";
  31. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  32. parameterStr=StringUtils.trim(parameterStr);
  33. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  34. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  35. Stringid=p.get("id");
  36. if(!StringUtils.isEmpty(id)){
  37. TaskJobtask=taskJobService.getTaskById(id);
  38. quartzManager.disableSchedule(task.getJobId());
  40. task.setJobEnabled("N");
  41. taskJobService.update(task);//将任务设置成非运行状态
  42. }
  44. }
  45. @RequestMapping("/add.do")
  46. publicvoidadd(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  47. StringparameterStr="";
  48. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  49. parameterStr=StringUtils.trim(parameterStr);
  50. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  51. Stringjobjson=p.get("jobjson");
  52. jobjson=URLDecoder.decode(jobjson,"utf-8");
  53. TaskJobtask=JsonUtil.toObject(jobjson,TaskJob.class);
  54. StringjobName=URLDecoder.decode(task.getJobName(),"utf-8");
  55. task.setJobName(jobName);
  56. if(!StringUtils.isEmpty(jobjson)){
  57. taskJobService.insert(task);
  58. }
  60. }
  62. @RequestMapping("/update.do")
  63. publicvoidupdate(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  64. StringparameterStr="";
  65. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  66. parameterStr=StringUtils.trim(parameterStr);
  67. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  68. Stringjobjson=p.get("jobjson");
  69. jobjson=URLDecoder.decode(jobjson,"utf-8");
  70. TaskJobtask=JsonUtil.toObject(jobjson,TaskJob.class);
  71. StringjobName=URLDecoder.decode(task.getJobName(),"utf-8");
  72. task.setJobName(jobName);
  73. if(!StringUtils.isEmpty(jobjson)){
  74. taskJobService.update(task);
  75. }
  77. }
  79. @RequestMapping("/delete.do")
  80. publicvoiddelete(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{
  81. StringparameterStr="";
  82. parameterStr=IOUtils.toString(request.getInputStream(),InputConstant.CHAR_SET);
  83. parameterStr=StringUtils.trim(parameterStr);
  84. parameterStr=URLDecoder.decode(parameterStr,"utf-8");
  85. Map<String,String>p=JsonUtil.getParameterMap(parameterStr);
  86. StringidStr=p.get("idStr");
  87. if(!StringUtils.isEmpty(idStr)){
  88. taskJobService.delete(idStr);
  89. }
  91. }
  92. @ResponseBody
  93. @RequestMapping("/taskList.do")
  94. publicRecordResultBeanlist(HttpServletRequestrequest,HttpServletResponseresponse,@RequestParam("pageSize")intpageSize,
  95. @RequestParam("startIndex")intstartIndex)throwsIOException{
  96. intpageNum=startIndex/pageSize+1;
  97. StringstartDate=request.getParameter("startDate");
  98. StringendDate=request.getParameter("endDate");
  99. StringjobName=request.getParameter("jobName");
  100. if(!StringUtils.isEmpty(jobName)){
  101. jobName=URLDecoder.decode(jobName,"UTF-8");
  102. jobName=URLDecoder.decode(jobName,"UTF-8");
  103. }
  104. RecordResultBeanresultBean=newRecordResultBean();
  105. try{
  107. Pagerpager=newPager(pageNum,pageSize);
  108. Map<String,Object>map=newHashMap<String,Object>();
  109. map.put("jobName",jobName);
  110. pager.setKeys(map);
  111. pager=taskJobService.findPage(pager);
  112. if(pager==null||pager.getTotalCount()==0){
  113. resultBean.setResult(false);
  115. }else{
  116. resultBean.setResult(true);
  117. resultBean.setBean(pager);
  118. }
  120. }catch(Exceptionex){
  121. log.warn(JDKStackTrace.getJDKStrack(ex));
  122. }
  124. returnresultBean;
  125. }
分享到：
| 分布式缓存技术PK：选择Redis还是Memcache ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    quartz demo

    Quartz 是一个开源的工作调度框架，常用于Java应用程序中实现定时任务的管理。Spring框架与Quartz的整合，使得在Spring应用中配置和管理定时任务变得更加便捷。在"quartz demo"这个项目中，我们将探讨如何在Spring...

    定时任务，JSP

    在实际项目中，通常会结合使用这些工具和方法，以实现灵活、可扩展的定时任务系统。例如，创建一个简单的JSP页面用于展示定时任务的状态，或者提供一个表单供用户添加新的定时任务。这需要对JSP语法、Servlet以及...

    quartz1.86+spring3.2测试实例

    这两个框架的结合使得开发者能够方便地在Spring管理的上下文中配置和控制Quartz定时任务，提高了应用程序的灵活性和可维护性。 Quartz 1.86是Quartz的一个较早版本，它支持创建、调度和执行任务。通过定义Job类来...

    页面管理.zip

    总的来说，"页面管理.zip"可能是一个集成了定时任务管理的Web工具，可以帮助开发者和运维人员更有效地管理和优化网站的各个页面，同时利用定时任务实现后台的自动化操作。通过这样的工具，可以提高工作效率，降低...

    企业后台管理基础框架 hsweb.zip

    定时调度支持,可在页面配置定时任务,编写任务脚本执行。演示示例:demo.hsweb.me测试用户:test (test2,test3,test4....) 密码:123456演示项目源码:hsweb-demo技术选型第三方：MVC:spring-boot. 开箱即用,学习成本低,...

    Maven+SpringMVC+SpringTask定时任务

    【标签】"定时任务"表明这个项目的核心功能之一是实现定期执行的自动化任务。在Java Web开发中，定时任务常常用于处理那些不需要立即响应但需要按计划进行的工作，例如清理过期数据、发送邮件通知、统计分析等。 ...

    quartz-golang-with-react-ui:演示版

    React UI则为用户提供了一个图形化界面，可以方便地查看、创建、编辑和删除定时任务。 【标签】"HTML"表明项目涉及到网页开发，HTML（超文本标记语言）是构建网页的基本元素，通常与CSS和JavaScript一起使用来构建...

    若依博客（ruoyi-blog-master.zip）

    定时任务:Quartz。 数据库连接池：Druid。 工具类：Fastjson。 除若依原有的功能外添加博客功能 导航管理 ：对博客前台显示配置，可以设置页面，也可设置分类 分类管理：对博客进行分类 标签管理：略 博客管理：对...

    java springboot 前后台博客系统，毕业设计，设计报告

    前后台博客系统 功能：用户角色菜单管理等。 导航管理 ：对博客前台显示配置，可以...5. 定时任务:Quartz。 6. 数据库连接池：Druid。 7. 工具类：Fastjson。 环境：java1.8 ，mysql5.7以上，idea。 源码+数据库文件。

    java学习文档

    - **实现方法**：利用注解方式配置Quartz定时任务。 - **日志改进** - **改进目的**：优化日志记录方式，提高日志的可读性和可维护性。 - **配置增量覆盖** - **改进目的**：允许增量覆盖配置文件，便于灵活...

    springboot完整架构,带后台管理

    - Quartz/Spring Scheduler：任务调度，实现定时任务。 综上所述，这个项目是一个全面的SpringBoot应用，具备后台管理功能，并与MySQL数据库集成。开发者可以在此基础上进行业务逻辑开发，实现高效且稳定的系统...

    黑马面试宝典知识点复习

    - **使用场景**：定时任务、计划任务等。 - **监控**：可以使用Quartz提供的API来监控任务执行状态。 #### MQ（消息队列） - **RabbitMQ**： - **定义**：一种消息中间件。 - **优点**：高可用性、支持多种语言、...

    基于JavaWeb的推荐数据后台管理系统的设计与实现 (2).docx

    - **定时任务**：使用Quartz实现定时任务调度，定期执行数据同步和备份操作。 - **数据迁移工具**：利用Flyway进行数据库版本控制和迁移，确保数据一致性。 #### 五、测试与部署 ##### 1. 单元测试 - 使用JUnit...

    基于springboot OA自动化办公系统源码.zip

    - **任务管理**：实现任务的创建、分配、跟踪和完成，可能涉及到Quartz或Spring Task进行定时任务的调度。 - **审批流程**：可能使用工作流引擎如Activiti或Flowable，实现流程定义和执行。 - **文档管理**：存储...

    学习java的30个目标.txt

    - **应用场景**：日志管理、定时任务调度等。 #### 目标21：掌握网络通信与缓存技术 - **技术框架**：JGroups、JCache等。 - **应用场景**：分布式系统的通信与数据缓存。 #### 目标22：学习全文搜索技术 - **...

    Beginning iOS 5 Development: Exploring the iOS SDK [Paperback]

    - **定时任务**：设定任务在特定时间自动执行。 #### 14. 图形绘制技术 - **Quartz 2D**：用于绘制简单的图形和文字。 - **OpenGL ES**：用于实现高质量的三维图形渲染。 #### 15. 触摸与手势识别 - **触摸事件*...

    J_HI 平台 及 开发文档

    4. **其他技术**：平台还集成了C3P0连接池、Quartz定时任务等技术。 #### 四、平台组成部分详解 1. **生成器** - **环境目录**：生成器需要特定的目录结构来进行配置和生成。 - **生成原理**：基于模板和配置...

    Spring Task.docx

    【Spring Task】定时任务在IT行业中扮演着至关重要的角色，特别是在大数据处理、系统维护和自动化流程中。本文将深入探讨Spring框架内置的定时任务模块，Spring Task，以及如何在实际业务场景中应用它。 首先，让...

Magicbox
Global site tag (gtag.js) - Google Analytics