欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot2整合ElasticJob框架過程詳解

 更新時間:2020年03月12日 14:26:00   作者:我是小白1  
這篇文章主要介紹了SpringBoot2整合ElasticJob框架過程詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

一、ElasticJob

簡介

1、定時任務

在前面的文章中,說過QuartJob這個定時任務,被廣泛應用的定時任務標準。但Quartz核心點在于執(zhí)行定時任務并不是在于關注的業(yè)務模式和場景,缺少高度自定義的功能。Quartz能夠基于數(shù)據(jù)庫實現(xiàn)任務的高可用,但是不具備分布式并行調(diào)度的功能。

-> QuartJob定時任務

2、ElasticJob說明基礎簡介

Elastic-Job 是一個開源的分布式調(diào)度中間件,由兩個相互獨立的子項目 Elastic-Job-Lite 和 Elastic-Job-Cloud 組成。Elastic-Job-Lite 為輕量級無中心化解決方案,使用 jar 包提供分布式任務的調(diào)度和治理。 Elastic-Job-Cloud 是一個 Mesos Framework,依托于Mesos額外提供資源治理、應用分發(fā)以及進程隔離等服務。

功能特點

  • 分布式調(diào)度
  • 協(xié)調(diào)彈性擴容縮容
  • 失效轉(zhuǎn)移
  • 錯過執(zhí)行
  • 作業(yè)重觸發(fā)作業(yè)分片一致性,保證同一分片在分布式環(huán)境中僅一個執(zhí)行實例

補刀:人家官網(wǎng)這樣描述的,這里贅述一下,充實一下文章。

基礎框架結(jié)構

該圖片來自ElasticJob官網(wǎng)。

由圖可知如下內(nèi)容:

需要Zookeeper組件支持,作為分布式的調(diào)度任務,有良好的監(jiān)聽機制,和控制臺,下面的案例也就沖這個圖解來。

3、分片管理

這個概念在ElasticJob中是最具有特點的,實用性極好。

分片概念

任務的分布式執(zhí)行,需要將一個任務拆分為多個獨立的任務項,然后由分布式的服務器分別執(zhí)行某一個或幾個分片項。

場景描述:假設有服務3臺,分3片管理,要處理數(shù)據(jù)表100條,那就可以100%3,按照余數(shù)0,1,2分散到三臺服務上執(zhí)行,看到這里分庫分表的基本邏輯涌上心頭,這就是為何很多大牛講說,編程思維很重要。

個性化參數(shù)

個性化參數(shù)即shardingItemParameter,可以和分片項匹配對應關系,用于將分片項的數(shù)字轉(zhuǎn)換為更加可讀的業(yè)務代碼。

場景描述:這里猛一讀好像很飄逸,其實就是這個意思,如果分3片,取名[0,1,2]不好看,或者不好標識,可以分別給個別名標識一下,[0=A,1=B,2=C]。

二、定時任務加載

1、核心依賴包

這里使用2.0+的版本。

<dependency>
  <groupId>com.dangdang</groupId>
  <artifactId>elastic-job-lite-core</www.lanboylsy.com artifactId>
  <version>2.1.5</version>
</dependency>
<dependency>
  <groupId>com.dangdang<www.yuanyangyul.com /groupId>
  <artifactId>elastic-job-lite-spring<www.lexuancaizc.cn /artifactId>
  <version>2.1.5</version>
</dependency>

2、核心配置文件

這里主要配置一下Zookeeper中間件,分片和分片參數(shù)。

zookeeper:
 server: 127.0.0.1:2181
 namespace: es-job
job-config:
 cron: 0/10 * * * * ?
 shardCount: 1
 shardItem: 0=A,1=B,2=shentuylzc.cn C,3www.yongxinylzn.cn=D

3、自定義注解

看了官方的案例,沒看到好用的注解,這里只能自己編寫一個,基于案例的加載過程和核心API作為參考。

核心配置類:

com.dangdang.ddframe.job.lite.config.LiteJobConfiguration

根據(jù)自己想如何使用注解的思路,比如我只想注解定時任務名稱和Cron表達式這兩個功能,其他參數(shù)直接統(tǒng)一配置(這里可能是受QuartJob影響太深,可能根本就是想省事...)

@Inherited
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface TaskJobSign www.zhuyngyule.cn{

  @AliasFor("cron"www.feiyuptzc.cn)
  String value(www.yinmao2zhuce.cn) default "";

  @AliasFor("value")
  String cron(www.wujiu5zhuce.cn) default "";

  String jobName(www.shengyunyule.cn) default "";

}

4、作業(yè)案例

這里打印一些基本參數(shù),對照配置和注解,一目了然。

@Component
@TaskJobSign(cron = www.anxing4zc.cn"0/5 * * * * ?",jobName =www.jucaiyle.cn "Hello-Job")
public class HelloJob implements SimpleJob {

  private static final Logger LOG = LoggerFactory.getLogger(HelloJob.class.getName()) ;

