使用Spring和sockJS在websocket上跺脚消息丢失

Question

在客户端javascript上，我有

    stomp.subscribe("/topic/path", function (message) {
        console.info("message received");
    });

在服务器端

public class Controller {
  private final MessageSendingOperations<String> messagingTemplate;
  ＠Autowired
  public Controller(MessageSendingOperations<String> messagingTemplate) {
      this.messagingTemplate = messagingTemplate;
  }
  @SubscribeMapping("/topic/path")
  public void subscribe() {
     LOGGER.info("before send");
     messagingTemplate.convertAndSend(/topic/path, "msg");
  }
}

从这个设置中，我偶尔（大约每30次页面刷新一次）会遇到消息丢失，这意味着我既看不到客户端的“message received”消息，也看不到Chrome调试工具的websocket流量。

“发送前”始终记录在服务器端。

这看起来像是当我在订阅（）方法中调用MessageSending操作时，它还没有准备好。（如果我把Thread.sleep（50）；在调用MessagingTemplate.convert和发送之前，问题会消失（或者不太可能重现））

我想知道以前是否有人经历过同样的情况，是否有事件可以告诉我MessageSendingOperations是否准备就绪。

Answer 1

有点晚了，但我想我应该加上我的解决方案。在通过消息传递模板发送数据之前，我遇到了订阅未注册的相同问题。这个问题很少发生，而且是不可预测的，因为与DefaultSub换算注册表的竞争。

不幸的是，我不能仅仅使用@SubscriptionMapping的返回方法，因为我们使用的是一个自定义对象映射器，它根据用户类型（本质上是属性过滤）进行动态更改。

我搜索了Spring代码，发现SubscriptionMethodReturnValueHandler负责发送订阅映射的返回值，并且与异步控制器的autowiredSimpMessageTemplate不同的messagingTemplate！！

因此，解决方案是将MessageChannel clientOutboundChannel自动连接到我的异步控制器中，并使用它创建SimpMessagingTemplate。（您不能直接连接它，因为您只需将模板发送给代理即可）。

在订阅方法中，我使用直接模板，而在其他方法中，我使用到代理的模板。

Answer 2

这是我的解决方案。它是沿着同样的路线。添加了一个ExecutorChannelInterceptor，并发布了一个自定义的SubcriptionSub换购事件。关键是在AbstractBrokerMessageHandler处理消息后发布事件，这意味着订阅已在代理处注册。

@Override
public void configureClientInboundChannel(ChannelRegistration registration) {
    registration.interceptors(new ExecutorChannelInterceptorAdapter() {

        @Override
        public void afterMessageHandled(Message<?> message, MessageChannel channel, MessageHandler handler, Exception ex) {
            SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor.wrap(message);
            if (accessor.getMessageType() == SimpMessageType.SUBSCRIBE && handler instanceof AbstractBrokerMessageHandler) {
                /*
                 * Publish a new session subscribed event AFTER the client
                 * has been subscribed to the broker. Before spring was
                 * publishing the event after receiving the message but not
                 * necessarily after the subscription occurred. There was a
                 * race condition because the subscription was being done on
                 * a separate thread.
                 */
                applicationEventPublisher.publishEvent(new SessionSubscribedEvent(this, message));
            }
        }
    });

}

Answer 3

您面临的问题在于clientInboundChannel的性质，默认情况下，它是executorSubscribebalChannel。

它有3个订户：

0 = {SimpleBrokerMessageHandler@5276} "SimpleBroker[DefaultSubscriptionRegistry[cache[0 destination(s)], registry[0 sessions]]]"
1 = {UserDestinationMessageHandler@5277} "UserDestinationMessageHandler[DefaultUserDestinationResolver[prefix=/user/]]"
2 = {SimpAnnotationMethodMessageHandler@5278} "SimpAnnotationMethodMessageHandler[prefixes=[/app/]]"

在taskExec导师中调用，因此是异步的。

这里的第一个（SimpleBrokerMessageHandler（或StompBrokerRelayMessageHandler）如果您使用代理中继），负责注册主题的订阅。

在WebSocket会话的订阅注册之前，可以执行您的MessagingTemplate.convertAnd发送（/title/path，"msg"）操作，因为它们是在单独的线程中执行的。因此，Broker处理程序不知道您要向会话发送消息。

可以在方法上配置返回，其中此方法的结果将作为对客户端上的订阅函数的回复发送。

嗯