kotlin spring batch job parameter 문제 - 해결했습니다.

Question

코틀린으로 간단한 배치를 공부 중에 있습니다. jobParameter를 별도 클래스로 분리하여 빈으로 등록 후 주입 받아 사용하려고 하는데 parameter가 전부 null로 나옵니다. 똑같은 코드를 자바로 구현했을때는 parameter가 잘 동작했는데 코틀린은 익숙하지 않아서 도움을 요청 드립니다.JobConfig.ktconst val JOB_NAME = "member" @Configuration class JobConfig( private val jobParameter: RequestJobParameter, private val entityManagerFactory: EntityManagerFactory ) { private val log = LoggerFactory.getLogger(this.javaClass)!! @Bean(name = [JOB_NAME + "_job"]) fun job(jobRepository: JobRepository, transactionManager: PlatformTransactionManager): Job { return JobBuilder(JOB_NAME + "_job", jobRepository) .start(step(jobRepository, transactionManager)) .build() } @Bean(name = [JOB_NAME + "_jobParameter"]) @JobScope fun jobParameter(@Value("#{jobParameters[requestDate]}") requestDateStr: String, @Value("#{jobParameters[status]}") status: MemberStatus): RequestJobParameter { val requestDate = LocalDateTime.parse(requestDateStr, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) return RequestJobParameter(requestDate, status) } @Bean(name = [JOB_NAME + "_step"]) @JobScope fun step(jobRepository: JobRepository, transactionManager: PlatformTransactionManager) : Step { return StepBuilder(JOB_NAME + "_step", jobRepository) .chunk(10, transactionManager) .reader(reader()) .processor(processor()) .writer(writer()) .build() } @Bean(name = [JOB_NAME + "_reader"]) @StepScope fun reader(): JpaPagingItemReader { val params = HashMap() // params["requestDate"] = requestDateStr!! params["status"] = jobParameter.getStatus() return JpaPagingItemReaderBuilder() .name(JOB_NAME + "_reader") .entityManagerFactory(entityManagerFactory) .pageSize(10) .queryString("select m from Member m where m.status = :status") .parameterValues(params) .build() } @Bean(name = [JOB_NAME + "_processor"]) @StepScope fun processor(): ItemProcessor { return ItemProcessor { member -> member.changeStatus(MemberStatus.WITHDRAW) member } } @Bean(name = [JOB_NAME + "_writer"]) @StepScope fun writer(): JpaItemWriter { return JpaItemWriterBuilder() .entityManagerFactory(entityManagerFactory) .build() } }RequestJobParameter.ktopen class RequestJobParameter( private val requestDate: LocalDateTime, private val status: MemberStatus ) { fun getRequestDate() = requestDate fun getStatus() = status }JobController.kt@RestController class JobController( private val jobLauncher: JobLauncher, private val job: Job ) { @GetMapping("/job") @Throws(JobInstanceAlreadyCompleteException::class, JobExecutionAlreadyRunningException::class, JobParametersInvalidException::class, JobRestartException::class) fun testJob(): String { val jobParametersBuilder = JobParametersBuilder() .addString("requestDate", LocalDateTime.now().toString()) .addString("status", MemberStatus.SLEEP.name) .toJobParameters() val jobExecution = jobLauncher.run(job, jobParametersBuilder) return jobExecution.toString() } }============================================================해결했습니다. open class RequestJobParameter( private val requestDate: LocalDateTime, private val status: MemberStatus ) { open fun getRequestDate() = requestDate open fun getStatus() = status } get 메소드에 open 키워드를 추가하니 잘 가져오네요. 왜 open을 추가해야 하는지 잘 몰라서 좀 더 공부해야 할 것 같습니다. ㅎㅎ...

초무쿤 · Answer

Scope 이 달라서 안됩니다.처음 빈 로딩시에 job parameter는 다 null이고 step scope부터 주입이 되요.(그전엔 null)좀 어처구니 없긴 한데 스프링 컴포넌트 재활용하려면 딱히 spring batch 말고 대안이 없다보니 그냥 씁니다. 이건 고쳐줄 생각이 없는듯..(물론 커스터마이징 오지게 하면 가능하긴 한데 사이드이펙트가 생겨서 추천드리지는 않아요. SI쪽에서는 카스터마이징 좀 하는편입니다. 본판이 워낙 괴기스럽다보니..궁금하면 github 위키한번 보시면 이것밀고도 쌩뚱밎은 부분이 많아서;;)

kotlin spring batch job parameter 문제 -> 해결했습니다.

1개의 답변

기술 목록