Java Spring WebSocket指定用户推送通知失效问题求助

核心问题分析 #

群发通知（convertAndSend）正常，但指定用户推送（convertAndSendToUser）失效，核心原因集中在用户身份绑定、消息代理路由配置、路径匹配三个方面，以下是针对性解决方案：

1. 修复消息代理路由配置（最可能的直接原因） #

当前enableSimpleBroker仅配置了/notification，但convertAndSendToUser发送的消息目标路径为/user/{username}/notification，代理需要处理/user前缀才能完成路由。

修改WebSocketBrokerConfiguration.java中的configureMessageBroker方法：

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    // 加入/user前缀，让代理能处理用户专属消息
    registry.enableSimpleBroker("/notification", "/user");
    registry.setApplicationDestinationPrefixes("/app");
}

2. 确保WebSocket会话绑定用户身份 #

Spring需要通过WebSocket会话的Principal识别目标用户，若连接时未绑定用户身份，会导致消息无法匹配到对应客户端。

后端配置：添加通道拦截器，绑定用户身份

在WebSocketBrokerConfiguration.java中添加客户端入站通道拦截器，从请求头获取用户标识并设置为Principal：

@Override
public void configureClientInboundChannel(ChannelRegistration registration) {
    registration.interceptors(new ChannelInterceptor() {
        @Override
        public Message<?> preSend(Message<?> message, MessageChannel channel) {
            StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
            if (StompCommand.CONNECT.equals(accessor.getCommand())) {
                // 从自定义请求头获取用户邮箱（需和前端传递一致）
                String userEmail = accessor.getFirstNativeHeader("X-User-Email");
                if (userEmail != null) {
                    // 设置Principal，名称需和convertAndSendToUser的第一个参数一致
                    accessor.setUser(() -> userEmail);
                }
            }
            return message;
        }
    });
}

前端修改：连接时携带用户标识

在Angular的连接代码中，向CONNECT帧添加用户邮箱头：

const currentUserEmail = "当前登录用户的邮箱"; // 从登录态中获取
stompClient.connect({
  'X-User-Email': currentUserEmail
}, frame => {
    console.log('[Websocket] Connected: ' + frame);
    stompClient.subscribe('/user/notification', data => {
        console.log('[Websocket] ', data);
    });
});

3. 验证用户标识一致性 #

确保后端调用convertAndSendToUser时的第一个参数（employee.getEmail()），与WebSocket会话中Principal的名称完全一致（大小写、格式必须完全匹配）。

4. 开启日志排查（辅助定位） #

添加日志配置，查看消息路由细节：
在application.yml中添加：

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

通过日志可查看消息的目标路径、用户匹配结果，确认是否存在会话未找到、路径不匹配等问题。

内容的提问来源于stack exchange，提问作者Benjamin Barbé