欧美成人乱码一二三区,宅男综合网

quartz是任務(wù)調(diào)用框架，和數(shù)據(jù)庫交互實現(xiàn)動態(tài)調(diào)度任務(wù)?？梢约耗Ｊ剑涸谟诟涌煽?，如果一個節(jié)點在執(zhí)行時間沒有調(diào)用，在有其它相同配置的集群內(nèi)其它配置的機器會同樣調(diào)度，同時它會檢查狀態(tài)，保證同一個任務(wù)只會在需要被調(diào)用的時間只調(diào)用一次。

優(yōu)勢在于動態(tài)，可以在執(zhí)行時暫?；蛘邉h除任務(wù)。

maven項目實現(xiàn)

spring版本：4.3.18

quartz：2.2.3

maven依賴：

<groupId>org.quartz-scheduler</groupId>

<artifactId>quartz</artifactId>

</dependency>

<groupId>org.quartz-scheduler</groupId>

<artifactId>quartz-jobs</artifactId>

</dependency>

這次配置的quartz是基于數(shù)據(jù)庫的表配置的，需要用到一些表：

基于mysql的建表語句：

DROP?TABLE?IF?EXISTS?QRTZ_FIRED_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_PAUSED_TRIGGER_GRPS;??

DROP?TABLE?IF?EXISTS?QRTZ_SCHEDULER_STATE;??

DROP?TABLE?IF?EXISTS?QRTZ_LOCKS;??

DROP?TABLE?IF?EXISTS?QRTZ_SIMPLE_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_SIMPROP_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_CRON_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_BLOB_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_TRIGGERS;??

DROP?TABLE?IF?EXISTS?QRTZ_JOB_DETAILS;??

DROP?TABLE?IF?EXISTS?QRTZ_CALENDARS;??

CREATE?TABLE?QRTZ_JOB_DETAILS(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

JOB_NAME?VARCHAR(200)?NOT?NULL,??

JOB_GROUP?VARCHAR(200)?NOT?NULL,??

DESCRIPTION?VARCHAR(250)?NULL,??

JOB_CLASS_NAME?VARCHAR(250)?NOT?NULL,??

IS_DURABLE?VARCHAR(1)?NOT?NULL,??

IS_NONCONCURRENT?VARCHAR(1)?NOT?NULL,??

IS_UPDATE_DATA?VARCHAR(1)?NOT?NULL,??

REQUESTS_RECOVERY?VARCHAR(1)?NOT?NULL,??

JOB_DATA?BLOB?NULL,??

PRIMARY?KEY?(SCHED_NAME,JOB_NAME,JOB_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_TRIGGERS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

JOB_NAME?VARCHAR(200)?NOT?NULL,??

JOB_GROUP?VARCHAR(200)?NOT?NULL,??

DESCRIPTION?VARCHAR(250)?NULL,??

NEXT_FIRE_TIME?BIGINT(13)?NULL,??

PREV_FIRE_TIME?BIGINT(13)?NULL,??

PRIORITY?INTEGER?NULL,??

TRIGGER_STATE?VARCHAR(16)?NOT?NULL,??

TRIGGER_TYPE?VARCHAR(8)?NOT?NULL,??

START_TIME?BIGINT(13)?NOT?NULL,??

END_TIME?BIGINT(13)?NULL,??

CALENDAR_NAME?VARCHAR(200)?NULL,??

MISFIRE_INSTR?SMALLINT(2)?NULL,??

JOB_DATA?BLOB?NULL,??

PRIMARY?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),??

FOREIGN?KEY?(SCHED_NAME,JOB_NAME,JOB_GROUP)??

REFERENCES?QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_SIMPLE_TRIGGERS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

REPEAT_COUNT?BIGINT(7)?NOT?NULL,??

REPEAT_INTERVAL?BIGINT(12)?NOT?NULL,??

TIMES_TRIGGERED?BIGINT(10)?NOT?NULL,??

PRIMARY?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),??

FOREIGN?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)??

REFERENCES?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_CRON_TRIGGERS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

CRON_EXPRESSION?VARCHAR(120)?NOT?NULL,??

TIME_ZONE_ID?VARCHAR(80),??

PRIMARY?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),??

FOREIGN?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)??

