java - spring websocket

WebSocket con Sockjs y Spring 4 pero sin Stomp

Question

¿Hay alguna manera de usar WebSockets con el cliente SockJS y el servidor Spring 4 pero sin usar STOMP?

Basado en este tutorial del sitio web de Spring, sé cómo configurar una aplicación basada en WebSocket usando Stomp y Spring 4. En el lado del cliente, tenemos:

     var socket = new SockJS(''/hello'');
        stompClient = Stomp.over(socket);
        stompClient.connect({}, function(frame) {
            setConnected(true);
            console.log(''Connected: '' + frame);
            stompClient.subscribe(''/topic/greetings'', function(greeting){
                showGreeting(JSON.parse(greeting.body).content);
            });
        });

Y en el lado del servidor, tenemos lo siguiente en el controlador:

@MessageMapping("/hello")
@SendTo("/topic/greetings")
public Greeting greeting(HelloMessage message) throws Exception {
    Thread.sleep(3000); // simulated delay
    return new Greeting("Hello, " + message.getName() + "!");
}

Ahora, entiendo que @MessageMapping("/hello") garantiza que si se envía un mensaje a un destino "/hello" , se llamará al método greeting() . Y dado que stompClient está suscrito a "/topic/greetings" , @SendTo("/topic/greetings") enviará el mensaje nuevamente a stompClient .

Pero el problema con lo anterior es que stompClient es un objeto Stomp. Y simplemente quiero usar sock.send(''test''); y enviarlo al destino de mi servidor. Y quiero hacer @SendTo("myownclientdestinationmap") , puedo recibirlo por

sock.onmessage = function(e) {
     console.log(''message'', e.data);
 };

Entonces, ¿hay alguna manera de hacer esto con Spring 4, SockJS y sin Stomp? ¿O Spring4 WebSocket solo es compatible con Stomp?

Answer 1

Spring es compatible con STOMP través de WebSocket pero el uso de un subprotocolo no es obligatorio ; puede tratar con el websocket sin procesar. Cuando se utiliza un websocket sin formato, el mensaje envía falta de información para hacer que Spring lo encamine a un método específico de manejo de mensajes (no tenemos ningún protocolo de mensajería), así que en lugar de anotar su controlador, deberá implementar un WebSocketHandler :

public class GreetingHandler extends TextWebSocketHandler {

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) {
        Thread.sleep(3000); // simulated delay
        TextMessage msg = new TextMessage("Hello, " + message.getPayload() + "!");
        session.sendMessage(msg);
    }
}

Y luego agregue su controlador al registro en la configuración (puede agregar más de un controlador y usar SockJS para las opciones de SockJS ):

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(greetingHandler(), "/greeting").withSockJS();
    }

    @Bean
    public WebSocketHandler greetingHandler() {
        return new GreetingHandler();
    }
}

El lado del cliente será algo como esto:

var sock = new SockJS(''http://localhost:8080/greeting'');

sock.onmessage = function(e) {
    console.log(''message'', e.data);
}