Изменения документа Задачи. Распределение, резервирование, очередь.

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Содержимое

...	...	@@ -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,15 +43,19 @@
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	+* Сравнительно просто. Не требует развертывания других типов хранилищ или брокеров сообщений.
	49	+* Наличие полной транзакционности.
48	48	)))
49		-|Минусы|
	51	+|(% style="width:71px" %)Минусы|(% style="width:1183px" %)(((
	52	+* Не самая малая задержка до начала выполнения.
	53	+* Не самый эффективный вариант.
50	50	)))
	55	+)))
51	51	|(% style="width:29px" %)1|(% style="width:1272px" %)(((
52	52	|(% style="width:67px" %) |(% style="width:1187px" %)Одна транзакция с блокировкой.
53	53	|(% style="width:67px" %)Плюсы|(% style="width:1187px" %)(((
54		-* Сравнительно просто.
55	55	* Нет записи на диск.
56	56	Но используется память БД для хранения блокировок.
57	57	)))
...	...	@@ -76,7 +76,6 @@
76	76	|(% style="width:75px" %) |(% style="width:1179px" %)InMemory (возможно unlogged) таблица в реляционной БД.
77	77	|(% style="width:75px" %)Плюсы|(% style="width:1179px" %)(((
78	78	* Запись о резервирование не нагружает диск.
79		-* Наличие полной транзакционности.
80	80	)))
81	81	|(% style="width:75px" %)Минусы|(% style="width:1179px" %)(((
82	82	* Необходим join с основной таблицей.