[Dalmuri] 맡김 API 호출해서 감정 분석하기 - WebClient를 이용해서

부제: 요즘은 돈없으면 개발도 못한다.

[Dalmuri] Java로 Google Cloud Nature Language API 호출해서 감정 다이어리 만들기

진짜 드럽고 치사한 세상이다... 거렁뱅이 개발자들은 개발 어떻게 하라고 맨날 과금타령 하는질 모르겠다. 난 클로드 코드도 돈아까워서 그냥 잼민이+클로드 고문하고 있는데...인텔리제이 1년치 요금도 대학교 계정으로 40퍼 할인받는것도 덜덜 떨면서 결제하고 있는데... 그리고 게시글 작성 기준일로 환율도 장난아니게 높아서 가격 더올랐을거다...

우리나라 환율도 박살났는데 일본은 섭종하나요,,,,?

---

기존 게시글 보면 알겠지만 원래 맡김 API를 사용해서 감정 분석을 하고 싶었다... 왜냐? 공짜니까.

근데 그 타이밍에 API가 고장나서 문의를 드렸고 다른 대체품이 있을까 검색하다가 Google 자연어 분석 API를 알게 되었고... 그걸 활용하려고 🐶고생 하면서 Google colud에 내 프로젝트 생성했고.. 권한 설정했고.. pom.xml에 의존성 추가하고 어쩌구 저쩌구 한건데...

이제 과금되서 돈 내고 사용하란다!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

그냥 여러가지 공부했다고 정신승리하련다...

---

1. 맡김 API란?

https://matgim.ai/public-api/

데이탄소프트라는 회사에서 출시한 API 서비스인데, 다양한 인공지능 API를 사용할 수 있는 서비스라고 한다. 실제로 감정 분석 API 말고도 다양한 API들이 있다.

심지어 비속어 추출 API 이런것도 있다. 이런걸 무료로 풀어주는게 너무 감사할 따름...

완벽한 무료는 아니고, 한달에 100회 이상은 만원 + a로 과금이 된다.

근데 플젝을 사용할 나나 내 친구들이 매일매일 일기를 쓸 정도로 부지런하지 않기 때문에(ㅋㅋㅋㅋㅋㅋㅋㅋㅋㅋㅋㅋ) 안심하고 과금 버전 사용할 수 있을거다. 친구들아 고마워!

 

2. 개발 순서

기존의 Google 자연어 분석 API를 싹 다 주석처리하고 거기에 새로이 맡김 API를 사용할 것이기 때문에 controller, service는 새로이 생성될 필요는 없다.

다만 Google에선 자체적으로 의존성을 추가시켜서 객체를 본인들이 생성해줬는데(Sentiment, LanguageServiceClient와 같이)

맡김은 그런거 없어서 내가 직접 객체를 생성해야 한다. 

 

(1) MatgimResponseDTO 객체 생성

맡김 API에서 다음과 같은 json 형식으로 가져오기 때문에 이것과 동일한 구조의 DTO를 만든다.

import com.fasterxml.jackson.databind.PropertyNamingStrategies;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.*;
import java.util.List;

@Getter
@Setter
@ToString
@NoArgsConstructor
@AllArgsConstructor
@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
public class MatgimResponseDTO {
    private boolean success;
    private Result result;

    @Getter
    @Setter
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    @JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
    public static class Result {
        private DocumentScore documentScore;
        private List<SentenceScore> sentenceScore;
    }

    @Getter
    @Setter
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    @JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
    public static class DocumentScore {
        private double score;
        private double posScore;
        private double negScore;
    }

    @Getter
    @Setter
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    @JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
    public static class SentenceScore {
        private String sentence;
        private double score;
    }

}

참고로

@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)

이건 Java객체의 camelCase와 Json 객체의 snake_case를 서로 매핑시켜주는 설정이다.

외부에서 들어오는 snake_case형식의 Json 데이터를 Java의 caleCase로 필드에 자동으로 매핑(역직렬화)해줄 수 있다.

 

현재 클래스는 

public class MatgimResponseDTO {  // 최상위 부모 클래스
    // 내부 클래스
    class Inner {}          // ❌ static 없음
    static class Inner2 {}  // ✅ static 있음
}

이런 구조이다.  

1. public class MatgimResponseDTO(최상위 클래스) : 부모 클래스라는 개념이 없음. 독립적인 파일 단위, 어디서든 new MatgimResopnseDTO()로 바로 생성할 수 있음.
2. public class inner : MatgimResponseDTO라는 '집' 안에서만 살 수 있는 클래스. 반드시 MatgimResponseDTO가 먼저 생성되어야 한다. static이 없는 내부 클래스일 때만(=public class Inner일때만) 외부 클래스 객체(MatgimResponseDTO)가 있어야 생성할 수 있다.
3. public static class Result(내부 클래스에 static이 있는 경우) : 이름표는 MatgimResponseDTO.Result를 달고 있지만 실제론 new MatgimResponseDTO.Result()로 혼자 태어날 수 있음

