기존 인프라(모놀리식)와 MSA의 차이점

// 문제 예시: 결제 로직의 버그가 전체 서비스를 다운시킨다 @Service public class PaymentService { public void processPayment(Order order) { // OOM 또는 무한 루프 발생 시 // 사용자 인증, 재고 조회, 알림 등 모든 기능이 함께 중단된다 heavyProcessing(order); } }

// 잘못된 방법: 다른 서비스의 DB를 직접 조회 (강결합, 안티패턴) @Repository public class OrderRepository { // Payment DB를 직접 참조 → 절대 하면 안 된다 @Query("SELECT o.*, p.status FROM orders o JOIN payment_db.payments p ON ...") List<Order> findOrdersWithPayment(); } // 올바른 방법 1: API 호출 (동기) @Service public class OrderService { private final PaymentClient paymentClient; // Feign Client public OrderDetailResponse getOrderDetail(Long orderId) { Order order = orderRepository.findById(orderId).orElseThrow(); // 결제 정보는 Payment Service API를 통해 조회 PaymentInfo payment = paymentClient.getPayment(order.getPaymentId()); return new OrderDetailResponse(order, payment); } } // 올바른 방법 2: 이벤트 기반 데이터 동기화 (비동기) // Payment Service에서 결제 완료 이벤트 발행 @Service public class PaymentService { public void completePayment(Long paymentId) { payment.complete(); paymentRepository.save(payment); // 이벤트 발행 → Order Service가 구독해서 자체 DB 업데이트 eventPublisher.publish(new PaymentCompletedEvent(paymentId, orderId)); } } // Order Service에서 이벤트 수신 후 자체 DB에 저장 (데이터 복제) @KafkaListener(topics = "payment-completed") public void handlePaymentCompleted(PaymentCompletedEvent event) { // Order DB에 결제 상태를 비정규화하여 저장 // → 이후 조회 시 Payment Service 호출 없이 자체 DB만으로 응답 가능 orderRepository.updatePaymentStatus(event.getOrderId(), PaymentStatus.COMPLETED); }

// API 버전 관리 예시 - 하위 호환성 보장 @RestController public class OrderController { // v1: 기존 클라이언트가 계속 사용 가능 @GetMapping("/api/v1/orders/{id}") public OrderV1Response getOrderV1(@PathVariable Long id) { return orderService.getOrderV1(id); } // v2: 새 필드 추가 (기존 v1 클라이언트에 영향 없음) @GetMapping("/api/v2/orders/{id}") public OrderV2Response getOrderV2(@PathVariable Long id) { return orderService.getOrderV2(id); // 추가 필드 포함 } }

# Kubernetes를 이용한 Canary 배포 예시 # 전체 트래픽의 10%만 새 버전으로 라우팅 apiVersion: apps/v1 kind: Deployment metadata: name: order-service-canary spec: replicas: 1 # stable: 9, canary: 1 → 10% 트래픽 selector: matchLabels: app: order-service track: canary template: spec: containers: - name: order-service image: codesche/order-service:v2.0.0 # 새 버전

# 단순한 배포 구조 - app.jar 하나 배포 - Nginx (리버스 프록시) - 단일 DB 서버 - 스케일아웃: 동일한 app.jar를 여러 서버에 복제 ┌─────────────────────────────┐ │ Client │ └──────────────┬──────────────┘ │ ┌──────────────▼──────────────┐ │ Nginx (L4/L7) │ └──────┬──────────────┬───────┘ │ │ ┌──────▼──────┐ ┌─────▼───────┐ │ App #1 │ │ App #2 │ ← 동일한 JAR 복제 │ (app.jar) │ │ (app.jar) │ └──────┬──────┘ └─────┬───────┘ └──────┬────────┘ ┌──────▼───────┐ │ 단일 DB │ └──────────────┘

# Spring Cloud Gateway 예시 spring: cloud: gateway: routes: - id: order-service uri: lb://order-service predicates: - Path=/api/orders/** filters: - AuthFilter - name: RequestRateLimiter args: redis-rate-limiter.replenishRate: 100 redis-rate-limiter.burstCapacity: 200 - id: payment-service uri: lb://payment-service predicates: - Path=/api/payments/**

