Springboot集成schedule内置任务调度@Scheduled(cron=”5 * * * * ?”)

Java光头强 • 2023年2月20日下午7:50 • 技术随笔 • 阅读 172

Spring内置任务调度使用是非常简便的，只需要一个类，三个注解就ok。

类上方加 @Component，标识为Bean。
方法上加 @Scheduled(fixedRate = 5000)，我这个写的是5秒调度一次，也可以写成cron表达式。如：@Scheduled(cron=“5 * * * * ?”)
cron表达式是由7个空格分隔的时间元素组成的（分别表示：秒分时日月周年），一般最后一个年都省略不写。不多说，想更深入了可以了解一下Quartz.
启动项上加 @EnableScheduling

package com.mycompany.myapp.schedule;

import com.mycompany.myapp.domain.AssetEquipment;
import com.mycompany.myapp.service.AssetEquipmentService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

/**
 * @author wangyan@163.com
 * @version 1.0
 * @date 2019-08-29 09:16
 */
@Component
public class OutTimeAssetEquipmentScheduleConfig {
    private static final Logger logger = LoggerFactory.getLogger(OutTimeAssetEquipmentScheduleConfig.class);
    private final AssetEquipmentService assetEquipmentService;

    public OutTimeAssetEquipmentScheduleConfig(AssetEquipmentService assetEquipmentService) {
        this.assetEquipmentService = assetEquipmentService;
    }

    @Scheduled(fixedRate = 5000)
    public void cronJobSchedule() {
        List<AssetEquipment> outTimeAssetEquipmentList = assetEquipmentService.systemOutTimeAssetEquipmentList();
        outTimeAssetEquipmentList.stream().forEach(item -> {
            assetEquipmentService.updateOutTimeAssetEquipmentFlag(item.getId());
        });
        List<AssetEquipment> preGuaranteeAssetEquipmentList = assetEquipmentService.preGuaranteeAssetEquipmentList();
        preGuaranteeAssetEquipmentList.stream().forEach(item -> {
            assetEquipmentService.systemPreGuaranteeAssetEquipmentFlag(item.getId());
        });
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
        Date now = new Date();
        logger.info("XXXX任务调度执行:" + sdf.format(now));
    }
}