百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术流 > 正文

Spring Batch 与 Spring Cloud Task 、Quartz 终于分清了

citgpt 2024-06-27 19:58 13 浏览 0 评论

背景

接上篇文章,继续来辨析一下这些技术概念:

  1. Spring Task,任务调度
  2. Quartz,任务调度框架
  3. Spring Cloud Task,短周期任务管理框架
  4. Spring Batch ,批处理应用构建框架
  5. Spring Cloud Data Flow,构建数据集成和实时数据处理流水线的工具包

任务调度框架

Spring Task 和 Quartz 是两个任务调度框架,都支持 Cron 表达式方式执行周期性的任务,对比如下:

Spring Batch 与 Spring Cloud Task 、Quartz 终于分清了

框架名称

厂商

使用方式

集群支持能力

Spring Task

Spring 框架

@Scheduled

Quartz

OpenSymphony开源组织

API

对于包含周期性任务调度的需求,可以选择用这两个框架。

Spring Cloud Task

Spring Cloud Task可以在平台环境中执行短生命周期的应用,并记录这些应用的结果,经由通过消息通知的机制来集成各个tasks。该特性可以让短生命周期的应用像长生命周期的应用一样,组成微服务架构。

本质就是通过 @EnableTask 标签,让某个 SpringBoot 应用的运行过程被记录下来。

Spring Batch

批处理应用构建框架,它不是一个任务调度框架,而是一个定义批处理流程的框架。任务的触发方式有两种,一种是手动触发,另一种定时任务触发。

Spring Batch 与 Spring Cloud Task 一起使用时,可以将批处理任务作为一个短运行期的应用被监控起来。

Spring Batch + Spring Cloud Task ,监控批处理任务。

Spring Batch + 任务调度框架,定期触发批处理任务,这是比较常见的使用组合,因为批处理任务的本质就是基于时间消息驱动应用。

Spring Cloud Data Flow

Spring Cloud Task 是 Spring Cloud Data Flow 的一个基础模块。构建数据流应用时,
Spring Cloud Data Flow 的数据处理有两种模式,分别是
Streaming 流式处理和 Batch 批次处理。

Streaming 处理模块是基于消息驱动的、长时间一直存在,数据来了就处理,没来就等着。

Batch 是处理时间较短的应用,启动一次处理一次,处理完就退出任务,需要手动或自动触发任务,这类应用可以用 Spring Batch 或 Spring Cloud Task 构建。

启示录

这几个技术可能会组合使用,仔细辨析一下,还是比较容易区分的。

再次总结一下各自的用法:

  1. 定时任务调度框架:Spring Task ,Quartz。
  2. 可监控的短运行期的应用构建框架:Spring Cloud Task。
  3. 批处理流程定义框架:Spring Batch,集成任务调度框架可以实现定时批处理任务运行;集成 Spring Cloud Task ,实现可监控的批处理应用。
  4. 实时数据流应用构建框架: Spring Cloud Data Flow,它可以集成 Spring Cloud Task 和 Spring Batch 的应用。

相关推荐

js中arguments详解

一、简介了解arguments这个对象之前先来认识一下javascript的一些功能:其实Javascript并没有重载函数的功能,但是Arguments对象能够模拟重载。Javascrip中每个函数...

firewall-cmd 常用命令

目录firewalldzone说明firewallzone内容说明firewall-cmd常用参数firewall-cmd常用命令常用命令 回到顶部firewalldzone...

epel-release 是什么

EPEL-release(ExtraPackagesforEnterpriseLinux)是一个软件仓库,它为企业级Linux发行版(如CentOS、RHEL等)提供额外的软件包。以下是关于E...

FullGC详解  什么是 JVM 的 GC
FullGC详解 什么是 JVM 的 GC

前言:背景:一、什么是JVM的GC?JVM(JavaVirtualMachine)。JVM是Java程序的虚拟机,是一种实现Java语言的解...

2024-10-26 08:50 citgpt

使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
  • 使用Spire.Doc组件利用模板导出Word文档
跨域(CrossOrigin)

1.介绍  1)跨域问题:跨域问题是在网络中,当一个网络的运行脚本(通常时JavaScript)试图访问另一个网络的资源时,如果这两个网络的端口、协议和域名不一致时就会出现跨域问题。    通俗讲...

微服务架构和分布式架构的区别

1、含义不同微服务架构:微服务架构风格是一种将一个单一应用程序开发为一组小型服务的方法,每个服务运行在自己的进程中,服务间通信采用轻量级通信机制(通常用HTTP资源API)。这些服务围绕业务能力构建并...

深入理解与应用CSS clip-path 属性
深入理解与应用CSS clip-path 属性

clip-pathclip-path是什么clip-path 是一个CSS属性,允许开发者创建一个剪切区域,从而决定元素的哪些部分可见,哪些部分会被隐...

2024-10-25 11:51 citgpt

HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
  • HCNP Routing&Switching之OSPF LSA类型(二)
Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
  • Redis和Memcached的区别详解
Request.ServerVariables 大全

Request.ServerVariables("Url")返回服务器地址Request.ServerVariables("Path_Info")客户端提供的路...

python操作Kafka

目录一、python操作kafka1.python使用kafka生产者2.python使用kafka消费者3.使用docker中的kafka二、python操作kafka细...

Runtime.getRuntime().exec详解

Runtime.getRuntime().exec详解概述Runtime.getRuntime().exec用于调用外部可执行程序或系统命令,并重定向外部程序的标准输入、标准输出和标准错误到缓冲池。...

promise.all详解 promise.all是干什么的
promise.all详解 promise.all是干什么的

promise.all详解promise.all中所有的请求成功了,走.then(),在.then()中能得到一个数组,数组中是每个请求resolve抛出的结果...

2024-10-24 16:21 citgpt

Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解
  • Content-Length和Transfer-Encoding详解

取消回复欢迎 发表评论: