多服务器环境中的用户目标？（SpringWebSocket和RabbitMQ）

Question

Spring WebSocket的留档状态为：

应用程序可以发送针对特定用户的消息，为此，Spring的STOMP支持识别前缀为“/user/”的目的地。例如，客户端可能订阅目的地"/user/队列/位置更新"。该目的地将由UserDestinationMessageHandler处理，并转换为用户会话独有的目的地，例如"/队列/位置-更新-用户123"。这提供了订阅通用命名目的地的便利，同时确保与订阅同一目的地的其他用户不发生冲突，以便每个用户都可以接收独特的股票头寸更新。

这应该在以RabbitMQ作为代理的多服务器环境中工作吗？

据我所知，用户的队列名称是通过附加simpSessionId来生成的。当使用推荐的客户端库时stomp.js这将导致第一个用户获得队列名称"/队列/位置-更新-用户0"，下一个用户获得"/队列/位置-更新-用户1"等等。这反过来意味着第一个连接到不同服务器的用户将订阅相同的队列（"/队列/位置-更新-用户0"）。

我在文档中能找到的唯一参考是：

在多应用程序服务器场景中，用户目的地可能仍未解决，因为用户连接到不同的服务器。在这种情况下，您可以配置一个目标来广播未解析的消息，以便其他服务器有机会尝试。这可以通过Java配置中MessageBroker注册表的userDestinationBroadcast属性和XML中消息代理元素的user-endation-Broadcast属性来实现。

但这只能使与来自不同服务器的用户进行通信成为可能，而不是建立Web套接字的服务器。

我觉得我错过了什么？是否有配置Spring以安全使用MessagingTemplate的方法。convertAndSendToUser（principal.getName（），destination，payload）在多服务器环境中？

Answer 1

如果他们需要进行身份验证（我假设他们的凭据存储在数据库中），您可以始终使用他们的数据库唯一用户id进行订阅。

我所做的是，当用户登录时，他们会自动订阅两个主题，一个帐户|系统主题，用于系统范围的广播和帐户|

您可以尝试类似于通知的方法|

由于用户ID对每个用户都是唯一的，所以只要每个环境都访问相同的数据库信息，集群环境中就不应该有问题。

以下是我的发送方法：

  public static boolean send(Object msg, String topic) {
    try {
      String destination = topic;
      String payload = toJson(msg); //jsonfiy the message 
      Message<byte[]> message = MessageBuilder.withPayload(payload.getBytes("UTF-8")).build();
      template.send(destination, message);
      return true;
    } catch (Exception ex) {
      logger.error(CommService.class.getName(), ex);
      return false;
    }
  }

我的目的地是预格式化的，因此如果我想向id为的用户发送消息，目的地看起来像/topic/account | 1。

我创建了一个乒乓球控制器，为连接的用户测试WebSocket，看看他们的环境是否允许WebSocket。我不知道这是否对您有帮助，但这在我的集群环境中确实有效。

/**
   * Play ping pong between the client and server to see if web sockets work
   * @param input the ping pong input
   * @return the return data to check for connectivity
   * @throws Exception exception
   */
  @MessageMapping("/ping")
  @SendToUser(value="/queue/pong", broadcast=false) // send only to the session that sent the request
  public PingPong ping(PingPong input) throws Exception {
    int receivedBytes = input.getData().length;
    int pullBytes = input.getPull();

    PingPong response = input;
    if (pullBytes == 0) {
      response.setData(new byte[0]);
    } else if (pullBytes != receivedBytes)  {
      // create random byte array
      byte[] data =  randomService.nextBytes(pullBytes);
      response.setData(data);
    }
    return response;
  }