옵저버 패턴

Java code

import java.util.*;
import java.util.function.Consumer;

public class ObserverPattern {
    // 이벤트 발행자
    static class EventEmitter<T> {
        private final Map<String, List<Consumer<T>>> listeners =
            new HashMap<>();

        void on(String event, Consumer<T> listener) {
            listeners.computeIfAbsent(event, k -> new ArrayList<>())
                     .add(listener);
        }

        void off(String event, Consumer<T> listener) {
            List<Consumer<T>> list = listeners.get(event);
            if (list != null) list.remove(listener);
        }

        void emit(String event, T data) {
            List<Consumer<T>> list = listeners.get(event);
            if (list != null) {
                list.forEach(l -> l.accept(data));
            }
        }
    }

    public static void main(String[] args) {
        EventEmitter<String> emitter = new EventEmitter<>();

        // 리스너 등록
        Consumer<String> logger = msg -> System.out.println("[LOG] " + msg);
        Consumer<String> alert = msg -> System.out.println("[ALERT] " + msg);

        emitter.on("error", logger);
        emitter.on("error", alert);
        emitter.on("info", logger);

        // 이벤트 발행
        emitter.emit("error", "서버 다운!");
        emitter.emit("info", "정상 동작");
    }
}