我们如何在两个不同的实例上并行运行一个spring batch应用程序？
在两个不同的实例上并行运行一个Spring Batch应用程序，可以通过以下步骤实现：
- 配置Spring Batch作业：创建一个Spring Batch作业，并配置作业的步骤、读取器、处理器和写入器等组件。确保作业的配置文件中包含了需要并行执行的步骤。
- 配置并行执行：在作业的配置文件中，使用
<split>元素将作业的步骤分割成多个子步骤，以便在不同的实例上并行执行。每个子步骤都可以在不同的实例上独立运行。 - 配置远程分区：使用Spring Batch的远程分区功能，将作业的数据分割成多个分区，并将每个分区分配给不同的实例。每个实例将独立处理自己分配到的分区数据。
- 配置分区处理器：为每个分区配置一个独立的处理器，确保每个实例都可以独立处理自己分配到的分区数据。可以使用Spring Batch提供的
PartitionHandler接口来实现分区处理器。 - 配置任务调度：使用任务调度器（如Quartz、Cron等）配置作业的调度规则，确保作业在不同的实例上并行运行。每个实例都会独立触发作业的执行。
- 配置数据库和存储：确保每个实例都连接到相同的数据库，并使用共享的存储（如共享文件系统、分布式文件系统等）来存储作业的中间结果和日志信息。
- 监控和管理：使用Spring Batch提供的监控和管理功能，可以实时监控作业的执行情况、处理进度和错误日志等信息。可以使用Spring Batch Admin或自定义的监控工具来实现。
推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE），腾讯云数据库（TencentDB），腾讯云对象存储（Tencent Cloud Object Storage，COS）等。
腾讯云产品介绍链接地址：
请注意，以上答案仅供参考，具体的实施步骤和产品选择应根据实际需求和环境来确定。
相关·内容
5回答
我有一个应用程序，它利用Spring Batch来读取和处理公共数据库中的记录。该作业在固定时间从调度程序触发，并且在单个应用程序实例上运行良好。我想横向扩展这个应用程序，以改善处理时间，同时使用相同的数据库。Spring Batch (信号量)中有没有什么东西可以管理被多个实例访问的数据，以防止它们访问和修改相同的记录？
我做了一个搜索，只在同一个应用程序实例中找到了多线程。
非常感谢
浏览 5提问于2020-12-01得票数 1
我正在使用SpringBoot2.7.1和spring-boot-starter-batch编写一个批处理。批处理需要两个不同的WebClient来调用具有不同身份验证系统的两个不同的API，这些API是我通过标准Spring属性(spring.security.oauth2.client等)配置的。
它工作得很好，但我意识到在运行时，批处理正在监听端口8080，因为我已经导入了spring-boot-starter-web，它通过注入一个ClientRegistrationRepository来支持WebClient的自动配置。这不是一个大问题，但它阻止我两次并行启动批处理，例如，因为端口已
浏览 14提问于2022-07-29得票数 3
我正在使用@SpringBatchTest在我的Spring应用程序上运行e2e测试。除了我同时运行两个测试类(将我的测试划分为正/负测试类)之外，一切都运行得很好。第一次运行并通过测试，但第二次尝试再次启动上下文失败。由于它已经启动，所以测试在InstanceAlreadyExistsException上失败。
我的两个测试类都定义了以下注释：
@RunWith(SpringRunner.class)
@SpringBatchTest
@EnableAutoConfiguration
@ContextConfiguration(classes = {MyTestConfiguration.c
浏览 1提问于2019-12-02得票数 0
回答已采纳
我正在使用spring batch (4.2.2.RELEASE)和弹簧执行器(2.2.6版本)。从4.2版本开始，spring batch提供了对基于微米(https://docs.spring.io/spring-batch/docs/4.2.x/reference/html/monitoring-and-metrics.html)的批量监控和度量的支持。 例如，我可以使用度量名称spring_batch_job查看作业的执行频率、状态和持续时间。 我希望使用grafana & prometheus监视此指标，并在最近xx分钟内作业失败时发出警报。 如果spring批处理应用程序
浏览 25提问于2020-04-24得票数 3
回答已采纳
1回答
我在负载均衡器后面有两个活动的服务器。假设负载均衡器是A，节点是A1和A2。
现在，A1和A2有了quartz调度器，A1和A2有了spring batch job实例。
假设在下午1:00，一个作业应该被踢开，并在A1或A2上运行。
但有时发生的情况是，A1和A2都启动了作业，但不知何故，它们运行了两次。它可以在不同的节点上运行，也可以在同一个节点上运行。
问题是，在这两个级别，quartz以某种方式踢开了同一作业的两个实例，而spring batch也以某种方式运行了这两个实例。
欢迎任何关于解决问题的建议或来自行业的最佳实践。
浏览 1提问于2016-03-19得票数 0
1回答
我正在使用spring批处理进行远程分区。我有多个运行spring批处理应用程序的实例。作为用例的一部分，我需要处理数据库中的所有记录。所以我给每个记录分配实例。因此，批处理应用程序的每个实例都可以处理特定于实例的记录。
例如：
Records1 -: instance1
Records2 -: instance1
Records3 -: instance2
Records4 -: instance2
.... so on
我知道我们可以使用Kafka或JMS来代替显式分区。在我的用例中，我不想使用任何消息传递中间件。因此，在为每个记录分配实例之后。我想调用这两个实例。如何调用这两个实例？
浏览 1提问于2022-08-17得票数 0
我有spring MVC的spring batch应用程序。在这个应用程序中，我必须调用Google API。API每秒最多有4个请求限制。现在，我必须从spring批处理内部调用google API。所以我有两个问题。 q1:如何实现对Google API的rest调用。我知道Rest模板，但我希望有更好的方法，比如我们在微服务中使用的feign客户端。 q2:如何限制每秒4次调用？ 以防你有任何问题。请让我知道
浏览 46提问于2019-01-15得票数 3
我试图并行运行多个步骤，但当不同的流试图更新JOB_EXECUTION统计数据时，会在后端Server数据库中出现错误(冲突)。我正在使用异步任务执行器，但除此之外，我不确定如何成功地运行这些流。
<batch:split id="createContextMaps" task-executor="asyncTaskExecutor" next="processBWReport">
<batch:flow>
<batch:step id="createTabcP
浏览 15提问于2022-05-25得票数 0
回答已采纳
在阅读了关于在Spring-Batch中扩展和并行处理的可能性之后，我们想知道Spring-batch的开箱即用行为是什么？
假设我们的工作有阅读器、5个步骤和一个写入器。
Spring-batch是否会读取一项，通过所有5个步骤，编写它，然后才继续下一项？就像一个巨大的for loop
或者是否存在某种并行性，因此当项目A移动到步骤2时，项目B被读取并处理到步骤1？
浏览 3提问于2018-12-17得票数 1
3回答
我有两个不同的Spring批处理项目，它们都被配置为具有元数据表的相同数据源(相同的DB模式)：
application.properties (春季批A)
spring.datasource.jdbc-url=jdbc:mysql://localhost:3306/my_batch
application.properties (弹簧批B)
spring.datasource.jdbc-url=jdbc:mysql://localhost:3306/my_batch
在成功运行了几次Spring之后，我运行了Spring，它抛出了一个JobExecutionAlreadyRu
浏览 0提问于2017-06-23得票数 6
回答已采纳
我正在迁移一个已经写入Spring batch的java应用程序。此应用程序将跨两个不同的环境进行数据迁移。应用程序的设计如下
1)根据某个标志从源数据库中读取一组用户id。
2)为每个用户从源环境中的3个不同数据库中读取用户特定数据。
3)将每个用户的数据写入目标库。
我还需要实现并行处理，以便一次运行10个或更多线程，每个线程负责迁移单个用户的数据。
我对spring完全陌生，因此在可视化我的配置xml的结构时遇到了问题。我正在考虑有一个步骤，首先读取用户Id集，然后将其传递到第二个步骤，该步骤将负责读取用户特定数据，并将其写入。但我在实现同样的方法时遇到了问题。如果有人能建议我在spri
浏览 1提问于2014-01-15得票数 0
我是Docker的新手，我将一个基于单一DB的Springboot REST应用程序容器化，没有任何问题。但是，当我尝试基于管理两个DB的应用程序执行类似的容器集时，我遇到了麻烦。当我运行Docker Compose时，我得到一个错误，说它找不到DB socio_bank_db。有关更多详细信息，请参阅列出的错误块。 sociobankdbpostgres | 2020-09-12 19:58:09.404 UTC [32] FATAL: database "socio_bank_db" does not exist
sociobank | 2020-09
浏览 47提问于2020-09-14得票数 0
我正在学习spring，我能够创建简单的单步应用程序()。
此应用程序包含以下作业：
从csv文件中读取人员
小写它们的名字
将它们保存到数据库中
现在我想学习分区特性，所以我添加了以下分区程序：
@Component
public class MyPartitioner implements Partitioner {
@Override
public Map<String, ExecutionContext> partition(int gridSize) {
Map<String, ExecutionContext&
浏览 1提问于2019-08-05得票数 2
我有一个Spring批处理应用程序，它读取平面文件CSV并转换一些数据，然后将其写入数据库。我们谈论的是数十万条记录或数百万条记录。 我想在第二天验证CSV中的行数是否与数据库中插入的记录数匹配。我想让这个过程自动化。目前，数据加载是由一些脚本完成的，这些脚本将这些CSV文件推送到我的S3批处理应用程序正在侦听的listening存储桶中。 触发这种“自动验证”的最佳方式是什么，以便在数据加载后，另一个服务可以检查所有批处理作业是否都以正确的exit_status != FAILURE完成，以及CSV中最初的记录数是否与数据库记录匹配？ 我想要有某种“触发器”，这样整个过程都是自动化的。在我
浏览 50提问于2021-07-01得票数 0
回答已采纳
1回答
是否可以在Spring批处理中重新启动特定参数的作业？
我在元表中有两个失败的作业实例。每个作业都有自己的作业参数。现在，我想用给定的参数重新启动作业。即使我传递了作业参数，它总是只重新启动最后一次失败的执行。
我的工作：
<batch:job id="JobA" incrementer="runIdIncrementer">
<batch:step id="abcde">
<batch:tasklet transaction-manager="transactionManager&
浏览 3提问于2015-12-12得票数 0
我们的要求是同时写入多个文件。我们使用spring batch来编写文件，并且我们从不同的线程启动spring batch。每个线程都有自己的应用程序上下文。因此，我们可以保证单例bean不会在多个线程之间共享。下面是我的代码片段。
Spring batch配置。
<bean id="reportDataReader" class="com.test.ist.batch2.rrm.batch.readers.RRMItmeReader"
scope="step">
<property name="ve
浏览 1提问于2015-07-19得票数 1
所以我有一个导出到jar中的程序。这是一个spring项目，重复地将数据库中的信息写入文本文件。有四个java文件：
JAVA FILES
App.java
Runscheduler.java
Rowmapper.java
pojoObject.java
和两个XML文件
XML files
job-request.xml
database.xml
以及两个配置文件
CONF
log4j.properties
configuration.properties
我有一个批处理文件，运行jar，一切工作正常。我唯一需要外部化的文件是
浏览 0提问于2015-11-20得票数 1
我刚来spring batch。我想在服务器a上运行spring batch作业，并想使用spring batch admin.is从服务器b启动这些作业，这是可能的吗？我通过以下两种方式进行了搜索：
1.JMX方式:我可以将spring batch beans转换为mbeans，但我无法从spring batch admin.can中读取它们。您能告诉我如何从spring batch admin中读取mbeans并启动它们吗？
2.公共存储库:我认为如果我对spring batch和spring batch管理使用相同的数据库存储库，那么我可以从spring batch管理(从服务器b).b
浏览 3提问于2012-01-30得票数 1
在我的spring批处理应用程序中，CustomItemWriter必须更新两个单独的表(DynamoDB)中的值。如果一个表更新成功，并且在更新第二个表时发生了一些异常，那么来自第一个表的更新也应该被回滚(这两个更新都应该是成功的或者都不是)。
我正在使用下面的spring batch配置
<bean id="jobRepository"
class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean">
<propert
浏览 0提问于2017-06-07得票数 0
1回答
我正在创建一个应用程序，它消耗了kafka的数据并对其进行了一些处理。由于这个应用程序的工作规模很大，我使用的是并发批处理侦听器(max.poll.records= 20)和Java8Executor服务。下面是一段带有注释的代码，我被困在其中：
//Below method is invoked by spring kafka concurrent batch listener
public void onMessage(List<ConsumerRecord<String,String>> records , Acknowledgement ack)
{
浏览 0提问于2020-03-18得票数 0
回答已采纳
我是短跑新手，我找不到我的问题的答案。
我正在尝试使用spring引导和spring批处理来实现一个作业。我的工作需要一个参数，所以我像这样执行应用程序：
/applications/botbit-batch/botbit-batch-1.0.0.jar --spring.batch.job.names=persistCustomerSuccessMetrics date=2015-12-13 -jar -Dspring.profiles.active=gus -Dspring.profiles.active=gus
用粗体表示，是我需要的参数。
我第一次执行了应用程序，但是在以后的执
浏览 1提问于2018-09-10得票数 0
2回答
我是Spring batch的新手，不知道该怎么做。
基本上，我有一个spring文件轮询器，它每隔N分钟运行一次，在特定目录中查找具有某个名称(例如: A.txt & B.txt)的文件。在任何时刻，此目录(A和B)中最多可能有2个文件。通过Spring Batch Job，这两个文件将被处理并持久化到两个不同的DB表中。
这些文件有点相似，所以使用相同的处理器/编写器。
现在，按照我设置的方式，每个轮询周期1文件都会被拾取并运行作业。
假设目录中有两个文件(A.txt和B.txt)，有没有办法创建两个作业，使这两个作业可以并行运行？
浏览 0提问于2017-08-17得票数 8
回答已采纳
我使用以下Spring (4.0.6.RELEASE)配置进行了现有的WAR：
<beans>
<context:annotation-config/>
<context:component-scan base-package="org.example"/>
</beans>
在此应用程序中，我添加了以下注释接口(逐字复制)：
package org.example;
@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target({ ElementType.MET
浏览 3提问于2014-07-19得票数 0
回答已采纳
我想知道是否有可能，以某种方式配置一个作业，我可以重复几个分块步骤，直到处理完整个数据？背景是，我需要处理一些真正的大数据，并且在处理它的过程中，有不必要的中止的风险。为了防止一遍又一遍地从头开始，我想对数据进行一些分区，这可以用来循环分块的步骤。由于给定的数据，不幸的是，无法利用spring-batch restartable-job特性来实现我的目标。我的源数据库由几个或多或少松散连接的表组成，每个表都在自己的步骤中进行处理。所以我有一些类似的东西：
... omitting job-configuration ...
<batch:step="A" next=
浏览 0提问于2020-03-03得票数 0
我的文件处理场景是，
read input file -> process -> generated output file
但我有两台物理上不同的机器，它们连接到一个存储区域，在那里我接收所有输入文件和一个数据库服务器，这两台机器上运行着两个应用程序服务器(每台服务器上一个)。
那么，我如何使用spring batch来并行处理这两个应用服务器上的输入文件呢？我的意思是，如果有10个文件，其中5个在server1 (P1)上，5个在(P2)上，可以做到吗？
浏览 0提问于2013-05-02得票数 10
在我的Spring应用程序中，我喜欢使用带有特定模式的Spring元表。建议使用表前缀。
我试图将batch.table.prefix=abc.BATCH_添加到属性文件中。我还试图重写配置：
@Configuration
@EnableBatchProcessing
public class BatchConfig {
@Bean
public JobRepository jobRepository(DataSource dataSource) throws Exception {
final JobRepositoryFactoryBean factory
浏览 4提问于2014-12-17得票数 1
回答已采纳
我们有一个带有块处理的Spring批处理应用程序，它从数据库中读取记录，处理它们，并调用一个服务/执行一些插入/更新数据库中的一些表作为编写器的一部分。
当saveState为false时，使用JDBCPagingItemReader是因为它是线程安全的。已设置排序关键字，以便线程不会相互交叉。此外，对于oracle数据源和Spring batch的JobRepository配置，也使用了隔离级别ISOLATION_READ_COMMITTED。
目前，在单个实例中使用ThreadPoolTaskExecutor的多线程运行得很好。
我们最终应该在OpenShift中部署这个Spring Bo
浏览 0提问于2019-07-09得票数 5
2回答
我必须实现一个独立应用程序的解决方案来管理和执行多个批处理过程。Java和Spring有什么最先进的解决方案吗？我一直在读到它，spring boot和spring batch似乎是真的，但我想知道正确的方式是为每个批处理进程创建一个spring boot应用程序，还是在同一个应用程序中创建所有进程更好。公开rest服务来调用执行是否安全？只通过命令行执行它们是不是更好？我在这方面有点新手！提前感谢！致以问候。
浏览 0提问于2017-11-07得票数 0
我是新来的春天，并寻找一个弹簧批解决方案简单的ETL过程。我遵循以下链接：用于学习。
它工作得很好，我得到了使用spring批处理进行ETL的基本结构的想法。
接下来，我想以PoC的形式从FTP服务器获取文件。基本上，我不使用硬编码的输入文件，我想添加从FTP获取.
在搜索时，我知道我们可以使用spring集成FTP/SFTP。
我遵循以下链接：创建一个tasklet，它将执行FTP/SFTP获取。
在现有的BatchConfiguration.java中，我添加了以下内容来添加我的FTP任务，作为第一步。
@Bean
public FtpGetRemoteFilesTasklet myFtp
浏览 3提问于2020-04-29得票数 0
3回答
我是GCP的新手，我正在尝试使用部署我的spring引导web服务。在我的docker-compose.yml文件中，我有3个服务:我的应用程序服务、mysql服务和Cassandra服务。在当地，它就像一种魅力。我还添加了一个cloudbuild.yaml文件：
steps:
- name: 'docker/compose:1.28.2'
args: ['up', '-d']
- name: 'gcr.io/cloud-builders/docker'
args: ['tag', 'workspa
浏览 5提问于2021-04-20得票数 2
回答已采纳
我正在使用Spring Batch的MultiResourceItemReader类。其中使用XML作为包含FlatFileReader请求的delegate.My文件，我从文件中批量读取请求命中它的地址，并将响应写入相应的输出文件。我想为每个文件处理定义一个线程，以减少执行时间。在我目前的需求中，我有四个输入文件，我想定义四个线程来读取，处理和写入文件。我试着用simpleTaskExecuter
task-executor="simpleTaskExecutor" throttle-limit="20"
但是在使用这个之后，flatfileReader抛出
浏览 0提问于2015-05-28得票数 0
2回答
我的服务器有两个GPU，我如何使用两个GPU同时进行训练，以最大限度地利用它们的计算能力？下面的代码正确吗？它能让我的模特接受适当的训练吗？
class MyModel(nn.Module):
def __init__(self):
super(MyModel, self).__init__()
self.bert = pretrained_model
# for param in self.bert.parameters():
# param.requires_grad = True
self.l
浏览 5提问于2022-08-07得票数 3
回答已采纳
我有两个API后端微服务，其中每个微服务都有MongoDB数据库。我希望在云提供商(如AWS )上的Kubernetes集群中部署其中每一个实例的两个或更多个实例。
Microservice的每个实例都在Pod中作为容器运行。是否可以将MongoDB部署为同一个Pod中的另一个容器？或者这个用例的最佳实践是什么？
如果同一微服务的两个或多个实例运行在不同的Pods中，是否需要部署两个或多个MongoDB实例，或者同一微服务的多个实例引用单个MongoDb？这个用例的最佳实践是什么？
每个Microservice都是Spring应用程序。我是否需要在Spring应用程序源代码中做一些特殊的事情，
浏览 17提问于2022-03-31得票数 0
回答已采纳
1回答
我使用以下逻辑重新启动未完成的Spring批处理(例如，应用程序异常终止后)作业：
public void restartUncompletedJobs() {
LOGGER.info("Restarting uncompleted jobs");
try {
jobRegistry.register(new ReferenceJobFactory(documetPipelineJob));
List<String> jobs = jobExplorer.getJobNames();
for (S
浏览 0提问于2018-07-28得票数 5
回答已采纳
对于依赖于JPA存储库来更新数据的spring批处理ItemWriter，我有一个问题。
下面是：
@Component
public class MessagesDigestMailerItemWriter implements ItemWriter<UserAccount> {
private static final Logger log = LoggerFactory.getLogger(MessagesDigestMailerItemWriter.class);
@Autowired
private MessageRepository mess
浏览 3提问于2016-07-09得票数 9
我使用Spring将大量数据从XML导入到Oracle数据库。
我的应用程序是多租户知道的，每个租户可以有单独的db模式，或者很少有租户可以同时共享单个db模式。
从我的XML中，我得到了唯一的租户标识符，我使用它作为租户数据库解析标识符，在运行时选择DB。
我正在使用Spring，hibernate。
我的XML
<users>
<user>
<userAccountDetail>
<tenantId>acmebank</tenantId>
<emailAddress>96601
浏览 4提问于2014-12-10得票数 0
看起来Spring Batch和它调用的ejb运行在同一个事务中。因此，当我们在ejb中获得回滚时，Spring Batch无法更新其在数据库中的状态。
我们得到的例外是：
org.springframework.batch.core.step.FatalStepExecutionException: JobRepository failure forcing exit with unknown status
at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.d
浏览 0提问于2011-12-15得票数 1
回答已采纳
给定使用分区的Spring批处理作业：
<job id="reportingJob" xmlns="http://www.springframework.org/schema/batch">
<batch:listeners>
<batch:listener ref="reportingJobExecutionListenerr" />
</batch:listeners>
<batch:step id="repo
浏览 0提问于2019-11-20得票数 0
回答已采纳
1回答
我有一个需求，其中一个流同步工作(请求-响应)，而在同一个应用程序中，另一组流在外部源上轮询更改信息。有没有人能告诉我如何使用spring来配置这个。我发现Spring Batch、Camel、Spring Integration可能满足我的需求，我想知道它们是否会有所帮助，或者是否有其他更简单或更好的解决方案？
谢谢。
浏览 0提问于2012-08-28得票数 0
我正在尝试在一个项目中使用spring batch和quartz。目标是使用Quartz调度一个spring-batch作业。我有以下豆子-
bean id="updateDataFeedJob" class="package.UpdateDataFeedJob" />
<bean id="UpdaterOnScheduleJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"&
浏览 0提问于2011-08-13得票数 2
回答已采纳
2回答
我正在尝试将Spring JdbcTemplate与Spring的SimpleAsyncTaskExecutor结合使用，这样就可以与数据库建立并发连接，并且与单线程环境相比，整个数据可以在更短的时间内插入到相关的表中。
我使用了下面的代码，但是它并没有提高我的应用程序的速度。
我能找到的唯一线索是，bean "campaignProductDBWriter“只构造了一次，而我希望在微线程中将”campaignProductDBWriter-limit“设置为10，从而创建10个单独的实例。
我做错了什么？任何帮助或建议都将不胜感激。
致以敬意，
<bean id="da
浏览 0提问于2011-03-07得票数 2
2回答
我有两个要并行运行的计划任务。这两个任务执行Spring批处理作业。一次每15秒，另一次每3秒。问题是其中一个将会运行，而另一个会被阻塞，直到它完成。
我似乎在任何地方都找不到类似的问题或例子。有什么想法吗？谢谢，/w
这是我的一些配置。我在Spring3.2中使用spring-task-3.2和spring-batch-2.2。
此批处理作业由mappingRunScheduler运行。另一个任务runScheduler非常相似，并且没有共享bean。
<job id="mappingJob" xmlns="http://www.springframework.
浏览 0提问于2014-01-28得票数 1
在这种情况下，我需要从存储在数据库中的不同版本的应用程序中读取数据，并将其写入到平面文件中。我将使用spring batch来实现这个场景。然而，在一些表中，与旧版本相比，我们有更多的列。 示例:假设版本1.0.0中的table1具有column1、column2，并且版本1.0.1中的相同table1具有column1、column2、column3。 假设客户1的版本为1.0.0，客户2的版本为1.0.1。我们想要写一个通用的解决方案，我们可以从dB中提取数据并将其写入到平面文件中。无论客户版本如何，平面文件都可以包含这三列，但如果客户的版本为1.0.0，则该值应为null。 我们如何使
浏览 12提问于2021-09-17得票数 0
spring batch中的Step，Tasklet和Chunk有什么不同？
另外，如何通过Spring Batch并行执行步骤。？
浏览 2提问于2016-10-14得票数 29
回答已采纳
1回答
我试图使用多线程步骤和并行作业的组合，在Spring批处理中获得一个复杂的作业流。
现在，我已经设置了3个作业(1，2，3)，其中第一个(1)在其他作业之前运行(如预期的那样)，并完成了对问题的处理。另外两个(2,3)应该并行运行，有一些自己的并行步骤。我试图运行的所有这些作业都封装在JobSteps中，然后在主作业(0)中运行。
问题只发生在作业2& 3中，其中一些JobStep失败，不总是在同一点，也不总是相同的JobStep。这是此类异常的堆栈跟踪：
2019-01-07 17:35:57,513 ERROR: o.s.b.c.s.AbstractStep [SimpleAsyn
浏览 1提问于2019-01-08得票数 0
1回答
我正在寻找一个简单的(我想是的) spring batch问题的帮助。我的任务是从数据库中读取事务列表，按帐号和日期对它们进行分组，然后为特定帐户number.Once的事务集做一些处理。我读取数据并按帐号进行分组，我可以并行处理这些块。每次这样的操作都会更新账户余额。我是spring batch的新手，正在寻找spring配置的示例。你能帮帮我吗?
浏览 0提问于2011-03-31得票数 1
我有一个使用spring-batch的web应用程序，现在我正在集成spring-batch-admin来进行基本管理。
问题是作业配置文件(与现有应用程序的配置共享)使用我的应用程序类路径中的文件的属性，但是spring-batch-admin的上下文不能加载它们。
快速的解决方案是覆盖spring-batch-admin中的placeholderProperties ，只需添加我的属性文件：
<bean id="placeholderProperties" class="org.springframework.beans.factory.config.Prop
浏览 6提问于2015-02-05得票数 1
在Spring批处理作业中，我试图使用JobExecutionContext在各个步骤之间共享数据，只有将步骤保持为单个线程才能工作，如下所示：
@EnableTask
@EnableBatchProcessing
@Configuration
@PropertySource(value = {"classpath:application.properties"})
public class Config{
private static final HashMap<String,Object> OVERRIDDEN
浏览 3提问于2021-05-16得票数 0
回答已采纳
5回答
在我的新应用程序中，我使用Spring excel读取excel文件.它被配置为批处理作业，并使用JobManager触发。现在我明白了这个错误。InputStream必须支持标记/重置，或者包装为PushbackInputStream
Caused by: java.lang.IllegalStateException: InputStream MUST either support mark/reset, or be wrapped as a PushbackInputStream
at org.springframework.batch.item.excel.poi.PoiItemRea
浏览 2提问于2015-11-20得票数 4
回答已采纳
我使用Scalatest、FlatSpec、Spring、Selenium DSL和BeforeAndAfterAll。其中一件事似乎阻止了ParallelTestExecution的正常工作。当我使用两个测试运行一个类时，会发生这样的情况：
一个浏览器打开并执行一些beforeAll内容(但不是Spring内容)
另一个浏览器打开并执行beforeAll内容
第二个浏览器用于第一次测试，然后关闭。
另一个浏览器打开并执行beforeAll内容，然后再进行第二次测试
第一和第三浏览器关闭
因此，基本上，除了打开了一个额外的窗口之外，测试运行与不使用ParallelT
浏览 2提问于2013-03-31得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
