java - 如果应用程序实现 CommandLineRunner,则 Spring Batch 重试在 Java 中不起作用
问题描述
以Retry not working with Spring Batch with Java Config作为参考,我签入了以下 spring 批处理阅读器重试示例https://github.com/atulkulkarni18/spring-batch-reader-retry的代码,并且重试功能按预期工作。但是实现 CommandLineRunner (如下面的代码所示),重试功能不起作用......有人可以建议吗?
@SpringBootApplication
@EnableBatchProcessing
@Data
@NoArgsConstructor
@AllArgsConstructor
@EnableRetry
public class Stack56170179Application implements CommandLineRunner {
@Autowired
JobLauncher jobLauncher;
@Autowired
private JobBuilderFactory jobs;
@Autowired
private StepBuilderFactory steps;
public static void main(String[] args) {
SpringApplication.run(Stack56170179Application.class, args);
}
@Bean
public Job job() {
return jobs.get("myJob").start(step1()).build();
}
@Bean
public Step step1() {
return steps.get("step1").<String, String>chunk(1).reader(myReader())
.processor(myProcessor())
.writer(myWriter())
.build();
}
@Override
public void run(String... args) throws Exception {
JobParameters params = new JobParametersBuilder()
.addString("JobID", String.valueOf(System.currentTimeMillis()))
.toJobParameters();
jobLauncher.run(job(), params);
}
@Bean
@StepScope
public MyReader myReader() {
return new MyReader();
}
@Bean
@StepScope
public MyProcessor myProcessor() {
return new MyProcessor();
}
@Bean
@StepScope
public MyWriter myWriter() {
return new MyWriter();
}
}
public class MyReader implements ItemReader<String> {
private long count;
private long retryCount;
@Override
@Retryable(include = { MyException.class }, maxAttempts = 5)
public String read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
final long value = count;
System.out.println("MyReader : " + value);
if (value == 3 && retryCount <= 2) {
retryCount++;
System.out.println("****");
Thread.sleep(500);
throw new MyException();
}
if (value < 5) {
count++;
Thread.sleep(500);
return String.valueOf(value);
} else {
return null;
}
}
}
public class MyProcessor implements ItemProcessor<String, String> {
@Override
public String process(final String arg0) throws Exception {
System.out.println("MyProcessor : " + arg0);
return arg0;
}
}
public class MyWriter implements ItemWriter<String> {
@Override
public void write(final List<? extends String> arg0) throws Exception {
System.out.println("MyWriter : " + arg0);
}
}
public class MyException extends Exception {
private static final long serialVersionUID = 1L;
}
预期输出:
MyReader : 0
MyProcessor : 0
MyWriter : [0]
MyReader : 1
MyProcessor : 1
MyWriter : [1]
MyReader : 2
MyProcessor : 2
MyWriter : [2]
MyReader : 3
****
MyReader : 3
****
MyReader : 3
****
MyReader : 3
MyProcessor : 3
MyWriter : [3]
MyReader : 4
MyProcessor : 4
MyWriter : [4]
MyReader : 5
解决方案
问题不在于对象,CommandLineRunner
而在于MyReader
对象。您已经创建了普通对象并且它不是 Spring 管理的。尝试像创建spring托管bean一样
@Bean
@StepScope
public MyReader myReader() {
return new MyReader();
}
并使用myReader()
inside 方法step1()
而不是new MyReader()
.
希望这有帮助!
推荐阅读
- node.js - JSON.Stringify() 解析大型 JSON 对象以存储在 Postgres JSONB 中时字符串长度无效
- r - Sys.time() 的差异是 R 中可靠的执行时间估计吗?
- c# - DataProtectionProvider.UnprotectAsync(IBuffer) 引发 ASN-1 错误
- c++ - 用于将 gcc 编译/链接选项转换为 icc 的翻译表
- php - PHP MySQL - 在 PHP 中验证电子邮件
- arrays - 如何在C中生成不重复的数字?
- angular - angular - 如何创建一个 canActivate 保护以仅允许来自另一个组件的重定向?
- java - Selenium Chrome 驱动程序无法选择或输入登录
- android-security - 易受意图重定向
- r - 如何将 1000 个模具卷的输出 6 次存储到矩阵中?