spring websockets未接收数据

Question

我正在尝试spring websockets，由于某些原因我不明白，我可以建立与服务器的连接，但当我发送数据时什么也没有发生。

下面是我的配置类（与其他spring websocket示例完全相同）：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketsConfig extends AbstractWebSocketMessageBrokerConfigurer {

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

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

}

我的控制器，在一个包中，我确保spring inicialites它，因为我用@PostConstruct注释说明init（）消息。如您所见，我编写了system.out.println以便在控制台中查看该方法是否触发，但这种情况从未发生，因此数据从未到达控制器：

@Controller
public class MonitorSpring {

@PostConstruct
protected void init() {
    System.out.println("init()");
}

@MessageMapping("/sendmessage")
@SendTo("/topic/message")
public ChatMessage sendMessage(@Payload ChatMessage chatMessage) {
    System.out.println("sendMessage here");
    return chatMessage;
}

@MessageMapping("/adduser")
@SendTo("/topic/user")
public ChatMessage addUser(@Payload ChatMessage chatMessage, SimpMessageHeaderAccessor headerAccessor) {
    System.out.println("addUser here");
    headerAccessor.getSessionAttributes().put("username", chatMessage.getSender());
    return chatMessage;
}

}

最后是我的JavaScript客户机，我将在这里简单地把重要的部分放在这里：

function connect(event) {
    username = document.querySelector('#name').value.trim();

    if(username) {
        usernamePage.classList.add('hidden');
        chatPage.classList.remove('hidden');

        var socket = new SockJS('https://' + document.location.host + '/ws');
        stompClient = Stomp.over(socket);

        stompClient.connect({}, onConnected, onError);
    }
    event.preventDefault();
}


function onConnected() {
    stompClient.subscribe('/topic/message', onMessageReceived);
    stompClient.subscribe('/topic/user', onMessageReceived);
    stompClient.send("/app/adduser", {}, JSON.stringify({sender: username, type: 'JOIN'}))

    connectingElement.classList.add('hidden');
}

function sendMessage(event) {
    var messageContent = messageInput.value.trim();
    if (messageContent && stompClient) {
        var chatMessage = {
            sender: username,
            content: messageInput.value,
            type: 'CHAT'
        };
        stompClient.send("/app/sendmessage", {}, JSON.stringify(chatMessage));
        messageInput.value = '';
    }
    event.preventDefault();
}

我确实连接并创建了websocket，没有任何问题，但是当我向服务器发送一些东西时，我会在chrome控制台中看到这条消息，但服务器上什么也没有发生：

>>> SEND
destination:/app/sendmessage
content-length:53

{"sender":"user1","content":"message1","type":"CHAT"}

我会做错什么？

Answer 1

不确定是否有人还在面对这些问题。

对未来的任何人来说

除了Tovidiu的答案之外，您还应该允许跨原点头

Registry.AddEndPoint（“/ws”）.SetAllowedOrigins（“*”）.WithSockJs（）；

Answer 2

首先，您应该实现WebSocketMessageBrokerConfigureer而不是AbstractWebSocketMessageBrokerConfigureer，因为这是不推荐使用的。

当您连接到websocket时

 var socket = new SockJS('https://' + document.location.host + '/ws');

您应该连接到http端点

 var socket = new SockJS('http://' + document.location.host + '/ws');

如果您试图向https发送消息，但没有配置证书，它可能会拒绝您的消息。