SpringBoot概述
創(chuàng)新互聯(lián)建站專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于成都做網(wǎng)站、成都網(wǎng)站制作、湘陰網(wǎng)絡(luò)推廣、微信小程序定制開發(fā)、湘陰網(wǎng)絡(luò)營(yíng)銷、湘陰企業(yè)策劃、湘陰品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等，從售前售中售后，我們都將竭誠(chéng)為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；創(chuàng)新互聯(lián)建站為所有大學(xué)生創(chuàng)業(yè)者提供湘陰建站搭建服務(wù)，24小時(shí)服務(wù)熱線：18980820575，官方網(wǎng)址：www.cdcxhl.com
SpringBoot是由Pivotal團(tuán)隊(duì)在2013年開始研發(fā)、2014年4月發(fā)布第一個(gè)版本的全新開源的輕量級(jí)框架。它基于Spring4.0設(shè)計(jì)，不僅繼承了Spring框架原有的優(yōu)秀特性，而且還通過簡(jiǎn)化配置來進(jìn)一步簡(jiǎn)化了Spring應(yīng)用的整個(gè)搭建和開發(fā)過程。另外SpringBoot通過集成大量的框架使得依賴包的版本沖突，以及引用的不穩(wěn)定性等問題得到了很好的解決。
SpringBoot特征
（1）可以創(chuàng)建獨(dú)立的Spring應(yīng)用程序，并且基于其Maven或Gradle插件，可以創(chuàng)建可執(zhí)行的JARs和WARs；
（2）內(nèi)嵌Tomcat或Jetty等Servlet容器；
（3）提供自動(dòng)配置的“starter”項(xiàng)目對(duì)象模型（POMS）以簡(jiǎn)化Maven配置；
（4）盡可能自動(dòng)配置Spring容器；
（5）提供準(zhǔn)備好的特性，如指標(biāo)、健康檢查和外部化配置；
（6）絕對(duì)沒有代碼生成，不需要XML配置。
在我們平時(shí)開發(fā)的項(xiàng)目中，定時(shí)任務(wù)基本屬于必不可少的功能，那大家都是怎么做的呢?但我知道的大多都是靜態(tài)定時(shí)任務(wù)實(shí)現(xiàn)。
基于注解來創(chuàng)建定時(shí)任務(wù)非常簡(jiǎn)單，只需幾行代碼便可完成。實(shí)現(xiàn)如下：
@Configuration
@EnableScheduling
public class SimpleScheduleTask {
//10秒鐘執(zhí)行一次
@Scheduled(cron = "0/10 * * * * ?")
private void tasks() {
System.out.println("【定時(shí)任務(wù)】 每10秒執(zhí)行一次!");
}
}
Cron表達(dá)式參數(shù)分別表示(從左到右)：
秒(0~59) 如0/5表示每5秒
分(0~59)
時(shí)(0~23)
日(0~31) 月的某一天
月(0~11)
周幾( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)
就上面幾行代碼，就能搞定一個(gè)定時(shí)任務(wù)。顯然，使用Scheduled 確實(shí)特別的方便，但有很大的缺點(diǎn)和局限，就是當(dāng)我們調(diào)整了執(zhí)行計(jì)劃的時(shí)間時(shí)，需要重啟服務(wù)才能生效，這就有些不方便。為了達(dá)到實(shí)時(shí)生效的效果，可以通過數(shù)據(jù)庫(kù)來動(dòng)態(tài)實(shí)現(xiàn)定時(shí)任務(wù)。
基于數(shù)據(jù)庫(kù)的動(dòng)態(tài)定時(shí)任務(wù)實(shí)現(xiàn)
將定時(shí)任務(wù)配置在數(shù)據(jù)庫(kù)，啟動(dòng)項(xiàng)目的時(shí)候，用mybatis讀取數(shù)據(jù)庫(kù)，實(shí)例化對(duì)象，并設(shè)定定時(shí)任務(wù)。如果需要新增，減少，修改定時(shí)任務(wù)，僅需要修改數(shù)據(jù)庫(kù)資料，并重啟項(xiàng)目即可，無(wú)需改代碼。
@Lazy(value = false)
@Component
public class ScheduleTask implements SchedulingConfigurer {
protected static Logger logger = LoggerFactory.getLogger(ScheduleTask.class);
private SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Autowired
private ScheduleTaskMapper scheduleTaskMapper;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
List tasks = getAllScheduleTasks();
logger.info("【定時(shí)任務(wù)啟動(dòng)】 啟動(dòng)任務(wù)數(shù)："+tasks.size()+"; time="+sdf.format(new Date()));
//校驗(yàn)數(shù)據(jù)
checkDataList(tasks);
//通過校驗(yàn)的數(shù)據(jù)執(zhí)行定時(shí)任務(wù)
int count = 0;
if(tasks.size()>0) {
for (int i = 0; i < tasks.size(); i++) {
try {
taskRegistrar.addTriggerTask(getRunnable(tasks.get(i)), getTrigger(tasks.get(i)));
count++;
} catch (Exception e) {
logger.error("task start error:" + tasks.get(i).getClassName() + ";" + tasks.get(i).getMethodName() + ";" + e.getMessage());
}
}
}
logger.info("started task number="+count+"; time="+sdf.format(new Date()));
};
/**
* 獲取要執(zhí)行的所有任務(wù)
* @return
*/
private List getAllScheduleTasks() {
ScheduleTaskExample example=new ScheduleTaskExample();
example.createCriteria().andIsDeleteEqualTo((byte) 0);
return scheduleTaskMapper.selectByExample(example);
}
/**
* 獲取Runnable
*
* @param task
* @return
*/
private Runnable getRunnable(ScheduleTask task){
return new Runnable() {
@Override
public void run() {
try {
Object obj = SpringUtil.getBean(task.getClassName());
Method method = obj.getClass().getMethod(task.getMethodName(),null);
method.invoke(obj);
} catch (InvocationTargetException e) {
logger.error("refect exception:"+task.getClassName()+";"+task.getMethodName()+";"+ e.getMessage());
} catch (Exception e) {
logger.error(e.getMessage());
}
}
};
}
/**
* 獲取Trigger
*
* @param task
* @return
*/
private Trigger getTrigger(ScheduleTask task){
return new Trigger() {
@Override
public Date nextExecutionTime(TriggerContext triggerContext) {
//將Cron 0/1 * * * * ?
CronTrigger trigger = new CronTrigger(task.getCron());
Date nextExec = trigger.nextExecutionTime(triggerContext);
return nextExec;
}
};
}
/**
* 校驗(yàn)數(shù)據(jù)
*
* @param list
* @return
*/
private List checkDataList(List list) {
String msg="";
for(int i=0;i
if(!checkOneData(list.get(i)).equalsIgnoreCase("ok")){
msg+=list.get(i).getTaskName()+";";
list.remove(list.get(i));
i--;
};
}
if(!StringUtils.IsEmpty(msg)){
msg="未啟動(dòng)的任務(wù):"+msg;
logger.error(msg);
}
return list;
}
/**
* 按每一條校驗(yàn)數(shù)據(jù)
*
* @param task
* @return
*/
private String checkOneData(ScheduleTask task){
String result="ok";
Class cal= null;
try {
cal = Class.forName(task.getClassName());
Object obj =SpringUtil.getBean(cal);
Method method = obj.getClass().getMethod(task.getMethodName(),null);
String cron=task.getCron();
if(StringUtils.isBlank(cron)){
result="no found the cron:"+task.getTaskName();
logger.error(result);
}
} catch (ClassNotFoundException e) {
result="not found the class:"+task.getClassName()+ e.getMessage();
logger.error(result);
} catch (NoSuchMethodException e) {
result="not found the method:"+task.getClassName()+";"+task.getMethodName()+";"+ e.getMessage();
logger.error(result);
} catch (Exception e) {
logger.error(e.getMessage());
}
return result;
}
}
數(shù)據(jù)庫(kù)配置
運(yùn)行的結(jié)果
這樣我們可以通過直接修改數(shù)據(jù)庫(kù)，執(zhí)行周期就會(huì)改變，并且不需要我們重啟應(yīng)用，十分方便。
重慶分公司
重慶分公司
