标签：return springboot ResponseDTO private cron 定时 动态 public

导入依赖：

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>

基于接口配置：

初始化bean实例是当cron配置存在时启动定时任务；
修改配置cron，先停止在重新启动。
具体myTaskScheduledConfig可参考下方

@Slf4j
@RestController
@RequestMapping("/task")
public class DynamicTaskController {

    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;

    private ScheduledFuture<?> future;

    @Autowired
    private CdsServiceImpl cdsService;

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        return new ThreadPoolTaskScheduler();
    }

    @PostConstruct
    private void init(){
        if (Strings.isNotEmpty(myTaskScheduledConfig.getCron())) {
            log.info("动态定时任务 init->start。。。{}", DateUtils.getCurrentTime());
            startTask();
        }

    }

    @PostMapping("/start")
    public ResponseDTO startCron() {
        if (Strings.isEmpty(myTaskScheduledConfig.getCron())) {
            CronConfigEntity cron = cdsService.getCron();
            if (Objects.isNull(cron)) {
                return ResponseDTO.onError("定时任务配置信息为空");
            }
            myTaskScheduledConfig.setCron(cron.getCorn());
        }
        startTask();
        return ResponseDTO.onSuccess("start success");
    }

    @PostMapping("/stop")
    public ResponseDTO stopCron() {
        stopTask();
        return ResponseDTO.onSuccess("stop success");
    }

    @PostMapping("/updateCron")
    public ResponseDTO updateCron(@RequestBody TaskVO vo) {
    	//修改配置 可以是mysql中的 也可以使用堆中的
        if (cdsService.updateCron(vo.getCron())) {
            myTaskScheduledConfig.setCron(vo.getCron());
            stopTask();
            startTask();
            return ResponseDTO.onSuccess("success");
        }
        return ResponseDTO.onError(ErrorCode.OPERATE_ERROR);

    }


    private void startTask() {
        log.info("动态定时任务 start。。。{}", DateUtils.getCurrentTime());
        future = threadPoolTaskScheduler.schedule(() -> {
            log.info("动态定时任务执行。。。{}", DateUtils.getCurrentTime());
           
            //业务代码
            log.info("动态定时任务执行结束。。。{}", DateUtils.getCurrentTime());
        }, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                return new CronTrigger(myTaskScheduledConfig.getCron()).nextExecutionTime(triggerContext);
            }
        });
    }

    private void stopTask() {
        if (future != null) {
            future.cancel(true);
        }
        log.info("动态定时任务 stop。。。{}", DateUtils.getCurrentTime());
    }


}

定时任务时间间隔配置MyTaskScheduledConfig

@Data
@Configuration
@EqualsAndHashCode(callSuper = false)
public class MyTaskScheduledConfig {

    private boolean enable;

    private String cron;

    @Autowired
    private CronConfigRepository cronConfigRepository;

    @PostConstruct
    private void init(){
        CronConfigEntity config = cronConfigRepository.findFirstByOrderByIdDesc();
        if (Objects.isNotNull(config)){
            this.enable = config.getIsEnable();
            this.cron = config.getCorn();
        }

    }
}

总结：

目前这个方式已经用在公司实际生产环境，虽然对比其他使用@Scheduled的静态定时任务没有那么优雅，也没有Quartz那么方便，当是我个人觉得能不添加其他依赖就尽量不添加，而且其本身也比较灵活。只是由于本人的技术水平有限暂时不知道怎么做到直接配置时间间隔的方式，可能需要自己做处理，等待后续研究出来再和大家分享。

标签：return,springboot,ResponseDTO,private,cron,定时,动态,public
来源： https://blog.csdn.net/weixin_41543212/article/details/117635380

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。