REFERENCES?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_SIMPROP_TRIGGERS??

??(????????????

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

STR_PROP_1?VARCHAR(512)?NULL,??

STR_PROP_2?VARCHAR(512)?NULL,??

STR_PROP_3?VARCHAR(512)?NULL,??

????INT_PROP_1?INT?NULL,??

????INT_PROP_2?INT?NULL,??

????LONG_PROP_1?BIGINT?NULL,??

????LONG_PROP_2?BIGINT?NULL,??

DEC_PROP_1?NUMERIC(13,4)?NULL,??

DEC_PROP_2?NUMERIC(13,4)?NULL,??

BOOL_PROP_1?VARCHAR(1)?NULL,??

BOOL_PROP_2?VARCHAR(1)?NULL,??

????PRIMARY?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),??

????FOREIGN?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)???

????REFERENCES?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_BLOB_TRIGGERS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

BLOB_DATA?BLOB?NULL,??

PRIMARY?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),??

INDEX?(SCHED_NAME,TRIGGER_NAME,?TRIGGER_GROUP),??

FOREIGN?KEY?(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)??

REFERENCES?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_CALENDARS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

CALENDAR_NAME?VARCHAR(200)?NOT?NULL,??

CALENDAR?BLOB?NOT?NULL,??

PRIMARY?KEY?(SCHED_NAME,CALENDAR_NAME))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_PAUSED_TRIGGER_GRPS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

PRIMARY?KEY?(SCHED_NAME,TRIGGER_GROUP))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_FIRED_TRIGGERS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

ENTRY_ID?VARCHAR(95)?NOT?NULL,??

TRIGGER_NAME?VARCHAR(200)?NOT?NULL,??

TRIGGER_GROUP?VARCHAR(200)?NOT?NULL,??

INSTANCE_NAME?VARCHAR(200)?NOT?NULL,??

FIRED_TIME?BIGINT(13)?NOT?NULL,??

SCHED_TIME?BIGINT(13)?NOT?NULL,??

PRIORITY?INTEGER?NOT?NULL,??

STATE?VARCHAR(16)?NOT?NULL,??

JOB_NAME?VARCHAR(200)?NULL,??

JOB_GROUP?VARCHAR(200)?NULL,??

IS_NONCONCURRENT?VARCHAR(1)?NULL,??

REQUESTS_RECOVERY?VARCHAR(1)?NULL,??

PRIMARY?KEY?(SCHED_NAME,ENTRY_ID))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_SCHEDULER_STATE?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

INSTANCE_NAME?VARCHAR(200)?NOT?NULL,??

LAST_CHECKIN_TIME?BIGINT(13)?NOT?NULL,??

CHECKIN_INTERVAL?BIGINT(13)?NOT?NULL,??

PRIMARY?KEY?(SCHED_NAME,INSTANCE_NAME))??

ENGINE=InnoDB;??

CREATE?TABLE?QRTZ_LOCKS?(??

SCHED_NAME?VARCHAR(120)?NOT?NULL,??

LOCK_NAME?VARCHAR(40)?NOT?NULL,??

PRIMARY?KEY?(SCHED_NAME,LOCK_NAME))??

ENGINE=InnoDB;??

--?這是是索引了--------------------------------------------??

CREATE?INDEX?IDX_QRTZ_J_REQ_RECOVERY?ON?QRTZ_JOB_DETAILS(SCHED_NAME,REQUESTS_RECOVERY);??

CREATE?INDEX?IDX_QRTZ_J_GRP?ON?QRTZ_JOB_DETAILS(SCHED_NAME,JOB_GROUP);??

CREATE?INDEX?IDX_QRTZ_T_J?ON?QRTZ_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);??

CREATE?INDEX?IDX_QRTZ_T_JG?ON?QRTZ_TRIGGERS(SCHED_NAME,JOB_GROUP);??

CREATE?INDEX?IDX_QRTZ_T_C?ON?QRTZ_TRIGGERS(SCHED_NAME,CALENDAR_NAME);??

CREATE?INDEX?IDX_QRTZ_T_G?ON?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);??

CREATE?INDEX?IDX_QRTZ_T_STATE?ON?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE);??

CREATE?INDEX?IDX_QRTZ_T_N_STATE?ON?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_STATE);??

