Блог

Я использую java springboot с maven, чтобы получить пакет стартовых сокетов spring boot. Мои клиенты используют angular с stompjs и sockjs-client. Я пытаюсь настроить простое приложение для веб-сокетов, которое позволяет использовать несколько комнат на основе roomId. Когда клиент присоединяется к комнате, он должен получать последние пять сообщений, отправленных в этой комнате.

Мое приложение Springboot имеет три класса, базовое приложение.java, который я использую для запуска приложения, класс конфигурации веб-сокета и контроллер веб-сокета:

 @Controller
public class WebSocketController {
    private final SimpMessagingTemplate template;

    @Autowired
    WebSocketController(SimpMessagingTemplate template){
        this.template = template;
    }

    @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);
    }

    @SubscribeMapping("/meeting/{roomId}")
    public String chatInit(@DestinationVariable String roomId) {
        System.out.println("Someone joined room: "   roomId);
        return getLastFiveMessages(roomId);
    }
}
 

 @Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration
        extends AbstractWebSocketMessageBrokerConfigurer {

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

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

мои клиенты подписываются на сокет следующим образом:

 stompClient.subscribe(`app/meeting/${roomId}`, (message) => {
    if (message.body) {
        console.log(message.body);
        messages  = '<br>'   message.body;
    }
});
 

и отправка сообщений, подобных этому:

 this.stompClient.send(`/app/meeting/${this.roomId}` , {}, message);
 

Отправка и обработка сообщений работают отлично, когда я настраиваю три клиента, два в первой комнате и один во второй комнате, сообщения из второй комнаты не отображаются в первой комнате, а сообщения из первой комнаты видны обоим клиентам.

Однако событие on subscribe не запускается независимо от того, к какой комнате я присоединяюсь. Очень важно, чтобы, когда клиент присоединяется к первой комнате, он получал какую-то историю этой комнаты. Любой совет относительно того, почему мой метод сопоставления подписок не запускается, когда клиент подписывается на номер?

/meeting Часть будет неявно добавлена к URL, который вы предоставляете при подписке. Итак, ваше отображение будет выглядеть так:

     @SubscribeMapping("/${roomId}")
    public String chatInit(@DestinationVariable String roomId) {
        System.out.println("Someone joined room: "   roomId);
        return getLastFiveMessages(roomId);
    }
 

Источник: https://docs.spring.io/spring/docs/5.0.0.BUILD-SNAPSHOT/spring-framework-reference/html/websocket.html