Spring SockJS跺脚不接收心跳以外的消息

Question

我使用的是Spring版本4.3.6。在服务器端和bowers客户端上发布"Stamp-webSocket"："2.0"和"Sockjs-Client"："1.1.4"

以下是服务器端的所有相关代码-

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer
{
  @Autowired
  private SimpMessagingTemplate brokerMessagingTemplate;

  @Override
  public void registerStompEndpoints(StompEndpointRegistry registry)
  {
    // for local testing, setting allowed origins to * - Should be removed later
    registry.addEndpoint("/websoc").setAllowedOrigins("*").withSockJS().setSupressCors(true);
  }

  @Override
  public void configureMessageBroker(MessageBrokerRegistry registry)
  {
    registry.setApplicationDestinationPrefixes("/app");
    registry.enableSimpleBroker("/topic", "/queue");
  }

  @Override
  public void configureClientOutboundChannel(ChannelRegistration registration)
  {
    registration.taskExecutor()
    .corePoolSize(10)
    .maxPoolSize(20);
  }

  @Override
  public void configureWebSocketTransport(WebSocketTransportRegistration registration)
  {
    registration.setSendTimeLimit( 15 * 1000)
    .setSendBufferSizeLimit( 512 * 1024)
    .setMessageSizeLimit( 128 * 1024);
  }

  @PostConstruct
  public void fetchNotifications()
  {

    NotificationsController.setMesgingTmpt(brokerMessagingTemplate);
  }
}


@Controller
public class NotificationsController
{
  private static SimpMessagingTemplate brokerMessagingTemplate;

  public static void setMesgingTmpt(SimpMessagingTemplate tmp)
  {
    brokerMessagingTemplate = tmp;
  }

  // @SendTo("/topic/userNotifications")
  public void testWSMessage(JUserNotification un)
  {
    LOGGER.debug("testWSMessage called");

    un.setAccountId("1");
    un.setUserId("1");

    try
    {
      LOGGER.debug("sending notif: {}", JSONUtils.stringify(un));
      brokerMessagingTemplate.convertAndSend("/topic/userNotifications", un);

    } catch (final Exception e)
    {
      LOGGER.debug("exception while sending msg to client: {}", e);
    }
   // return un;
  }
}

@Component
public class CustomApplicationListener implements ApplicationListener<ApplicationEvent>
{
    @Override
  public void onApplicationEvent(ApplicationEvent event)
  {
    if (event instanceof SessionSubscribeEvent)
    {
      LOGGER.debug("subscribe event received. Some params - ");
      final SessionSubscribeEvent se = (SessionSubscribeEvent) (event);
      final StompHeaderAccessor headers = StompHeaderAccessor.wrap(se.getMessage());
      LOGGER.debug("sessionId: {}", headers.getSessionId());
      LOGGER.debug("sessionAttributes: {}", headers.getSessionAttributes());
      LOGGER.debug("ack: {}", headers.getAck());
      LOGGER.debug("command: {}", headers.getCommand());
      LOGGER.debug("destination: {}", headers.getDestination());
      LOGGER.debug("subscriptionId: {}", headers.getSubscriptionId());
      LOGGER.debug("user: {}", headers.getUser());


      // test code
      final NotificationsController notifs = new NotificationsController();
      final JUserNotification usrNotif = new JUserNotification();
      notifs.testWSMessage(usrNotif);
    }
  }
}

在客户机上，这是代码-

    this.set("webSockURL", this.get("serverInfo").getWebsocketEndPoint());
    this.set("sock", new SockJS(this.get("webSockURL")));
    this.set("stompClient", Client.over(this.get("sock")));

    var stompcli = this.get("stompClient");

    var subscribeCallBack = function(message) {
    console.log("inside subscribeCallBack");
      this._processNotifications(message)
    };

    var connectCallBack = function() {
      console.log("inside connectCallBack");
      stompcli.subscribe("topic/userNotifications", subscribeCallBack);
    };

    stompcli.connect({}, {}, connectCallBack);

Websocket connect建立后，我收到心跳消息，但没有收到我正在发送的通知。我甚至尝试过使用@SendTo注释，但它不起作用。

当我使用webjarstomp和sockjs尝试相同的服务器代码并在本地运行时，我会收到消息。这让我觉得是客户机库出了问题，但我对此不确定。

服务器作为反向代理在nginx后面的docker容器上运行。我已经将ELB配置为允许WebSocket并启用了proxy_协议。

由于连接本身已经成功建立，我不怀疑它的基础设施部分。任何想法都将不胜感激。

Answer 1

您在编写topic/userNotifications时，没有在topic之前编写/，因此请尝试将javascript代码重写为如下代码：

stompcli.subscribe("/topic/userNotifications", subscribeCallBack);