日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

如何在SchedulerX 2.0平臺上托管ElasticJob任務

更新時間:

分布式任務調度SchedulerX 2.0兼容開源ElasticJob任務接口,您無需修改代碼,即可將ElasticJob任務在SchedulerX 2.0平臺上進行托管。本文介紹如何在SchedulerX 2.0平臺上托管ElasticJob任務。

背景信息

ElasticJob基于Quartz開發并且依賴ZooKeeper作為注冊中心,是一款輕量級、無中心化的分布式任務調度框架,目前已經通過Apache開源。更多信息,請參見ElasticJob

SchedulerX 2.0優勢

豐富的可視化能力

  • 查看用戶大盤1

  • 查看任務歷史記錄2

  • 查看用戶運行日志3

  • 查看任務運行堆棧4

  • 查看任務操作記錄5

高級特性

  • 任務編排

    支持工作流(DAG)進行任務編排,可通過拖拽對前端進行操作。詳細的任務狀態圖方便您了解下游任務執行失敗的原因。6

  • 限流

    常見場景為夜間離線報表業務,例如,很多報表任務是凌晨1點或者2點開始,需控制應用最大并發的任務數量(否則業務無法支撐),達到并發上限的任務會在隊列中等待。若同時要求早上9點前必須完成KPI報表,可以設置KPI任務高優先級,高優先級任務會搶占低優先級任務,從而實現優先調度。

    SchedulerX 2. 0支持可搶占的任務優先級隊列,只需要在控制臺進行配置即可。

    7
  • 資源隔離

    支持命名空間和應用級別資源隔離,支持多租戶權限管理。

商業化報警運維

  • 報警

    支持通過郵件、釘釘、短信或電話進行任務執行失敗、超時和無可用機器報警通知。

  • 運維操作

    支持原地程序運行、重刷數據、標記成功、查看堆棧、停止任務和指定機器等。

免運維、低成本

ElasticJob依賴ZooKeeper作為任務存儲和任務調度協調,至少需要3個節點的ZooKeeper。如果有節點發生故障,需要重新配置ZooKeeper的服務端和客戶端的配置,可能需要重啟所有的應用。同時,受ZooKeeper功能限制,如果任務量級比較大,一個ZooKeeper集群將無法支撐住,且ZooKeeper無法水平擴展支持更大的TPS,就需要維護多個ZooKeeper集群,這樣會增加機器成本。

通過SchedulerX 2.0托管ElasticJob任務,您無需自己維護ZooKeeper集群,也無需關注任務量級的增長,從而節省了機器和人力的維護成本。

高可用

SchedulerX 2.0采用高可用架構,任務多備份機制,經歷阿里集團多年雙十一、容災演練,可以做到整個集群任意2個節點發生故障或者任意一個機房斷電,任務調度都不會受到影響。

與開源ElasticJob的區別

對比項

開源ElasticJob

SchedulerX為底座的ElasticJob任務

Simple任務

對對

Script任務

對對

Dataflow任務

對對

單機

對對

分片廣播

對對

定時

cron

cron、fixed_rate、fixed_delay、one_time

工作流

錯對

可視化

歷史記錄、日志服務、運行堆棧、操作記錄、用戶大盤等

監控報警

郵件

郵件、釘釘群、短信、電話

運維操作

運行一次、原地重跑、重刷數據、標記成功、停止運行

Spring Boot接入方法

以ElasticJob-3.0.1版本為例。更多信息,請參見Demo工程

  1. pom.xml文件增加schedulerx2-plugin-elasticjob插件,刪除elasticjob的依賴。

     <!-- 排掉elasticjob的依賴 -->
    <!--
     <dependency>
         <groupId>org.apache.shardingsphere.elasticjob</groupId>
         <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
         <version>3.0.1</version>
    </dependency>
    -->
    <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-plugin-elasticjob</artifactId>
        <version>3.0.1.3</version>
    </dependency>
  2. SchedulerX控制臺創建您的命名空間和應用。具體操作,請參見創建命名空間應用管理

  3. application.yml移除elasticjob的配置,增加schedulerx的配置。

    #elasticjob:
    #  regCenter:
    #    serverLists: localhost:2181
    #    namespace: elasticjob-springboot-demo
    schedulerx: #需增加一個"schedulerx:",則以下任務會自動同步到schedulerx控制臺
      jobs:
        simpleJob:
          elasticJobClass: com.alibaba.elasticjob.test.processor.SpringBootSimpleJob
          cron: 0/10 * * * * ?
          shardingTotalCount: 1
          overwrite: true
        shardingJob:
          elasticJobClass: com.alibaba.elasticjob.test.processor.SpringBootShardingJob
          cron: 0 * * * * ?
          shardingTotalCount: 3
          shardingItemParameters: 0=Beijing,1=Shanghai,2=Guangzhou
          overwrite: true
    #增加以下schedulerx的配置。更多信息,請參見Spring Boot應用接入SchedulerX。 
    spring:
       schedulerx2:
          endpoint: acm.aliyun.com
          namespace: 433d8b23-xxxx-xxxx-xxxx-90d4d1b9a4af
          groupId: xueren_primary
          appKey: xxxxxxxxxxx
          regionId: public
          aliyunAccessKey: xxxxxxxxxxxx
          aliyunSecretKey: xxxxxxxxxxxx
  4. 啟動程序增加自動掃描com.alibaba.schedulerx.plugin.*

    image..png
  5. 配置日志服務,搜集客戶端的日志。使用log4j2配置log4j2.xml。具體操作,請參見阿里巴巴任務調度SchedulerX支持日志服務

    <?xml version="1.0" encoding="UTF-8"?>
    <Configuration status="off">
    	<Appenders>
    		<Console name="Console" target="SYSTEM_OUT">
    			<PatternLayout
    				pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %m%n" />
    		</Console>
    		<SchedulerxLog4j2Appender name="schedulerxLog"
                timeFormat="yyyy-MM-dd'T'HH:mmZ"
                timeZone="UTC"
                ignoreExceptions="true">
            <PatternLayout pattern="%d %-5level [%thread] %logger{0}: %msg"/>
        </SchedulerxLog4j2Appender>
    	</Appenders>
    	<Loggers>
    		<Root level="info">
    			<AppenderRef ref="Console" />
    		</Root>
    		<Logger name="schedulerx" level="info" additivity="false">
    			<AppenderRef ref="schedulerxLog" />
    		</Logger>
    	</Loggers>
    </Configuration>

    Java執行類如下所示。

    image..png
  6. 啟動程序后,SchedulerX控制臺會自動同步任務。

    • 調度頻率為秒級別,時間類型會更改為second_delay。

    • 分片個數大于1,執行方式為分片運行,否則為單機運行。

    image..png

    通過控制臺,可以直接看到任務的運行日志

    63