Перейти к содержимому

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

Редактировал(а) Alexandr Fokin 2026/04/27 13:28
От версии 24.1
отредактировано Alexandr Fokin
на 2026/04/10 19:43
Изменить комментарий: Загрузить новое вложение Родительский дочерний процесс. Sequence.graphml
К версии 27.8
отредактировано Alexandr Fokin
на 2026/04/11 00:21
Изменить комментарий: К данной версии нет комментариев

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -98,11 +98,27 @@
98 98  Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
99 99  )))
100 100  |(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
101 +|(% style="width:870px" %)(((
102 +Возможен вариант №2, когда мы просто ставит timerTrigger на условно 1-5 минуту (насколько важна задержка) и перепроверяем условие завершения (по нагрузке на БД будет еще меньше). Из минус, что родительский процесс узнает о завершении дочерних процессов с задержкой (хотя в задержке можно использовать функцию от количества необработанных дочерних процессов, но тогда нужно считать количество).
103 +
104 +* Но тут будет join нагрузка на БД (если шаг проверки выполняется пакетно), иначе будет просто много одиночны запросов на чтение (условно раз в минуту).
105 +* Если дочерний процесс остановиться в ошибке, то родительский либо также продолжит крутиться в проверке, либо должен также пробросить ошибку в себя чтобы приостановиться.
106 +В случае с решением 1, со страхующим триггером это можно обойти через фильтрующий индекс если мы начинаем идти сразу с таблицы процессов (т.е. процессы с ошибкой сразу будут игнорироваться).
107 +* Но все равно, именно данный движек может позволить настроить 2 процесса таким образом, что 1 процесс будет исполняться (1 процесс - 1 транзакция) в параллельном режиме (пока создаются множественные дочерние процессы), 2 процесс будет исполняться в пакетном режиме (N процессов - 1 транзакция) чтобы проверять выполнение условия завершения дочерних процессов через запрос (один пакетный).
108 +
109 +плюсы: меньше пишущей нагрузки (т.к. триггер со счетчиком будет делать условно одну запись на процесс в 5-20 секунд), а тут будет одна запись в 1-5 минуту на обновление таймера.
110 +минусы: больше читающей нагрузки с join (раз 1-5 минуту нужно будет выполнить join незавершенных процессов с дочерними). У решения 1 тоже есть такая нагрузка, но на страхующем триггер (условно раз 10-30 минут) и процессы упавшие в ошибку не будут генерировать нагрузку (если фильтрующий индекс).
101 101  )))
112 +)))
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 значение).
115 +|(% style="width:94px" %) |(% style="width:1002px" %)(((
116 +* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
117 +* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
118 +За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
119 +* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
120 +* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
121 +)))
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 -
140 +----
141 +
142 +==== Внутренние ссылки: ====
143 +
144 +====== Дочерние страницы: ======
145 +
146 +{{children/}}
147 +
148 +====== Обратные ссылки: ======
149 +
150 +{{velocity}}
151 +#set ($links = $doc.getBacklinks())
152 +#if ($links.size() > 0)
153 + #foreach ($docname in $links)
154 + #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
155 + * [[$escapetool.xml($rdoc.fullName)]]
156 + #end
157 +#else
158 + No back links for this page!
159 +#end
160 +{{/velocity}}
161 +
162 +----
TransactionOutbox. Sequence.graphml
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.cccc1808
Размер
... ... @@ -1,0 +1,1 @@
1 +33.6 KB
Содержимое
TransactionOutbox. Sequence.jpg
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.cccc1808
Размер
... ... @@ -1,0 +1,1 @@
1 +247.1 KB
Содержимое
Родительский дочерний процесс. Sequence.jpg
Author
... ... @@ -1,0 +1,1 @@
1 +XWiki.cccc1808
Размер
... ... @@ -1,0 +1,1 @@
1 +247.1 KB
Содержимое