PD
Ну, тогда реализуй все на очереди прямо в базе, это будет проще и надежнее всего.
Size: a a a
2021 April 16
G
Хм, а куда читать/копать? PG_LISTEN/NOTIFY?
PD
Нет, конечно.
G
Я не очень понимаю, как увязать то, что пара тысяч обработчиков вебсокет-соединений будет раз в N времени ходить в базу проверить, не появились ли новые данные. Поэтому и был вопрос про связующее звено для всех потребителей
PD
Тут, наверно, я подробнее всего про эту задачу рассказывал
PD
Только зачем тебе 2000 обработчиков? У тебя в памяти сидят соединения, воркер забирает события из БД и укладывает в нужные соединения - и все.
G
Хм. Вы предлагаете хранить коннекты к вебсокету в списке (добавляя при присоединении и убирая при отсоединении), и когда приходит событие, обходить их аля "кому подходит, тому и отправлю"?
PD
Зачем в списке? В мапе по имени пользователя, для которого сообщение.
Получаешь сообщение из очереди в базе, смотришь адресата, отправляешь в его сокет сообщение - все.
Получаешь сообщение из очереди в базе, смотришь адресата, отправляешь в его сокет сообщение - все.
PD
В базе для правильной фильтрации - таблица со списком "пользователей онлайн", что бы лишнего не обходить.
G
В ту же мапу ложатся группы/орги в принципе, если сообщение на массовую рассылку. Логично.
PD
Ну, сокет на группу не получится, так что сообщения на группу раскрываются и кладутся в сокеты на членов группы.
PD
При такой небольшой нагрузке все нормально делается через select for update skip locked
PD
(Я то сейчас решаю эту задачу для 10mln пользователей и 10K сообщений в секунду, тут уже PG не спасает...)
G
{"username1": [socket1], "org.team": [socket1, socket2, socket3]}
PD
Ну, для 1000 человек сойдет, а так не очень хорошая идея )
p
А зачем тут кафка или mq?
G
Та я вот тоже увидел throughput у кафки в миллионы сообщений в секунду и как-то подумалось, что *слегка* оверкилл для селфхостед систем до 1к юзеров
PD
В базе у тебя таблица
queues(reciever,..)
online(reciever)
ты перед skip locked их джойнишь, что бы из "неонлайн" очередей ничего не забирать.
И все получается очень просто и надежно
queues(reciever,..)
online(reciever)
ты перед skip locked их джойнишь, что бы из "неонлайн" очередей ничего не забирать.
И все получается очень просто и надежно
PD
Ну, если бы НФТ были другими - то было бы полезно.