실시간 알림 채널 통합

WebSocket STOMP 메시지 브로드캐스트 서비스. Redis 채널 구독 후 연결된 모든 세션에 이벤트를 전파합니다.

+ @Service
+ public class WebSocketNotificationService implements ApplicationListener<CommentCreatedEvent> {
+     private final SimpMessagingTemplate messaging;
+     private final RedisPublisher publisher;
  
+     @Override
+     public void onApplicationEvent(CommentCreatedEvent event) {
+         publisher.publish("notification:" + event.getThreadId(), event);
+     }
+ }

STOMP over WebSocket 엔드포인트 설정. /ws 핸드셰이크 엔드포인트와 /topic 메시지 브로커를 등록합니다.

+ @Configuration
+ @EnableWebSocketMessageBroker
+ public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+     @Override
+     public void registerStompEndpoints(StompEndpointRegistry registry) {
+         registry.addEndpoint("/ws").setAllowedOriginPatterns("*").withSockJS();
+     }
+ }

React 훅 — STOMP 클라이언트 수명 주기 관리, 자동 재연결(지수 백오프), Zustand 스토어에 신규 댓글 merge.

+ export function useCommentNotification(threadId: string) {
+   const addComment = useCommentStore(s => s.addComment);
+   useEffect(() => {
+     const client = new Client({ brokerURL: WS_URL });
+     client.onConnect = () => {
+       client.subscribe(`/topic/thread/${threadId}`, msg => {
+         addComment(JSON.parse(msg.body));
+       });
+     };
+     client.activate();
+     return () => client.deactivate();
+   }, [threadId]);
+ }

이메일 다이제스트와 WebSocket 알림 중복 발송 방지 로직 추가. 사용자 "조용한 시간대" 설정을 존중하도록 리팩터링.

- if (user.emailEnabled) {
+ if (user.emailEnabled && !user.isQuietHours()) {
      queue.enqueue(new EmailDigestJob(user, comment));
  }