利用Linux中的crontab实现分布式项目定时任务功能
认识crond服务
1、crond是Linux用来定期执行程序的命令。当安装完成操作系统之后，默认便会启动此任务调度命令。crond命令每分锺会定期检查是否有要执行的工作，如果有要执行的工作便会自动执行该工作。而Linux任务调度的工作主要分为以下两类：
①系统执行的工作：系统周期性所要执行的工作，如备份系统数据、清理缓存
②个人执行的工作：某个用户定期要做的工作，例如每隔10分钟检查邮件服务器是否有新信，这些工作可由每个用户自行设置
2、Crontab是UNIX系统下的定时任务触发器，其使用者的权限记载在下列两个文件中：
①/etc/cron.deny该文件中所列的用户不允许使用Crontab命令
②/etc/cron.allow该文件中所列的用户允许使用Crontab命令
3、/var/spool/cron/是所有用户的crontab文件
4、启动、停止、查看crond服务：
①启动：servicecrondstart
②停止：servicecrondstop
③查看：servicecrondstatus
@Controller
@RequestMapping("/task/topic")
publicclassTopicQuartzController{
protectedLoggerlogger=LoggerFactory.getLogger(TopicQuartzController.class);
@Autowired
privateLiveTopicServiceliveTopicService;
@RequestMapping("execute")
@ResponseBody
publicCommonResultexecute(HttpServletRequestrequest,HttpServletResponseresponse,Stringtype){
longt1=System.currentTimeMillis();
logger.error("topic定时器执行开始"+type);
CommonResultresult=newCommonResult();
if(QlchatUtil.isEmpty(type)){
result.setMsg("参数为空");
result.setSuccess(false);
returnresult;
}
try{
switch(type){
case"autoEndTopic":
this.autoEndTopic();
break;
case"oneWeek":
this.endTopicOneWeek();
break;
default:
break;
}
result.setSuccess(true);
result.setMsg("执行完成"+type);
}catch(Exceptione){
logger.error("topic定时器执行异常"+type,e);
result.setMsg("topic定时器执行异常"+type);
result.setSuccess(false);
}
longt2=System.currentTimeMillis();
logger.error("topic定时器执行结束"+type+",耗时="+(t2-t1)+"ms");
returnresult;
}
privatevoidautoEndTopic(){
Stringsql="SELECTid_topicIdFROMskg_live_topicltWHERElt.`status_`='beginning'ANDlt.end_time_ISNOTNULLANDlt.`end_time_`>resultMap=jdbcTemplate.queryForList(sql);
for(Mapmap:resultMap){
StringtopicId=String.valueOf(map.get("topicId"));
try{
LiveTopicPoliveTopicPo=liveTopicService.loadCache(topicId);
liveTopicService.endTopic(liveTopicPo,liveTopicPo.getCreateBy());
}catch(Exceptione){
logger.error("autoEndTopic异常"+topicId,e);
}
}
}
/**
*结束之前的没有结束时间的话题，只跑一周
*/
privatevoidendTopicOneWeek(){
Stringsql="SELECTid_topicIdFROMskg_live_topicltWHERElt.`status_`='beginning'ANDlt.end_time_ISNULLANDlt.start_time_<=(NOW()-interval48hour)";
JdbcTemplatejdbcTemplate=SpringHelper.getBean(JdbcTemplate.class);
List>resultMap=jdbcTemplate.queryForList(sql);
for(Mapmap:resultMap){
StringtopicId=String.valueOf(map.get("topicId"));
try{
LiveTopicPoliveTopicPo=liveTopicService.loadCache(topicId);
liveTopicService.endTopic(liveTopicPo,liveTopicPo.getCreateBy());
}catch(Exceptione){
logger.error("autoEndTopic异常"+topicId,e);
}
}
}
}
像上面这样写好定时任务的逻辑类
创建一个contab.txt
*/30****curl'http://10.47.161.40:8181/task/topic/execute.do?type=oneWeek' */30****curl'http://10.47.161.40:8181/task/topic/execute.do?type=autoEndTopic'
里面这样调用方法去执行即可实现分布式项目的定时任务
上面即每30分钟执行一次
总结
以上所述是小编给大家介绍的利用Linux中的crontab实现分布式项目定时任务功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！