[TIL] 프로젝트 23일차.. 카카오톡 알림 구현하기!!

🌞 오늘은 어떤 하루였지..

가장 먼저 배송 생성 실패 시 재고 복원을 위한 로직을 구현했다.
주문 생성 토픽에 들어가 있던 재고 감소 로직과 함께 따로 재고 관련 토픽을 생성해서 메시지 분기 처리가 될 수 있도록 로직을 구현하려고 했다.

// 재고 관련 Kafka Listener
@KafkaListener(topics = "${kafka.topic.product}", groupId = "${spring.kafka.consumer.product.inventory.group-id}")
public void listenInventory(@Header(KafkaHeaders.RECEIVED_KEY) String key, String value) {
    try {
        OperationWrapperDto wrapperDto = JsonHelper.fromJson(value, OperationWrapperDto.class);
        OperationType type = wrapperDto.operationType();

        switch (type) {
            case ORDER_PAYMENT_INVENTORY_DECREASE -> routeInventoryDecreaseMessage(key, value);
            case DELIVERY_FAIL_INVENTORY_RESTORE -> routeInventoryIncreaseMessage(key, value);
            default -> log.error("❌ 지원하지 않는 메시지 타입 수신: {}", type);
        }
    } catch (ConflictException e) {
        log.warn("⚠️ 재고 부족으로 메시지 처리 실패: {}", e.getMessage());
    } catch (NotFoundException e) {
        log.warn("⚠️ 필수 데이터 누락으로 메시지 처리 실패 ({}): {}", e.getErrorCode(), e.getMessage());
    } catch (NumberFormatException e) {
        log.warn("⚠️ 잘못된 orderId 형식입니다. key: {}, message: {}", key, e.getMessage());
    } catch (Exception e) {
        log.error("❌ 예기치 못한 오류로 메시지 처리 실패: {}", e.getMessage());
    }
}

• INVENTORY_DECRERASE: 재고 감소
• INVENTORY_INCREASE: 재고 복원

DeliverySerive에서 예외 발생 시 KafkaTemplate을 활용해서 메시지를 발행할 수 있도록 하면 될 것 같았다.
그럼 Listener는 요청한 메시지를 받아서 재고 복원 로직을 수행하면 된다.

kafkaTemplate.send(productTopic, request.orderId().toString(), request);

private void routeInventoryIncreaseMessage(String key, String value) {
    // todo 배송 실패 시 재고 복원 로직 작성
    log.info("📥 Kafka 재고 복원 메시지 수신: key={}, value={}", key, value);

    // 재고 복원 로직
    try {
        Long orderId = Long.valueOf(key);
        productOptionCombinationService.increaseProductOptionCombinationInventory(orderId);
    } catch (NumberFormatException e) {
        log.error("❌ orderId 파싱 실패. 잘못된 key 형식: {}", key);
    }
}

kafkaTemplate에서 key로 orderId를 넘겨주고 있기 때문에, 재고 복원 로직에서는 key를 활용해서 메서드를 수행할 수 있다.

ORDER_PAYMENT_INVENTORY_DECREASE,
DELIVERY_FAIL_INVENTORY_RESTORE

그리고 다음과 같이 명확하게 확인할 수 있는 메시지 타입으로 수정했다.

String payload = JsonHelper.toJson(request);
OperationWrapperDto wrapper = OperationWrapperDto.from(OperationType.DELIVERY_FAIL_INVENTORY_RESTORE, payload);
String wrappedMessage = JsonHelper.toJson(wrapper);

kafkaTemplate.send(productTopic, request.orderId().toString(), wrappedMessage);

그리고 다음과 같이 CreateDeliveryRequest를 바로 보내는 것이 아니라 WrapperDto로 변환해서 메시지 타입이 포함된 Dto로 보내줄 수 있도록 처리 과정이 필요해서 추가적으로 작성했다.

 

재고 복원 로직 구현이 완성되고 카카오톡 알림 메시지 전송으로 넘어갔다.

KakaoMessageBuilder

@Slf4j
@Component
public class KakaoMessageBuilder {

    public String buildTextTemplateObject(UserNotification userNotification) {
        try {
            ObjectMapper objectMapper = new ObjectMapper();

            // 텍스트 블록 구성
            String text = """
                [상품 출고 안내]
                주문하신 상품이 발송되었습니다.
                
                배송 조회까지 평일 기준 1~2일 정도 소요될 수 있습니다.
                상품 수령까지 조금만 기다려주세요!
                
                ■ 주문 정보
                주문번호: %s
                
                ■ 배송 정보
                택배사: %s
                송장번호: %s
                
                ■ 참고사항
                - 정해진 출고지(%s)에서 출고됩니다.
                """.formatted(
                userNotification.orderId(),
                userNotification.courierName(),
                userNotification.trackingNumber(),
                userNotification.senderName()
            );

            ObjectNode root = objectMapper.createObjectNode();
            root.put("object_type", "text");
            root.put("text", text);

            ObjectNode link = objectMapper.createObjectNode();
            link.put("web_url", userNotification.trackingUrlTemplate());
            link.put("mobile_web_url", userNotification.trackingUrlTemplate());

            root.set("link", link);
            root.put("button_title", "주문 조회");

            return objectMapper.writeValueAsString(root);
        } catch (Exception e) {
            log.error("❌ 카카오 텍스트 템플릿 생성 실패: {}", e.getMessage());
            return null;
        }
    }
}

