170 похожих чатов

Приветствую! Подскажи, пожалуйста. Есть Вебсокет сервер (WSAPP) в нескольких инстансах. Клиент (WSCLIENT)

через envoy идёт в нужный инстанс WSAPP.
Есть множество других сервисов, которые хотят отправить WSCLIENT сообщение, с WSAPP они общаются через rabbitmq, как можно организовать роутинг, чтобы сторонний сервис знал в какой инстанс WSAPP слать сообщение?
И WSAPP и сторонние сервисы знаю userId WSCLIENT.
Я знаю пару подходов для таких случаев:
1. Динамические очереди(или routing key), на каждый ws коннекшн создаёшь новую очередь с routing key = userId, и роутинг реббита делает своё дело
2. Сервис-прослойка который хранит в БД какой инстанс с каким userId держит коннекшн
У обоих подходов есть свои недостатки.
Может кто-то сталкивался с подобным и знает элегантное решение?

4 ответов

14 просмотров

в смысле не ответ на какое-то полученное сообщение, а просто какой-то сервис шлет новое и надо чтобы его обработал именно нужный инстанс ? если не хочется тащить кафку, то можно вместо очереди использовать топики. каждый инстанс читает сообщение и решает, можно ли ему его процессить.

Anton- Автор вопроса
Alexander Komarov
в смысле не ответ на какое-то полученное сообщение...

Да, всё верно, тут нужно чтобы какой-то сервис отправил сообщение и его обработал нужный инстанс. Да, идею с топиком понял, спасибо

Anton- Автор вопроса
Alexander Komarov
в смысле не ответ на какое-то полученное сообщение...

Тут видится 1 недостаток, что если инстанс1 WSAPP упал, все клиенты попытаются сделать реконнект к другому инстансу, и если в этот момент будет сообщение в очереди то все инстансы WSAPP его скипнут потому что ещё нигде не зареган userId. Подумаю над этим

Anton
Тут видится 1 недостаток, что если инстанс1 WSAPP ...

а тут всегда будет какой-то трейдофф. надо будет или решать проблему потерянных сообщений. или проблему с задвоением. или платить перфомансом, если например заиспользовать распределенные транзакции

Похожие вопросы

Обсуждают сегодня

Сообщение* в закодированном виде. То есть, просто сделать sendMessage?text=Привет бла-бла! не получится, надо в HEX переводить, и добавлять процент, типа такого: sendMessage?t...
КТ315
21
А случайно нет ли в паскале штатной возможности передать указатель и количество туда где array of в качестве аргумента?
zamtmn
25
Anyone here suffers from unexplained aural migraines, who would be up for talking for a bit? Doesn't *have* to be aural, but I am not asking about headaches, I mean actual mi...
Martin Rys
58
Только такой if ($modx->event->name == 'OnBeforeCartItemAdding') { $meta = $params['item']['meta']; $lang = $modx->getConfig('_lang'); // проверяем, задана ли опция i...
Multi Web
1
Всем привет. Испытываю проблемы в работе БД, а именно огромного роста логов, такого характера: 024-05-16 18:39:07 +05 sentry sentry [unknown] 1050169 7-1 app-sentry01.corp.ru>...
Alexey
2
Ну раз я пока тут, задам пару глупых вопросов. Зачем писать на ассемблере если компилятор довольно умный, а ассемблер много времени занимает? В каких прикладных задачах сейчас...
Максим Рябцев
20
Хм. А телеграм апи работают через HTTP?
The Bird of Hermes
14
Почему Telegram пишет, что объект media не найден, хотя на самом деле я его передаю? Делаю на urllib, без зависимостей, так надо. Вызываю метод sendMediaGroup с таким JSON: ...
Alexey S
1
Если подытожить: По мнению Розыча и Хемуля и др. - предпочтительно по возможности объявлять в секции имплементации потому-что: 1) Выше скорость компиляции 2) Не замусоривается...
notme
7
я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
100
Карта сайта