Spring Boot延遲執(zhí)行實(shí)現(xiàn)方法

更新時(shí)間：2025年04月01日 16:53:18 作者：何中應(yīng)

本文介紹了在Spring Boot項(xiàng)目中延遲執(zhí)行方法的實(shí)現(xiàn),以及延遲執(zhí)行下聲明式事務(wù)和編程式事務(wù)的使用情況,感興趣的朋友一起看看吧

搭建Demo

首先，創(chuàng)建一個(gè)Spring Boot項(xiàng)目，pom.xml如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.12</version>
        <relativePath/>
    </parent>
    <groupId>com.hezy</groupId>
    <artifactId>delay_thread_demo</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.8</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.2</version>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.76</version>
        </dependency>
    </dependencies>
</project>

寫個(gè)接口，打印進(jìn)入方法時(shí)的時(shí)間

import com.hezy.service.DelayService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.text.SimpleDateFormat;
import java.util.Date;
@RestController
@RequestMapping("/demo")
@Log4j2
public class DemoController {
    @Autowired
    private DelayService delayService;
    @GetMapping
    public String demo() {
        return "Hello World!";
    }
    @GetMapping("/delay1/{time}")
    public String delay1(@PathVariable Integer time) {
        log.info("enter delay1...date={} time={}",
                new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
        delayService.delay1(time);
        return "success";
    }
}

延遲執(zhí)行實(shí)現(xiàn)

delayService，delay1()實(shí)現(xiàn)，如下：

    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
    /**
     * 延遲執(zhí)行
     * @param time
     */
    public void delay1(Integer time) {
        scheduler.schedule(() -> {
            log.info("run delay1...date={} time={}",
                    new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
        }, time, TimeUnit.SECONDS);
    }

就是開了一個(gè)線程來(lái)執(zhí)行，可設(shè)置延遲時(shí)間。啟動(dòng)項(xiàng)目，測(cè)試，如下：

（發(fā)送請(qǐng)求，響應(yīng)結(jié)果即刻返回）

（控制臺(tái)可見任務(wù)延遲5秒執(zhí)行）

事務(wù)問(wèn)題

寫個(gè)實(shí)體類

import lombok.Data;
@Data
public class User {
    private Integer id;
    private String username;
    private String password;
}

再寫個(gè)Mapper，里面寫個(gè)insert()方法

import com.hezy.pojo.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UserMapper {
    @Insert("insert into user (id, username, password) values (#{id}, #{username}, #{password})")
    void insert(User user);
}

新建個(gè)延遲方法，delay2()，方法生加聲明式注解，方法內(nèi)手動(dòng)制造一個(gè)異常

（controller）

    @PostMapping("/delay2/{time}")
    public String delay2(@RequestBody User user, @PathVariable Integer time) {
        log.info("enter delay2...date={} time={}",
                new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
        delayService.delay2(user, time);
        return "success";
    }

（service）

    /**
     * 聲明式事務(wù)
     */
    @Transactional(rollbackFor = Exception.class)
    public void delay2(User user, Integer time) {
        scheduler.schedule(() -> {
            log.info("run delay2...date={} time={}",
                    new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
            userMapper.insert(user);
            int i = 1 / 0;
            user.setId(3);
            userMapper.insert(user);
        }, time, TimeUnit.SECONDS);
    }

啟動(dòng)項(xiàng)目，調(diào)用方法

控制臺(tái)沒有報(bào)錯(cuò)

數(shù)據(jù)庫(kù)，插入了一條數(shù)據(jù)，事務(wù)沒有控制住

以上說(shuō)明，聲明式事務(wù)無(wú)法控制延遲執(zhí)行的方法，并且異常也被線程內(nèi)捕獲了，沒有拋出來(lái)。

編程式事務(wù)

試下編程式事務(wù)，手動(dòng)實(shí)現(xiàn)事務(wù)，如下：

（controller）

    @PostMapping("/delay3/{time}")
    public String delay3(@RequestBody User user, @PathVariable Integer time) {
        log.info("enter delay3...date={} time={}",
                new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
        delayService.delay3(user, time);
        return "success";
    }

（service）

    @Autowired
    private PlatformTransactionManager transactionManager;
    /**
     * 編程式事務(wù)
     */
    public void delay3(User user, Integer time) {
        scheduler.schedule(() -> {
            TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
            try {
                log.info("run delay3...date={} time={}",
                        new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()), time);
                userMapper.insert(user);
                // 故意產(chǎn)生異常
                int i = 1 / 0;
                user.setId(3);
                userMapper.insert(user);
                // 提交事務(wù)
                transactionManager.commit(status);
            } catch (Exception e) {
                transactionManager.rollback(status);
                e.printStackTrace();
            }
        }, time, TimeUnit.SECONDS);
    }

把數(shù)據(jù)庫(kù)記錄刪掉，啟動(dòng)項(xiàng)目，測(cè)試