KakaoMessageService

@Slf4j
@Service
@RequiredArgsConstructor
public class KakaoMessageService {

    private final KakaoMessageBuilder kakaoMessageBuilder;
    private final WebClient webClient;

    @Value("${kakao.token}")
    private String token;

    @Value("${kakao.url}")
    private String url;

    public void sendMessage(UserNotification userNotification) {
        String templateObject = kakaoMessageBuilder.buildTextTemplateObject(userNotification);

        if (templateObject == null || templateObject.isBlank()) {
            log.warn("⚠️ 템플릿 생성 실패로 메시지 전송이 중단되었습니다.");
            return;
        }

        webClient.post()
            .uri(url)
            .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
            .body(BodyInserters.fromFormData("template_object", templateObject))
            .retrieve()
            .bodyToMono(String.class)
            .doOnNext(response -> log.info("✅ 카카오 메시지 전송 성공: {}", response))
            .subscribe(
                response -> log.info("✅ 카카오 응답 성공: {}", response),
                error -> {
                    if (error instanceof WebClientResponseException e) {
                        log.warn("❌ 카카오 API 응답 실패: {} - {}", e.getStatusCode(), e.getResponseBodyAsString());
                    } else {
                        log.error("❌ 카카오 메시지 전송 중 알 수 없는 오류 발생", error);
                    }
                }
            );
    }
}

 

이렇게 모든 설정이 끝난 후 배송을 출고하게 되면 다음과 같이 카카오톡 알림 메시지가 도착한다!

배송 출고 완료 카카오톡 알림 메시지

 

💡 새롭게 알게 된 내용은 뭐가 있더라..?!

✅ 1. 카카오 개발자 콘솔 접속

🔗 https://developers.kakao.com

1. 카카오 계정으로 로그인
2. 오른쪽 상단 메뉴에서 내 애플리케이션 → 애플리케이션 추가

✅ 2. 애플리케이션 생성

• 앱 이름: 자유롭게 (TurtleMart Test 등)
• 사업자명: 생략 가능

앱이 생성되면,
→ REST API 키를 복사해둔다! (Access Token 발급할 때 사용된다.)

✅ 3. 플랫폼 설정

📍 좌측 메뉴 → 플랫폼 > Web 플랫폼 등록

• 사이트 도메인 입력:
• <http://localhost:8080>

✅ 4. 카카오 로그인 설정

📍 좌측 메뉴 → 제품 설정 > 카카오 로그인

• "카카오 로그인 활성화": ✅ ON
• Redirect URI 등록:
• <http://localhost:8080/oauth/kakao/callback>

이 URI는 나중에 Access Token 받을 때 사용하는 주소다!

✅ 5. 동의 항목 설정

📍 좌측 메뉴 → 카카오 로그인 > 동의항목 설정

1. 카카오톡 메시지 전송(talk_message) 항목을 찾는다.
2. "필수 동의" 또는 "선택 동의"로 ON

✅ 이걸 안 켜면 메시지 전송이 거절된다!

✅ 6. 앱 키 확인

📍 좌측 메뉴 → 앱 키

• REST API 키
• JavaScript 키

→ 둘 다 복사해둬도 좋다.

✅ 7. 테스트용 Access Token 발급 (수동)

이건 Postman이나 브라우저로 수동 발급할 수 있다.

🔗 1단계: 인가 코드 요청 (브라우저에서)

<https://kauth.kakao.com/oauth/authorize>?
response_type=code&
client_id={REST_API_KEY}&
redirect_uri=http://localhost:8080/oauth/kakao/callback&
scope=talk_message

→ 사용자 동의하고 나면? code=xxxxx 붙은 URL로 리다이렉트 된다.
→ 여기서 code 값을 복사한다!

🔐 2단계: Access Token 요청 (Postman 또는 CURL)

POST <https://kauth.kakao.com/oauth/token>

Content-Type: application/x-www-form-urlencoded

grant_type=authorization_code
&client_id={REST_API_KEY}
&redirect_uri=http://localhost:8080/oauth/kakao/callback
&code={위에서 받은 인가코드}

응답:

{
  "access_token": "⭐ 여기에 있는 값을 yml에 넣으면 됨 ⭐",
  ...
}

 

 

🗓️ 내일은 뭐 하지?!

✔️ 카카오톡 알림 메시지 마무리하기
✔️ 결제-재고 감소 흐름 이어주기
✔️ 가격 변동 로직 설계하기
✔️ TIL 작성하기