마이크로서비스 통신 패턴

Java code

import java.util.*;
import java.util.concurrent.*;

public class MicroserviceCommunication {
    // 1. 동기 통신 (REST)
    interface UserClient {
        String getUser(String id); // HTTP GET 호출
    }

    // 2. 비동기 통신 (메시지 큐)
    static class MessageBroker {
        private final Map<String, List<java.util.function.Consumer<String>>> subscribers =
            new ConcurrentHashMap<>();

        void subscribe(String topic, java.util.function.Consumer<String> handler) {
            subscribers.computeIfAbsent(topic, k -> new CopyOnWriteArrayList<>())
                       .add(handler);
        }

        void publish(String topic, String message) {
            System.out.printf("[MQ] 발행 %s: %s%n", topic, message);
            List<java.util.function.Consumer<String>> handlers = subscribers.get(topic);
            if (handlers != null) {
                handlers.forEach(h -> {
                    CompletableFuture.runAsync(() -> h.accept(message));
                });
            }
        }
    }

    public static void main(String[] args) throws Exception {
        MessageBroker broker = new MessageBroker();

        // 주문 서비스 -> 이벤트 발행
        broker.subscribe("order.created", msg ->
            System.out.println("[재고서비스] 재고 차감: " + msg));
        broker.subscribe("order.created", msg ->
            System.out.println("[알림서비스] 이메일 발송: " + msg));
        broker.subscribe("order.created", msg ->
            System.out.println("[분석서비스] 데이터 수집: " + msg));

        broker.publish("order.created", "주문#1234");

        Thread.sleep(500); // 비동기 처리 대기
    }
}