MB
поэтому я и спросил, где тут ожидается выигрыш и какой?
Побольше бы таких вопросов в коммьюнити программистов задавалось бы. Глядишь, и перестали бы кучу ритуалов выполнять...
Size: a a a
2020 June 04
MP
с буфером есть другая куча проблем - надо понять какого он должен быть размера, чтобы давать какую-то пользу, и что с ним делать, если он все-таки переполнился
MK
ок, тогда пример с емейлом
гарантия доставки - at most once
если что - пользователь еще раз попросит
есть 2 варианта
синхронный - есть некий интерфейс/протокол отправщика и синхронно его дергаем
и ассинхронный - есть очередь без буфера и в другом треде/го-блоке происходит отправка
при этом, если очердь не пуста, то отправитель блокируется и ждет
в чем разница?
гарантия доставки - at most once
если что - пользователь еще раз попросит
есть 2 варианта
синхронный - есть некий интерфейс/протокол отправщика и синхронно его дергаем
и ассинхронный - есть очередь без буфера и в другом треде/го-блоке происходит отправка
при этом, если очердь не пуста, то отправитель блокируется и ждет
в чем разница?
MP
ок, тогда пример с емейлом
гарантия доставки - at most once
если что - пользователь еще раз попросит
есть 2 варианта
синхронный - есть некий интерфейс/протокол отправщика и синхронно его дергаем
и ассинхронный - есть очередь без буфера и в другом треде/го-блоке происходит отправка
при этом, если очердь не пуста, то отправитель блокируется и ждет
в чем разница?
гарантия доставки - at most once
если что - пользователь еще раз попросит
есть 2 варианта
синхронный - есть некий интерфейс/протокол отправщика и синхронно его дергаем
и ассинхронный - есть очередь без буфера и в другом треде/го-блоке происходит отправка
при этом, если очердь не пуста, то отправитель блокируется и ждет
в чем разница?
это кейс, когда есть относительно быстрый генератор событий, который долджен быстро завершиться и относительно медленные воркеры, которые потом будут обрабатывать эти события.
MK
не ждем завершения задачи? только это отличие?
MP
причем флоу контроль тут как бы за кадром остается
MP
а с ним много интересного тоже.
D
dead letter queue?
MP
не ждем завершения задачи? только это отличие?
ну вот если хочется, чтобы генератор событий отрабатывал быстро, а обработка медленно
MK
ну вот если хочется, чтобы генератор событий отрабатывал быстро, а обработка медленно
а если буфера нет?
MP
если нет, то генератор событий напрямую вызывает обработчик и синхронно ждет пока он все обработает
MB
У меня пока есть чувство, что очереди для разделения подсистем имеют смысл, только если их использовать в духе эрланга, с отказоустойчивостью и прочими приколами
MP
У меня пока есть чувство, что очереди для разделения подсистем имеют смысл, только если их использовать в духе эрланга, с отказоустойчивостью и прочими приколами
ерланг ту не при чем как бы
VL
service oriented architecture
VL
зачем нужна kafka?
IG
kafka нужна для передачи сообщений между системами, в.ч. датацентрами, на большие расстояния
IG
и для агрегации многих данных о фирме
IG
в том же manifold из коробки идет отличный pub-sub bus
IG
любой компонент можно написать как воркер, который подсасывается к топику и читает-пишет в него
IG
плюс всегда можно подключить второй воркер для медленных операций