[TIL] 프로젝트 15일차.. 프로젝트 리팩토링 및 고도화 고민하기!

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

오늘은 팀원분이 풀리퀘 올리고 merge 된 코드를 pull 받아서 내 코드를 옮기는 작업을 했다.

지금까지는 내가 개인적으로 테스트 Controller를 만들고 거기서 작업을 진행하고 있었다. 하지만 이제는 팀원의 코드와 합쳐야 하니 내 코드가 잘 동작할 수 있도록 옮기는 작업을 했다!
완벽하게 다 옮기려고 했지만 결제 파트에서 넘어오는 DTO를 예상할 수 없어서 로직을 다 작성하지 못하고 우선은 틀만 잡아두고 팀원의 양식대로 나머지 코드를 작성했다.

case INVENTORY_DECREASE -> {
    // todo 결제 파트에서 전달되는 payload 구조 확인 후 DTO 정의
    // log.info("📥 Kafka 재고 감소 메시지 수신: {}", message);

    // 재고 감소 로직 진행
    // productOptionCombinationService.decreaseProductOptionCombinationInventory(payload.orderId());
    // log.info("👉 재고 감소 성공! 모든 상품의 재고 차감이 정상적으로 처리되었습니다.");

    // todo 배송 생성 메시지 발행
    // kafkaTemplate.send(deliveryTopic, request);
    // log.info("\uD83D\uDCE4 Kafka 배송 생성 메시지 전송: {}", request);
}

@Slf4j
@Component
@RequiredArgsConstructor
public class DeliveryKafkaListener {

    private final DeliveryService deliveryService;

    @KafkaListener(topics = "${kafka.topic.delivery}", groupId = "${spring.kafka.consumer.delivery.group-id}")
    public void listenDeliveryCreate(@Header(KafkaHeaders.RECEIVED_KEY) String key, String value) {
        // 메시지 전체를 OperationWrapperDto로 파싱
        OperationWrapperDto wrapperDto = JsonHelper.fromJson(value, OperationWrapperDto.class);

        // payload 필드 추출
        String payload = wrapperDto.payload();

        // payload를 CreateDeliveryRequest로 다시 파싱
        // todo CreateDeliveryRequest 대신 WrapperRequest로 다시 작성 필요
        CreateDeliveryRequest request = JsonHelper.fromJson(payload, CreateDeliveryRequest.class);
        log.info("📥 Kafka 배송 생성 메시지 수신: {}", request);

        deliveryService.createDelivery(request);
        log.info("👉 배송 생성 성공! 배송 생성이 정상적으로 처리되었습니다.");
    }
}

그다음은 풀리퀘 피드백받은 부분을 수정했다!

KafkaProducerConfig에서 ProducerFactory<String, KafkaMessage<InventoryDecreasePayload>>로 사용하고 있었는데, ProducerFactory<String, Object>로 사용할 수 있어서 하나로 통일해 주었다.

또 중복으로 사용되는 부분을 메서드로 추출했다.

Map<String, Object> configProps = new HashMap<>();
configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);

이 부분이 계속 겹쳐서 사용하기 때문에 메서드로 추출해서 관리해 줘도 괜찮을 거 같다고 해서 따로 메서드로 추출했다.

그리고 비동기 처리 흐름을 좀 더 고민하는 시간을 가졌다.
지금은 Kafka를 사용하고 있지만 뭔가 동기 느낌이 있어서 어떻게 처리하는 것이 더 효율적 일지 고민해 보고, 그것도 머리에서 잘 잡히지 않아서 Canva에서 지금 구조를 그려가면서 정리하고 흐름을 잡아갔다.

그 결과 슬랙 알림 메시지를 통해 예외 상황을 알려주면 좋을 것 같다는 아이디어가 떠올라서 슬랙 알림에 대해 찾아보고 하루를 마무리했다.

 

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

✅  웹훅(Webhook)이란?

이벤트 기반 자동 HTTP 요청 시스템

