Spring Task定時任務的實現詳解

Posted on by

Spring Task定時任務

Cron表達式

以6-7位的一組數字,中間用空格間隔的字符串,表達一種時間

每位的含義及取值范圍:

秒(0-59) 分(0-59) 時(0-23) 日(1-31) 月(1-12) 周(1-7或SUN-SAT) 年(四位數,可省略)

符號的含義:

  1. *表示所有值(秒位是*,則表示每秒)
  2. ?表示未說明的值,(日和周必須有一位為?,因為不合邏輯)
  3. -表示一個指定的范圍
  4. ,表示一個可能值
  5. /符號前表示開始時間,符號後表示每次遞增的值
  6. L最後的,在’天’上表示這個月最後一天,用在’周’上表示’7或SUN’,在周上與數字一起,如"7L"表示這個月的最後一個周六(阿麥利卡日歷,1表示周日)
  7. W隻能用在’天’上, 用來描敘最接近指定天的工作日（周一到周五） ,如"15W"指"最近接這個月第15天的工作日",如果第15天是周六,那麼會在第14天即周五觸發
  8. # 隻能在’周’上使用,用來指定這個月的第幾個周幾,如’6#3’表示這個月的第三個周五(6表示周五,3表示第三周).如果指定日期不存在,那麼將不會觸發
  9. C指和canlendar聯系後計算過的值,如在’天’上標註’5C’指這個月第五天或之後包括canlendar的第一天;在’周’上標’1C’指這周日或之後包括calendar的第一天.

當然不理解也沒關系,網上一搜就有很多Cron表達式在線生成器

實現定時任務

背景

使用異步進行文件上傳,將獲取token文件存到數據庫中,如果用戶在提交表單之前反復上傳文件會產生很多僵屍數據,需要使用定時任務刪除僵屍token字段和上傳到服務器的圖片

實現

開啟任務調度

@EnableScheduling //開啟任務調度
@SpringBootApplication
public class UploadApplication {
    public static void main(String[] args) {
        SpringApplication.run(UploadApplication.class, args);
    }
}

編寫清除僵屍token業務

//mapper
//獲取僵屍token的id
List<Integer> selectDeadTokens();
//清除僵屍數據
int deleteDeadToken(@Param("ids") List<Integer> ids);
<delete id="deleteDeadToken">
       delete from imagetoken where id in
       <foreach collection="ids" item="e" open="(" separator="," close=")">
           #{e}
       </foreach>
</delete>
<select id="selectDeadTokens" resultType="java.lang.Integer">
        SELECT id FROM imagetoken t
        WHERE t.token NOT IN (select token FROM good)
</select>
//service 
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.SERIALIZABLE)
    @Override
    public void deleteDeadToken() {
        System.out.println("---開始清除所有僵屍token---");
        List<Integer> list = imagetokenMapper.selectDeadTokens();
        System.out.println("已找到"+list.size()+"條數據");
        if (list.size()>0) {
            int result = imagetokenMapper.deleteDeadToken(list);
            System.out.println("本次刪除"+result+"條數據");
        }
    }

查找數據庫中存放文件地址的集合

 @Override
    public List<String> getList() {
        //條件構造器 查存放地址
        LambdaQueryWrapper<Good> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.select(Good::getSavepath);
        //this指的是當前service
        List<Good> list = this.list(queryWrapper);
//        System.out.println("查詢到的數據:");
//        System.out.println(list);
        //獲取數據庫中所有圖片的絕對路徑List<String>
        ArrayList<String> paths = new ArrayList<>();
        //將查到的數據中的文件地址遍歷到String類型的list中
        list.stream().forEach(good -> {
            paths.add(good.getSavepath());
        });
        //System.out.println("查到的路徑:"+paths);
        return  paths;
    }

使用@Scheduled註解開啟任務調度

@Value("${image.savepath}")
    String savePath;
    /**
     * 每天晚上23點清除無效token數據並刪除圖片
     */
    @Scheduled(cron = "0 0 23 * * ?")
    public void delete(){
        //1.清除無效token
        imagetokenService.deleteDeadToken();
        //2.刪除僵屍文件
        //2.1獲取數據庫中文件存儲列表
        List<String> paths = goodService.getList();
        //2.2 獲取圖片存儲地址
        File target=new File(savePath);
        //2.3遍歷圖片存儲所在文件夾的文件
        File[] files=target.listFiles();
        for (File file : files) {
            if (file.isFile()){
                //2.4獲取存儲文件的絕對地址,需要將盤符修改,
                String absPath = file.getAbsolutePath().replaceAll("\\\\", "/");
                //2.5將不存在的文件刪除
                if(!paths.contains(absPath)){
                     //System.out.println("要刪除文件的覺得路徑:"+absPath);
                     file.delete();
                 }
            }
        }
    }

到此這篇關於Spring Task定時任務的實現詳解的文章就介紹到這瞭,更多相關Spring定時任務內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：