Mình là TUẤN hiện đang là một Full-stack Developer tại Tokyo 😉.
Nếu bạn thấy Blog này hay xin hãy cho mình một like và đăng ký để ủng hộ mình nhé 😊.
Lần này mình sẽ giới thiệu về JAVA Spring Batch. Bạn nào làm JAVA thì chắc ko xa lạ gì về cái này. Trong quá trình tìm hiểu về JAVA Spring Batch mình thấy một trong những vấn đề cũng đáng quan tâm đó là: Phân biệt giữa Tasklets vs Chunks. Và hôm nay mình sẽ nói về nó. (Bonus là mình cũng sẽ chỉ các bạn cách để Debug Java Spring Batch)
GÉT GÔ 😊
1. Giới thiệu
Spring Batch cung cấp hai cách khác nhau để thực hiện một job: sử dụng tasklet và chunks .
Trong bài viết này, chúng ta sẽ tìm hiểu cách định cấu hình và triển khai cả hai hàm bằng một ví dụ thực tế đơn giản.
2. Dependencies
Hãy bắt đầu bằng cách thêm các Dependencies cần thiết:
<dependency><groupId>org.springframework.batch</groupId><artifactId>spring-batch-core</artifactId><version>4.3.0</version></dependency><dependency><groupId>org.springframework.batch</groupId><artifactId>spring-batch-test</artifactId><version>4.3.0</version><scope>test</scope></dependency>Để có được phiên bản mới nhất của spring-batch-core và spring-batch-test , vui lòng tham khảo Maven Central.
3. Case mà chúng ta sẽ xử lý
Xét một tệp CSV có nội dung sau:
Mae Hodges,10/22/1972
Gary Potter,02/22/1953
Betty Wise,02/17/1968
Wayne Rose,04/06/1977
Adam Caldwell,09/27/1995
Lucille Phillips,05/14/1992
Vị trí đầu tiên của mỗi dòng thể hiện tên của một người và vị trí thứ hai ngày tháng năm sinh của người đó .
Trường hợp sử dụng của chúng ta là tạo một tệp CSV khác chứa tên và tuổi của mỗi người :
Mae Hodges,45
Gary Potter,64
Betty Wise,49
Wayne Rose,40
Adam Caldwell,22
Lucille Phillips,25
Bây giờ nhiệm vụ của chúng ta đã rõ ràng, hãy tiếp tục và xây dựng một giải pháp bằng cách sử dụng cả hai cách tiếp cận. Chúng ta sẽ bắt đầu với các tasklet.
4. Tasklets
4.1. Giới thiệu và thiết kế
Tasklet có nghĩa là thực hiện một nhiệm vụ duy nhất trong một bước. Job của chúng ta sẽ bao gồm một số bước thực hiện lần lượt. Mỗi bước chỉ nên thực hiện một nhiệm vụ nhất định .
Job của chúng ta sẽ bao gồm ba bước:
- Đọc các dòng từ tệp CSV đầu vào.
- Tính tuổi cho mỗi người trong tệp CSV đầu vào.
- Ghi tên và tuổi của từng người vào tệp CSV đầu ra mới.
Bây giờ thì mọi thứ đã sẵn sàng, hãy tạo các class step.
LinesReader sẽ phụ trách việc đọc dữ liệu từ tệp đầu vào:
publicclassLinesReaderimplementsTasklet{// ...}LinesProcessor sẽ tính tuổi cho mọi người trong tệp:
publicclassLinesProcessorimplementsTasklet{// ...}Cuối cùng, LinesWriter sẽ có trách nhiệm ghi tên và tuổi vào tệp đầu ra:
publicclassLinesWriterimplementsTasklet{// ...}Tại thời điểm này, tất cả các bước của chúng ta đều implement Tasklet interface. Điều đó sẽ buộc chúng ta phải triển khai hàm execute của nó:
@OverridepublicRepeatStatusexecute(StepContribution stepContribution,ChunkContext chunkContext)throwsException{// ...}Hàm này là nơi chúng ta sẽ thêm logic cho mỗi bước. Trước khi bắt đầu với code đó, hãy cấu hình job của chúng ta.
4.2. Cấu hình
Chúng ta cần thêm một số config vào contexts của Spring App. Sau khi thêm khai báo bean tiêu chuẩn cho các lớp đã tạo trong phần trước, chúng ta đã sẵn sàng tạo định nghĩa job của mình:
@Configuration@EnableBatchProcessingpublicclassTaskletsConfig{@AutowiredprivateJobBuilderFactory jobs;@AutowiredprivateStepBuilderFactory steps;@BeanprotectedStepreadLines(){return steps
.get("readLines").tasklet(linesReader()).build();}@BeanprotectedStepprocessLines(){return steps
.get("processLines").tasklet(linesProcessor()).build();}@BeanprotectedStepwriteLines(){return steps
.get("writeLines").tasklet(linesWriter()).build();}@BeanpublicJobjob(){return jobs
.get("taskletsJob").start(readLines()).next(processLines()).next(writeLines()).build();}// ...}Điều này có nghĩa là “taskletsJob” của chúng ta sẽ bao gồm ba bước. Cái đầu tiên ( readLines ) sẽ thực thi tasklet được định nghĩa trong bean linesReader và chuyển sang bước tiếp theo: processLines. ProcessLines sẽ thực hiện tasklet được định nghĩa trong bean linesProcessor và chuyển đến bước cuối cùng: writeLines .
Quy trình thực hiện job của chúng ta đã được xác định và đã sẵn sàng thêm một số logic!
4.3. Model và Utils
Vì chúng ta sẽ thao tác trên các dòng trong tệp CSV, chúng ta sẽ tạo một Class Line:
publicclassLineimplementsSerializable{privateString name;privateLocalDate dob;privateLong age;// standard constructor, getters, setters and toString implementation}Xin lưu ý rằng Line implement Serializable. Đó là vì Line sẽ hoạt động như một DTO để truyền dữ liệu giữa các bước. Khi dùng Spring Batch, các đối tượng được chuyển giữa các bước phải có thể tuần tự hóa.
Mặt khác, chúng ta có thể bắt đầu suy nghĩ về việc dùng một thư viện nào đó để đọc và viết các dòng.
Vì vậy, chúng ta sẽ sử dụng OpenCSV:
<dependency><groupId>com.opencsv</groupId><artifactId>opencsv</artifactId><version>4.1</version></dependency>Tìm phiên bản OpenCSV mới nhất trong Maven Central.
Khi OpenCSV được thêm vào, chúng ta cũng sẽ tạo một lớp FileUtils . Nó sẽ cung cấp các hàm để đọc và ghi các dòng CSV:
publicclassFileUtils{publicLinereadLine()throwsException{if(CSVReader==null)initReader();String[] line =CSVReader.readNext();if(line ==null)returnnull;returnnewLine(
line[0],LocalDate.parse(
line[1],DateTimeFormatter.ofPattern("MM/dd/yyyy")));}publicvoidwriteLine(Line line)throwsException{if(CSVWriter==null)initWriter();String[] lineStr =newString[2];
lineStr[0]= line.getName();
lineStr[1]= line
.getAge().toString();CSVWriter.writeNext(lineStr);}// ...}Lưu ý rằng readLine hoạt động như một trình bao bọc trên hàm readNext của OpenCSV và trả về một đối tượng Line .
Theo cách tương tự, writeLine kết thúc writeNext của OpenCSV khi nhận một đối tượng Line .
Triển khai đầy đủ lớp này thì sẽ trông như thế này:
publicclassFileUtils{privatefinalLogger logger =LoggerFactory.getLogger(FileUtils.class);privateString fileName;privateCSVReaderCSVReader;privateCSVWriterCSVWriter;privateFileReader fileReader;privateFileWriter fileWriter;privateFile file;publicFileUtils(String fileName){this.fileName = fileName;}publicLinereadLine(){try{if(CSVReader==null)initReader();String[] line =CSVReader.readNext();if(line ==null)returnnull;returnnewLine(line[0],LocalDate.parse(line[1],DateTimeFormatter.ofPattern("MM/dd/yyyy")));}catch(Exception e){
logger.error("Error while reading line in file: "+this.fileName);returnnull;}}publicvoidwriteLine(Line line){try{if(CSVWriter==null)initWriter();String[] lineStr =newString[2];
lineStr[0]= line.getName();
lineStr[1]= line
.getAge().toString();CSVWriter.writeNext(lineStr);}catch(Exception e){
logger.error("Error while writing line in file: "+this.fileName);}}privatevoidinitReader()throwsException{ClassLoader classLoader =this.getClass().getClassLoader();if(file ==null) file =newFile(classLoader
.getResource(fileName).getFile());if(fileReader ==null) fileReader =newFileReader(file);if(CSVReader==null)CSVReader=newCSVReader(fileReader);}privatevoidinitWriter()throwsException{if(file ==null){
file =newFile(fileName);
file.createNewFile();}if(fileWriter ==null) fileWriter =newFileWriter(file,true);if(CSVWriter==null)CSVWriter=newCSVWriter(fileWriter);}publicvoidcloseWriter(){try{CSVWriter.close();
fileWriter.close();}catch(IOException e){
logger.error("Error while closing writer.");}}publicvoidcloseReader(){try{CSVReader.close();
fileReader.close();}catch(IOException e){
logger.error("Error while closing reader.");}}}Tại thời điểm này, tất cả đã sẵn sàng để bắt đầu với việc triển khai từng bước.
4.4. LinesReader
Hãy tiếp tục và hoàn thành lớp LinesReader của chúng ta :
publicclassLinesReaderimplementsTasklet,StepExecutionListener{privatefinalLogger logger =LoggerFactory.getLogger(LinesReader.class);privateList<Line> lines;privateFileUtils fu;@OverridepublicvoidbeforeStep(StepExecution stepExecution){
lines =newArrayList<>();
fu =newFileUtils("taskletsvschunks/input/tasklets-vs-chunks.csv");
logger.debug("Lines Reader initialized.");}@OverridepublicRepeatStatusexecute(StepContribution stepContribution,ChunkContext chunkContext)throwsException{Line line = fu.readLine();while(line !=null){
lines.add(line);
logger.debug("Read line: "+ line.toString());
line = fu.readLine();}returnRepeatStatus.FINISHED;}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
fu.closeReader();
stepExecution
.getJobExecution().getExecutionContext().put("lines",this.lines);
logger.debug("Lines Reader ended.");returnExitStatus.COMPLETED;}}Hàm thực thi của LinesReader tạo ra một instance FileUtils trên đường dẫn tệp đầu vào. Sau đó, thêm các dòng vào danh sách cho đến khi không còn dòng nào để đọc .
Lớp của chúng ta cũng implement StepExecutionListener cung cấp hai hàm bổ sung: beforeStep và afterStep. Chúng ta sẽ sử dụng các hàm đó để khởi tạo và đóng mọi thứ trước và sau khi chạy execute.
Nếu chúng ta xem code afterStep, sẽ nhận thấy dòng mà nơi danh sách kết quả được đặt trong contexts của job để làm cho nó có sẵn ở bước tiếp theo: (Dùng để chấm chấm chấm liên tục ấy 😂)
stepExecution
.getJobExecution().getExecutionContext().put("lines",this.lines);Tại thời điểm này, bước đầu tiên của chúng ta đã hoàn thành cơ bản các việc cần làm: tải các dòng trong CSV vào một Danh sách trong bộ nhớ. Hãy chuyển sang bước thứ hai và xử lý chúng.
4.5. LinesProcessor
LinesProcessor cũng sẽ implement StepExecutionListener và tất nhiên là cả Tasklet. Điều đó có nghĩa là nó cũng sẽ implement các hàm beforeStep , execute và afterStep :
publicclassLinesProcessorimplementsTasklet,StepExecutionListener{privateLogger logger =LoggerFactory.getLogger(LinesProcessor.class);privateList<Line> lines;@OverridepublicvoidbeforeStep(StepExecution stepExecution){ExecutionContext executionContext = stepExecution
.getJobExecution().getExecutionContext();this.lines =(List<Line>) executionContext.get("lines");
logger.debug("Lines Processor initialized.");}@OverridepublicRepeatStatusexecute(StepContribution stepContribution,ChunkContext chunkContext)throwsException{for(Line line : lines){long age =ChronoUnit.YEARS.between(
line.getDob(),LocalDate.now());
logger.debug("Calculated age "+ age +" for line "+ line.toString());
line.setAge(age);}returnRepeatStatus.FINISHED;}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
logger.debug("Lines Processor ended.");returnExitStatus.COMPLETED;}}Thật dễ dàng để hiểu việc này đã giúp chúng ta tải danh sách các dòng từ contexts của job và tính tuổi của mỗi người .
Không cần đặt danh sách kết quả khác trong contexts vì các sửa đổi xảy ra trên cùng một đối tượng đến từ bước trước.
Và chúng ta đã sẵn sàng cho bước cuối cùng của mình.
4.6. LinesWriter
Nhiệm vụ của LinesWriter là duyệt qua danh sách dòng và ghi tên và tuổi vào tệp đầu ra :
publicclassLinesWriterimplementsTasklet,StepExecutionListener{privatefinalLogger logger =LoggerFactory.getLogger(LinesWriter.class);privateList<Line> lines;privateFileUtils fu;@OverridepublicvoidbeforeStep(StepExecution stepExecution){ExecutionContext executionContext = stepExecution
.getJobExecution().getExecutionContext();this.lines =(List<Line>) executionContext.get("lines");
fu =newFileUtils("output.csv");
logger.debug("Lines Writer initialized.");}@OverridepublicRepeatStatusexecute(StepContribution stepContribution,ChunkContext chunkContext)throwsException{for(Line line : lines){
fu.writeLine(line);
logger.debug("Wrote line "+ line.toString());}returnRepeatStatus.FINISHED;}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
fu.closeWriter();
logger.debug("Lines Writer ended.");returnExitStatus.COMPLETED;}}Chúng ta đã hoàn thành việc triển khai job của mình! Hãy tạo đoạn test để chạy nó và xem kết quả.
4.7. Chạy job
Để execute job, chúng ta sẽ tạo một đoạn test: (Cài này cũng giải thích cho một số bạn hay hỏi mình là làm cách nào để Debug Batch)
@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes =TaskletsConfig.class)publicclassTaskletsTest{@AutowiredprivateJobLauncherTestUtils jobLauncherTestUtils;@TestpublicvoidgivenTaskletsJob_whenJobEnds_thenStatusCompleted()throwsException{JobExecution jobExecution = jobLauncherTestUtils.launchJob();assertEquals(ExitStatus.COMPLETED, jobExecution.getExitStatus());}}Chú thích: ContextConfiguration đang trỏ đến lớp cấu hình contexts Spring, có định nghĩa job của chúng ta.
Chúng ta sẽ cần thêm một vài Bean để bổ sung trước khi chạy Test:
@BeanpublicJobLauncherTestUtilsjobLauncherTestUtils(){returnnewJobLauncherTestUtils();}@BeanpublicJobRepositoryjobRepository()throwsException{JobRepositoryFactoryBean factory =newJobRepositoryFactoryBean();
factory.setDataSource(dataSource());
factory.setTransactionManager(transactionManager());return factory.getObject();}@BeanpublicDataSourcedataSource(){DriverManagerDataSource dataSource =newDriverManagerDataSource();
dataSource.setDriverClassName("org.sqlite.JDBC");
dataSource.setUrl("jdbc:sqlite:repository.sqlite");return dataSource;}@BeanpublicPlatformTransactionManagertransactionManager(){returnnewResourcelessTransactionManager();}@BeanpublicJobLauncherjobLauncher()throwsException{SimpleJobLauncher jobLauncher =newSimpleJobLauncher();
jobLauncher.setJobRepository(jobRepository());return jobLauncher;}Mọi thứ đã sẵn sàng! Hãy thử run Test nào!
Sau khi job kết thúc, output.csv có nội dung dự kiến và các console hiển thị luồng đã thực thi:
[main] DEBUG o.b.t.tasklets.LinesReader-LinesReader initialized.[main] DEBUG o.b.t.tasklets.LinesReader-Read line:[MaeHodges,10/22/1972][main] DEBUG o.b.t.tasklets.LinesReader-Read line:[GaryPotter,02/22/1953][main] DEBUG o.b.t.tasklets.LinesReader-Read line:[BettyWise,02/17/1968][main] DEBUG o.b.t.tasklets.LinesReader-Read line:[WayneRose,04/06/1977][main] DEBUG o.b.t.tasklets.LinesReader-Read line:[AdamCaldwell,09/27/1995][main] DEBUG o.b.t.tasklets.LinesReader-Read line:[LucillePhillips,05/14/1992][main] DEBUG o.b.t.tasklets.LinesReader-LinesReader ended.[main] DEBUG o.b.t.tasklets.LinesProcessor-LinesProcessor initialized.[main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 45for line [MaeHodges,10/22/1972][main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 64for line [GaryPotter,02/22/1953][main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 49for line [BettyWise,02/17/1968][main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 40for line [WayneRose,04/06/1977][main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 22for line [AdamCaldwell,09/27/1995][main] DEBUG o.b.t.tasklets.LinesProcessor-Calculated age 25for line [LucillePhillips,05/14/1992][main] DEBUG o.b.t.tasklets.LinesProcessor-LinesProcessor ended.[main] DEBUG o.b.t.tasklets.LinesWriter-LinesWriter initialized.[main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [MaeHodges,10/22/1972,45][main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [GaryPotter,02/22/1953,64][main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [BettyWise,02/17/1968,49][main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [WayneRose,04/06/1977,40][main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [AdamCaldwell,09/27/1995,22][main] DEBUG o.b.t.tasklets.LinesWriter-Wrote line [LucillePhillips,05/14/1992,25][main] DEBUG o.b.t.tasklets.LinesWriter-LinesWriter ended.Ok xong việc với Tasklets. Bây giờ chúng ta có thể chuyển sang cách tiếp cận khác đó là Chunks.
5. Chunks
5.1. Giới thiệu và thiết kế
Dịch thô từ Chunks là các bạn đã biết, chunks là thực hiện các hành động trên từng phần của dữ liệu . Nghĩa là, thay vì đọc, xử lý và ghi tất cả các dòng cùng một lúc, nó sẽ đọc, xử lý và ghi một lượng record cố định (chunk) tại một thời điểm xác định.
Sau đó, nó sẽ lặp lại chu kỳ cho đến khi không còn dữ liệu nào trong tệp.
Do đó, luồng của Chunks sẽ hơi khác một chút:
Chúng ta cũng cần tạo ba class Bean cho cách tiếp cận theo định hướng Chunks (phân đoạn):
publicclassLineReader{// ...}publicclassLineProcessor{// ...}publicclassLinesWriter{// ...}Trước khi chuyển sang phần triển khai, hãy cấu hình job trước đã nhé.
5.2. Cấu hình
Định nghĩa job của chunks cũng sẽ khác:
@Configuration@EnableBatchProcessingpublicclassChunksConfig{@AutowiredprivateJobBuilderFactory jobs;@AutowiredprivateStepBuilderFactory steps;@BeanpublicItemReader<Line>itemReader(){returnnewLineReader();}@BeanpublicItemProcessor<Line,Line>itemProcessor(){returnnewLineProcessor();}@BeanpublicItemWriter<Line>itemWriter(){returnnewLinesWriter();}@BeanprotectedStepprocessLines(ItemReader<Line> reader,ItemProcessor<Line,Line> processor,ItemWriter<Line> writer){return steps.get("processLines").<Line,Line>chunk(2).reader(reader).processor(processor).writer(writer).build();}@BeanpublicJobjob(){return jobs
.get("chunksJob").start(processLines(itemReader(),itemProcessor(),itemWriter())).build();}}Trong trường hợp này, chỉ có một bước thực hiện duy nhất một đó là một tasklet.
Tuy nhiên, tasklet đó xác định một trình đọc, một trình ghi và một bộ xử lý sẽ hoạt động trên các phần dữ liệu.
Lưu ý rằng khoảng thời gian cam kết cho biết rằng lượng dữ liệu sẽ được xử lý trong Chunks. Job của chúng ta sẽ đọc, xử lý và viết hai dòng cùng một lúc.
Bây giờ chúng ta đã sẵn sàng để thêm logic vào
5.3. LineReader
LineReader sẽ phụ trách việc đọc một record và trả về một instance Line với nội dung của nó.
Để trở thành Reader thì lớp của chúng ta phải implement interface ItemReader :
publicclassLineReaderimplementsItemReader<Line>{@OverridepublicLineread()throwsException{Line line = fu.readLine();if(line !=null)
logger.debug("Read line: "+ line.toString());return line;}}Code rất đơn giản, nó chỉ đọc một dòng và trả về. Chúng ta cũng sẽ triển khai StepExecutionListener cho phiên bản cuối cùng của lớp này:
publicclassLineReaderimplementsItemReader<Line>,StepExecutionListener{privatefinalLogger logger =LoggerFactory.getLogger(LineReader.class);privateFileUtils fu;@OverridepublicvoidbeforeStep(StepExecution stepExecution){
fu =newFileUtils("taskletsvschunks/input/tasklets-vs-chunks.csv");
logger.debug("Line Reader initialized.");}@OverridepublicLineread()throwsException{Line line = fu.readLine();if(line !=null) logger.debug("Read line: "+ line.toString());return line;}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
fu.closeReader();
logger.debug("Line Reader ended.");returnExitStatus.COMPLETED;}}Cần lưu ý rằng beforeStep và afterStep lần lượt thực thi trước và sau toàn bộ các bước (step).
5.4. LineProcessor
LineProcessor tuân theo logic tương tự như LineReader .
Tuy nhiên, trong trường hợp này, chúng ta sẽ implement ItemProcessor và hàm process_()_ :
publicclassLineProcessorimplementsItemProcessor<Line,Line>{privateLogger logger =LoggerFactory.getLogger(LineProcessor.class);@OverridepublicLineprocess(Line line)throwsException{long age =ChronoUnit.YEARS
.between(line.getDob(),LocalDate.now());
logger.debug("Calculated age "+ age +" for line "+ line.toString());
line.setAge(age);return line;}}Hàm process() nhận một dòng đầu vào, xử lý nó và trả về một dòng đầu ra. Một lần nữa, chúng ta cũng sẽ implement StepExecutionListener:
publicclassLineProcessorimplementsItemProcessor<Line,Line>,StepExecutionListener{privateLogger logger =LoggerFactory.getLogger(LineProcessor.class);@OverridepublicvoidbeforeStep(StepExecution stepExecution){
logger.debug("Line Processor initialized.");}@OverridepublicLineprocess(Line line)throwsException{long age =ChronoUnit.YEARS
.between(line.getDob(),LocalDate.now());
logger.debug("Calculated age "+ age +" for line "+ line.toString());
line.setAge(age);return line;}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
logger.debug("Line Processor ended.");returnExitStatus.COMPLETED;}}5.5. LinesWriter
Không giống như trình đọc và trình xử lý, LinesWriter sẽ viết toàn bộ các dòng nó nhận được_:_
publicclassLinesWriterimplementsItemWriter<Line>,StepExecutionListener{privatefinalLogger logger =LoggerFactory.getLogger(LinesWriter.class);privateFileUtils fu;@OverridepublicvoidbeforeStep(StepExecution stepExecution){
fu =newFileUtils("output.csv");
logger.debug("Line Writer initialized.");}@Overridepublicvoidwrite(List<?extendsLine> lines)throwsException{for(Line line : lines){
fu.writeLine(line);
logger.debug("Wrote line "+ line.toString());}}@OverridepublicExitStatusafterStep(StepExecution stepExecution){
fu.closeWriter();
logger.debug("Line Writer ended.");returnExitStatus.COMPLETED;}}Nhìn vào Code LinesWriter bạn sẽ thấy điều đó. Và một lần nữa, chúng ta đã sẵn sàng để test job của mình.
5.6. Run Job
Chúng ta sẽ tạo một đoạn test mới, giống như đoạn test mà phần trước chúng ta đã tạo cho cách tiếp cận theo hướng tasklets:
@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes =ChunksConfig.class)publicclassChunksTest{@AutowiredprivateJobLauncherTestUtils jobLauncherTestUtils;@TestpublicvoidgivenChunksJob_whenJobEnds_thenStatusCompleted()throwsException{JobExecution jobExecution = jobLauncherTestUtils.launchJob();assertEquals(ExitStatus.COMPLETED, jobExecution.getExitStatus());}}Sau khi cấu hình ChunksConfig như đã giải thích ở trên cho TaskletsConfig, chúng ta đã sẵn sàng để chạy test!
Sau khi hoàn thành job, chúng ta có thể thấy rằng output.csv lại chứa kết quả như mong đợi và console mô tả luồng đã :
[main] DEBUG o.b.t.chunks.LineReader - Line Reader initialized.
[main] DEBUG o.b.t.chunks.LinesWriter - Line Writer initialized.
[main] DEBUG o.b.t.chunks.LineProcessor - Line Processor initialized.
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Mae Hodges,10/22/1972]
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Gary Potter,02/22/1953]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 45 for line [Mae Hodges,10/22/1972]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 64 for line [Gary Potter,02/22/1953]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Mae Hodges,10/22/1972,45]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Gary Potter,02/22/1953,64]
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Betty Wise,02/17/1968]
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Wayne Rose,04/06/1977]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 49 for line [Betty Wise,02/17/1968]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 40 for line [Wayne Rose,04/06/1977]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Betty Wise,02/17/1968,49]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Wayne Rose,04/06/1977,40]
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Adam Caldwell,09/27/1995]
[main] DEBUG o.b.t.chunks.LineReader - Read line: [Lucille Phillips,05/14/1992]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 22 for line [Adam Caldwell,09/27/1995]
[main] DEBUG o.b.t.chunks.LineProcessor - Calculated age 25 for line [Lucille Phillips,05/14/1992]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Adam Caldwell,09/27/1995,22]
[main] DEBUG o.b.t.chunks.LinesWriter - Wrote line [Lucille Phillips,05/14/1992,25]
[main] DEBUG o.b.t.chunks.LineProcessor - Line Processor ended.
[main] DEBUG o.b.t.chunks.LinesWriter - Line Writer ended.
[main] DEBUG o.b.t.chunks.LineReader - Line Reader ended.
Chúng ta có cùng một kết quả với 2 cách tiếp cận khác nhau Tasklets và Chunks. Chúng ta cũng đã ghi log thể hiện rõ ràng cách thực hiện job theo cách tiếp cận này.
6. Kết luận
Các ngữ cảnh khác nhau sẽ cho thấy sự cần thiết của cách tiếp cận này hay cách tiếp cận khác là phù hợp hơn. Trong khi Tasklet thì tự nhiên hơn đối với các tình huống ‘hết nhiệm vụ này đến nhiệm vụ khác’, thì Chunks cung cấp một giải pháp đơn giản để đối phó với các lần đọc được phân trang hoặc các tình huống mà chúng ta không muốn giữ một lượng lớn dữ liệu trong bộ nhớ.
Spring bottom
Như mọi khi, mình hy vọng bạn thích bài viết này và biết thêm được điều gì đó mới.
Cảm ơn và hẹn gặp lại các bạn trong những bài viết tiếp theo! 😍
Nếu bạn thấy thích blog của mình thì nhấn theo dõi để ủng hộ mình nhé. Thank you.😉
Ref
Nguồn: viblo.asia