Spring WebSocket-通知订阅者不起作用

Question

我正在尝试让Spring WebSocket（Spring 4）在我一直在做的项目中工作。到目前为止，我已经打开了WebSocket，添加了订阅者并发送了消息。

从昨天开始，我一直在试图弄清楚为什么我的endpoint不处理HTML中包含的stomp客户端发送的消息。控制台中实际上也没有错误（好吧，我不完全确定这里的“连接到服务器未定义”是什么意思）。

以下是Chrome控制台的输出：

Opening Web Socket...
Web Socket Opened...

>>> CONNECT
accept-version:1.1,1.0
heart-beat:10000,10000

<<< CONNECTED
version:1.1
heart-beat:0,0
user-name:[e-mail]

connected to server undefined

Connected: CONNECTED
user-name:[e-mail]
heart-beat:0,0
version:1.1


>>> SUBSCRIBE
id:sub-0
destination:/my-project/notify-open-documents/1

Sending message : {"documentId":"1"}

>>> SEND
destination:/my-project/ws/lock-document
content-length:19

{"documentId":"1"}

这是我的代码：

配置：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/notify-open-documents");
        registry.setApplicationDestinationPrefixes("/ws");   
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
        stompEndpointRegistry.addEndpoint("/lock-document");
        stompEndpointRegistry.addEndpoint("/lock-document").withSockJS();
    }
}

控制员：

@Controller
public class DocumentWebsocketController {

    @MessageMapping("/lock-document")
    @SendTo("/notify-open-documents/{id}")
    public Response response(@DestinationVariable("id") Long id, Message message) {
        return new Response(message.getDocumentId());
    }
}

以及我的HTML中与跺脚相关的部分：

<script type="text/javascript">

    $(document).ready(function() { 
        connect(); 
    });

    var stompClient = null;

    function connect() {
        var socket = new SockJS('<spring:url value="/lock-document"/>');
        stompClient = Stomp.over(socket);
        stompClient.connect({}, function (frame) {
            console.log('Connected: ' + frame);
            stompClient.subscribe('<spring:url value="/notify-open-documents/${id}"/>', function (messageOutput) {
                console.log('Receiving message: ' + JSON.parse(messageOutput.body));
            });
            sendName();
        });
    }

    function disconnect() {
        if (stompClient !== null) {
            stompClient.disconnect();
        }
        console.log("Disconnected");
    }

    function sendName() {
        console.log("Sending message : " + JSON.stringify({'documentId' : "${id}" }));
        stompClient.send('<spring:url value="/ws/lock-document"/>', {}, JSON.stringify({'documentId': "${id}"}));
    }

</script>

我真的不知道可能出了什么问题，我的浏览器支持WebSocket，从我在日志中看到的，WebSocket正在正确打开，消息正在发送，但我不明白的是为什么我的控制器无法处理传入的消息。

Answer 1

从您的HTML代码片段中，我看到您正在使用spring:url标记生成STOMP目的地。spring:url标记添加了上下文路径，这对于STOMP目的地来说没有意义。

您正在配置的应用程序目标前缀是/ws，代理目标前缀是/enected-open-文档，这些都不匹配您的上下文路径，即/my-project（从控制台输出）。从您的订阅目的地和发送消息时（不是从SockJS URL）删除上下文路径：

stompClient.send('/ws/lock-document', {}, JSON.stringify({'documentId': "${id}"}));