그렇다면 public class와 public static class의 차이는?

• public class : 외부 클래스의 인스턴스가 먼저 생성되야만 존재할 수 있는 클래스. 단 최상위 클래스의 경우 외부 클래스라는 개념도 없다(ex. MatgimResponseDTO)
• public static class : public class 내부에서만 쓸 수 있는 정적 클래스. 여기선 public Static class Result, public static class DocumentScore, public static class SentenceScore가 있다. 일반 클래스처럼 혼자 생성 가능하며 주로 DTO 계층 구조를 만들 때 권장된다.

👉 "내부 클래스일 때" static 없으면 “부모 없이는 못 태어남” → MatgimResponseDTO에선 해당 없음(애초에 내부 클래스가 아니기 때문)
👉 static 있으면 “혼자 태어날 수 있음”

MatgimResponseDTO
 └── Result
      └── DocumentScore
      └── SentenceScore

여기서 MatgimResponseDTO는 최상위 클래스로 부모가 없다. 

Result, DocumentScore, SentenceScore은 MatgimResponseDTO 안에 포함된 내부 클래스.

Result 나 DocumentScore을 static으로 선언해야 하는 이유는

1. 독립적 인스턴스화 : Jackson이 JSON을 Java객체로 바꿀 때, 외부 클래스인 MatgimResponseDTO를 먼저 만들지 않고도 내부의 Result객체를 생성할 수 있어야 한다.
2. 메모리 효율 : static이 아니면 내부 클래스 객체는 자신을 감싸고 있는 외부 클래스의 정보를 항상 들고 있어야 한다. DTO처럼 단순 데이터를 담는 용도라면 이런 연결 고리는 메모리 낭비만 초래한다.
3. 구조적 그룹화 : 관련 있는 데이터 구조(Result, Score)를 따로 만들지 않고 하나의 파일 안에서 논리적으로 묶어 관리할 수 있어 가독성이 좋아진다.

따라서 static이 붙지 않는 내부 클래스는 부모(외부)가 있어야 태어날 수 있는 자식이고, static class는 부모 집 안에 살지만 자기 차와 열쇠를 따로 가지고 있는 독립된 성인이라 볼 수 있다.

 

(2) WebClient 설정

실무에서 RestTemplate를 이용해서 외부 API와 연결하는게 표준이었는데, 요즘 RestTemplate 쓰는것도 구시대적이라 권장되지 않는다고 한다. (그래서 선배가 리팩토링 하다가 기존 코드 다 이상해져서 롤백한건 안비밀)

그래서 초장부터 그냥 RestTemplate말고 좀 더 좋은게 뭐가 있을지 생각하다가 WebClient라는걸 발견했다. WebClient는 비동기 및 비차단 통신을 효율적으로 처리하는 반응형 Http client라고 한다.

1. 비동기, 논블로킹(Non-Blocking) 방식 : WebClient는 Reactive Stack을 기반으로 한다. API요청을 보낸 뒤 응답이 올 때 까지 스레드가 대기(Block)하지 않고 다른 일을 할 수 있다. 적은 수의 스레드로 훨씬 많은 동시 요청을 할 수 있기 때문에 서버의 처리량이 획기적으로 늘어난다. 
2. 싱글톤(Singleton)으로 관리되는 재사용성 : @Bean으로 등록하면 스프링 컨테이너가 WebClient 객체를 딱 하나만 만들어서 관리한다. 리소스를 절약하고 설정을 공유할 수 있다. 
3. 유연한 확장성: 나중에 타임아웃 설정, 로깅용 필터, 특정 API 전용 인증 헤더 추가 등등을 builder에 한줄만 추가하면 된다. 또한 한번 빌드된 WebClient는 상태가 변하지 않으므로 여러 스레드에서 동시에 사용해도 안전하다.
4. 가독성과 유지보수 : .retrieve().bodyToMono(MatgimResponseDTO.class) 이거 한줄이면 API응답인 snake_case를 우리가 만든 camelCase로 자동 변환해준다.

참고로 스레드(thread)란?

하나의 프로세스 안에서 독립적으로 실행되는 '작은 실행 단위'

쉽게 비유하자면 "일꾼"이다.  자바 애플리케이션(서버)이라는 식당에서 손님의 주문을 받고 요리해서 서빙까지 하는 직원 한 명이 곧 스레드 하나라고 생각하면 된다.

