Динамические пространства имён в socket.io

Question

[Антон Медведев]

Пытаюсь реализовать динамические пространства в socket.io, но сталкиваюсь с различными багами. В интернете по этому вопросу много вопросов, но мало нормальных ответов. Вот моя реализация:

app.get '/:namespace', (req, res) ->
  namespace = '/' + req.params.namespace

  # Is already created namespace?
  namespaceExist = io.sockets.manager.namespaces[namespace]?

  # Send responce
  res.json yes

  return if namespaceExist

  # Socket.io
  io.of(namespace).on 'connection', (socket) ->
    # do something 

Клиент:

$.getJSON server, {}, (yes) =>
     socket = io.connect server
     # do something  

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

Может кто-нибудь знает как нравильно организовать динамические простраранства имён?

Answer 1

[No_Time]

1) Что мешает использовать комнаты?
2) Можно так:

io.sockets.on('connection', function(socket){

        var namespace = '/' + socket.handshake.namespace.toLowerCase();
        
        if (!io.namespaces[namespace]){

            io.of(namespace).on('connection', function(socket){

            });
        }
});

Имя нэимспэйса передавайте в ф-цию авторизации и соответственно сохраняйте в хэндшейк.

Comments

[No_Time]

Так. Тот, кто поставил минус — почему? Это прекрасно работает, в чем трабл?

[Антон Медведев]

( я не ставил =) )

Комнаты я использую для другого.
А как тогда должен выглядить клиент? Он должен устанавливать два соединения? А что происходит при реконнекте? Пожалуйста, приведите полный рабочий пример. Заранее спасибо!

[No_Time]

Нету доступа к коду, пишу по памяти, так что могут быть косяки, но вроде все так:

Клиент коннектится примерно вот так, те мы заранее подключаемся к нужному namespace, и передаем его имя в handshakeData:

io.connect('/your_namespace', {query: "namespace=your_namespace"})

Сервер, в глобальной авторизации:

io.configure(function (){
        io.set('authorization', function (handshakeData, callback) {
            // custom namespace validation
           handshakeData.namespace = handshakeData.query["namespace"],;
           callback(null, true);
          });
});

А далее я уже приводил код сервера, который непосредственно выполняет connection.

Рекконект вроде бы работал из коробки без проблем. Но точно сказать не могу :( Но даже если он не заработает, что вам мешает дописать реконнект на клиенте? Если соединение разорвано, то с интервалом в 5 сек пробуйте заново соединится, после n неудачных попыток нужно паниковать=) В socket.IO это впринципи также реализуется…

+ стандартный рекконект не работает через реверс проксю(при 2х и более серверах), никакие sticky sessions не помогают, поэтому все равно приходится писать свой велосипед.

[Антон Медведев]

Круто, большое спасибо за помощь!