WebSocket消息并不总是传递

Question

我有一个带有WebSockets的应用程序，使用spring-boot应用程序作为后端，在客户端使用stomp/sockjs，spring-boot应用程序使用JMS队列消息并将更改通知给正确的用户。问题出在哪里？有时工作有时不工作，同样的代码和用户可以工作或不工作。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration implements WebSocketMessageBrokerConfigurer {

   @Override
   public void registerStompEndpoints(StompEndpointRegistry registry) {

      registry
         .addEndpoint("/stomp")
         .setAllowedOrigins("*")
         .withSockJS();
   }

   public void configureMessageBroker(MessageBrokerRegistry registry) {

      registry
         .setApplicationDestinationPrefixes("/app")
         .enableSimpleBroker("/xxxx/yyyy", "/ccccc");
   }

   @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())) {
                 Object raw = message
                         .getHeaders()
                         .get(SimpMessageHeaderAccessor.NATIVE_HEADERS);

                 if (raw instanceof Map) {
                     Object name = ((Map<?,?>) raw).get("email");

                     if (name instanceof LinkedList) {
                         String user = ((LinkedList<?>) name).get(0).toString();
                         accessor.setUser(new User(user));
                     }
                 }
             }
             return message;
         }
      });
   }
}

@Component
public class UserEventListener {

   private final Logger logger = LoggerFactory.getLogger(getClass());
   private final SimpMessagingTemplate template;

   @Autowired
   public UserEventListener(SimpMessagingTemplate pTemplate) {
      this.template = pTemplate;
   }

   @JmsListener(destination="user/events")
   public void onStatusChange(Map<String, Object> props) {

      if (props.containsKey("userEmail")) {
         logger.debug("Event for user received: {}", props.get("userEmail"));
         template.convertAndSendToUser((String)props.get("userEmail"), "/ccccc", props);
      }
   }
}

编辑1：

经过更多的调试，当不工作的时候，WebSocket的“会话”似乎被Spring配置丢失了。我看不到任何关于“断开连接”消息或类似消息的日志信息，此外，如果我远程调试服务器，当这种情况发生时，问题不会在调试会话期间出现。一些主意？Spring中会话消失的类是DefaultSimpUserRegistry。

Answer 1

经过更多的研究，我发现了一个问题与同样的问题和解决方案在这里。基本上结论是这样的：

通道拦截器不是对用户进行身份验证的正确位置，我们需要使用自定义握手处理程序来更改它。