Лучший способ справиться с живым обновлением панели пользовательских оповещений

Question

Я хотел бы создать классическую панель предупреждений, использующую угловую и Java-пружинную загрузку, которая реагирует на события и обновления в режиме реального времени, чтобы пользователю не приходилось обновлять страницу, чтобы получать свои новейшие предупреждения. Из-за необходимости обновления в реальном времени кажется, что веб-сокеты - мой лучший выбор.

После просмотра некоторых руководств кажется, что подключение к внутреннему разъему под углом будет довольно простым, и подключение можно легко включать / выключать. Это будет использовать stompjs и sock js-client.

Однако, похоже, мои проблемы будут лежать в основе при создании различных «тем», на которые пользователи будут подписываться. Все эти учебные пособия охватывают только создание статической комнаты на сервере, к которой должен присоединиться каждый пользователь (например, приложение чата). Но для моего сценария мне нужно было бы динамически создавать темы на лету (одна отдельная тема на пользователя) вместо создания всех моих тем в начале.

Кто-нибудь имеет опыт использования весенней или весенней загрузки для динамического создания тем, на которые могут подписаться мои пользователи?

Основное учебное пособие, на которое я смотрел: https://medium.com/oril/spring-boot-websockets-angular-5-f2f4b1c14cee

Answer 1

я обнаружил, что с помощью этого в моем контроллере:

@MessageMapping("/meeting/{roomId}")
private void sendMessageTpPrivateRoom(String message, @DestinationVariable String roomId) throws IOException {
    System.out.println("message sent to: " + roomId);
    this.template.convertAndSend("/meeting/" + roomId, message);
    addToHistory(roomId, message);
}

в сочетании с этим в моей конфигурации:

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/socket")
            .setAllowedOrigins("*")
            .withSockJS();
}

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setApplicationDestinationPrefixes("/app")
            .enableSimpleBroker("/chat", "/meeting");
}

Я могу динамически создавать чаты, где клиенты водна комната не получает сообщения от клиентов в другой