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

Ребят, вот у меня есть вопрос, он более абстрактный, и

не относится конкретно к ГО, а скорее в целом к архитектуре, мне интересно как горизонтально масштабировать этот момент.
Допустим есть какой-то сервер пусть будет Джанго который делает publish в какой-то редис канал на какой-то ивент.

И есть микросервис:
Допустим приложение Го. подписывается на этот канал и когда туда приходит сообщение, что-то с ним делает, например в базу записывает что-то, неважно,

И допустим у нас создаётся несколько инстансов Джанги потому что нагрузка на сервер выросла, и надо больше серверов с джанго, мы скейлим джанго приложение просто ставя апп на дополнительные сервереа, и все они при своих ивентам шлют какой-то паблиш в редис

Приложение на го всё ещё на одном сервере один инстанс поднят и подписанный на этот канал что-то делает.

Если мы поднимем второй инстанс нашего ГО подписчика, то при паблише инфы в канал редиса, они же оба его подхватят и сделает тупо двойную работу....

Как нормально можно скелйить Подписчиков на какой-то канал в редисе?

Длиновато получилось.......

7 ответов

15 просмотров

Если у вас из очереди в вашем message broker (redis, rabbitmq, kafka etc) сообщение было считано, почему вы предполагаете оно должно продублироваться во второй инстанс?

Hiroki Fujisawa
Если у вас из очереди в вашем message broker (redi...

потому, что на выбор у нас есть at most once (риск потери) и at least once (риск дублирования) а exactly once, который все хотят, не бывает в природе

Daniel Podolsky
потому, что на выбор у нас есть at most once (риск...

что значит «не бывает в природе»? насколько я знаю, в рэббите такое поведение по умолчанию, если у очереди несколько консьюмеров

Daniel Podolsky
потому, что на выбор у нас есть at most once (риск...

У кафки вполне себе бывает, но сами знаете почему ;-)

Hiroki Fujisawa
В RMQ как раз at least once

а, да, спутал. там acks позволяют избежать дублирования, которое описывает Ярослав

Hiroki Fujisawa
В RMQ как раз at least once

ну можно и at most once (если поставить auto-ack)

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

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

а через ESC-код ?
Alexey Kulakov
29
30500 за редактор? )
Владимир
47
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
13
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Как передать управляющий символ в открытую через CreateProcess консоль? Собсна, есть процедура: procedure TRedirectThread.WriteData(Data: OEMString); var Written: Cardinal;...
Serjone
6
program test; {$mode delphi} procedure proc(v: int32); overload; begin end; procedure proc(v: int64); overload; begin end; var x: uint64; begin proc(x); end. Уж не знаю...
notme
6
Ребят в СИ можно реализовать ООП?
Николай
33
у вас два процесса. один посылает другому сигнал. у вас есть код обоих процессов? если всё не так - расскажите как оно на самом деле. а именно кто кому чего, есть-ли консоли,...
Karagy
6
вы делали что-то подобное и как? может есть либы готовые? увидел картинку нокода, где всё линиями соединено и стало интересно попробовать то же в ddl на lua сделать. решил с ч...
Victor
8
Карта сайта