원격 청킹 : JSON 객체에서 인스턴스화 할 수 없습니다.

Question

원격 청킹과 함께 스프링 일괄 처리를 사용하고 있습니다. json 형식 (application/json)을 사용하여 요청 대기열에서 master publih 이벤트가 발생하면 예외가 발생합니다 슬레이브가이 json 이벤트를 읽을 때.

예외 :

의해 발생 : com.fasterxml.jackson.databind.JsonMappingException : 형 검색 결과에서 적합한 생성자 [단순형 클래스 org.springframework.batch.integration.chunk.ChunkRequest] : JSON 개체 (기본 생성자 또는 작성자가 누락되었거나 형식 정보를 추가/사용 가능하게 설정하지 않아도 됨)에서 인스턴스를 생성 할 수 없습니다. [출처 : { "jobId": 0, "items": [{ "aaa": "11111" " "0", "filterCount": 0, "readSkipCount": 0, "writeSkipCount" ": 0,"processSkipCount ": 0,"exitStatus ": {"exitCode ":"EXECUTING ","exitDescription ":" ","실행 중 : "}"skipCount ": 0 , "stepSkipCount": 0}, "sequence": 0}; 행 1, 열 2]

RabbitMQ 메시지 :

헤더 :
유형 ID : org.springframework.batch.integration.chunk.ChunkRequest CONTENT_ENCODING : UTF-8 CONTENT_TYPE : 애플리케이션/JSON 페이 308 바이트 인코딩 : 문자열 { "작업 ID"0 "항목": [{ "AAA": "11111", "BBB" '22222', 'CCC' " 33333 "} ] 0, "writeCount": 0, "filterCount": 0, "readSkipCount": 0, "writeSkipCount": 0, "processSkipCount": 0, "exitStatus": { "exitCode" ":"실행 ","exitDescription ":" ","실행 "TRUE},"SKIPCOUNT ": 0,"stepSkipCount ": 0},"순서 "0}

나는 'Jackson2JsonMessageConverter'를 사용 'AmqpOutboundEndpoint'및 'AmqpInboundChannelAdapter'에 대한 메시지 변환기로

제발 도와 줄 수 있습니까?

고마워요.

Answer 1

ChunkRequestdoesn't support Jackson JSON serialization - 기본 CTOR가 없습니다.

Java 직렬화 만 지원합니다. 대신 SimpleMessageConverter을 사용하십시오.

또는 사용자 정의 Jackson 디시리얼라이저를 작성하십시오.