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

Сводка

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

Подробности

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

Содержимое

...	...	@@ -18,13 +18,13 @@
18	18	* Транзакции: транзакции.
19	19	* Транзакции: savepoint.
20	20	(если используются, можно обрабатывать каждый шаг отдельной транзакцией или весь процесс без savepoint изоляции ошибок между шагами).
21		-* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: updatelock.
22		-* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: updatelock skip locked.
	21	+* Блокировка: updatelock.
	22	+* Блокировка: updatelock skip locked.
23	23	(частично можно обойтись без него).
24		-* [[Блокировки>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.WebHome]]: sharelock
	24	+* Блокировка: sharelock
25	25	(можно обойтись без него без сильного влияния)
26		-* [[Уровни изоляции>>doc:Разработка.Базы данных.SQL.Механизмы.Транзакции и блокировки.Уровни изоляции | Isolation levels.WebHome]]: работает на read committed, то что нужно блокируется руками.
27		-* Для некоторых кейсов желательно возможность выполнить [[Upsert>>doc:Разработка.Базы данных.SQL.Сценарии и вопросы.Insert or update\. Upsert.WebHome]] (insert on conflict).
	26	+* Уровень изоляции: работает на read committed, то что нужно блокируется руками.
	27	+* Для некоторых кейсов желательно возможность выполнить upsert (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,7 +60,6 @@
60	60	См. пример 2.
61	61	)))
62	62	|(% style="width:159px" %)Перехват ошибок|(% style="width:1168px" %)Перехват и обработка ошибок, если процесс выкинул exception в движок. Реализацию простого retry с задержкой (создается триггер на следующую попытку).
63		-В случае пакетной транзакции движок не знает какой конкретно из процессов породил ошибку (если она не перехвачена вручную), то ошибка выставляется на все незавершенные процессы.
64	64	|(% style="width:159px" %)Параллельное выполнение|(% style="width:1168px" %)Допускается запуск нескольких раннеров (на разных нодах), работающих с одной таблицей процессов для распределения нагрузки между ними.
65	65	Допускается фильтрация типов процессов между нодами (чтобы нода выполняла только определенные типы процессов, в том числе по приоритету).
66	66	Доступно для раннеров процессов и триггеров.
...	...	@@ -99,19 +99,11 @@
99	99	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
100	100	)))
101	101	|(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
102		-|(% style="width:870px" %)(((
103		-
104	104	)))
105		-)))
106	106	|(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]]
107	107	|(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)(((
108		-|(% style="width:94px" %) |(% style="width:1002px" %)(((
109		-* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
110		-* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
111		-За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
112		-* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
113		-* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
114		-)))
	104	+|(% style="width:94px" %) |(% style="width:1002px" %)Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
	105	+Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
115	115	|(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)(((
116	116	* При получении события о засыпании процесса:
117	117	Фиксирует смещение процесса обработки и сравнивает со смещением сообщения.
...	...	@@ -121,6 +121,7 @@
121	121	Если процесс не спит (по флагу в триггере), то ничего не делает.
122	122	Если процесс спит (по флагу), то пробуждает процесс.
123	123
	115	+
124	124	Отслеживает смещение обработки процесса и последнего события.
125	125	Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать.
126	126	Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса.
...	...	@@ -130,26 +130,4 @@
130	130	)))
131	131	)))
132	132
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		-----
	125	+

TransactionOutbox. Sequence.jpg

Author

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

Размер

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

Содержимое