Spring Cloud Task 配置DataSource

清疚 2023-02-28 01:29 13阅读 0赞

### 文章目录 ###

*   *  Spring Cloud Task 配置DataSource
     *  源代码

## Spring Cloud Task 配置DataSource ##

Spring Cloud Task使用一个数据源来存储task执行的结果。默认情况下，提供一个内存中的H2实例来作为数据源。但是，在生产环境中，还是需要配置自己的数据源。如果只使用一个DataSource，并且该DataSourc同时用为业务数据存储和task执行结果的存储，那么所需要做的就是提供任何DataSource，比如MySQL。最简单的方法是通过Spring Boot的配置约定。

本篇博文就使用mysql来存储task的执行结果，下面来看看具体的配置和代码。

关于代码我们还是使用之前一样的代码：

package com.example;
    
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.task.configuration.EnableTask;
    import org.springframework.cloud.task.listener.annotation.AfterTask;
    import org.springframework.cloud.task.listener.annotation.BeforeTask;
    import org.springframework.cloud.task.listener.annotation.FailedTask;
    import org.springframework.cloud.task.repository.TaskExecution;
    import org.springframework.context.annotation.Bean;
    
    @SpringBootApplication
    @EnableTask
    public class HelloWorldApplication { 
    
    
        @Bean
        public CommandLineRunner commandLineRunner() { 
            return new MyCommonLineRunner();
        }
    
        @BeforeTask
        public void beforeTask(TaskExecution taskExecution){ 
            System.out.println("task start.." + taskExecution.toString());
        }
    
    
        @AfterTask
        public void afterTask(TaskExecution taskExecution){ 
            System.out.println("task end.." + taskExecution.toString());
        }
    
    
        @FailedTask
        public void failedTask(TaskExecution taskExecution){ 
            System.out.println("task fail.." + taskExecution.toString());
        }
    
        public static class MyCommonLineRunner implements CommandLineRunner { 
            @Override
            public void run(String... args) throws Exception { 
                System.out.println("Hello, World");
            }
        }
    
        public static void main(String[] args) { 
            SpringApplication.run(HelloWorldApplication.class, args);
        }
    }

然后我们需要加上maven的依赖：

<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>8.0.21</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-jpa</artifactId>
    		</dependency>

还有加上配置，然后还有docker安装好mysql，然后创建一个database，命名为testdb

# 将Spring Cloud Task的日志记录设置为DEBUG, 可以更方便的让我们调试应用
    logging.level.org.springframework.cloud.task=DEBUG
    # 设置application name (会转为task name)
    spring.application.name=HelloWorld
    
    
    # docker pull mysql
    # docker run --name mysql -p 3306:3306 -e MYSQL_ROOT_PASSWORD=root -d mysql
    spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
    spring.datasource.url = jdbc:mysql://192.168.99.100:3306/testdb?useUnicode=true&character_set_server=utf8mb4&useSSL=false&allowPublicKeyRetrieval=true
    spring.datasource.username = root
    spring.datasource.password = root

然后我们运行项目

