日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

簡介

Spring Cloud Task使創(chuàng)建短期微服務變得容易。它提供了在生產環(huán)境中按需執(zhí)行短期JVM進程的功能。

10多年的城陽網站建設經驗，針對設計、前端、開發(fā)、售后、文案、推廣等六對一服務，響應快，48小時及時工作處理。營銷型網站的優(yōu)勢是能夠根據用戶設備顯示端的尺寸不同，自動調整城陽建站的顯示方式，使網站能夠適用不同顯示終端，在瀏覽器中調整網站的寬度，無論在任何一種瀏覽器上瀏覽網站，都能展現優(yōu)雅布局與設計，從而大程度地提升瀏覽體驗。成都創(chuàng)新互聯從事“城陽網站設計”,“城陽網站推廣”以來，每個客戶項目都認真落實執(zhí)行。

環(huán)境要求

你需要安裝Java(Java 8或更高的版本)。要進行構建，還需要安裝Maven。

數據庫要求

Spring Cloud Task使用關系數據庫存儲已執(zhí)行任務的結果。雖然你可以在沒有數據庫的情況下開始開發(fā)任務(任務的狀態(tài)記錄為任務存儲庫更新的一部分)，但對于生產環(huán)境，你希望使用受支持的數據庫。Spring Cloud Task 目前支持以下數據庫：

• DB2
• H2
• HSQLDB
• MySql
• Oracle
• Postgres
• SqlServer

依賴管理

  org.springframework.boot
  spring-boot-starter-data-jpa


  org.springframework.cloud
  spring-cloud-starter-task


  mysql
  mysql-connector-java

配置文件

server:
  port: 8082
---
spring:
  datasource:
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/tasks?serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
    username: root
    password: root
    type: com.zaxxer.hikari.HikariDataSource
    hikari:
      minimumIdle: 10
      maximumPoolSize: 200
      autoCommit: true
      idleTimeout: 30000
      poolName: MasterDatabookHikariCP
      maxLifetime: 1800000
      connectionTimeout: 30000
      connectionTestQuery: SELECT 1
---
spring:
  h2:
    console:
      enabled: true
      settings:
        web-allow-others: true
      path: /h2
---
spring:
  application:
    name: taskDemo      
---
logging:
  level:
    org.springframework.cloud.task: DEBUG

簡單任務

@SpringBootApplication
@EnableTask
public class SpringCloudTaskDemoApplication {

  @Bean
  public CommandLineRunner helloRunner() {
    return new CommandLineRunner() {
      @Override
      public void run(String... args) throws Exception {
        System.out.println("開始執(zhí)行任務") ;
        TimeUnit.SECONDS.sleep(1) ;
        System.out.println("任務執(zhí)行完成") ;
      }
    };
  }
  
  public static void main(String[] args) {
    SpringApplication.run(SpringCloudTaskDemoApplication.class, args);
  }

}

注意這里需要@EnableTask開啟功能，然后自定義了一個CommandLineRunner類型的Bean。我們的任務都應該在CommandLineRunner或者ApplicationRunner中執(zhí)行。

執(zhí)行

run方法執(zhí)行完以后我們的JVM進程也跟著結束了。這就是所謂的短期任務了，我們不需要任務一直執(zhí)行，只需要在需要的時候執(zhí)行即可。

任務執(zhí)行完以后會在數據表中記錄相關的執(zhí)行結果信息。

這些表記錄了本次任務執(zhí)行的相關信息，成功，失敗等。

事件監(jiān)聽

我們任務的執(zhí)行在每一個節(jié)點上都可以進行相關的監(jiān)聽處理

@Component
public class TaskListenerConfig {
  
  @BeforeTask
  public void before(TaskExecution taskExecution) {
    System.out.println("任務執(zhí)行前") ;
  }

  @AfterTask
  public void after(TaskExecution taskExecution) {
    System.out.println("任務執(zhí)行后") ;
  }

  @FailedTask
  public void fail(TaskExecution taskExecution, Throwable throwable) {
    System.out.println("任務執(zhí)行失敗，" + throwable.getMessage()) ;
  }
  
}

以上是通過注解的方式實現，我們也可以通過實現TaskExecutionListener接口的方式實現。

@Component
public class DemoListener implements TaskExecutionListener {

  @Override
  public void onTaskStartup(TaskExecution taskExecution) {
  }

  @Override
  public void onTaskEnd(TaskExecution taskExecution) {
  }

  @Override
  public void onTaskFailed(TaskExecution taskExecution, Throwable throwable) {
  }

}

任務監(jiān)聽發(fā)生異常

如果TaskExecutionListener事件處理程序引發(fā)異常，則該事件處理程序的所有偵聽器處理都將停止。例如，如果已啟動三個onTaskStartup偵聽器，并且第一個onTaskStartup事件處理程序引發(fā)異常，則不會調用其他兩個onTaskStartup方法。但是，會調用TaskExecutionListeners的其他事件處理程序(onTaskEnd和onTaskFailed)。因為執(zhí)行這些回調方法都是在不同的階段執(zhí)行的，所以只會影響那個階段的事件并不會影響其它階段事件。

限制任務執(zhí)行

如果你要控制每個任務只允許同時允許一個，那么我們可以通過如下方式控制：

添加依賴：

  org.springframework.integration
  spring-integration-core


  org.springframework.integration
  spring-integration-jdbc

上面2個依賴是必須的，這是限制任務執(zhí)行所需要的。

添加配置：

spring:
  cloud:
    task:
      singleInstanceEnabled: true

開啟單任務執(zhí)行。

完畢!!

新聞標題：SpringCloudTask一個允許短期運行的微服務組件
鏈接分享：http://www.5511xx.com/article/dpppehg.html