  @Override
  public void execute(ShardingContext shardingContext) {
    LOG.info("當前線程: "+Thread.currentThread().getId());
    LOG.info("任務分片:"+shardingContext.getShardingTotalCount());
    LOG.info("當前分片:"+shardingContext.getShardingItem());
    LOG.info("分片參數(shù):"+shardingContext.getShardingParameter());
    LOG.info("任務參數(shù):"+shardingContext.getJobParameter());
  }
}

5、加載定時任務

既然自定義注解,那加載過程自然也要自定義一下,讀取自定義的注解,配置化,加入容器,然后初始化,等著任務執(zhí)行就好。

@Configuration
public class ElasticJobConfig {

  @Resource
  private ApplicationContext applicationContext ;
  @Resource
  private ZookeeperRegistryCenter zookeeperRegistryCenter;

  @Value("${job-config.cron}") private String cron ;
  @Value("${job-config.shardCount}"www.jucaiylzc.cn) private int shardCount ;
  @Value("${job-config.shardItem}") private String shardItem ;
  
  /**
   * 配置任務監(jiān)聽器
   */
  @Bean
  public ElasticJobListener elasticJobListener() {
    return new TaskJobListener();
  }
  /**
   * 初始化配置任務
   */
  @PostConstruct
  public void initTaskJob() {
    Map<String, SimpleJob> jobMap = this.applicationContext.getBeansOfType(SimpleJob.class);
    Iterator iterator = jobMap.entrySet().iterator();
    while (iterator.hasNext()) {
      // 自定義注解管理
      Map.Entry<String, SimpleJob> entry = (Map.Entry)iterator.next();
      SimpleJob simpleJob = entry.getValue();
      TaskJobSign taskJobSign = simpleJob.getClass().getAnnotation(TaskJobSign.class);
      if (taskJobSign != null){
        String cron = taskJobSign.cron() ;
        String jobName = taskJobSign.jobName() ;
        // 生成配置
        SimpleJobConfiguration simpleJobConfiguration = new SimpleJobConfiguration(
                        JobCoreConfiguration.newBuilder(jobName, cron, shardCount)
                        .shardingItemParameters(shardItem).jobParameter(jobName).build(),
                        simpleJob.getClass().getCanonicalName());
        LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(
                        simpleJobConfiguration).overwrite(true).build();
        TaskJobListener taskJobListener = new TaskJobListener();
        // 初始化任務
        SpringJobScheduler jobScheduler = new SpringJobScheduler(
                        simpleJob, zookeeperRegistryCenter,
                        liteJobConfiguration, taskJobListener);
        jobScheduler.init();
      }
    }
  }
}

絮叨一句:不要疑問這些API是怎么知道,看下官方文檔的案例,他們怎么使用這些核心API,這里就是照著寫過來,就是多一步自定義注解類的加載過程。當然官方文檔大致讀一遍還是很有必要的。

補刀一句:如何快速學習一些組件的用法,首先找到官方文檔,或者開源庫Wiki,再不濟ReadMe文檔(如果都沒有,酌情放棄,另尋其他),熟悉基本功能是否符合自己的需求,如果符合,就看下基本用法案例,熟悉API,最后就是研究自己需要的功能模塊,個人經(jīng)驗來看,該過程是彎路最少,坑最少的。

6、任務監(jiān)聽

用法非常簡單,實現(xiàn)ElasticJobListener接口。

@Component
public class TaskJobListener implements ElasticJobListener {
  private static final Logger LOG = LoggerFactory.getLogger(TaskJobListener.class);

  private long beginTime = 0;

  @Override
  public void beforeJobExecuted(ShardingContexts shardingContexts) {
    beginTime = System.currentTimeMillis();
    LOG.info(shardingContexts.getJobName()+"===>開始...");
  }

  @Override
  public void afterJobExecuted(ShardingContexts shardingContexts) {
    long endTime = System.currentTimeMillis();
    LOG.info(shardingContexts.getJobName()+
    "===>結(jié)束...[耗時:"+(endTime - beginTime)+"]");
  }
}

絮叨一句:before和after執(zhí)行前后,中間執(zhí)行目標方法,標準的AOP切面思想,所以底層水平?jīng)Q定了對上層框架的理解速度,那本《Java編程思想》上的灰塵是不是該擦擦?

三、動態(tài)添加

1、作業(yè)任務

有部分場景需要動態(tài)添加和管理定時任務,基于上面的加載流程,在自定義一些步驟就可以。

@Component
public class GetTimeJob implements SimpleJob {

  private static final Logger LOG = LoggerFactory.getLogger(GetTimeJob.class.getName()) ;

  private static final SimpleDateFormat format =
      new SimpleDateFormat("yyyy-MM-dd HH:mm:ss") ;

  @Override
  public void execute(ShardingContext shardingContext) {
    LOG.info("Job Name:"+shardingContext.getJobName());
    LOG.info("Local Time:"+format.format(new Date()));
  }
}

2、添加任務服務

這里就動態(tài)添加上面的任務。

@Service
public class TaskJobService {

  @Resource
  private ZookeeperRegistryCenter zookeeperRegistryCenter;