.   ____          _            __ _ _
     /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
     \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
      ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.4.0-SNAPSHOT) 2020-07-18 22:23:50.800 INFO 15012 --- [ main] com.example.HelloWorldApplication : Starting HelloWorldApplication using Java 1.8.0_92 on C with PID 15012 (C:\Users\c\Desktop\spring-cloud-task-demo\target\classes started by c in C:\Users\c\Desktop\spring-cloud-task-demo) 2020-07-18 22:23:50.803 INFO 15012 --- [ main] com.example.HelloWorldApplication : No active profile set, falling back to default profiles: default 2020-07-18 22:23:51.338 INFO 15012 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data JPA repositories in DEFERRED mode. 2020-07-18 22:23:51.357 INFO 15012 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 8 ms. Found 0 JPA repository interfaces. 2020-07-18 22:23:51.915 INFO 15012 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor' 2020-07-18 22:23:51.926 INFO 15012 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Starting... 2020-07-18 22:23:52.064 INFO 15012 --- [ main] com.zaxxer.hikari.HikariDataSource : HikariPool-1 - Start completed. 2020-07-18 22:23:52.126 INFO 15012 --- [ task-1] o.hibernate.jpa.internal.util.LogHelper : HHH000204: Processing PersistenceUnitInfo [name: default] 2020-07-18 22:23:52.146 DEBUG 15012 --- [ main] o.s.c.t.c.SimpleTaskAutoConfiguration : Using org.springframework.cloud.task.configuration.DefaultTaskConfigurer TaskConfigurer 2020-07-18 22:23:52.147 DEBUG 15012 --- [ main] o.s.c.t.c.DefaultTaskConfigurer : EntityManager was found, using JpaTransactionManager 2020-07-18 22:23:52.199 INFO 15012 --- [ task-1] org.hibernate.Version : HHH000412: Hibernate ORM core version 5.4.18.Final 2020-07-18 22:23:52.417 INFO 15012 --- [ task-1] o.hibernate.annotations.common.Version : HCANN000001: Hibernate Commons Annotations {5.1.0.Final} 2020-07-18 22:23:52.496 DEBUG 15012 --- [ main] o.s.c.t.r.s.TaskRepositoryInitializer : Initializing task schema for mysql database 2020-07-18 22:23:52.654 INFO 15012 --- [ task-1] org.hibernate.dialect.Dialect : HHH000400: Using dialect: org.hibernate.dialect.MySQL8Dialect 2020-07-18 22:23:52.917 INFO 15012 --- [ task-1] o.h.e.t.j.p.i.JtaPlatformInitiator : HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform] 2020-07-18 22:23:52.935 INFO 15012 --- [ task-1] j.LocalContainerEntityManagerFactoryBean : Initialized JPA EntityManagerFactory for persistence unit 'default' 2020-07-18 22:23:53.048 DEBUG 15012 --- [ main] o.s.c.t.r.support.SimpleTaskRepository : Creating: TaskExecution{executionId=0, parentExecutionId=null, exitCode=null, taskName='HelloWorld', startTime=Sat Jul 18 22:23:52 GMT+08:00 2020, endTime=null, exitMessage='null', externalExecutionId='null', errorMessage='null', arguments=[]} task start..TaskExecution{executionId=1, parentExecutionId=null, exitCode=null, taskName='HelloWorld', startTime=Sat Jul 18 22:23:52 GMT+08:00 2020, endTime=null, exitMessage='null', externalExecutionId='null', errorMessage='null', arguments=[]} 2020-07-18 22:23:53.073 INFO 15012 --- [ main] DeferredRepositoryInitializationListener : Triggering deferred initialization of Spring Data repositories… 2020-07-18 22:23:53.073 INFO 15012 --- [ main] DeferredRepositoryInitializationListener : Spring Data repositories initialized! 2020-07-18 22:23:53.081 INFO 15012 --- [ main] com.example.HelloWorldApplication : Started HelloWorldApplication in 2.701 seconds (JVM running for 5.796) Hello, World task end..TaskExecution{executionId=1, parentExecutionId=null, exitCode=0, taskName='HelloWorld', startTime=Sat Jul 18 22:23:52 GMT+08:00 2020, endTime=Sat Jul 18 22:23:53 GMT+08:00 2020, exitMessage='null', externalExecutionId='null', errorMessage='null', arguments=[]} 2020-07-18 22:23:53.098 DEBUG 15012 --- [ main] o.s.c.t.r.support.SimpleTaskRepository : Updating: TaskExecution with executionId=1 with the following {exitCode=0, endTime=Sat Jul 18 22:23:53 GMT+08:00 2020, exitMessage='null', errorMessage='null'} 2020-07-18 22:24:52.941 INFO 15012 --- [extShutdownHook] j.LocalContainerEntityManagerFactoryBean : Closing JPA EntityManagerFactory for persistence unit 'default' 2020-07-18 22:24:52.944 INFO 15012 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor'
    2020-07-18 22:24:52.944  INFO 15012 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown initiated...
    2020-07-18 22:24:52.950  INFO 15012 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown completed.
    
    Process finished with exit code 0

从日志输出来看，我们已经使用了MySQL作为我们的数据源了。

然后我们查看我们的tables

show tables ;

可以看到自动创建了下面这些表

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nja2V2aW5jeWg_size_16_color_FFFFFF_t_70]

然后我们可以查看task的执行结果记录。

select  * from TASK_EXECUTION;

![在这里插入图片描述][20200718231232619.png]

## 源代码 ##

[https://gitee.com/cckevincyh/Spring-Cloud-Task/tree/task-datasource][https_gitee.com_cckevincyh_Spring-Cloud-Task_tree_task-datasource]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nja2V2aW5jeWg_size_16_color_FFFFFF_t_70]: /images/20230209/0eff47f30b6e45e8a6a6981998300bda.png
[20200718231232619.png]: /images/20230209/d290bf40cdd3452fa87501968f5dbe5f.png
[https_gitee.com_cckevincyh_Spring-Cloud-Task_tree_task-datasource]: https://gitee.com/cckevincyh/Spring-Cloud-Task/tree/task-datasource