Задачи. Распределение, резервирование, очередь.

1.1

1

|(% style="width:157px" %) |(% style="width:1277px" %)(((

2

|(% style="width:105px" %) |(% style="width:1138px" %)

3

|(% style="width:105px" %)Распределение|(% style="width:1138px" %)

4

|(% style="width:105px" %)Резервирование|(% style="width:1138px" %)Резервирование помогает отслеживать факт того, что экземпляр назначен на выполнение или выполняется (чтобы не пытаться запустить его на другом исполнителе).

5

Резервирование накладывается с timeout.

6

|(% style="width:105px" %) |(% style="width:1138px" %)

7

)))

8

|(% style="width:157px" %)Очередь и резервирование на основе [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]]|(% style="width:1277px" %)(((

9

|(% style="width:93px" %)Ветка|(% style="width:1151px" %)feature/redis_typed_process_queue

10

|(% style="width:93px" %)Топология|(% style="width:1151px" %)DbSelector -> (Queue with reserve) -> Executor.

11

ExecutorRunner -> (Queue with reserve) -> Executor.

12

|(% style="width:93px" %)Компоненты|(% style="width:1151px" %)(((

13

|(% style="width:369px" %)В качестве очереди выступает один или группа SortedSet и PubSub channel.|(% style="width:759px" %)(((

14

* SortedSet - позволяет хранить заявки на обработку (без дублей) и имеет упорядоченность (можно указать критерий, например приоритет или дата создания).

15

Использование нескольких SortedSet позволяет выполнить разделение по типу / приоритету процесса, чтобы ноды Executor могли отбирать только указанные для них типы задач.

16

* PubSub channel - используется для оповещения Executor о том, что в определенную очередь поступило сообщение. Executor может попытаться его считать, при наличии у него свободных слотов на обработку (параллелизм).

17

)))

18

|(% style="width:369px" %)В качестве системы резервирования используется HashSet.|(% style="width:759px" %)Позволяет гарантировать уникальность (при резервировании), а также позволяет задействовать ExperationTimeout (автоматическое снятие резервирования, если вдруг нода упада и не смогла снять сама).

19

)))

20

|(% style="width:93px" %)Плюсы|(% style="width:1151px" %)(((

21

* Все временные данные расположены в оперативной памяти.

22

Нет записи на диск. Их потеря не критична, она приведет к временной задержке, но система продолжит работу.

23

* При выборке из БД достаточно только чтения. Не требуется ни транзакция, ни блокировка, ни запись.

24

* Максимально быстрое попадание в Executor (Если обработчик публикует сразу в Queue (наличие такой возможности)).