인프런 커뮤니티 질문&답변

현재 버전이 구버전이라 xml 로 되어있어..

MessageChannelPartitionHandler

에서 파티션을 한 후에 문제가 되지 않나 추측중이야

 heapdump 를 보니 stepExecution 객체가 누적되는 걸로 추측이 되고 있거든!

버전에 따라 이야기가 달라질 수 있다. 사용중인 버전을 알려주면 보다 정확한 판단을 하도록하겠다.

우선 배치5를 기준으로 이야기하자면
StepExecution이 계속 누적된다면 

잡이 돌 때마다 MessageChannelPartitionHandler 빈이 새로 생성되거나
(이게 가능하려면 Master step이 JobScope로 선언되어야하는데 내 기억이 맞다면 최신 버전 기준, Manager Step은 JobScope를 달면 동작하지 않는다) 

그게 아니라면 MessageChannelPartitionHandler의 워커 스텝 결과 취합 과정에 오류가있는것으로보인다

메타데이터 저장소 폴링 방식으로 결과를 취합하는가 아니면 별도 inputChannel을 구성해서 워커로부터 메세지를 전달받는가?

미들웨어는 mq를 사용하는가 아니면 카프카?

미들웨어는 activeMQ 사용중이야!

그리고 xml 설정을 보니 <int:channel> 형식으로 선언 되어있어!

회사에서 적용해서 사용중이라 일단 생각나는 부분은 여기까지고 추가적으로 필요한 부분들은 다음주에 더 취합해볼께!

신경써줘서 너무 고마워!

굿굿 형  취합되면 편하게 말씀부탁

xml 설정을 확인해보니

<bean id="pushHandler" class="org.springframework.batch.integration.partition.MessageChannelPartitionHandler">

<int:aggregator ref="pushHandler"
input-channel= "abc"
output-channel = "efg"
send-timeout= "3600000"/>

<int:channel id ="abc"/>

<int:channel id="efg">
    <int:queue/>
</int:channel>

이렇게 설정이 되어 있어!

현재 내가 조취를 해봤던 부분

int:aggregator // 석처리 

해놓고 돌려보니

heapDump 상에 org.springframework.integration.channel.QueueChannel 객체가 사라진 것까진 확인해봤어

내가 접근한 방법이 맞는걸까??

다른 방향이 있으면 알려줬으면 좋겠어!

확인이 늦었다 Jaess형💀

현재 구성이 메타데이터 저장소 폴링 방식이 아니라 replyChannel로 워커의 결과를 전달받는 방식으로 되어 있는 것으로 보인다.

문제는 이 QueueChannel에서 메시지 소비가 제대로 안 되서 데이터가 계속 쌓이는 것으로 보인다.

확인이 필요한 부분
1. MessageChannelPartitionHandler의 receiveReplies() 메서드가 정상적으로 호출되는가? 
2. 그 내부의 messagingGateway.receive(replyChannel)이 정상적으로 메시지를 읽어가는가?

답변 고마워!

일단 aggregator 를 비활성화 하고 처리하는 걸로 일단락 됐어!

replyChannel

설정에 channel 설정으로 되어 있어서 소비 되는 걸로 추측은 되고 있고 xml 설정이라 추가적으로 형이 알려준 메서드가 호출되는지는 파악이 어려운 상황이야!