Изменения документа Примеры
Редактировал(а) Alexandr Fokin 2026/08/26 19:05
От версии 8.32
отредактировано Alexandr Fokin
на 2026/07/27 20:17
на 2026/07/27 20:17
Изменить комментарий:
К данной версии нет комментариев
К версии 8.27
отредактировано Alexandr Fokin
на 2026/07/27 03:29
на 2026/07/27 03:29
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -62,7 +62,7 @@ 62 62 * Если сигналов нет, то нет пустых срабатываний в отличие от варианта 2 (т.к. нет поступления сигнала от дочерних процессов). 63 63 ))) 64 64 |((( 65 -|Вариант №5: Trigger + Счетчик в [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]].65 +|Вариант №5: Trigger + Счетчик в Redis. 66 66 |InMemory счетчик, нагрузка на БД и конкуренция. 67 67 Дочерний процесс уменьшает счетчик. И публикует событие только если счетчик достиг 0. 68 68 |((( ... ... @@ -70,24 +70,16 @@ 70 70 71 71 Возможно: 72 72 73 -1. В начале транзакции (или шага) атомарно проверяем MemberSet, если есть запись то удаляем и увеличиваем счетчик на 1. 74 -1. До коммита транзакции атомарно добавляем значение в MemberSet и уменьшаем счетчик на 1. Если счетчик равен 0, то публикуем TriggerEvent. 75 -1. После коммита транзакции удаляем запись из MemberSet. 76 -1. Trigger получает событие. (Необязательно) в хендлере может првоерить значения счетчиков и MemberSet. 73 +1. До коммита транзакции уменьшаем счетчик и записываем id дочернего процесса в redis hashset. Если счетчик 0, то публикуем triggerEvent через TransactionalOutbox. 74 +(На старте транзакции проверить и удалить из HashSet и если удалили, то увеличить счетчик на 1 - значит была упавшая транзакция). 75 +1. После коммита транзакции удаляем id дочернего процесса из redis hashset. 76 +1. Trigger при получении события смотрит значение счетчика и HashSet. 77 +Если счетчик 0 и HashSet пустой, то скорее всего все корректно и триггер может активироваться. 78 +Иначе если HashSet не пустой, то можно попытаться проверить статус процесса (если он завершен, то можно удалить значение из HashSet). 77 77 ))) 78 -|((( 79 -В случае обнаружения повреждения обработка фактически переходит в режим 1.4: начинает публиковать событий каждый раз и используется задержка. 80 - 81 -Примеры проблемы: 82 - 83 -* Падение InMemory хранилища. Предполагается режим без снимков и удаление ключей. 84 -Обнаружение (со стороны дочернего процесса) через отсутствие ключей (проверяется в транзакции). 85 -* Дублирование обновления счетчика. 86 -Обнаружение (со стороны дочернего процесса) через значение счетчика < 0. 87 -Обнаружение (со стороны триггера) через активацию триггера (поступления сигнала от процесса), при этом обнаруживается что не все процессы завершены. 80 +|Проблемы: Потеря счетчика целиком или искажения значения в случае падения Redis. 88 88 ))) 89 89 ))) 90 -))) 91 91 |2|(% style="width:188px" %)Transaction outbox stream process.|(% style="width:1268px" %)[[image:TransactionOutbox. Sequence.jpg]] 92 92 |3|(% style="width:188px" %)Stream trigger|(% style="width:1268px" %)((( 93 93 | |(((