Spring Boot 스케줄러 @Scheduled 어노테이션 사용

※ 1분마다 실행하여 특정폴더의 1분전 화일 삭제하기

 

@SpringBootApplication에 @EnableScheduling 선언

@EnableScheduling
@SpringBootApplication
public class DevApplication {
 
    @Bean
    public ObjectMapper objectMapper() {
        ObjectMapper objectMapper = new ObjectMapper();
        SimpleModule module = new SimpleModule();
        objectMapper.registerModule(module);
        return objectMapper;
    }
 
    public static void main(String[] args) {
        SpringApplication.run(DevApplication.class, args);
    }
 
}

 

@Scheduled > fixedDelay 사용

package com.coforward.dev.service;
 
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
 
import java.io.File;
import java.text.SimpleDateFormat;
import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
 
@Service
public class SchedulerService {
 
    @Value("${file.data}")
    private String dataFolder;
 
    // 1분전 화일 삭제
    @Scheduled(fixedDelay = 100000) // 1분마다 실행
    public void run() {
 
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        for(int i=1; i<=3; i++) {
            String path = dataFolder.replace("file:///", "") + "channel"+i;
            File folder = new File(path);
            try {
                File[] folder_list = folder.listFiles(); //파일리스트 얻어오기
                System.out.println("folder_list.length >>>>>>>" + folder_list.length);
                for (int j = 0; j < folder_list.length; j++) {
 
                    File files = new File(String.valueOf(folder_list[j]));
 
                    String date = String.valueOf(sdf.format(files.lastModified())).replaceAll("[^0-9]", "");
 
                    int reg_year = Integer.parseInt(date.substring(0, 4));
                    int reg_month = Integer.parseInt(date.substring(4, 6));
                    int reg_day = Integer.parseInt(date.substring(6, 8));
                    int reg_hour = Integer.parseInt(date.substring(8, 10));
                    int reg_min = Integer.parseInt(date.substring(10, 12));
                    int reg_sec = Integer.parseInt(date.substring(12, 14));
 
                    // 현재 날짜
                    LocalDate now = LocalDate.now();
 
                    // 현재 시간
                    LocalTime time = LocalTime.now();
 
                    LocalDateTime startDateTime = LocalDateTime.of(reg_year, reg_month, reg_day, reg_hour, reg_min, reg_sec);
                    LocalDateTime endDateTime = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), time.getHour(), time.getMinute(), time.getSecond());
 
                    Duration duration = Duration.between(startDateTime, endDateTime);
					
                    // .ts 확장자를 duration.getSeconds() 60초 이상 화일들 삭제
                    if (String.valueOf(folder_list[j]).contains(".ts") == true && duration.getSeconds() > 60) {
                        System.out.println("60초 이후 화일 삭제 ==>> " + folder_list[j] + " -- " + sdf.format(files.lastModified()) + " -- " + duration.getSeconds());
                        folder_list[j].delete(); //파일 삭제
                    }
                }
            } catch (Exception e) {
                e.getStackTrace();
            }
        }
    }
}