// Eureka 클라이언트 등록 예시 @SpringBootApplication @EnableEurekaClient public class OrderServiceApplication { public static void main(String[] args) { SpringApplication.run(OrderServiceApplication.class, args); } } // application.yml eureka: client: service-url: defaultZone: http://eureka-server:8761/eureka/ instance: prefer-ip-address: true

// Resilience4j 서킷 브레이커 적용 @Service public class OrderService { @CircuitBreaker(name = "paymentService", fallbackMethod = "paymentFallback") @TimeLimiter(name = "paymentService") public CompletableFuture<PaymentResult> processPayment(Long orderId) { return CompletableFuture.supplyAsync(() -> paymentClient.process(orderId) ); } // 결제 서비스 장애 시 임시 응답 반환 public CompletableFuture<PaymentResult> paymentFallback(Long orderId, Exception e) { log.warn("Payment service unavailable. orderId={}", orderId, e); return CompletableFuture.completedFuture( PaymentResult.pending(orderId, "결제 서비스 일시 중단 - 잠시 후 다시 시도해주세요") ); } }

# Resilience4j 설정 resilience4j: circuitbreaker: instances: paymentService: failure-rate-threshold: 50 # 실패율 50% 이상이면 회로 차단 wait-duration-in-open-state: 30s # 30초 후 Half-Open 상태 전환 sliding-window-size: 10 # 최근 10번 요청 기준

# Spring Boot + Micrometer Tracing 설정 management: tracing: sampling: probability: 1.0 # 전체 요청 추적 (운영환경은 0.1 권장) spring: zipkin: base-url: http://zipkin:9411

# Order Service Kubernetes Deployment apiVersion: apps/v1 kind: Deployment metadata: name: order-service namespace: production spec: replicas: 3 selector: matchLabels: app: order-service strategy: type: RollingUpdate rollingUpdate: maxSurge: 1 maxUnavailable: 0 # 무중단 배포 template: metadata: labels: app: order-service spec: containers: - name: order-service image: codesche/order-service:v1.2.0 ports: - containerPort: 8080 resources: requests: cpu: "250m" memory: "512Mi" limits: cpu: "500m" memory: "1Gi" livenessProbe: httpGet: path: /actuator/health/liveness port: 8080 initialDelaySeconds: 30 readinessProbe: httpGet: path: /actuator/health/readiness port: 8080 --- apiVersion: autoscaling/v2 kind: HorizontalPodAutoscaler metadata: name: order-service-hpa spec: scaleTargetRef: apiVersion: apps/v1 kind: Deployment name: order-service minReplicas: 3 maxReplicas: 20 metrics: - type: Resource resource: name: cpu target: type: Utilization averageUtilization: 70

// Choreography-based Saga 예시 (Kafka 이벤트 기반) // 1. 주문 서비스: 주문 생성 후 이벤트 발행 @Service public class OrderService { public Order createOrder(OrderRequest request) { Order order = orderRepository.save(new Order(request, OrderStatus.PENDING)); eventPublisher.publish(new OrderCreatedEvent(order.getId(), order.getItems())); return order; } } // 2. 재고 서비스: 이벤트 수신 후 재고 차감 @KafkaListener(topics = "order-created") public void handleOrderCreated(OrderCreatedEvent event) { try { inventoryService.reserve(event.getItems()); eventPublisher.publish(new InventoryReservedEvent(event.getOrderId())); } catch (InsufficientStockException e) { // 보상 트랜잭션: 주문 취소 이벤트 발행 eventPublisher.publish(new OrderCancelledEvent(event.getOrderId(), "재고 부족")); } } // 3. 결제 서비스: 재고 확보 확인 후 결제 진행 @KafkaListener(topics = "inventory-reserved") public void handleInventoryReserved(InventoryReservedEvent event) { // 결제 처리 로직 }