• SSE 는 컨슈머 측에서 토픽에 대한 데이터를 구독할 때를 기준으로 send 처리

  public void registerClient(String userInfo, SseEmitter emitter) {
  		clients.put(userInfo, emitter);
  		log.info("Registered client for user: {}", userInfo);
  		log.debug("Current clients: {}", clients.keySet());
  		emitter.onCompletion(() -> {
  			clients.remove(userInfo);
  			log.info("Client disconnected: {}", userInfo);
  		});
  		emitter.onTimeout(() -> clients.remove(userInfo));
  		emitter.onError((e) -> clients.remove(userInfo));
  	}
  

  • SseEmitter는 시간이 지나면 타임아웃되거나 오류가 발생할 수 있기에 위의 3가지 속성을 통해 각 상황에서의 로그 추적이 가능

  public void sendFeedNotification(String userInfo, Notification notification) {
  		SseEmitter emitter = clients.get(userInfo);
  		if (emitter != null) {
  			try {
  				emitter.send(SseEmitter.event()
  					.name("feed-notification")
  					.data(notification));
  				log.info("sse success send event");
  			} catch (Exception e) {
  				clients.remove(userInfo);
  				log.error("Error while sending feed notification: {}", e.getMessage());
  			}
  		}
  	}
  

  • 알림을 전송할 대상에 대하여 사용자의 서버 연결이 유지되어 있다면 알림 데이터에 대해 특정 이름의 이벤트로 클라이언트 측에 전달
  • 전송 중 문제가 발생하거나, 서버가 연결을 끊은 경우 해당 사용자를 clients(유저정보와 SSE 연결이 담긴 Map)에서 삭제 후 로그 남기기
    • ConcurrentHashMap<>() : 다중 스레드 환경에서 스레드 간 충돌 없이 안전하게 데이터를 읽고, 쓰고, 삭제할 수 있는 Map 구현체
    • 여러 클라이언트의 SSE 연결을 관리하면서, 다수의 요청이 동시에 clients Map에 접근할 가능성 높기에 동시성을 최소화 하기 위해 사용
    • 동시 읽기/쓰기가 많은 환경에 적합
    • 연결이 끊어진 사용자나 예외가 발생한 사용자를 안전하게 **clients.remove(userInfo)**로 제거

  // text/event-stream을 설정하여 서버가 클라이언트로 SSE 스트림을 전송함을 알림
  	@GetMapping(value = "/feed/{userInfo}", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
  	public SseEmitter feedNotification(@PathVariable String userInfo) {
  		log.info("Received userInfo: {}", userInfo);
  		SseEmitter emitter = new SseEmitter(0L); // 클라이언트와 서버 간의 지속적인 연결을 관리하는 객체, 기본적으로 연결은 클라이언트가 끊을 때까지 열려 있음
  		notificationKafkaListener.registerClient(userInfo, emitter); // 클라이언트 등록
  		return emitter;
  
  	}
  

  • GET api (경로변수를 통하여 url 처리)
  • new SseEmitter(0L); 를 통하여 서버와 클라이언트 무제한 연결 ← 알림을 받기 위해서는 계속 연결이 필요하기 때문
  • api 테스트에 대해 swagger/postman 는 단일 요청-응답 모델에 적합하기에 브라우저를 통해 url을 입력하여 직접 연결 테스트

• FCM 처리를 위해 의존성 주입 후 config class 설정

  @Configuration
  public class FirebaseConfig {
  
  	@Bean
  	public FirebaseMessaging firebaseMessaging() throws IOException{
  		FileInputStream notificationAccount = new FileInputStream(
  			"src/main/resources/??????????????????????????????????.json");
  
  		// GoogleCredentials.fromStream()을 사용하여 Firebase의 인증을 처리, json 파일을 읽고, 이를 통해 Firebase 인증을 구성
  		GoogleCredentials credentials = GoogleCredentials.fromStream(notificationAccount);
  
  		FirebaseOptions options = FirebaseOptions.builder()
  			.setCredentials(credentials)
  			.build();
  		FirebaseApp app = FirebaseApp.initializeApp(options);
  		return FirebaseMessaging.getInstance(app);
  	}
  }
  

  • Firebase 프로젝트의 인증을 위해 JSON 형식의 서비스 계정 키 파일 읽음
  • 일반적으로 이 파일은 src/main/resources 디렉토리에 위치
  • 서비스 계정 키 파일은 Firebase 프로젝트와의 연결을 설정하기 위한 민감한 정보입니다. 반드시 보안을 유지하고, 소스 코드 저장소(Git 등)에 업로드하지 않도록 주의
  • JSON 파일에서 Firebase 인증 정보를 로드하여 GoogleCredentials 객체를 생성
  • FirebaseOptions.builder(): Firebase를 초기화하기 위한 옵션을 설정 (평소 사용하던 Lombok 의 Builder X )
  • FirebaseApp.initializeApp(options) : Firebase SDK를 초기화하여, 애플리케이션이 Firebase 서비스를 사용할 수 있게 설정 (초기화 과정에서 인증 정보와 Firebase 프로젝트 설정이 로드 )

  public void sendPushFeedNotification(String token, Notification notification) {
  		// com.google.firebase.messaging.Notification 은 Builder 클래스에 대한 public 접근을 허용하지 않지만, Notification.builder()라는 정적 메서드를 제공
  		com.google.firebase.messaging.Notification fcmNotification =
  			com.google.firebase.messaging.Notification.builder() // builder() 메서드 사용
  				.setTitle(notification.getTitle())  // 제목 설정
  				.setBody(notification.getContent()) // 내용 설정
  				.build(); // 빌드하여 Notification 객체 생성
  
  		Message message = Message.builder()
  			.setToken(token)
  			.setNotification(fcmNotification)
  			.build();
  
  		try {
  			String response = firebaseMessaging.send(message);
  			log.info("FCM Notification sent: {}", response);
  		} catch (FirebaseMessagingException e) {
  			log.error("FCM Notification Error: {}", e.getMessage());
  		}
  	}
  

  • token 값은 특정 디바이스로 알림을 전송하기 위해 FCM에서 사용하는 고유 식별자 ← front 측에서 전달 받을 방법 필요
    • sendPushFeedNotification(receiverUuid, notification); 현재 이러한 인자값으로 처리되어 있는데, 유저 정보가 아닌 토큰으로 변경 필요 ← sse 연결과 동시에 토큰 받기 처리할 예정
  • FCM의 Notification 객체를 생성
  • builder() 메서드는 Notification 객체를 빌드하는 데 사용 ( lombok의 builder X )
  • title 값과 content값 입력
  • setNotification(fcmNotification) : 알림 데이터를 메세지에 추가
  • 이후 로직을 통해 FCM 서버가 클라이언트 디바이스로 전달
  • FirebaseMessaging 객체의 send() 메서드를 호출하여 메시지를 전송
  • 예외 발생시에 메세지를 로그에 기록하여 디버깅에 활용

                                      sse 실행 결과 테스트

                        sse & fcm 결과 테스트, fcm 경우는 토큰값 처리에 대한 변경 필요