You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

README.md 4.7 kB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. # spring-boot-demo-task
  2. > 此 demo 主要演示了 Spring Boot 如何快速实现定时任务。
  3. ## pom.xml
  4. ```xml
  5. <?xml version="1.0" encoding="UTF-8"?>
  6. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  7. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  8. <modelVersion>4.0.0</modelVersion>
  9. <artifactId>spring-boot-demo-task</artifactId>
  10. <version>1.0.0-SNAPSHOT</version>
  11. <packaging>jar</packaging>
  12. <name>spring-boot-demo-task</name>
  13. <description>Demo project for Spring Boot</description>
  14. <parent>
  15. <groupId>com.xkcoding</groupId>
  16. <artifactId>spring-boot-demo</artifactId>
  17. <version>1.0.0-SNAPSHOT</version>
  18. </parent>
  19. <properties>
  20. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  21. <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  22. <java.version>1.8</java.version>
  23. </properties>
  24. <dependencies>
  25. <dependency>
  26. <groupId>org.springframework.boot</groupId>
  27. <artifactId>spring-boot-starter-web</artifactId>
  28. </dependency>
  29. <dependency>
  30. <groupId>org.apache.commons</groupId>
  31. <artifactId>commons-lang3</artifactId>
  32. </dependency>
  33. <dependency>
  34. <groupId>org.projectlombok</groupId>
  35. <artifactId>lombok</artifactId>
  36. <optional>true</optional>
  37. </dependency>
  38. <dependency>
  39. <groupId>cn.hutool</groupId>
  40. <artifactId>hutool-all</artifactId>
  41. </dependency>
  42. <dependency>
  43. <groupId>org.springframework.boot</groupId>
  44. <artifactId>spring-boot-starter-test</artifactId>
  45. <scope>test</scope>
  46. </dependency>
  47. </dependencies>
  48. <build>
  49. <finalName>spring-boot-demo-task</finalName>
  50. <plugins>
  51. <plugin>
  52. <groupId>org.springframework.boot</groupId>
  53. <artifactId>spring-boot-maven-plugin</artifactId>
  54. </plugin>
  55. </plugins>
  56. </build>
  57. </project>
  58. ```
  59. ## TaskConfig.java
  60. > 此处等同于在配置文件配置
  61. >
  62. > ```properties
  63. > spring.task.scheduling.pool.size=20
  64. > spring.task.scheduling.thread-name-prefix=Job-Thread-
  65. > ```
  66. ```java
  67. /**
  68. * <p>
  69. * 定时任务配置,配置线程池,使用不同线程执行任务,提升效率
  70. * </p>
  71. *
  72. * @author yangkai.shen
  73. * @date Created in 2018-11-22 19:02
  74. */
  75. @Configuration
  76. @EnableScheduling
  77. @ComponentScan(basePackages = {"com.xkcoding.task.job"})
  78. public class TaskConfig implements SchedulingConfigurer {
  79. @Override
  80. public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
  81. taskRegistrar.setScheduler(taskExecutor());
  82. }
  83. /**
  84. * 这里等同于配置文件配置
  85. * {@code spring.task.scheduling.pool.size=20} - Maximum allowed number of threads.
  86. * {@code spring.task.scheduling.thread-name-prefix=Job-Thread- } - Prefix to use for the names of newly created threads.
  87. * {@link org.springframework.boot.autoconfigure.task.TaskSchedulingProperties}
  88. */
  89. @Bean
  90. public Executor taskExecutor() {
  91. return new ScheduledThreadPoolExecutor(20, new BasicThreadFactory.Builder().namingPattern("Job-Thread-%d").build());
  92. }
  93. }
  94. ```
  95. ## TaskJob.java
  96. ```java
  97. /**
  98. * <p>
  99. * 定时任务
  100. * </p>
  101. *
  102. * @author yangkai.shen
  103. * @date Created in 2018-11-22 19:09
  104. */
  105. @Component
  106. @Slf4j
  107. public class TaskJob {
  108. /**
  109. * 按照标准时间来算,每隔 10s 执行一次
  110. */
  111. @Scheduled(cron = "0/10 * * * * ?")
  112. public void job1() {
  113. log.info("【job1】开始执行:{}", DateUtil.formatDateTime(new Date()));
  114. }
  115. /**
  116. * 从启动时间开始,间隔 2s 执行
  117. * 固定间隔时间
  118. */
  119. @Scheduled(fixedRate = 2000)
  120. public void job2() {
  121. log.info("【job2】开始执行:{}", DateUtil.formatDateTime(new Date()));
  122. }
  123. /**
  124. * 从启动时间开始,延迟 5s 后间隔 4s 执行
  125. * 固定等待时间
  126. */
  127. @Scheduled(fixedDelay = 4000, initialDelay = 5000)
  128. public void job3() {
  129. log.info("【job3】开始执行:{}", DateUtil.formatDateTime(new Date()));
  130. }
  131. }
  132. ```
  133. ## application.yml
  134. ```yaml
  135. server:
  136. port: 8080
  137. servlet:
  138. context-path: /demo
  139. # 下面的配置等同于 TaskConfig
  140. #spring:
  141. # task:
  142. # scheduling:
  143. # pool:
  144. # size: 20
  145. # thread-name-prefix: Job-Thread-
  146. ```
  147. ## 参考
  148. - Spring Boot官方文档:https://docs.spring.io/spring-boot/docs/2.1.0.RELEASE/reference/htmlsingle/#boot-features-task-execution-scheduling