CREATE?INDEX?IDX_QRTZ_T_N_G_STATE?ON?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP,TRIGGER_STATE);??

CREATE?INDEX?IDX_QRTZ_T_NEXT_FIRE_TIME?ON?QRTZ_TRIGGERS(SCHED_NAME,NEXT_FIRE_TIME);??

CREATE?INDEX?IDX_QRTZ_T_NFT_ST?ON?QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE,NEXT_FIRE_TIME);??

CREATE?INDEX?IDX_QRTZ_T_NFT_MISFIRE?ON?QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME);??

CREATE?INDEX?IDX_QRTZ_T_NFT_ST_MISFIRE?ON?QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_STATE);??

CREATE?INDEX?IDX_QRTZ_T_NFT_ST_MISFIRE_GRP?ON?QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_GROUP,TRIGGER_STATE);??

CREATE?INDEX?IDX_QRTZ_FT_TRIG_INST_NAME?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME);??

CREATE?INDEX?IDX_QRTZ_FT_INST_JOB_REQ_RCVRY?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME,REQUESTS_RECOVERY);??

CREATE?INDEX?IDX_QRTZ_FT_J_G?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP);??

CREATE?INDEX?IDX_QRTZ_FT_JG?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_GROUP);??

CREATE?INDEX?IDX_QRTZ_FT_T_G?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP);??

CREATE?INDEX?IDX_QRTZ_FT_TG?ON?QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_GROUP);??

commit;???

這里mysql的InnoDB，在mysql新版本中可有會存在字符過長的問題，VARCHAR(200)，默認最長byte為767,200*4超過了767所有會有問題，這里可以打開mysql的innodb_large_prefix = true,默認是為false,或者把varchar改為190，可能會有問題，我這次暫時先改成190，嘗試了了一個定時任務(wù)，暫時沒發(fā)現(xiàn)有異常。

配置quartz.properties

#quartz是否自動啟動,設(shè)為false將不會執(zhí)行調(diào)度

org.quartz.autoStartup=false

#ID設(shè)置為自動獲取每一個必須不同（所有調(diào)度器實例中是唯一的）

org.quartz.scheduler.instanceId=AUTO

org.quartz.scheduler.instanceName =DefaultQuartzScheduler

org.quartz.scheduler.rmi.export =false

org.quartz.scheduler.rmi.proxy =false

org.quartz.scheduler.wrapJobExecutionInUserTransaction =false

org.quartz.threadPool.class =org.quartz.simpl.SimpleThreadPool

org.quartz.threadPool.threadCount =10

org.quartz.threadPool.threadPriority =5

org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread =true

org.quartz.jobStore.misfireThreshold =60000

#org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

org.quartz.jobStore.class =org.quartz.impl.jdbcjobstore.JobStoreTX

#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.HSQLDBDelegate

org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate

#org.quartz.jobStore.useProperties = true

org.quartz.jobStore.tablePrefix =QRTZ_

org.quartz.jobStore.isClustered =false

org.quartz.jobStore.maxMisfiresToHandleAtATime=1

配置:xml文件，或者直接寫在項目xml文件里

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

? ? ? xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

? ? ? xmlns:tx="http://www.springframework.org/schema/tx"

? ? ? xsi:schemaLocation="

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.2.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.2.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-3.2.xsd">

? ? <bean name="scheduler" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

? ? ? ? <property name="startupDelay" value="3" /> // 延遲加載

<property name="autoStartup" value="true" /> //自動啟動

<property name="configLocation" value="/WEB-INF/quartz.properties"/> // 選定配置文件

<property name="dataSource" ref="newsboard"/> //選定數(shù)據(jù)庫

</bean>

</beans>

這里的雙下劃線注釋均為寫這篇的時間加上去了，程序代碼需要刪除

配置完成后

@Autowired

private Scheduler scheduler;

自動注入后，通過scheduler的a'pi對定時任務(wù)進行操作

添加corn調(diào)度任務(wù)：

