Spring boot websocket 聊天（stomp）接收功能不起作用

Question

我目前正在使用 stomp 实现 websockets 但是，发送功能在前端可以工作，但我在服务器端无法接收。

发送 目的地：/应用程序/chatAddUser 内容长度：15

package com.lsm.backend.config creating questions in the future, there will be only one body field, but for best results remember to include both a description of your problem and what you’ve tried.;

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").setAllowedOrigins("http://localhost:3000").withSockJS();
    }
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app");
        registry.enableSimpleBroker("/queue", "/topic");

    }

}

package com.lsm.backend.controller;

import com.lsm.backend.model.ChatMessageDTO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.messaging.simp.SimpMessageSendingOperations;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ChatController {
    @Autowired
    private SimpMessageSendingOperations messagingTemplate;
    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    @MessageMapping("/app/chatSendMessage")
    public void sendMessage(@Payload ChatMessageDTO chatMessageDTO) {
        logger.info("Received message from client: " + chatMessageDTO);
        messagingTemplate.convertAndSend("/topic/public", chatMessageDTO);
    }
    @MessageMapping("/app/chatAddUser")
    public void addUser(@Payload ChatMessageDTO chatMessageDTO) {
        logger.info("joined", chatMessageDTO);
        messagingTemplate.convertAndSend("/topic/public", chatMessageDTO); 
    }
}

package com.lsm.backend.model;

import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class ChatMessageDTO {
    private MessageType type;
    private String content;
    private String sender;
    public enum MessageType{
        CHAT,
        JOIN,
        LEAVE
    }


}

这是我的后端源代码。至此，该项目的 CORS CSRF 设置完成。 我可以看到发送函数正在前端执行，但是我在服务器端没有看到任何日志，当然我也没有在前端收到任何接收。

我尝试了各种 github 存储库的修复，但仍然遇到同样的问题。

Answer 1

检查代码后，用

@MessageMapping

注释的方法应根据

configureMessageBroker

配置映射到不带应用程序目标前缀的目标。

这里的问题在于您的

@MessageMapping

注释参数。它们不应包含您通过配置中的

setApplicationDestinationPrefixes("/app")

定义为“/app”的应用程序前缀。

因此，您的控制器应该如下所示：

@RestController
public class ChatController {
    @Autowired
    private SimpMessageSendingOperations messagingTemplate;
    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    @MessageMapping("/chatSendMessage")
    public void sendMessage(@Payload ChatMessageDTO chatMessageDTO) {
        logger.info("Received message from client: " + chatMessageDTO);
        messagingTemplate.convertAndSend("/topic/public", chatMessageDTO);
    }

    @MessageMapping("/chatAddUser")
    public void addUser(@Payload ChatMessageDTO chatMessageDTO) {
        logger.info("Joined: " + chatMessageDTO);
        messagingTemplate.convertAndSend("/topic/public", chatMessageDTO);
    }
}

在此示例中，我从

@MessageMapping("/app/chatSendMessage")

和

@MessageMapping("/app/chatAddUser")

中删除了“/app”前缀，因此它们现在分别是

@MessageMapping("/chatSendMessage")

和

@MessageMapping("/chatAddUser")

。

当您通过WebSocket发送数据时，您应该将其发送到“/app/chatSendMessage”或“/app/chatAddUser”。根据您的配置，“/app”前缀将被删除，剩余的目的地（“/chatAddUser”或“/chatSendMessage”）将用于路由到相应的方法。