Springboot Batch結(jié)果輸出怎么弄

小樊
81
2024-09-25 02:29:19

在Spring Boot Batch應(yīng)用中，將處理結(jié)果輸出到不同的渠道（例如：控制臺(tái)、文件、數(shù)據(jù)庫(kù)等）可以通過(guò)配置StepExecutionListener和ItemWriter來(lái)實(shí)現(xiàn)。以下是一個(gè)簡(jiǎn)單的示例，演示如何將結(jié)果輸出到控制臺(tái)和文件。

  1. 首先，創(chuàng)建一個(gè)實(shí)現(xiàn)ItemWriter接口的類(lèi)，用于將處理結(jié)果寫(xiě)入到文件中：
import org.springframework.batch.item.ItemWriter;
import org.springframework.stereotype.Component;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;

@Component
public class FileItemWriter implements ItemWriter<String> {

    private String filePath;

    public FileItemWriter(String filePath) {
        this.filePath = filePath;
    }

    @Override
    public void write(List<? extends String> items) throws IOException {
        try (BufferedWriter writer = new BufferedWriter(new FileWriter(filePath, true))) {
            for (String item : items) {
                writer.write(item);
                writer.newLine();
            }
        }
    }
}
  1. 創(chuàng)建一個(gè)實(shí)現(xiàn)StepExecutionListener接口的類(lèi)，用于在步驟執(zhí)行前后執(zhí)行操作，并輸出處理結(jié)果到控制臺(tái)：
import org.springframework.batch.core.ExitStatus;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.StepExecutionListener;
import org.springframework.stereotype.Component;

@Component
public class ConsoleStepExecutionListener implements StepExecutionListener {

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        System.out.println("處理結(jié)果: " + stepExecution.getJobExecution().getJobParameters().getString("result"));
        return null;
    }

    @Override
    public void beforeStep(StepExecution stepExecution) {
    }
}
  1. 在你的JobConfiguration類(lèi)中，配置Step，并將上面創(chuàng)建的FileItemWriter和ConsoleStepExecutionListener添加到Step中：
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.Arrays;

@Configuration
public class JobConfiguration {

    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Autowired
    public StepBuilderFactory stepBuilderFactory;

    @Bean
    public Job job() {
        return jobBuilderFactory.get("job")
                .incrementer(new RunIdIncrementer())
                .start(step())
                .build();
    }

    @Bean
    public Step step() {
        return stepBuilderFactory.get("step")
                .<String, String>chunk(1)
                .reader(reader())
                .writer(fileItemWriter())
                .listener(consoleStepExecutionListener())
                .build();
    }

    // 配置你的Reader和其他組件
}

現(xiàn)在，當(dāng)你運(yùn)行你的Spring Boot Batch應(yīng)用時(shí)，處理結(jié)果將被同時(shí)輸出到控制臺(tái)和指定的文件中。

0 踩