springboot 예약 작업을 생성하는 방법

springboot에 대해 더 알고 싶다면 다음을 클릭하세요. JAVA tutorial

SpringBoot를 사용하여 예약된 작업을 생성하는 방법은 현재 매우 간단합니다.

　 1. 주석 기반(@Scheduled)

2. 인터페이스 기반(SchedulingConfigurer) 전자는 다들 익숙하실 거라 생각하지만, 실제 사용에서는 지정된 시간을 데이터베이스에서 동적으로 읽어오고 싶은 경우가 많습니다. 예약된 작업을 실행합니다. 이때 인터페이스 기반 예약 작업이 유용합니다.

3. 주석을 기반으로 멀티 스레드 예약 작업 설정

1. 정적: 주석 기반

주석 기반 @Scheduled는 다중 스레드인 경우 기본값은 단일 스레드입니다. 작업이 활성화되면 작업 실행 시간은 이전 작업의 실행 시간에 영향을 받습니다. @Scheduled默认为单线程，开启多个任务时，任务的执行时机会受上一个任务执行时间的影响。

1、创建定时器

使用SpringBoot基于注解来创建定时任务非常简单，只需几行代码便可完成。 代码如下：

@Component
@Configuration      //1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling   // 2.开启定时任务
public class SaticScheduleTask {
    //3.添加定时任务
    @Scheduled(cron = "0/5 * * * * ?")
    //或直接指定时间间隔，例如：5秒
    //@Scheduled(fixedRate=5000)
    private void configureTasks() {
        System.err.println("执行静态定时任务时间: " + LocalDateTime.now());
    }
}

Cron表达式参数分别表示：

　　秒（0~59） 例如0/5表示每5秒

　　分（0~59）

　　时（0~23）

　　日（0~31）的某天，需计算

　　月（0~11）

　　周几（ 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT）

@Scheduled：除了支持灵活的参数表达式cron之外，还支持简单的延时操作，例如 fixedDelay ，fixedRate 填写相应的毫秒数即可。

2、启动测试

启动应用，可以看到控制台打印出如下信息：

显然，使用@Scheduled 注解很方便，但缺点是当我们调整了执行周期的时候，需要重启应用才能生效，这多少有些不方便。为了达到实时生效的效果，可以使用接口来完成定时任务。

二、动态：基于接口

基于接口（SchedulingConfigurer

1. 타이머 만들기

SpringBoot를 사용하여 주석을 기반으로 예약된 작업을 만드는 것은 매우 간단하며 단 몇 줄의 코드로 완료할 수 있습니다. 코드는 다음과 같습니다.

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
        <version>2.0.4.RELEASE</version>
    </parent>

    <dependencies>
        <dependency><!--添加Web依赖 -->
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency><!--添加MySql依赖 -->
             <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency><!--添加Mybatis依赖 配置mybatis的一些初始化的东西-->
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.1</version>
        </dependency>
        <dependency><!-- 添加mybatis依赖 -->
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.5</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

Cron 표현식 매개변수는 각각 다음을 나타냅니다.
초(0~59) 예를 들어 0/5는 5초마다를 의미합니다.

분(0~59)시간(0~23)

Days 일(0~31)에는 월(0~11)

과 요일(1~7 또는 SUN/MON/TUE/WED/THU/FRI/ 입력 가능)을 계산해야 합니다. SAT)

@Scheduled : 유연한 매개변수 표현 cron을 지원하는 것 외에도fixedDelay 및fixedRate와 같은 간단한 지연 작업도 지원합니다. 해당 숫자를 밀리초 단위로 입력하면 됩니다.
2. 테스트 시작

애플리케이션을 시작하면 콘솔에 다음 정보가 출력되는 것을 볼 수 있습니다:

물론 @Scheduled 주석을 사용하는 것은 매우 편리하지만 단점은 실행 주기를 조정할 때 , 적용하려면 애플리케이션을 다시 시작해야 하는데 이는 다소 불편합니다. 실시간 효과를 얻으려면 인터페이스를 사용하여 예약된 작업을 완료할 수 있습니다.

2. 동적: 인터페이스 기반

인터페이스 기반(SchedulingConfigurer)

1. 종속성 패키지 가져오기

