Spring和SockJs的控制器组件问题

Question

我在使用Spring和SockJs配置WebSocket时遇到问题。

我已经像Spring Documentation一样配置了我的所有应用程序，连接似乎很好，但当我发送消息时，Controller从未参与其中，它也不起作用。

这是配置组件：

@Configuration
@EnableWebMvc
@EnableWebSocketMessageBroker
public class MyWebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer implements WebSocketConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/mySocket").withSockJS().setInterceptors(new MySocketHandshakeInterceptor());;
    }
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app").enableSimpleBroker("/topic");
    }
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
    }
}

这是HandshakeInterceptor的实现：

public class MySocketHandshakeInterceptor implements HandshakeInterceptor {
    @Override
    public void afterHandshake(ServerHttpRequest paramServerHttpRequest, ServerHttpResponse paramServerHttpResponse, WebSocketHandler paramWebSocketHandler, Exception paramException) {
        // TODO Auto-generated method stub
        System.out.println("MySocketHandshakeInterceptor afterHandshake");
    }
    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> paramMap)
            throws Exception {
        System.out.println("MySocketHandshakeInterceptor beforeHandshake");
        return true;
    }
}

这是控制器组件：

@Controller
public class MySocketController {
    @MessageMapping("/testsocket")
    @SendTo("/topic/testresponse")
    public MessageOut test(MessageIn message) throws Exception {
        System.out.println("MySocketController start");
        System.out.println("MySocketController test "+ message);
        return new MessageOut("test OK");
    }
}

它们是MessageIn和MessageOut:

public class MessageIn {
    private String test;
    /**
     * @return the test
     */
    public String getTest() {
        return test;
    }
}

public class MessageOut {
    private String result;
    public MessageOut(String result) {
        super();
        this.result = result;
    }
    /**
     * @return the test
     */
    public String getResult() {
        return result;
    }
    /**
     * @param result the result to set
     */
    public void setResult(String result) {
        this.result = result;
    }
}

最后，这是客户端（javascript）：

var socketSession = {};
connectToMySocket();
function connectToVideoSocket() {
    socketSession.socket = new SockJS("/mySocket");
    socketSession.socket.stomp = Stomp.over(socketSession.socket);
    socketSession.socket.stomp.debug = null;
    socketSession.socket.stomp.connect({}, function () {
        socketSession.socket.stomp.subscribe("/topic/testresponse", function (data) {
            console.log(data);
        });
    });
}

这是我启动的测试套接字的命令：

socketSession.socket.stomp.send("app/testsocket", {}, JSON.stringify({'test': 'test'}));

在系统输出控制台中，我只能看到两行：

MySocketHandshakeInterceptor beforeHandshake
MySocketHandshakeInterceptor afterHandshake

拦截器运行良好，但我没有看到控制器组件的任何打印。

怎么了？谢谢

Answer 1

我自己解决了。

这是客户端的问题。

正确的脚本是：

var mySocket = undefined;
var stompClient = undefined;
connectToVideoSocket();
function connectToVideoSocket() {
    mySocket = new SockJS('/mySocket');
    stompClient = Stomp.over(mySocket);
    stompClient.debug = null;
    stompClient.connect({}, function(frame) {
        stompClient.subscribe('/topic/testresponse', function(data){
            console.log(JSON.parse(data.body).result);
        });
    });
}

这样做效果很好。