Пользовательские направления в многосерверной среде? (Spring WebSocket и RabbitMQ)

Если они нуждаются в аутентификации (я предполагаю, что их учетные данные хранятся в базе данных), вы всегда можете использовать их уникальный идентификатор пользователя базы данных для подписки.

Что я делаю, так это то, что когда пользователь входит в систему, он автоматически подписывается на две темы: account|system тему для общесистемных трансляций и account|<userId> тему для определенных трансляций.

Вы можете попробовать что-то вроде notification|<userid> для каждого человека, на который подписаться, а затем отправить сообщение в эту тему, и они его получат.

Поскольку идентификаторы пользователей уникальны для каждого пользователя, у вас не должно возникнуть проблем в кластерной среде, пока каждая среда обращается к одной и той же информации базы данных.

Вот мой метод отправки:

  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;
    }
  }

Мои пункты назначения предварительно отформатированы, поэтому, если я хочу отправить сообщение пользователю с идентификатором, равным одному, пункты назначения выглядят примерно как /topic/account|1.

Ive создал контроллер для пинг-понга, который тестирует веб-сокеты для пользователей, которые подключаются, чтобы узнать, позволяет ли их среда использовать веб-сокеты. Я не знаю, поможет ли это вам, но это работает в моей кластерной среде.

/**
   * 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;
  }