Spring STOMP WebSocket订阅完成后发送入群消息的实现咨询

针对你遇到的问题——SessionSubscribeEvent触发时机过早、@SubscribeMapping返回值仅能发给自身，提供两种可行方案：

方案一：监听SubscribedEvent事件 #

SubscribedEvent是Spring WebSocket在客户端订阅成功建立后触发的事件，比SessionSubscribeEvent的触发时机更晚，此时客户端已完成订阅流程，能够接收目标目的地的消息。

替换原有监听逻辑为：

@EventListener
public void handleWebSocketSubscribedListener(SubscribedEvent event) {
    StompHeaderAccessor headerAccessor = StompHeaderAccessor.wrap(event.getMessage());
    
    // 直接通过事件获取订阅ID，无需从header解析
    final Long chattingRoomId = Long.valueOf(event.getSubscriptionId());
    final String loginId = headerAccessor.getUser().getName();

    chattingRoomConnectService.connectChattingRoom(chattingRoomId, loginId, headerAccessor.getSessionId());
    // 此时发送消息，客户端已完成订阅，全群可接收
    chattingService.sendEnterMessage(chattingRoomId, loginId);
    chattingService.updateCountAllZero(chattingRoomId, loginId);

    headerAccessor.getSessionAttributes().put(SUB, chattingRoomId);
}

方案二：在@SubscribeMapping中手动广播消息 #

如果需要针对特定订阅路径做定制化处理，可以直接在@SubscribeMapping方法内完成订阅逻辑后，手动向聊天室的广播目的地发送消息（而非依赖方法返回值）。

示例代码：

@SubscribeMapping("/chat/room/{roomId}")
public void handleChatRoomSubscribe(@DestinationVariable Long roomId, Principal principal, SimpMessageHeaderAccessor headerAccessor) {
    String loginId = principal.getName();
    String sessionId = headerAccessor.getSessionId();

    // 执行连接与状态更新逻辑
    chattingRoomConnectService.connectChattingRoom(roomId, loginId, sessionId);
    chattingService.updateCountAllZero(roomId, loginId);

    // 手动向聊天室广播目的地发送入群消息（确保sendEnterMessage指向/topic/开头的广播路径）
    chattingService.sendEnterMessage(roomId, loginId);

    headerAccessor.getSessionAttributes().put(SUB, roomId);
}

关键注意事项 #

• 确保sendEnterMessage方法是向广播类型目的地（如/topic/chat/room/{roomId}）发送消息，而非点对点路径。
• 若使用SubscribedEvent，需确认event.getSubscriptionId()的取值逻辑与业务中聊天室ID的映射关系一致。

内容的提问来源于stack exchange，提问作者dionisos198