domain/notify/
├── controller/
│   └── NotifyController.java               # SSE 구독 API
├── service/
│   ├── NotifyService.java                 # SSE 연결 및 알림 전송
│   ├── NotificationPublisher.java         # Redis 메시지 발행
│   └── NotificationSubscriber.java        # Redis 메시지 구독
├── entity/
│   └── Notify.java                        # 알림 엔티티
├── dto/
│   ├── NotifyDto.java                     # 응답 DTO
│   └── NotificationEvent.java             # 이벤트 DTO
├── repository/
│   ├── NotifyRepository.java              # 알림 JPA 레포지토리
│   └── EmitterRepository.java             # SSE Emitter 메모리 저장소
├── enums/
│   ├── NotificationType.java              # 알림 유형
│   └── ReceiverType.java                  # 수신자 유형
└── config/
    └── NotificationConfig.java            # Redis 구독 설정

@Entity
public class Notify {
    private Long id;                    // 알림 ID
    private String content;             // 알림 내용
    private String url;                 // 관련 URL
    private Boolean isRead;             // 읽음 여부
    private User receiver;              // 사용자 수신자
    private Trainer trainer;            // 트레이너 수신자
    private NotificationType type;      // 알림 타입
    private ReceiverType receiverType;  // 수신자 타입
    private LocalDateTime createdAt;    // 생성일시
}

// 생성자 오버로딩으로 수신자 타입 자동 설정
public Notify(User receiver, ...) {
    this.receiver = receiver;
    this.receiverType = ReceiverType.USER;
}

public Notify(Trainer trainer, ...) {
    this.trainer = trainer;
    this.receiverType = ReceiverType.TRAINER;
}

// 헬퍼 메소드로 통합 접근
public Long getReceiverId() {
    return receiverType == ReceiverType.USER ? 
        receiver.getId() : trainer.getId();
}

// 연결 저장
Map<String, SseEmitter> emitters = new ConcurrentHashMap<>();
String key = userId + ":" + timestamp;
emitters.put(key, sseEmitter);

// 사용자별 모든 연결 조회
public Map<String, SseEmitter> findAllEmittersById(Long userId) {
    String keyPrefix = userId + ":";
    return emitters.stream()
        .filter(key -> key.startsWith(keyPrefix))
        .collect(toMap());
}

// 발행
String channel = "notification:USER:" + userId;
redisTemplate.convertAndSend(channel, notificationEvent);

// 구독 (ApplicationReadyEvent 시 자동 설정)
redisMessageListenerContainer.addMessageListener(
    notificationSubscriber, 
    new PatternTopic("notification:*")
);

// Redis에 임시 저장
public void saveNotifyToRedis(Long userId, Notify notify) {
    String key = "notify:" + userId;
    List<Notify> notifications = getValuesForNotification(key);
    notifications.add(notify);
    redisTemplate.opsForValue().set(key, notifications);
}

const eventSource = new EventSource('/notify/subscribe', {
    headers: {
        'Authorization': 'Bearer ' + token,
        'Last-Event-ID': lastEventId  // 연결 복구용
    }
});

eventSource.onmessage = function(event) {
    const notification = JSON.parse(event.data);
    displayNotification(notification);
};

eventSource.onerror = function(event) {
    // 재연결 로직
    setTimeout(() => {
        eventSource = new EventSource('/notify/subscribe');
    }, 3000);
};

알림 발생 ─→ Publisher 또는 직접 전송
    │
    ▼
Redis Pub/Sub ─→ Subscriber 수신
    │                │
    ▼                ▼
데이터베이스 저장 ─→ SSE 실시간 전송
    │                │
    ▼                ▼
영구 보존      ─→ 클라이언트 수신
    │                │
    ▼                ▼
읽음 상태 관리 ─→ UI 업데이트

@Configuration
@ConditionalOnProperty(name = "spring.cache.type", havingValue = "redis")
public class NotificationConfig implements ApplicationListener<ApplicationReadyEvent> {
    
    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
        // 애플리케이션 완전 준비 후 구독 설정
        redisMessageListenerContainer.addMessageListener(
            notificationSubscriber,
            new PatternTopic("notification:*")
        );
    }
}

Authorization: Bearer {token}
Last-Event-ID: {lastEventId}  // 선택사항, 연결 복구용

// SSE 스트림
data: {
    "id": "123",
    "name": "사용자명",
    "content": "알림 내용",
    "type": "REVIEW",
    "createdAt": "2024-06-01T10:30:00"
}