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

SpringBatch从入门到放弃012- Spring Batch 4.X 新特性

citgpt 2024-06-27 19:59 9 浏览 0 评论

在Spring Batch 4.1 里面,增加了这些内容:

  • 增加了一个注解@SpringBatchTest,用于更方便的测试batch组件
  • 增加了一个注解@EnableBatchIntegration,用于简化远程分块和远程分区的配置
  • 新的 JsonItemReader 和 JsonFileItemWriter 支持JSON格式
  • 支持通过对象验证API 来验证items
  • 支持JSP-305 注解
  • 增强FlatFileItemWriterBuilder 类

@SpringBatchTest 注解

SpringBatch从入门到放弃012- Spring Batch 4.X 新特性

Spring Batch提供了一些不错的实用工具类(例如JobLauncherTestUtils和JobRepositoryTestUtils)以及测试执行侦听器(StepScopeTestExecutionListener和JobScopeTestExecutionListener)来测试批处理。但是,要使用这些工具类,必须显式配置它们。此版本引入了一个名为@SpringBatchTest的新注释,它自动将这些工具类和侦听器添加到测试上下文中,并使它们可用于自动装配,如以下示例所示:

?

@EnableBatchIntegration 注解

对于之前版本,定义一个远程分块,需要定义一下Bean:

  • 从消息传递中间件(JMS,AMQP和其他)获取连接的连接工厂
  • MessagingTemplate将Master请求发送给 Worker 并再次返回
  • Spring Integration的输入通道和输出通道,用于从消息传递中间件获取消息
  • 一个可以从Master发送chunk 数据到Workers端的ItemWriter( ChunkMessageChannelItemWriter ),以便Workers可以执行这些数据
  • 一个可以接受Master 发来数据的消息监听器( ChunkProcessorChunkHandler )

乍一看这可能有点令人生畏。此版本引入了名为 @EnableBatchIntegration 的新注释以及API( RemoteChunkingMasterStepBuilder 和 RemoteChunkingWorkerBuilder )以简化配置。

具体配置如下:

?

这个新的注释和构建器负责配置基础架构bean的繁重工作。您现在可以在工作方轻松配置主步骤和Spring Integration流程。

就像远程分块配置简化一样,此版本还引入了新的API来简化远程分区设置: RemotePartitioningMasterStepBuilder 和 RemotePartitioningWorkerStepBuilder 。如果存在 @EnableBatchIntegration ,则可以在配置类中自动装配这些,如以下示例所示:

?

JSON 支持

Spring Batch 4.1增加了对JSON格式的支持。此版本引入了一个新的项目阅读器,可以按以下格式读取JSON资源:

与 StaxEventItemReader for XML类似,新的 JsonItemReader 使用流API来读取块中的JSON对象。 Spring Batch支持两个库:

  • Jackson
  • Gson
  • 要添加其他库,可以实现 JsonObjectReader 接口。通过 JsonFileItemWriter 也支持编写JSON数据。

Bean验证API支持

此版本带来了一个名为 BeanValidatingItemProcessor 的新_20112实现,它允许您验证使用Bean Validation API(JSR-303)注释注释的项目。例如,给定以下类型 Person

?

您可以通过在应用程序上下文中声明 BeanValidatingItemProcessor bean来验证项目,并在面向块的步骤中将其注册为处理器:

?

JSR-305支持

此版本增加了对JSR-305注释的支持。它利用Spring Framework的 Null-safety 注释,并将它们添加到Spring Batch的所有公共API上。

这些注释不仅在使用Spring Batch API时强制执行null安全性,而且还可以由IDE用于提供与可空性相关的有用信息。例如,如果用户想要实现 ItemReader 接口,则任何支持JSR-305注释的IDE都将生成如下内容:

?

read 方法上出现的 @Nullable 注释清楚地表明该方法的 Contract 表明它可能返回 null 。这强制执行其Javadoc中的内容, read 方法应该在数据源耗尽时返回 null 。

FlatFileItemWriterBuilder增强功能

此版本中添加的另一个小功能是简化了写入平面文件的配置。具体来说,这些更新简化了分隔和固定宽度文件的配置。以下是更改之前和之后的示例。

?

相关推荐

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详解

取消回复欢迎 发表评论: