Как сделать рассылку n-ым подключенным клиентам?

Question

[Александр Антонов]

Учу nodejs и решил попробовать себя в реализации простой онлайн игры (крестики-нолики), знаю про socket.io но было интересно можно ли подобное реализовать на EventEmitter.

Создание игр и подключение к ним я сделал но вот столкнулся с вопросом как отправить событие только двум игрокам в комнате (активной игре), сначала решил что можно двоих забивать в массив и хранить их объект Response но потом после ошибок решил что такое не прокатит так как resp закрывается после того как отработает, сейчас предполагаю что можно взять объект socket (видел в свойствах) но сомневаюсь, нужна ваша помощь, заранее благодарю

Comments

[Александр Антонов]

Пишу по большей части для себя, это мое расследование и решение вопроса

Пока изучал этот вопрос понял что единственные данные которые у нас есть это слушатели они же функции, забитые в event через которые мы можем отлавливать нужных нам клиентов и слать им необходимые события но все усложняет то что забиваются они по индексам а не по ключам uuid которые мы могли бы контролировать, индексы вещь не стабильная и постоянно меняющееся так что быть уверенным в том что если мы отошлем событие 2-ому индексу и это точно будет тот кто нам нужен мы не можем, остается два варианта, хранить массив с uuid клиентов который мы создаем и индексами их слушателей которые ручками будем постоянно менять при подключении и отключении клиента или же второй вариант, создавать кастомный список слушателей который будем забивать в объект с uuid, второй выглядит более громоздким так как в памяти будет храниться два списка слушателей

ну или как вариант написать свою реализацию эмиттера где слушатели будут храниться так как нам нужно, в крайнем случае конечно

Answer 1

[Александр Антонов]

Все оказалось куда проще, решение такого, при каждом подключении сохраняю uuid пользователя в массив, при отключении соответственно удаляю, так как слушатели это простой массив то список uuid будет работать так же как и список слушателей, то есть они по идее должны быть синхронизированы по индексам, соответственно вот сама реализация рассылки

public broadcast(type: string, receivers: string[], msg?: any) {
    const events = this.emitter.eventNames()

    if (!events.includes(type)) {
      console.warn('Предупреждение: такое событие не добавлено!')
      return
    }

    const list = receivers.map(id => this._players.indexOf(id))
    const listeners = this.emitter.listeners(type)

    for (const index of list) {
      const fn = listeners[index]

      if (typeof fn === 'function')
        fn(msg)
      else
        console.error(`Ошибка, под индексом ${index} нет слушателя!`)
    }
  }