本文旨在解决stomp over %ignore_a_1%连接成功但消息无法被服务器处理的问题。核心原因在于客户端和服务器端在发送和转换消息时，未能正确使用目的地（destination）前缀。教程将详细阐述spring websocket消息代理的工作机制，并提供客户端javascript和服务器端spring boot的修正方案，确保消息能够被正确路由和处理。
引言：Stomp over WebSocket消息路由挑战
在使用Stomp over WebSocket构建实时通信应用时，开发者常会遇到一个令人困惑的问题：客户端与服务器的WebSocket连接已成功建立，Stomp握手也顺利完成，但当客户端发送消息时，服务器端的 @MessageMapping 方法却始终未能接收到消息，或者通过 SimpMessagingTemplate 发送的消息无法到达订阅的客户端。这通常不是连接本身的问题，而是消息路由配置，特别是目的地（destination）前缀使用不当所致。
本教程将深入分析这一常见问题，基于Spring WebSocket和Stomp.js客户端库，详细解释消息代理的工作原理，并提供具体的代码修正方案，确保消息能够正确地在客户端和服务器之间流动。
问题分析：目的地前缀的重要性
Spring WebSocket消息代理（Message Broker）在处理Stomp消息时，会根据预设的规则对消息的目的地进行验证和路由。这些规则主要通过 MessageBrokerRegistry 进行配置，包括：
应用程序目的地前缀 (/app)：通过 registry.setApplicationDestinationPrefixes(“/app”) 配置。所有发往 @MessageMapping 方法的消息都必须以 /app 开头。当客户端发送消息到 /app/someDestination 时，Spring会将 /app 剥离，然后将 someDestination 路由到相应的 @MessageMapping 方法。简单消息代理前缀 (/topic, /queue)：通过 registry.enableSimpleBroker(“/topic”, “/queue”) 配置。这些前缀用于直接由消息代理处理的消息，例如广播到 /topic 或点对点发送到 /queue。当客户端订阅或服务器通过 SimpMessagingTemplate 发送消息到这些前缀时，消息代理会直接处理，而不会经过 @MessageMapping 方法。
问题的核心在于，无论是客户端发送到服务器，还是服务器发送到客户端，消息的目的地都必须以正确的、带有前导斜杠（/）的前缀开头。如果缺少前导斜杠，消息代理将无法识别目的地，从而导致消息被丢弃或无法正确路由。在Spring的 AbstractBrokerMessageHandler#checkDestinationPrefix 方法中，会进行严格的目的地前缀匹配检查。
客户端修正：Stomp.js消息发送目的地
在客户端JavaScript代码中，当使用 stompClient.send() 方法发送消息时，其目的地应与服务器端 @MessageMapping 注解的值匹配，并且需要包含应用程序目的地前缀。
原始问题代码示例：
function sendMessage() { let message = JSON.stringify({"from":"User1", "messageBody":"Connected", "to":''}); console.log(message); stompClient.send("app/greeting", {}, message); // 缺少前导斜杠}
在上述代码中，”app/greeting” 缺少了 / 前缀。尽管服务器配置了 /app 作为应用程序目的地前缀，但Stomp协议要求目的地以 / 开头。
修正方案：
将 stompClient.send() 的目的地参数改为 /app/greeting。
讯飞绘文
讯飞绘文：免费AI写作/AI生成文章
118 查看详情
import Stomp from 'stompjs';// ... 其他代码function sendMessage() { let message = JSON.stringify({"from":"User1", "messageBody":"Connected", "to":''}); console.log("SENDING: ", message); // 修正：目的地加上前导斜杠 stompClient.send("/app/greeting", {}, message);}// ... 其他代码
解释：通过添加 / 前缀，Stomp客户端将发送一个符合规范的Stomp SEND 帧，其目的地为 /app/greeting。服务器端的 WebsocketConfiguration 中配置了 registry.setApplicationDestinationPrefixes(“/app”)，这意味着所有发往 /app 开头的消息都将路由到应用程序的 @MessageMapping 方法。此时，@MessageMapping(“/greeting”) 将正确匹配并处理消息。
服务器端修正：Spring SimpMessagingTemplate 消息转换与发送
在服务器端，当使用 SimpMessagingTemplate 将消息发送给订阅的客户端时，同样需要确保目的地前缀的正确性。这些目的地通常是简单消息代理（Simple Broker）管理的前缀，如 /topic 或 /queue。
原始问题代码示例：
@RequiredArgsConstructor@Controller@Slf4jclass WebSocketController { private static final Map userToSessionMap = new ConcurrentHashMap(); SimpMessagingTemplate simpMessagingTemplate; // 假设已通过构造器注入 @MessageMapping("/greeting") public void addUserAndNotifyOthers(@Header("simpSessionId") String sessionId, @Payload Message initialMessage) { userToSessionMap.put(initialMessage.getFrom(), sessionId); log.warn(initialMessage.toString()); // THIS LOG IS NEVER DISPLAYED (因为客户端消息未到达) // 修正前：目的地缺少前导斜杠 simpMessagingTemplate.convertAndSend("topic/greeting", initialMessage); } // ...}
在上述代码中，simpMessagingTemplate.convertAndSend(“topic/greeting”, initialMessage); 同样缺少了 / 前缀。尽管 WebsocketConfiguration 中配置了 registry.enableSimpleBroker(“/topic”, “/queue”);，但消息代理在内部验证时，要求目的地以 /topic 或 /queue 完整匹配。
修正方案：
将 simpMessagingTemplate.convertAndSend() 的目的地参数改为 /topic/greeting。
import lombok.RequiredArgsConstructor;import lombok.extern.slf4j.Slf4j;import org.springframework.messaging.handler.annotation.Header;import org.springframework.messaging.handler.annotation.MessageMapping;import org.springframework.messaging.handler.annotation.Payload;import org.springframework.messaging.simp.SimpMessagingTemplate;import org.springframework.stereotype.Controller;import java.util.Map;import java.util.concurrent.ConcurrentHashMap;@RequiredArgsConstructor@Controller@Slf4jclass WebSocketController { private static final Map userToSessionMap = new ConcurrentHashMap(); private final SimpMessagingTemplate simpMessagingTemplate; // 确保通过构造器注入 @MessageMapping("/greeting") public void addUserAndNotifyOthers(@Header("simpSessionId") String sessionId, @Payload Message initialMessage) { userToSessionMap.put(initialMessage.getFrom(), sessionId); log.warn("Received message from client: {}", initialMessage.toString()); // 现在应该会显示此日志 // 修正：目的地加上前导斜杠 simpMessagingTemplate.convertAndSend("/topic/greeting", initialMessage); } // ...}
解释：通过添加 / 前缀，SimpMessagingTemplate 将向 /topic/greeting 发送消息。由于 WebsocketConfiguration 中配置了 registry.enableSimpleBroker(“/topic”, “/queue”)，消息代理将识别 /topic 前缀并将其路由到所有订阅了 /topic/greeting 的客户端。
核心配置回顾
为了确保Stomp over WebSocket消息的正确路由，以下Spring WebSocket配置是至关重要的：
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@EnableWebSocketMessageBrokerpublic class WebsocketConfiguration implements WebSocketMessageBrokerConfigurer { @Override public void registerStompEndpoints(StompEndpointRegistry registry) { // 注册 /chat 路径作为Stomp端点，允许SockJS回退 registry.addEndpoint("/chat").setAllowedOrigins("http://localhost:5000"); registry.addEndpoint("/chat").setAllowedOrigins("http://localhost:5000").withSockJS(); } @Override public void configureMessageBroker(MessageBrokerRegistry registry) { // 配置简单消息代理，处理 /topic 和 /queue 前缀的消息 registry.enableSimpleBroker("/topic", "/queue"); // 配置应用程序目的地前缀，所有发往 @MessageMapping 方法的消息都应以此开头 registry.setApplicationDestinationPrefixes("/app"); }}
registry.enableSimpleBroker(“/topic”, “/queue”)：定义了由消息代理直接处理的目的地前缀。客户端订阅 /topic/greeting 或服务器 convertAndSend 到 /topic/greeting 时，消息代理会直接处理。registry.setApplicationDestinationPrefixes(“/app”)：定义了路由到应用程序 @MessageMapping 方法的目的地前缀。客户端发送消息到 /app/greeting 时，Spring会找到 @MessageMapping(“/greeting”) 方法。
总结与注意事项
前导斜杠至关重要：无论是客户端发送消息，还是服务器通过 SimpMessagingTemplate 发送消息，所有Stomp消息的目的地都必须以 / 开头。区分应用程序目的地和代理目的地：发往 @MessageMapping 方法的消息使用应用程序目的地前缀（通常是 /app）。由消息代理直接处理（如广播、点对点）的消息使用代理目的地前缀（如 /topic、/queue）。日志调试：当遇到消息无法到达的问题时，仔细检查客户端浏览器的网络请求（WebSocket帧）和服务器端的日志输出。Spring WebSocket会打印出消息代理处理过程中的相关信息，有助于定位问题。SockJS兼容性：在 registerStompEndpoints 中同时注册普通WebSocket端点和 withSockJS() 端点是一个好的实践，可以增强客户端的兼容性。依赖检查：确保客户端 package.json 中包含 stompjs 或 stomp-websocket，以及 sockjs-client（如果使用SockJS）。
通过理解并正确配置Stomp消息的目的地前缀，开发者可以有效地解决Stomp over WebSocket消息路由问题，构建稳定可靠的实时通信应用。
以上就是Stomp over WebSocket消息未达服务器：目的地前缀配置详解的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/894331.html
微信扫一扫 
支付宝扫一扫 
