Изменения документа Движок cccc1808. ProcessEngine

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
• Вложения (0 изменено, 1 добавлено, 0 удалено)
  • TransactionOutbox. Sequence.jpg

Подробности

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

Содержимое

...	...	@@ -18,13 +18,13 @@
18	18	* Транзакции: транзакции.
19	19	* Транзакции: savepoint.
20	20	(если используются, можно обрабатывать каждый шаг отдельной транзакцией или весь процесс без savepoint изоляции ошибок между шагами).
21		-* Блокировка: updatelock.
22		-* Блокировка: updatelock skip locked.
	21	+* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: updatelock.
	22	+* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: updatelock skip locked.
23	23	(частично можно обойтись без него).
24		-* Блокировка: sharelock
	24	+* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: sharelock
25	25	(можно обойтись без него без сильного влияния)
26		-* Уровень изоляции: работает на read committed, то что нужно блокируется руками.
27		-* Для некоторых кейсов желательно возможность выполнить upsert (insert on conflict).
	26	+* [[Уровни изоляции>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.Уровни изоляции | Isolation levels.WebHome]]: работает на read committed, то что нужно блокируется руками.
	27	+* Для некоторых кейсов желательно возможность выполнить [[Upsert>>doc:Разработка.Базы данных.SQL.Сценарии и вопросы.Insert or update\. Upsert.WebHome]] (insert on conflict).
28	28	)))
29	29	|(% style="width:150px" %)Брокер сообщений|(% style="width:1177px" %)(((
30	30	Используется для накопления и доставки TriggerEvent.
...	...	@@ -35,8 +35,8 @@
35	35	)))
36	36	)))
37	37	|(% style="width:132px" %)Особенности|(% style="width:1301px" %)(((
38		-|(% style="width:159px" %)Батчинг при выполнении.|(% style="width:1168px" %)(((
39		-Возможность использовать и комбинировать разные типы выполнения как
	38	+|(% style="width:159px" %)Пакетные транзакции (батчинг).|(% style="width:1168px" %)(((
	39	+Возможность использовать и комбинировать типы выполнения для разных типов процессов:
40	40
41	41	* (1 транзакция - 1 процесс),
42	42	* (1 транзакция - N процессов).
...	...	@@ -60,6 +60,7 @@
60	60	См. пример 2.
61	61	)))
62	62	|(% style="width:159px" %)Перехват ошибок|(% style="width:1168px" %)Перехват и обработка ошибок, если процесс выкинул exception в движок. Реализацию простого retry с задержкой (создается триггер на следующую попытку).
	63	+В случае пакетной транзакции движок не знает какой конкретно из процессов породил ошибку (если она не перехвачена вручную), то ошибка выставляется на все незавершенные процессы.
63	63	|(% style="width:159px" %)Параллельное выполнение|(% style="width:1168px" %)Допускается запуск нескольких раннеров (на разных нодах), работающих с одной таблицей процессов для распределения нагрузки между ними.
64	64	Допускается фильтрация типов процессов между нодами (чтобы нода выполняла только определенные типы процессов, в том числе по приоритету).
65	65	Доступно для раннеров процессов и триггеров.
...	...	@@ -98,11 +98,19 @@
98	98	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
99	99	)))
100	100	|(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
	102	+|(% style="width:870px" %)(((
	103	+
101	101	)))
	105	+)))
102	102	|(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]]
103	103	|(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)(((
104		-|(% style="width:94px" %) |(% style="width:1002px" %)Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
105		-Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
	108	+|(% style="width:94px" %) |(% style="width:1002px" %)(((
	109	+* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
	110	+* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
	111	+За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
	112	+* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
	113	+* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
	114	+)))
106	106	|(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)(((
107	107	* При получении события о засыпании процесса:
108	108	Фиксирует смещение процесса обработки и сравнивает со смещением сообщения.
...	...	@@ -112,7 +112,6 @@
112	112	Если процесс не спит (по флагу в триггере), то ничего не делает.
113	113	Если процесс спит (по флагу), то пробуждает процесс.
114	114
115		-
116	116	Отслеживает смещение обработки процесса и последнего события.
117	117	Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать.
118	118	Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса.
...	...	@@ -122,4 +122,26 @@
122	122	)))
123	123	)))
124	124
125		-
	133	+----
	134	+
	135	+==== Внутренние ссылки: ====
	136	+
	137	+====== Дочерние страницы: ======
	138	+
	139	+{{children/}}
	140	+
	141	+====== Обратные ссылки: ======
	142	+
	143	+{{velocity}}
	144	+#set ($links = $doc.getBacklinks())
	145	+#if ($links.size() > 0)
	146	+ #foreach ($docname in $links)
	147	+ #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
	148	+ * [[$escapetool.xml($rdoc.fullName)]]
	149	+ #end
	150	+#else
	151	+ No back links for this page!
	152	+#end
	153	+{{/velocity}}
	154	+
	155	+----

TransactionOutbox. Sequence.jpg

Author

...	...	@@ -1,0 +1,1 @@
	1	+XWiki.cccc1808

Размер

...	...	@@ -1,0 +1,1 @@
	1	+247.1 KB

Содержимое