You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Spring WebSocket Controller无返回,STOMP收发异常求助

Spring WebSocket STOMP消息收发异常排查

已成功通过ws://localhost:port/ws建立WebSocket连接,但使用STOMP命令收发消息时存在异常:消息可发送,但无法收到响应(如ACK、返回消息等)。

相关代码

WebSocket配置类

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic"); 
        config.setApplicationDestinationPrefixes("/app"); 
    }
    
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws");
        registry.addEndpoint("/ws").withSockJS(); 
    }
}

Controller代码

@Controller
public class SignalingController {
    @MessageMapping("/offer/sendOffer")
    @SendTo("/topic/offer")
    public String sendOffer(String offer){
        // Process the offer and send a response
        return "Received offer: " + offer;
    }

    @MessageMapping("/receive/receiveOffer")
    @SendTo("/topic/answer")
    public String sendAnswer(String answer) {
        // Process the answer and send a response
        return "Received answer: " + answer;
    }
}

测试场景

使用Postman发送STOMP请求,内容如下:

SEND
destination:/app/offer/sendOffer
content-type:text/plain

Test message!
^@

请求已发出,但未收到任何响应。


排查及解决步骤

  1. 完成STOMP握手流程
    发送SEND命令前必须先执行CONNECT握手,服务器才会处理后续消息:

    CONNECT
    accept-version:1.2
    
    ^@
    

    收到服务器返回的CONNECTED帧后,再发送业务消息。

  2. 订阅目标主题
    @SendTo("/topic/offer")会将返回消息推送到该主题,需提前订阅才能接收:

    SUBSCRIBE
    id:sub-1
    destination:/topic/offer
    
    ^@
    

    id为自定义唯一标识即可。

  3. 校验消息格式完整性
    确保STOMP帧以^@(ASCII 0字符)结尾,避免服务器无法解析完整消息。

  4. 优化参数接收方式
    直接用String接收纯文本消息时,若仍无响应,可改用包装类接收:

    public class MessageDTO {
        private String content;
        // getter、setter方法
    }
    

    修改Controller方法:

    @MessageMapping("/offer/sendOffer")
    @SendTo("/topic/offer")
    public String sendOffer(@Payload MessageDTO dto){
        return "Received offer: " + dto.getContent();
    }
    

    发送请求时将content-type改为application/json,消息体改为{"content":"Test message!"}。

  5. 开启日志排查细节
    在application.properties中添加日志配置,查看STOMP消息的处理链路:

    logging.level.org.springframework.messaging=DEBUG
    logging.level.org.springframework.web.socket=DEBUG
    

    通过日志可确认服务器是否接收、处理消息,以及是否推送返回帧。

内容的提问来源于stack exchange,提问作者averageCodder23

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.06 06:05:56