欢乐颂第一季免费阅读,我欲封天耳根小说

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案

SpringCloudTask一個(gè)允許短期運(yùn)行的微服務(wù)組件

簡(jiǎn)介

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

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

環(huán)境要求

你需要安裝Java(Java 8或更高的版本)。要進(jìn)行構(gòu)建，還需要安裝Maven。

數(shù)據(jù)庫(kù)要求

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

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

簡(jiǎn)單任務(wù)

@SpringBootApplication
@EnableTask
public class SpringCloudTaskDemoApplication {

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

}

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

執(zhí)行

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

任務(wù)執(zhí)行完以后會(huì)在數(shù)據(jù)表中記錄相關(guān)的執(zhí)行結(jié)果信息。

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

事件監(jiān)聽

我們?nèi)蝿?wù)的執(zhí)行在每一個(gè)節(jié)點(diǎn)上都可以進(jìn)行相關(guān)的監(jiān)聽處理

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

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

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

以上是通過注解的方式實(shí)現(xiàn)，我們也可以通過實(shí)現(xiàn)TaskExecutionListener接口的方式實(shí)現(xiàn)。

@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) {
  }

}

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

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

限制任務(wù)執(zhí)行

如果你要控制每個(gè)任務(wù)只允許同時(shí)允許一個(gè)，那么我們可以通過如下方式控制：

添加依賴：


  org.springframework.integration
  spring-integration-core


  org.springframework.integration
  spring-integration-jdbc

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

添加配置：

spring:
  cloud:
    task:
      singleInstanceEnabled: true

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

完畢!!

分享題目：SpringCloudTask一個(gè)允許短期運(yùn)行的微服務(wù)組件
轉(zhuǎn)載來于：http://fisionsoft.com.cn/article/dpppehg.html