• 스레드가 많으면? 일꾼이 많으니 동시에 여러 손님을 응대할 수 있지만, 일꾼마다 월급(메모리 점유)을 줘야 하고 관리하기가 힘들어짐
• 스레드가 적으면? 서버가 사용하는 메모리가 적고 가볍지만, 일꾼이 모자라면 손님들이 줄을 서서 기다려야함

❌ Thread 1개

요청1 → 끝나야 → 요청2 → 끝나야 → 요청3 👉 느림

 

✔ Thread 여러 개

요청1
요청2
요청3
동시에 처리👉 빠름

 

 

그럼 프로세스(process)란?

시스템에서 실행 중인 프로그램

이제 왜 최근에 RestTemplate가 아닌 WebClient가 사용되는지 이제 알겠다~

 

1️⃣ pom.xml에 의존성 추가

<!-- webClient -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

 

2️⃣ WebCientConfig 작성하기

@Configuration
public class WebClientConfig {

    @Bean
    public WebClient MatgimWebClient(){
       return WebClient.builder()
               .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
               .build();
    }
}

• @Configuration : 스프링이 시작될 때 Configuration 어노테이션을 읽어서 설정을 실행함. 자바의 일반 클래스가 아닌 스프링 시스템의 설계도 역할
• @Bean : 다른 서비스 클래스에서 new WebClient()를 매번 할 필요 없이 스프링이 미리 만들어준 이 객체를 "주입(@Autowired)"바당 쓸 수 있음(싱글톤 패턴)
• public WebClient MatgimWebClient() : 생성될 객체의 타입은 WebClient, 이 Bean의 이름은 MatgimWebClient
• WebClient.builder() : WebClient 객체를 만들기 위한 조립 도구(Builder)를 꺼내는 단계
• defaultHeader(HttpHeader.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) : 클라이언트로 보내는 모든 요청은 기본적으로 JSON임을 명시함)
• build() : 설정을 마친 최종 객체가 생성되어 스프링 컨테이너에 보관됨

3️⃣ API 호출하기

String body = request.getText();
Map<String,String> bodyMap = new HashMap<>();
bodyMap.put("document", body);

MatgimResponseDTO result = webClient.post()
        .uri(matgimUrl)
        .header("Content-Type", "application/json")
        .header("x-auth-token", matgimApiKey)
        .bodyValue(bodyMap)
        .retrieve()
        .bodyToMono(MatgimResponseDTO.class)
        .block();

이제 service단에서 API 호출부를 작성하면 된다. 

• 요청 데이터 준비

String body = request.getText(); // 사용자가 보낸 일기 내용 등을 가져옴
Map<String, String> bodyMap = new HashMap<>();
bodyMap.put("document", body); // API가 원하는 {"document": "내용"} 형식으로 만듦

• 호출부 작성

MatgimResponseDTO result = webClient.post() // 1. POST 방식
        .uri(matgimUrl) // 2. 목적지 주소(URL) 설정
        .header("Content-Type", "application/json") // 3. JSON 데이터라고 알림
        .header("x-auth-token", matgimApiKey) // 4. 인증 키를 헤더에 담음
        .bodyValue(bodyMap) // 5. 준비한 데이터를 몸체(Body)에 실음
        .retrieve() // 6. 이제 요청을 쏨
        .bodyToMono(MatgimResponseDTO.class) // 7. 받은 JSON을 아까 만든 DTO 객체로 자동 변환
        .block(); // 8. 결과가 올 때까지 기다림 (동기적 처리)

.block()의 의미: 원래 WebClient는 비동기(Non-blocking)로 동작하지만, 여기서 .block()을 쓰면 응답이 올 때까지 다음 코드로 넘어가지 않고 기다린다. 왜냐면

double score = result != null ? result.getResult().getDocumentScore().getScore() * 2.5 : 0;
        score = Math.max(-1, Math.min(1, score));

        double positive = result != null ? result.getResult().getDocumentScore().getPosScore() : 0;
        double negative = result != null ? result.getResult().getDocumentScore().getNegScore() : 0;
        double magnitude = (Math.abs(positive) + Math.abs(negative)) * 5;

        response.setScore(score);
        response.setMagnitude(magnitude);
        return ResponseEntity.ok(response);

이 로직 때문에.. 기존에 google api에선 감정을 score과 magnitude로 분리해서 보내줬는데, 맡김은 긍정적인 감정, 부정적인 감정의 점수만 알려준다. 그래서 그걸 score과 magnitude로 변환한 개인적인 로직이다... 이 부분은 필수는 아니다!

 

[참고 문헌]

https://m.blog.naver.com/seek316/223337685249 

[Java] Spring Boot - WebClient 사용하기

https://coding-factory.tistory.com/279

[Java] 자바 Thread(스레드) 사용법 & 예제