private void addCronTriggerByExpression(HttpServletRequest request, HttpServletResponse response)throws Exception {

//獲取觸發(fā)器名稱

? ? String triggerName = request.getParameter("triggerName");

String cronExpression = request.getParameter("cronExpression");

String jobClass=request.getParameter("jobClass");

if (StringUtils.isEmpty(triggerName) || StringUtils.isEmpty(cronExpression)) {

response.getWriter().println(1);

}

// 驗證cronExpression表達式是否合法

? ? if(!CronExpression.isValidExpression(cronExpression)){

response.getWriter().println(1);

}

JobDetail jobDetail =null;

try{

Class obj=? Class.forName(jobClass);

String jobName = jobClass.substring(jobClass.lastIndexOf(".")+1);

jobDetail = JobBuilder.newJob(obj)

.withIdentity(jobName, Scheduler.DEFAULT_GROUP)

.build();

}catch(Exception e){

e.printStackTrace();

}

// 增加觸發(fā)器

? ? schedulerService.schedule(triggerName, cronExpression, jobDetail);

// response.setContentType("text/xml;charset=utf-8");

? ? response.getWriter().println(0);

}

public void schedule(String name, CronExpression cronExpression,String group,JobDetail jobDetail) {

if (name ==null || name.trim().equals("")) {

name = UUID.randomUUID().toString();

}else{

//在名稱后添加UUID，保證名稱的唯一性

? ? ? ? ? ? name +="&"+UUID.randomUUID().toString();

}

try {

CronTrigger cronTrigger = TriggerBuilder.newTrigger()

.withIdentity(name, group)

.withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))//在任務(wù)調(diào)度器中，使用任務(wù)調(diào)度器的 CronScheduleBuilder 來生成一個具體的 CronTrigger 對象

? ? ? ? ? ? ? ? ? ? .build();

//注冊作業(yè)和觸發(fā)器

? ? ? ? ? ? scheduler.scheduleJob(jobDetail, cronTrigger);

//開始調(diào)度任務(wù)

//? ? ? ? ? ? scheduler.start();

? ? ? ? }catch (SchedulerException e) {

throw new RuntimeException(e);

}

添加一個簡單定時任務(wù)：

/**

* 增加 Simple Trigger

* @param request

* @param response

private void addSimpleTrigger(HttpServletRequest request, HttpServletResponse response)throws IOException {

// 獲取前臺所有配置參數(shù)

? ? Map tempMap = WebUtils.getParametersStartingWith(request,"p_");

Map filterMap =new HashMap();

for (String key : tempMap.keySet()){

filterMap.put (key, (String)tempMap.get(key));

}

String jobClass=request.getParameter("jobClass");

if (StringUtils.isEmpty(filterMap.get(QuartzConstants.STARTTIME))) {

response.getWriter().println(1);

}

JobDetail jobDetail=null;

try {

Class obj=? Class.forName(jobClass);

String jobName = jobClass.substring(jobClass.lastIndexOf(".")+1);

jobDetail = JobBuilder.newJob(obj)

.withIdentity(jobName,Scheduler.DEFAULT_GROUP)

.build();

}catch (Exception e) {

e.printStackTrace();

}

// 增加觸發(fā)器

? ? schedulerService.schedule(filterMap,jobDetail);

// response.setContentType("text/xml;charset=utf-8");

? ? response.getWriter().println(0);

}

//停止觸發(fā)，移除觸發(fā)，刪除觸發(fā)

TriggerKey triggerKey = TriggerKey.triggerKey(triggerName,group);

// 停止觸發(fā)器

? ? ? ? ? ? scheduler.pauseTrigger(triggerKey);

// 移除觸發(fā)器

? ? ? ? ? ? return scheduler.unscheduleJob(triggerKey);

// 刪除任務(wù)

//? ? ? ? ? ? return scheduler.deleteJob(JobKey.jobKey(jobname,group));

//重啟觸發(fā)器

scheduler.resumeTrigger(new TriggerKey(triggerName, group));

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av

spring 配置動態(tài)quartz任務(wù)調(diào)度

spring 配置動態(tài)quartz任務(wù)調(diào)度

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九 欧美,1769亚洲,黄色成人av

spring 配置動態(tài)quartz任務(wù)調(diào)度

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容

色偷偷精品伊人,欧洲久久精品,欧美综合婷婷骚逼,国产AV主播,国产最新探花在线,九色在线视频一区,伊人大交九欧美,1769亚洲,黄色成人av