Задать вопрос
@jeruthadam
Я крут
node.js

Как изолировать ивент для определенного юзера?

Использую вебсокеты и ws.

В обычном случае, ws это отдельное конкретное соединение, т.е. этот код посылает ответ непосредственно отправителю

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    ws.send(payload);
  });
})


Пробую сделать систему подписок используя EventEmitter, и таким образом сообщенеи уходит вообще всем соединениям

const EventEmitter = require('events');
const pubsub = new EventEmitter();

wss.on('connection', ws => {
  pubsub.on('test', payload => {
    ws.send(payload);
  });
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload);
  });
})


Соответвенно, как только отрабатывает ивент рассылается по всем ws.

А как ограничить в данном случае?
  • Вопрос задан
  • 101 просмотр
Комментировать
Подписаться 1 Простой Комментировать
Решения вопроса 1
Xuxicheta
@Xuxicheta
инженер
spoiler
const EventEmitter = require('events');
const pubsub = new EventEmitter();

wss.on('connection', ws => {
  pubsub.on('test', (payload, _ws) => {
    if (_ws !== ws) {
      return;
    }
    ws.send(payload);
  });
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, ws);
  });
})


const EventEmitter = require('events');
const pubsub = new EventEmitter();

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, ws);
  });
});

 pubsub.on('test', (payload, _ws) => {
   _ws.send(payload);
});


const EventEmitter = require('events');
const pubsub = new EventEmitter();

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, { payload, ws });
  });
});

 pubsub.on('test', ({ payload, ws }) => {
   ws.send(payload);
});


const EventEmitter = require('events');
const pubsub = new EventEmitter();

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, outcome => ws.send(outcome));
  });
});

 pubsub.on('test', (payload, send) => {
   send(payload);
});
Ответ написан
1 комментарий
1 комментарий
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
Вакансии с Хабр Карьеры
Senior Backend Developer Node.js
Radium Finance • Москва
от 300 000 до 400 000 ₽
Node.js разработчик
ДАЛЕЕ • Москва
от 200 000 ₽
Node.js Developer (middle)
ROBOTMIA • Новосибирск
от 130 000 ₽
Ещё вакансии
Заказы с Хабр Фриланса
Каталог AI tools
18 апр. 2024, в 01:12
150000 руб./за проект
Загрузка характеристик из xml/csv файла в карточки товаров WordPress
18 апр. 2024, в 00:58
5000 руб./за проект
Нарисовать подарки для соц сети
18 апр. 2024, в 00:10
50000 руб./за проект
Ещё заказы