spring-boot 如何实现单次执行程序

 更新时间:2021年09月07日 14:31:40   作者:zombres  
这篇文章主要介绍了spring-boot 实现单次执行程序方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

spring-boot 单次执行程序

spring-boot做为spring的集大成框架,大部分时候作为WEB服务被集成使用,但某些情况下,需要手动执行一些逻辑的情况下,单次运行的类似脚本的程序也是很有用的。

本文记录一下使用spring-boot作为单次可执行程序配置方式。

pom.xml

注意:pom.xml部分只需引入spring-boot-starter模块,尤其不要引入web模块,其他非spring本身模块可以随意引入

<?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>
        <!-- 按工程习惯处理parent部分 -->
    </parent>
    <groupId>com.leon</groupId>
    <artifactId>sprint-boot-task</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <version>2.0.4</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

主要代码结构

Service类

@Service
public class StatService {
    public void doSomething() {
        System.out.println("===================: this is a test service but nothing");
    }
}

执行逻辑入口类

@Component
public class StatTask {
    private StatService statService;
    @Autowired
    public StatTask(StatService statService) {
        this.statService = statService;
    }
    public void doSomething() {
        statService.doSomething();
    }
}

Spring-boot 启动类

@SpringBootApplication
public class TaskApplication {
    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(TaskApplication.class, args);
        StatTask statTask = context.getBean(StatTask.class);  // 获取逻辑入口类的实例
        statTask.doSomething();
    }
}

如此这般后,启动这个springboot工程,执行完启动类中的调用过程后,程序就会自动退出。

基本上,不配置启用spring mvc和定时Job,这种配置下的springboot就是一个“脚本”程序。

这里举个?,上面的代码加上两个注解,就会变成常驻进程程序:

执行逻辑入口类

@Component
public class StatTask {
    private StatService statService;
    @Autowired
    public StatTask(StatService statService) {
        this.statService = statService;
    }
    
 @Scheduled(fixedRate = 5000L)   // --------------这里-----------------
    public void doSomething() {
        statService.doSomething();
    }
}

Spring-boot 启动类

@SpringBootApplication
@EnableScheduling   // --------------这里---------------
public class TaskApplication {
    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(TaskApplication.class, args);
        StatTask statTask = context.getBean(StatTask.class);
        statTask.doSomething();
    }
}

与最上面区别的是,上面只执行一次,输出 “this is a test service but nothing” 就完事了,进程自动退出,

加上两个注解后就会每5秒输出一次 “this is a test service but nothing”,且进程永驻。

当然这种情况下使用脚本语言如python、nodeJs等可能更好一些,但在其他语言不熟的情况下,使用spring-boot来应急也是极好的。

启动时执行单次任务

最近做任务遇到一个问题,需要在项目启动时候执行扫描数据库表的任务,用于异常恢复容灾,一开始想的是可不可以使用定时任务

代码如下 并且在启动类加上

@EnableScheduling注解就可以实现定时去执行任务了

package com.beihui.service.task; 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
@Component
public class XXXTask {
    private Logger logger = LoggerFactory.getLogger(this.getClass());
 
    @Scheduled(cron = "0 0 0 * * ?")
    public void bTask() {
        long startCurrentTime = System.currentTimeMillis();
        logger.info("开始执行定时任务:" + startCurrentTime);
        //业务处理
        long endTime = System.currentTimeMillis();
        logger.info("定时任务:执行结束,花费时间" + (endTime - startCurrentTime));
    } 
 
    @Scheduled(cron = "0 */1 * * * ?")
    public void runUpdateDbTask() {
        long startCurrentTime = System.currentTimeMillis();
        logger.info("开始执行更新数据库剩余次数定时任务:" + startCurrentTime);
       //业务处理
        long endTime = System.currentTimeMillis();
        logger.info("定时任务:执行结束,花费时间" + (endTime - startCurrentTime));
    }
 
    @Scheduled(fixedDelay = 60 * 1000 * 10)
    public void cTask() {
        long startCurrentTime = System.currentTimeMillis();
       //业务处理
 
        long endTime = System.currentTimeMillis();
        logger.info("定时任务:执行结束,花费时间" + (endTime - startCurrentTime));
    } 
}

但是这个并不能单次执行任务,所以后来 使用listener

代码如下,并在启动类加上

@ServletComponentScan注解

package xx.xx.xx; 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; 
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener; 
@WebListener
public class XXXListener implements ServletContextListener {
    private Logger logger = LoggerFactory.getLogger(this.getClass()); 
 
//项目启动执行
    @Override
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        long startTime = System.currentTimeMillis();
        logger.info("开始执行启动任务,{}"+startTime);
        //业务处理
        long endTime = System.currentTimeMillis();
        logger.info("执行启动任务结束,共花费时间{}"+(startTime-endTime));
    }
 
//项目终止时执行
    @Override
    public void contextDestroyed(ServletContextEvent servletContextEvent) { 
    }
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java实现发红包功能

    Java实现发红包功能

    这篇文章主要为大家详细介绍了Java实现发红包功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-11-11
  • Java中空指针异常该如何避免详解

    Java中空指针异常该如何避免详解

    空指针(Null Pointer Exception,NPE)是Java中最常见不过的异常了,其原因虽然显而易见,但是开发人员往往会忽略,或未能及时采取措施,下面这篇文章主要给大家介绍了关于Java中空指针异常该如何避免的相关资料,需要的朋友可以参考下
    2022-03-03
  • SpringBoot整合RocketMQ实现消息发送和接收的详细步骤

    SpringBoot整合RocketMQ实现消息发送和接收的详细步骤

    这篇文章主要介绍了SpringBoot整合RocketMQ实现消息发送和接收功能,我们使用主流的SpringBoot框架整合RocketMQ来讲解,使用方便快捷,本文分步骤给大家介绍的非常详细,需要的朋友可以参考下
    2021-08-08
  • Java开发工具IntelliJ IDEA安装图解

    Java开发工具IntelliJ IDEA安装图解

    这篇文章主要介绍了Java开发工具IntelliJ IDEA安装图解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • SpringMVC 中的视图使用 JSP的过程

    SpringMVC 中的视图使用 JSP的过程

    本文介绍了如何在 SpringMVC 中使用 JSP 视图,包括如何创建 JSP 视图、配置 JSP 视图解析器、以及如何在控制器方法中使用JSP视图,本文给大家介绍的非常详细,需要的朋友参考下吧
    2023-07-07
  • SpringBoot连接Redis2种模式解析

    SpringBoot连接Redis2种模式解析

    这篇文章主要介绍了SpringBoot连接Redis2种模式解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • Java设置Excel数据验证的示例代码

    Java设置Excel数据验证的示例代码

    数据验证是Excel 2013版本中,数据功能组下面的一个功能。本文将通过Java程序代码演示数据验证的设置方法及结果,感兴趣的可以了解一下
    2022-05-05
  • Java kafka如何实现自定义分区类和拦截器

    Java kafka如何实现自定义分区类和拦截器

    这篇文章主要介绍了Java kafka如何实现自定义分区类和拦截器,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • mybatis动态sql之新增与更新方式

    mybatis动态sql之新增与更新方式

    这篇文章主要介绍了mybatis动态sql之新增与更新方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • IntelliJ IDEA修改新建文件自动生成注释的user名

    IntelliJ IDEA修改新建文件自动生成注释的user名

    今天小编就为大家分享一篇关于IntelliJ IDEA修改新建文件自动生成注释的user名,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2018-10-10

最新评论