Язык: Spring Boot, JS
Обзор : я реализую функциональность отправленных событий с сервера в моем приложении, которое будет развернуто в облачном литейном производстве, в котором на основе нового сообщения в очереди(на который я подписался в моем микросервисе), я отправлю некоторое обновление своему клиенту / браузеру (который использует EventSource).Для этого я поддерживаю список SseEmitters (для сохранения всех активных SseEmitter) на моей стороне сервера.Как только я получу новое сообщение из очереди на основе идентификатора (поле в сообщении очереди), я отправлю сообщение соответствующему клиенту.
ПРОБЛЕМА : Как будет работать вышеуказанный сценарий, когда я масштабирую свое приложение, создавая несколько его экземпляров .Поскольку только один экземпляр получит новое сообщение очереди, может случиться так, что активный SseEmitter не поддерживается в этом конкретном экземпляре, как мне решить эту проблему?