带Sockjs&Spring4但不带Stomp的WebSocket

Question

根据Spring网站上的这个教程，我知道了如何使用Stomp和Spring4建立一个基于WebSocket的应用程序。在客户端，我们有：

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

在服务器端，控制器中有以下内容：

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

现在，我明白了@messagemapping（“/hello”）确保如果消息发送到目标“/hello”，那么将调用greeting()方法。由于stompclient订阅了“/topic/greatures”，@sendto（“/topic/greatures”）将消息发送回stompclient。

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

那么，有什么方法可以用Spring4、SockJS和没有跺脚的情况下做到这一点呢？还是Spring4WebSocket只支持stomp？

Answer 1

Spring支持stomp对WebSocket的支持，但是不强制使用子协议，您可以处理原始WebSocket。当使用原始websocket时，发送的消息缺乏使Spring将其路由到特定消息处理程序方法的信息（我们没有任何消息传递协议），因此您必须实现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);
    }
}

然后将处理程序添加到配置中的注册表中（您可以添加多个处理程序，并使用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();
    }
}

客户端将如下所示：

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

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