Перейти к содержимому
Редактировал(а) Alexandr Fokin 2026/08/20 12:16
От версии 1.12
отредактировано Alexandr Fokin
на 2026/08/20 12:03
Изменить комментарий: К данной версии нет комментариев
К версии 1.13
отредактировано Alexandr Fokin
на 2026/08/20 12:16
Изменить комментарий: К данной версии нет комментариев

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -14,12 +14,12 @@
14 14  |(% style="width:93px" %)Топология|(% style="width:1151px" %)DbSelector -> (Queue with reserve) -> Executor.
15 15  ExecutorRunner -> (Queue with reserve) -> Executor.
16 16  |(% style="width:93px" %)Компоненты|(% style="width:1151px" %)(((
17 -|(% style="width:369px" %)В качестве очереди выступает один или группа SortedSet и PubSub channel.|(% style="width:759px" %)(((
17 +|(% style="width:260px" %)В качестве очереди выступает один или группа SortedSet и PubSub channel.|(% style="width:921px" %)(((
18 18  * SortedSet - позволяет хранить заявки на обработку (без дублей) и имеет упорядоченность (можно указать критерий, например приоритет / дата создания/ дата последней обработки).
19 19  Использование нескольких SortedSet позволяет выполнить разделение по типу / приоритету процесса, чтобы ноды Executor могли отбирать только указанные для них типы задач.
20 20  * PubSub channel - используется для оповещения Executor о том, что в определенную очередь поступило сообщение. Executor может попытаться его считать, при наличии у него свободных слотов на обработку (параллелизм).
21 21  )))
22 -|(% style="width:369px" %)В качестве системы резервирования используется HashSet.|(% style="width:759px" %)(((
22 +|(% style="width:260px" %)В качестве системы резервирования используется HashSet.|(% style="width:921px" %)(((
23 23  Позволяет гарантировать уникальность (при резервировании), а также позволяет задействовать ExperationTimeout (автоматическое снятие резервирования, если вдруг нода упада и не смогла снять сама).
24 24  
25 25  Используется для обработки ситуации, когда задача была взята из очереди в обработку и обрабатывается (в этот промежуток нет смысла помещать в очередь повторно). В конце обработки (при нормальном завершение) резервирование снимается или при падении сработает ExperationTimeout.
... ... @@ -43,12 +43,12 @@
43 43  )))
44 44  |(% style="width:157px" %)Резервирование на основе БД|(% style="width:1277px" %)(((
45 45  |(% style="width:29px" %) |(% style="width:1272px" %)(((
46 -|Плюсы|(((
46 +|(% style="width:71px" %)Плюсы|(% style="width:1183px" %)(((
47 47  * Гибкая конфигурация распределения задач по типам и нодам обработки.
48 48  * Сравнительно просто. Не требует развертывания других типов хранилищ или брокеров сообщений.
49 49  * Наличие полной транзакционности.
50 50  )))
51 -|Минусы|(((
51 +|(% style="width:71px" %)Минусы|(% style="width:1183px" %)(((
52 52  * Не самая малая задержка до начала выполнения.
53 53  * Не самый эффективный вариант.
54 54  )))