Как инициализировать единственное WebSocket соединение для нескольких запросов к серверу?

Question

[IvanRobot]

Есть класс, который организует запросы к серверу. Среди методов есть один, который отвечает за WebSocket. Данный метод принимает параметры и инициализирует соединение с сервером.

Requests.prototype.wsQuery = function(msg, callback) {
    // Инициализируется каждый раз при вызове метода. Бред!
    var w = new ws('wss://api.something.com/ws/');

    w.on('open', function() {
        w.send(JSON.stringify(msg));
    });

    w.on('message', function(res) {
        callback(res);
    });  
}

// ***

module.exports = new Requests;

Проблема в том, что при нескольких инициализациях соединение вылетает `ошибка 429`, то есть слишком много запросов к серверу...

Как организовать код, что бы инициализация WebSocket происходила всего один раз? При объявление каждого объекта Request указывать в параметрах WebSocket? Или может как-то иначе можно?

const w = new ws('wss://api.something.com/ws/');

let obj = Request(w);
let obj_2 = Request(w);
// ***

Answer 1

[RidgeA]

Не совсем понятно, зачем создавать несколько объектов Request и почему бы не делать все запросы в рамках одного.

Но если действительно так надо - твой вариант не так уж и плох.

Можно скрыть инициализацию объекта в функции:

function getRequestFactory() {
  const ws = initWSConnection();
  return () => { return new Request(ws) }
}

Можно еще что-то придумать....

Comments

[IvanRobot]

В рамках одного объекта все запросы? Мне же потом нужно сортировать ответы от сервера. Ответы идут такого типа `[channel , [data]]`. Если в один объект закинуть все запросы, то в ответ получу уйму каналов и будет не понятно, к какому запросу принадлежит определённый канал.

Если же для каждого запроса делать объект, то можно хоть как-то отсортировать ответы.

А так, функция интересная, но хотелось бы не вклеивать WebSocket в каждый объект. Может можно как-нибудь сразу внутри класса встроить инициализированный WebSocket, а затем раздавать его на все объекты этого класса Request?

[RidgeA]

Не знаю, в чем суть приложения, возможно такой подход себя и оправдывает. Но держать несколько соединений с одного клиента может быть идея не очень.
Возможно в обработчике сообщений с сервера можно реализовать какой-то роутинг (по параметру сhannel я так понимаю), какому классу - инициатору (подписчику) запроса возвращать ответ.
Я бы порекомендовал подумать как это можно реализовать в рамках одного соединения и протестировать сколько одновременно соединений с одного клиента можно держать.

Как-то так (рассматривай это как псевдокод):

class WS {
  constructor() {
    this.ws = initWS();
    this.subscribers = {};
  }
  subscibe(channel, subscriber) {
    this.subscribers[channel].push(subscriber) //естественно, надо предусмотреть инициализацию массива для первого подписчика
  }
  
  messageHandler(messagePayload) {
    this.subscribers[messagePayload.channel].forEach(subscriber => subscriber.notify(messagePayload))
  }
}

subscriber.notify - обработчик сообщения для определенного канала.

А так, функция интересная, но хотелось бы не вклеивать WebSocket в каждый объект. Может можно как-нибудь сразу внутри класса встроить инициализированный WebSocket, а затем раздавать его на все объекты этого класса Request?

можно инициализировать соединение в глобальной области видимости и в Request его использовать, но это отличается от варианта с функцией в худшую (ИМХО) сторону.