웹훅은 말 그대로 "웹(Web)에 갈고리(Hook)를 걸어둔다"는 의미이다.
즉, 특정 이벤트가 발생했을 때, 설정해 둔 URL로 자동으로 HTTP 요청을 보내는 것이 웹훅이다.

✅  왜 사용하는 걸까?

❓ 기존 방식

• 일정 주기마다 서버가 계속 물어봐야 해.
• 예: "새 주문 생겼어?", "업데이트 됐어?"를 5초마다 계속 요청

✅ 웹훅 방식

• 이벤트가 실제로 발생했을 때만 요청을 보냄
• 서버 부하 감소, 빠른 응답, 실시간 처리에 매우 유리

✅  웹훅 동작 구조

[어떤 서비스] --- 이벤트 발생 ---> [너의 서버로 HTTP POST 요청]

예시: GitHub 웹훅

• GitHub 저장소에서 Push 발생 → 등록한 서버의 /github/webhook에 자동으로 POST 전송

예시: Slack 웹훅

• 너의 서버에서 배송 실패 발생 → Slack이 발급한 Webhook URL로 POST → 알림 전송

✅  웹훅 vs API

구분	Webhook	API
작동 방식	이벤트 기반 자동 전송	클라이언트가 요청해야 응답
데이터 흐름	서버 ➝ 클라이언트	클라이언트 ➝ 서버
예시	"배송 실패" 알림 자동 전송	프론트에서 /delivery API 호출

✅  웹훅이 사용하는 기술

• 대부분 HTTP POST 요청
• 본문은 일반적으로 JSON
• 헤더에 인증 토큰이나 시그니처를 포함해서 보안 유지

POST /webhook HTTP/1.1
Content-Type: application/json

{
  "event": "DELIVERY_FAILED",
  "orderId": 12345,
  "reason": "재고 없음"
}

 

✅  Slack Webhook 예시

Slack은 Incoming Webhook 기능을 제공해.

• 사용자가 만든 메시지를 Slack 채널로 자동 전송 가능
• Slack이 발급하는 Webhook URL로 메시지를 POST 하면 채널에 뜸

POST <https://hooks.slack.com/services/T000/B000/abcxyz>
Content-Type: application/json

{
  "text": "❌ 배송 실패: 주문 번호 12345"
}

 

✅  웹훅 구성 요소

구성 요소	설명
이벤트	트리거가 되는 행위 (예: 주문 실패, GitHub push 등)
Webhook URL	이벤트 발생 시 호출할 외부 주소 (받는 쪽 서버 주소)
Payload	함께 전송할 데이터 (JSON 등)
Header	보통 Content-Type이나 인증 토큰 포함

✅  웹훅을 사용하는 대표적인 서비스들

서비스	Webhook 사용 사례
GitHub	코드 Push, PR, Issue 생성 시 알림 전송
Slack	외부 앱이 Slack 채널에 메시지 전송
Stripe	결제 성공/실패 시 너의 서버로 알림
KakaoPay, Toss	결제 승인/취소 이벤트 전송
Notion	페이지 변경 이벤트 전송 (베타)

✅  실무에서의 사용 예시 (Spring 기준)

@RestController
@RequestMapping("/webhook")
public class SlackWebhookReceiver {

    @PostMapping
    public ResponseEntity<Void> receiveWebhook(@RequestBody WebhookPayload payload) {
        System.out.println("📩 받은 웹훅: " + payload);
        return ResponseEntity.ok().build();
    }
}

또는 알림을 보내는 역할이라면:

restTemplate.postForEntity("<https://hooks.slack.com/>...", request, String.class);

 

✅  주의할 점 (보안)

• Webhook URL은 노출되면 누구든 메시지를 보낼 수 있으므로 비공개 유지해야 함
• Slack이나 GitHub 등은 보통 서명(signature)을 함께 보내서 요청의 진위를 검증할 수 있음

✅ 한 문장 요약

웹훅은 "이벤트가 발생했을 때 자동으로 알림을 외부 시스템에 보내주는 기술"이야.

 

🗓️ 내일은 뭐 하지?!

✔️ Slack 알림 구현하기
✔️ TIL 작성하기