DROP DATABASE IF EXISTS `socks`;
CREATE DATABASE `socks`;
USE `SOCKS`;
DROP TABLE IF EXISTS `cron`;
CREATE TABLE `cron`  (
  `cron_id` varchar(30) NOT NULL PRIMARY KEY,
  `cron` varchar(30) NOT NULL  
);
INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');

2.

로컬 데이터베이스 mysql을 열고, 쿼리 창을 마음대로 연 후 다음과 같이 스크립트 내용을 실행합니다.

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/socks
    username: root
    password: 123456

그런 다음 프로젝트의 application.yml에 데이터 소스를 추가합니다.

@Component
@Configuration      //1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling   // 2.开启定时任务
public class DynamicScheduleTask implements SchedulingConfigurer {

    @Mapper
    public interface CronMapper {
        @Select("select cron from cron limit 1")
        public String getCron();
    }

    @Autowired      //注入mapper
    @SuppressWarnings("all")
    CronMapper cronMapper;

    /**
     * 执行定时任务.
     */
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

        taskRegistrar.addTriggerTask(
                //1.添加任务内容(Runnable)
                () -> System.out.println("执行动态定时任务: " + LocalDateTime.now().toLocalTime()),
                //2.设置执行周期(Trigger)
                triggerContext -> {
                    //2.1 从数据库获取执行周期
                    String cron = cronMapper.getCron();
                    //2.2 合法性校验.
                    if (StringUtils.isEmpty(cron)) {
                        // Omitted Code ..
                    }
                    //2.3 返回执行周期(Date)
                    return new CronTrigger(cron).nextExecutionTime(triggerContext);
                }
        );
    }

}

3. 타이머 만들기
데이터베이스가 데이터를 준비한 후 예약된 작업을 작성합니다. 여기서 TriggerTask는 데이터베이스에 설정한 실행 주기를 주기적으로 읽고 실행하는 것입니다. 관련된 예정된 작업의 내용.

　구체적인 코드는 다음과 같습니다.

//@Component注解用于对那些比较中立的类进行注释；
//相对与在持久层、业务层和控制层分别采用 @Repository、@Service 和 @Controller 对分层中的类进行注释
@Component
@EnableScheduling   // 1.开启定时任务
@EnableAsync        // 2.开启多线程
public class MultithreadScheduleTask {

        @Async
        @Scheduled(fixedDelay = 1000)  //间隔1秒
        public void first() throws InterruptedException {
            System.out.println("第一个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
            System.out.println();
            Thread.sleep(1000 * 10);
        }

        @Async
        @Scheduled(fixedDelay = 2000)
        public void second() {
            System.out.println("第二个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
            System.out.println();
        }
    }

4. 테스트 시작

🎜🎜🎜🎜애플리케이션을 시작한 후 콘솔에서 예상대로 인쇄 시간이 10초에 한 번인지 확인합니다. Navicat을 열고 실행 주기를 변경합니다. 그림과 같이 6초마다 실행되도록 수정되었습니다: 🎜🎜🎜🎜🎜 콘솔을 확인하고 실행 주기가 변경되었음을 확인하면 애플리케이션을 다시 시작할 필요가 없습니다. 편리한. 그림에 표시된 대로: 🎜🎜🎜🎜🎜🎜 참고: 🎜 데이터베이스 수정 시 형식 오류가 발생하면 예약된 작업이 중지됩니다. 이때 수정이 정확하더라도 프로젝트는 다음을 통해서만 복원할 수 있습니다. 프로젝트를 다시 시작합니다. 🎜🎜🎜🎜3. 멀티 스레드 예약 작업🎜🎜🎜🎜주석을 기반으로 멀티 스레드 예약 작업 설정🎜🎜1. 멀티 스레드 예약 작업 생성🎜rrreee🎜🎜🎜2. 테스트 시작🎜🎜🎜🎜🎜후 애플리케이션을 실행하고 콘솔 보기: 🎜🎜🎜🎜

콘솔에서 볼 수 있듯이 첫 번째 예약된 작업과 두 번째 예약된 작업은 서로 영향을 미치지 않습니다.

그리고 멀티 스레딩이 활성화되어 있으므로 첫 번째 작업의 실행 시간은 자체 실행에 의해 제한되지 않습니다. 시간이므로 반복된 작업으로 인해 데이터 이상이 발생할 수 있다는 점에 유의해야 합니다.

위 내용은 springboot 예약 작업을 생성하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!