脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring Boot延迟执行

Spring Boot延迟执行实现方法

 更新时间：2025年04月01日 16:53:18   作者：何中应  
本文介绍了在Spring Boot项目中延迟执行方法的实现,以及延迟执行下声明式事务和编程式事务的使用情况,感兴趣的朋友一起看看吧

说明：本文介绍如何在Spring Boot项目中，延迟执行某方法，及讨论延迟执行方法的事务问题。

搭建Demo

首先，创建一个Spring Boot项目，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>

写个接口，打印进入方法时的时间

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";
    }
}

延迟执行实现

delayService，delay1()实现，如下：

    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
    /**
     * 延迟执行
     * @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);
    }

就是开了一个线程来执行，可设置延迟时间。启动项目，测试，如下：

（发送请求，响应结果即刻返回）

（控制台可见任务延迟5秒执行）

事务问题

写个实体类

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

再写个Mapper，里面写个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);
}

新建个延迟方法，delay2()，方法生加声明式注解，方法内手动制造一个异常

（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）

    /**
     * 声明式事务
     */
    @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);
    }

启动项目，调用方法

控制台没有报错

数据库，插入了一条数据，事务没有控制住

以上说明，声明式事务无法控制延迟执行的方法，并且异常也被线程内捕获了，没有抛出来。

编程式事务

试下编程式事务，手动实现事务，如下：

（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;
    /**
     * 编程式事务
     */
    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);
                // 故意产生异常
                int i = 1 / 0;
                user.setId(3);
                userMapper.insert(user);
                // 提交事务
                transactionManager.commit(status);
            } catch (Exception e) {
                transactionManager.rollback(status);
                e.printStackTrace();
            }
        }, time, TimeUnit.SECONDS);
    }

把数据库记录删掉，启动项目，测试

控制台报错

数据库没有插入记录，编程式事务控制住了

总结

本文介绍了在Spring Boot项目中延迟执行方法的实现，以及延迟执行下声明式事务和编程式事务的使用情况。

完整源码：https://github.com/HeZhongYing/delay_thread_demo

到此这篇关于Spring Boot延迟执行实现的文章就介绍到这了,更多相关Spring Boot延迟执行内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • 使用java + selenium + OpenCV破解网易易盾滑动验证码的示例

    使用java + selenium + OpenCV破解网易易盾滑动验证码的示例

    这篇文章主要介绍了使用java + selenium + OpenCV破解网易易盾滑动验证码,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-02-02
  • java 排序算法之冒泡排序

    java 排序算法之冒泡排序

    这篇文章主要介绍了java 排序算法之冒泡排序，文中运用大量的代码讲解相关知识，非常详细，感兴趣的小伙伴可以参考一下
    2021-09-09
  • Mybatis 如何传入字符串参数,分割并遍历

    Mybatis 如何传入字符串参数,分割并遍历

    这篇文章主要介绍了Mybatis 如何传入字符串参数，分割并遍历，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-01-01
  • hibernate多表操作实例代码

    hibernate多表操作实例代码

    这篇文章主要介绍了hibernate多表操作实例代码，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下
    2018-02-02
  • java高并发之线程的基本操作详解

    java高并发之线程的基本操作详解

    本文主要介绍java高并发线程的基本操作，这里整理详细的资料来解释线程的知识，有需要的学习高并发的朋友可以参考下
    2021-10-10
  • @JsonSerialize序列化注解的使用

    @JsonSerialize序列化注解的使用

    这篇文章主要介绍了@JsonSerialize序列化注解的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-08-08
  • Springboot如何配置yml文件与映射到java类

    Springboot如何配置yml文件与映射到java类

    这篇文章主要介绍了Springboot如何配置yml文件与映射到java类问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • SpringCloud Gateway网关功能介绍与使用

    SpringCloud Gateway网关功能介绍与使用

    SpringCloud Gateway 是 Spring Cloud 的一个全新项目，它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。这篇文章主要介绍了SpringCloud Gateway网关作用,需要的朋友可以参考下
    2022-12-12
  • Spring框架学习之Spring @Autowired实现自动装配的代码

    Spring框架学习之Spring @Autowired实现自动装配的代码

    自动装配就是说，你不用手动实现bean之间的组合关系，只要使用了@Autowired注解，程序就会自动的注入这个需要的bean，前提是你的Spring容器有这个bean，这篇文章主要介绍了Spring @Autowired实现自动装配,需要的朋友可以参考下
    2021-12-12
  • Java foreach相关原理及用法解析

    Java foreach相关原理及用法解析

    这篇文章主要介绍了Java foreach相关原理及用法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07

最新评论