[📛 Error] Object를 List<XXXDto>로 캐스팅하니 타입 불일치 에러 발생

📛 에러 설명

class java.util.LinkedHashMap cannot be cast to class com.XXXX.
XXXX.app.interfaces.devices.service.dto.StatusDto

 

👉 java.util.LinkedHashMap을 StatusDto 객체로 강제로 캐스팅하려 할 때 발생하는 ClassException이다.

Java에서 타입 불일치로 인해 발생하는건데, 왜 이러한 상황이 발생하는지 알아보자...

 

에러가 발생하는 상황

🔶 수정 전 코드 

@Override
    public Flux<Dto> getAll() {
    
        return deviceRepository.findByXXXX()
                .switchIfEmpty(Mono.error(new IllegalArgumentException("사용자의 디바이스를 찾을 수 없습니다.")))
                .flatMapMany(device -> {
                    Object attributes = device.getStatus().get("attributes");
                    Object operations = device.getStatus().get("operations");

                    List<StatusDto> deviceAttributes = new ArrayList<>();

                    deviceAttributes.addAll((List<StatusDto>) attributes);
                    deviceAttributes.addAll((List<StatusDto>) operations);

                    log.info("deviceAttributes {}", deviceAttributes);

                    return repository.findAll()
                            .flatMap(mode -> {
                                
                                Dto dto = new Dto();

                                for(StatusDto statusDto : wallPadAttributes) {
                                    if (statusDto.getCode().equals(mode.getCode()))
                                        dto.setValue(statusDto.getValue());
                                }

                                return Flux.just(dto);
                            });
                	});
   		});
    }

 

• deviceRepository를 통해 조회한 Device의 필드 중 Map<String, Object> status 필드가 존재한다.
• DB에 Device의 status가 아래와 같이 저장되어있다.

{
  "status": {
    "attributes": [
      { "code": "outgoing", "value": "event" },
      { "code": "in", "value": "run" }
    ],
    "operations" : [
      { "code": "out", "value": "run" },
    ]
  }
}

• device.getStatus().get("attributes")의 반환타입은 Object이기 때문에
  List<StatusDto> attributes = (List<StatusDto>) device.getStatus().get("attributes")로 코드를 작성하면 알아서 캐스팅이 잘 될거라 생각했다.
• 하지만 getClass()를 이용해 타입을 확인한 결과, List<StatusDto> 타입이 아니라 List<LinkedHashMap>이었다. 

👉 왜 Object가 LinkedHashMap이 되는걸까 ? 🤔

 

 

MongoDB에서의 JSON 직렬화

MongoDB와 같은 NoSQL DB에서는 위의 status 필드를 JSON 형식으로 데이터를 저장한다. 

Java에서 JSON 데이터를 다룰 때 자동으로 Map<String, Object> 형태로 변환된다. 

{
  "status": {
    "attributes": [
      { "code": "outgoing", "value": "event" },
      { "code": "in", "value": "run" }
    ],
    "operations" : [
      { "code": "out", "value": "run" },
    ]
  }
}

 

위의 데이터를 Java에서 읽으면 아래와 같이 매핑된다.

Map<String, Object> status = new HashMap<>();

status.put("attributes", List.of(
    Map.of("code", "outgoing", "value", "event"),
    Map.of("code", "in", "value", "run")
));

status.put("operations", List.of(
    Map.of("code", "out", "value", "run")
));

List<?> attributesList = (List<?>) attributes;
System.out.println(attributesList.get(0).getClass());

// 출력결과
// >>> class java.util.LinkedHashMap

 

 

해결방법

List<Map<String, Object>> 👉 List<StatusDto>로 변환하는 과정을 추가해야한다.

private StatusDto mapToStatusDto(Map<String, Object> map) {
    StatusDto statusDto = new StatusDto();
    statusDto.setCode((String) map.get("code"));
    statusDto.setValue(map.get("value"));
    return statusDto;
}

 

 

 

수정 후 코드 

@Override
    public Flux<Dto> getAll(String username) {
        return deviceRepository.findByXXXX()
                .switchIfEmpty(Mono.error(new IllegalArgumentException("사용자의 디바이스를 찾을 수 없습니다.")))
                .flatMapMany(device -> {
                    Object attributes = device.getStatus().get("attributes");
                    Object operations = device.getStatus().get("operations");

                    log.info("attributes : {}", attributes);
                    log.info("operations : {}", operations);

                    List<StatusDto> deviceAttributes = new ArrayList<>();


					// Map을 StatusDto로 변환
                    for (Object attr : (List<?>) attributes) {
                        deviceAttributes.add(mapToStatusDto((Map<String, Object>) attr));
                    }

                    for (Object op : (List<?>) operations) {
                        deviceAttributes.add(mapToStatusDto((Map<String, Object>) op));
                    }

                    return repository.findAll()
                            .flatMap(mode -> {
                                
                                Dto dto = new Dto();
                                
                                for(StatusDto statusDto : deviceAttributes) {
                                    if (statusDto.getCode().equals(mode.getCode()))
                                        dto.setValue(statusDto.getValue());
                                }

                                return Flux.just(dto);
                            });
                });
        });
    }