🔄 리팩토링

• 불필요한 @Transaction 제거

  서비스 계층에서 단일 SELECT 쿼리와 같은 조회 작업에서 불필요한 트랜잭션 오버헤드 제거

• GlobalExceptionHandler 예외 처리

  각 상황에 맞는 오류 코드와 명확한 메시지를 사용자에게 전달하여 클라이언트 후처리에 유용하게 사용

• 생성자 주입(@RequiredArgsConstructor)과 final 필드를 활용한 싱글톤 빈 생성

  Spring Bean 간 의존성을 생성자 주입 방식으로 관리하고 필드의 불변성을 보장

• .yml 내부 변수값들을 TypeSafeProperties 객체로서 관리

  여러 객체에서 변수를 일관되게 주입받아 사용할 수 있으며, 필드 타입 지정을 통해 타입 안전성을 확보

💻 주요 개선 시도

✅ Spring Batch

현재 처리 데이터는 500건 미만의 소규모지만, 향후 대용량 데이터 처리의 도입이나 코드 재사용 가능성을 고려하여 Reader/Processor/Writer 역할 명확화 및 최적화 등 확장성 중심의 개선을 수행하고자 하였다.

현재 Writer 객체에서는 Reader 객체가 가져온 API 데이터와 DB 데이터를 비교하여 실제로 업데이트가 필요한 Row만 선별하지만, 여기서는 모든 데이터가 업데이트되는 경우를 가정하고 진행한다.

(1). 적절한 PageSize 선택

StrString xmlResponse = webClient
				.get()
				.uri(uriBuilder -> uriBuilder.scheme("https")
						// 호스트 경로
						.host(typeSafeProperties.getApiHost())
						// 엔드포인트 경로
						.path(typeSafeProperties.getApiRltmPath()) 
						// API 서비스키 전달
						.queryParam("serviceKey", typeSafeProperties.getApiNormalEncoding())
						.queryParam("pageNo", currPage)
						// 100 -> 500
						.queryParam("numOfRows", 500)
						.build()
						)
				// API로부터 데이터를 가져옴
				.retrieve() 
				// API로부터 오류가 있을때 오류 반환
				.onStatus(status -> status.isError(), clientResponse -> Mono.error(new Exception()))
				// XML 응답을 String으로 받음
				.bodyToMono(String.class) 
				.retryWhen(Retry.fixedDelay(3, Duration.ofSeconds(2)))
				// 비동기 요청을 동기적으로 기다리고 결과를 반환 (Mono의 단일 값 처리)
				.block(); 

문제 인식 :

Reader 객체에서 API를 호출할 때 PageSize가 너무 작으면 HTTP 요청 횟수가 증가하여 네트워크 오버헤드가 커지고, 전체 배치 성능이 저하될 수 있다.

변경점 :

해당 API는 총 413건 가량의 데이터를 반환한다. 기존 PageSize 100은 배치 사이클 당 처리 건수가 적지만 HTTP 요청이 5회 발생하게 되며 네트워크 오버헤드를 증가시켰다.

따라서 PageSize를 500으로 늘려 한 번에 더 많은 데이터를 가져오도록 수정하였다.