TIL 2024-08-08 Feign Client 더 잘 써보기

다들 코로나 조심하세요.. 나 죽어

 

@Override
@Transactional
public void createOrder(OrderCreateDto orderCreateDto)
        throws ParseException, JsonProcessingException {

    Order order = Order.of(orderCreateDto);
    orderRepository.save(order);

    Set<Long> productIds = new HashSet<>();

    String products = productClient.getProducts();
    JSONParser jsonParser = new JSONParser();
    JSONObject parsedJson = (JSONObject) jsonParser.parse(products);
    JSONArray jsonArray = (JSONArray) parsedJson.get("data");

    ObjectMapper objectMapper = new ObjectMapper();
    for (Object object : jsonArray) {
        JSONObject jsonObject = (JSONObject) object;
        String productIdStr = jsonObject.get("product_id").toString();
        Long productId = objectMapper.readValue(productIdStr, Long.class);
        productIds.add(productId);
    }

    for (Long id : orderCreateDto.product_ids()) {
        if (!productIds.contains(id)) {
            throw new OrderException(ExceptionMessage.NOT_FOUND_PRODUCT);
        }
        OrderProductCreateDto orderProductCreateDto = new OrderProductCreateDto(order, id);
        order.addOrderProduct(orderProductService.createOrderProduct(orderProductCreateDto));;
    }
}

 

기존 코드다.

FeignClient 를 이용하여 Json Data를 받고 파싱을 하는 과정이다

 

왜 파싱을 하냐면

@Builder(access = PRIVATE)
public record SuccessResponse<T> (
        boolean success,
        @NonNull
        String message,
        @JsonInclude(value = NON_NULL) T data
) implements CommonResponse {

    public static <T> SuccessResponse<T> success(String message, T data) {

        return SuccessResponse.<T>builder()
                              .success(true)
                              .message(message)
                              .data(data)
                              .build();
    }

    public static SuccessResponse<?> success(String message) {

        return SuccessResponse.builder()
                              .success(true)
                              .message(message)
                              .build();
    }
}

 

이렇게 success, message, data 를 받는 Response를 정의해서 사용하고 있기 때문이다.

 

이걸 리팩토링 할 거다!

 

Feign Client 는 객체 지원을 한다.

말 그대로다.

Json 으로 받는 타입을 객체로 역직렬화를 할 수 있다.

우와 그러면..? 파싱을 안해도된다!!

 

리팩토링 시작~

 

그러면 SuccessResponse 와 같은 형식으로 클래스를 작성해주자

 

추상 클래스로 하나 만들어줄 거다 코드의 중복을 피하기 위함이다.

 

public abstract class CommonResponseData {

    private final boolean success;

    private final String message;

    public CommonResponseData(boolean success, String message) {
        this.success = success;
        this.message = message;
    }
}

 

이제 data를 받아야 하니 Json 에 들어올 List 데이터에 맞게 클래스 하나를 작성해주자

 

public record ProductResponseDto (
        Long product_id,
        String name,
        Integer supply_price
) {

}

 

data List로 들어올 아이다.

 

@Getter
public class ProductsResponse extends CommonResponseData {

    private final List<ProductResponseDto> data;

    public ProductsResponse(boolean success, String message, ArrayList<ProductResponseDto> data) {
        super(success, message);
        this.data = data;
    }

}

 

그리구 이렇게 CommonResponseData를 상속받는 Response를 작성해주자

이름 맞춰서 data로!

 

Feign Client도 수정하자!!

@GetMapping("/products")
ProductsResponse getProducts();

 

 

 

@Override
@Transactional
public void createOrder(OrderCreateDto orderCreateDto) {

    Order order = Order.of(orderCreateDto);
    orderRepository.save(order);

    ProductsResponse products = productClient.getProducts();

    for (Long id : orderCreateDto.product_ids()) {
        if (products.getData().stream().noneMatch(product -> product.product_id().equals(id))) {
            throw new OrderException(ExceptionMessage.NOT_FOUND_PRODUCT);
        }
        OrderProductCreateDto orderProductCreateDto = new OrderProductCreateDto(order, id);
        order.addOrderProduct(orderProductService.createOrderProduct(orderProductCreateDto));;
    }
}

 

그리고 createOrder를 수정해주자.. ㅎㅎ

stream() 을 쓰기 때문에 성능이 안 좋을 수 있는데 Set 으로 리팩토링하면 된다.

 

한 눈에 봐도 파싱하는 부분이 적어지니 엄청 코드 수가 줄어들었다.

 

이렇게 사용하면 되게 쉽게 사용할 수 있다~~ 야호야호