Сервер отправил конечную точку событий

Question

Я ищу способ создания SSE для моего приложения.Что я хочу сделать, это создать sse, который проверяет, когда пользователь создается, также вы должны зарегистрироваться, чтобы сделать это.Таким образом, только люди, которые зарегистрированы, могут получать постоянные обновления о новых пользователях через канал sse.

Может ли кто-нибудь указать мне правильное направление решения этой проблемы.

Answer 1

Вы можете использовать Spring's SseEmitter

@Autowired
UserService userService;

@GetMapping("/users/validate")
public ResponseBodyEmitter userValidateEvent(){
     final SseEmitter emitter = new SseEmitter();

     if(userService.validate(dummyUser)) {
         emitter.send("Some string" , MediaType.TEXT_PLAIN);
     }
     else {
         // log and return as per your requirement 
         return null;
     }
     emitter.complete();
     return emitter;
}