  public void addTaskJob(final String jobName,final SimpleJob simpleJob,
              final String cron,final int shardCount,final String shardItem) {
    // 配置過程
    JobCoreConfiguration jobCoreConfiguration = JobCoreConfiguration.newBuilder(
                          jobName, cron, shardCount)
                          .shardingItemParameters(shardItem).build();
    JobTypeConfiguration jobTypeConfiguration = new SimpleJobConfiguration(jobCoreConfiguration,
                          simpleJob.getClass().getCanonicalName());
    LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(
                          jobTypeConfiguration).overwrite(true).build();
    TaskJobListener taskJobListener = new TaskJobListener();
    // 加載執(zhí)行
    SpringJobScheduler jobScheduler = new SpringJobScheduler(
        simpleJob, zookeeperRegistryCenter,
        liteJobConfiguration, taskJobListener);
    jobScheduler.init();
  }

}

補刀一句:這里添加之后,任務就會定時執(zhí)行,如何停止任務又是一個問題,可以在任務名上做一些配置,比如在數(shù)據(jù)庫生成一條記錄[1,job1,state],如果調(diào)度到state為停止狀態(tài)的任務,直接截胡即可。

3、測試接口

@RestController
public class TaskJobController {

  @Resource
  private TaskJobService taskJobService ;

  @RequestMapping("/addJob")
  public String addJob(@RequestParam("cron") String cron,@RequestParam("jobName") String jobName,
             @RequestParam("shardCount") Integer shardCount,
             @RequestParam("shardItem") String shardItem) {
    taskJobService.addTaskJob(jobName, new GetTimeJob(), cron, shardCount, shardItem);
    return "success";
  }
}

四、源代碼地址

GitHub

·地址https://github.com/cicadasmile/middle-ware-parentGitEE

·地址https://gitee.com/cicadasmile/middle-ware-parent

以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

  • Java8 Stream對兩個 List 遍歷匹配數(shù)據(jù)的優(yōu)化處理操作

    Java8 Stream對兩個 List 遍歷匹配數(shù)據(jù)的優(yōu)化處理操作

    這篇文章主要介紹了Java8 Stream對兩個 List 遍歷匹配數(shù)據(jù)的優(yōu)化處理操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-08-08
  • java實現(xiàn)微信支付結(jié)果通知

    java實現(xiàn)微信支付結(jié)果通知

    這篇文章主要為大家詳細介紹了java實現(xiàn)微信支付結(jié)果通知,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-01-01
  • java防盜鏈在報表中的應用實例(推薦)

    java防盜鏈在報表中的應用實例(推薦)

    下面小編就為大家?guī)硪黄猨ava防盜鏈在報表中的應用實例(推薦)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-09-09
  • 利用微信小程序+JAVA實現(xiàn)微信支付的全過程

    利用微信小程序+JAVA實現(xiàn)微信支付的全過程

    微信支付是一種在線支付解決方案,允許用戶通過微信內(nèi)的支付功能進行付款,下面這篇文章主要給大家介紹了關于利用微信小程序+JAVA實現(xiàn)微信支付的相關資料,需要的朋友可以參考下
    2024-08-08
  • java判斷各類型字符個數(shù)實例代碼

    java判斷各類型字符個數(shù)實例代碼

    大家好,本篇文章主要講的是java判斷各類型字符個數(shù)實例代碼,感興趣的同學趕快來看一看吧,對你有幫助的話記得收藏一下,方便下次瀏覽
    2021-12-12
  • Classloader隔離技術在業(yè)務監(jiān)控中的應用詳解

    Classloader隔離技術在業(yè)務監(jiān)控中的應用詳解

    這篇文章主要為大家介紹了Classloader隔離技術在業(yè)務監(jiān)控中的應用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-08-08
  • SpringBoot+vue+Axios實現(xiàn)Token令牌的詳細過程

    SpringBoot+vue+Axios實現(xiàn)Token令牌的詳細過程

    Token是在服務端產(chǎn)生的,前端可以使用用戶名/密碼向服務端請求認證(登錄),服務端認證成功,服務端會返回?Token?給前端,Token可以使用自己的算法自定義,本文給大家介紹SpringBoot+vue+Axios實現(xiàn)Token令牌,感興趣的朋友一起看看吧
    2023-10-10
  • 教你輕松制作java音樂播放器

    教你輕松制作java音樂播放器

    這篇文章主要介紹了如何編寫屬于自己的java音樂播放器,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2016-10-10
  • Spring Bean 依賴注入常見錯誤問題

    Spring Bean 依賴注入常見錯誤問題

    這篇文章主要介紹了Spring Bean 依賴注入常見錯誤問題,文中提到value的工作大體分為三個核心步驟,具體內(nèi)容詳情跟隨小編一起看看吧
    2021-09-09
  • 關于spring?boot使用?jdbc+mysql?連接的問題

    關于spring?boot使用?jdbc+mysql?連接的問題

    這篇文章主要介紹了spring?boot使用?jdbc+mysql?連接,在這里mysql?8.x版本驅(qū)動包,要使用?com.mysql.cj.jdbc.Driver作為驅(qū)動類,文中給大家詳細介紹,需要的朋友可以參考下
    2022-03-03

最新評論