Двунаправленная репликация между двумя базами (постановка) - История изменений

SYSDBA: /* Лог изменений */

2009-09-10T16:23:00Z

‎Лог изменений

SYSDBA: /* Передача статуса активной базы данных */

2009-09-10T09:30:31Z

‎Передача статуса активной базы данных

SYSDBA: /* АБД */

2009-09-10T09:28:03Z

‎АБД

SYSDBA: /* Блокировка рекурсивных записей в логе */

2009-09-09T10:19:26Z

‎Блокировка рекурсивных записей в логе

SYSDBA: /* Разрывность последовательности номеров изменений */

2009-09-09T09:47:41Z

‎Разрывность последовательности номеров изменений

SYSDBA: /* НБД */

2009-09-09T09:45:05Z

‎НБД

SYSDBA: /* Соответствие номера изменения */

2009-09-09T09:39:19Z

‎Соответствие номера изменения

SYSDBA: /* Структура сообщения */

2009-09-09T09:35:42Z

‎Структура сообщения

SYSDBA: /* Лог изменений */

2009-09-09T08:39:13Z

‎Лог изменений

SYSDBA: /* Изменение объекта и регистрация изменения на одной транзакции */

2009-09-09T08:24:33Z

‎Изменение объекта и регистрация изменения на одной транзакции

@@ Строка 64: / Строка 64: @@
 * целочисленный порядковый номер изменения (начиная с единицы),
-* идентификатор объекта,
+* идентификатор объекта (RUID),
 * тип объекта,
 * вид операции (создание, изменение, удаление),

@@ Строка 171: / Строка 171: @@
 ## Если за время T<sub>r</sub> ответ не получен, то в журнал заносится соответствующее событие и повторяется последовательность действий начиная с п.1.
-Если АБД получила этот статус на ограниченное время, то по его истечении:
+=== Если АБД получила статус активности на ограниченное время ===
 # Все изменения отсылаются на НБД.
 # Ожидается подтверждение передачи всех изменений.
 # После его получения отсылается сообщение '''"Передача статуса АБД"'''.

@@ Строка 200: / Строка 200: @@
 ### Если запрашиваемый объект находится в состоянии S, то передаем его на ЦБД. Удаляем сообщение из очереди и продолжаем обрабатывать список. Помещаем в журнал информацию о повторной передаче объекта.
 ### Если запрашиваемый объект находится в состоянии L или C, или вообще отсутствует в списке, то игнорируем сообщение и удаляем его из очереди, а в журнал помещаем запись с информацией о запросе на передачу ранее переданного и подтвержденного объекта.
 === НБД ===

← Предыдущая		Версия 10:19, 9 сентября 2009
Строка 283:		Строка 283:

	При переносе объекта с АБД необходимо предусмотреть механизм, чтобы в лог НБД не попадала запись о его изменении и не срабатывал механизм блокировки редактирования объектов на НБД.		При переносе объекта с АБД необходимо предусмотреть механизм, чтобы в лог НБД не попадала запись о его изменении и не срабатывал механизм блокировки редактирования объектов на НБД.
		+
		+	=== Синхронизация генераторов при переносе изменений ===
		+
		+	Так как номер изменения, которое передается АБД на НБД может более чем на единицу отличаться от последнего номера изменения в логе НБД, мы должны соответствующим образом инкрементировать генератор НБД.

	[[Category:Постановка]]		[[Category:Постановка]]

← Предыдущая		Версия 09:47, 9 сентября 2009
Строка 77:		Строка 77:

	N<sub>i + 1</sub> - N<sub>i</sub> >= 1		N<sub>i + 1</sub> - N<sub>i</sub> >= 1
		+
		+	Мы не можем гарантировать неразрывность последовательности номеров изменений, так как при физической реализации для нумерации будет использован генератор, инкремент которого происходит вне контекста транзакции.

	=== Соответствие номера изменения ===		=== Соответствие номера изменения ===

@@ Строка 215: / Строка 215: @@
 # Очередь не пуста.
 ## Сортируем сообщения в порядке номеров. Выкидываем все сообщения '''"Состояние БД"''', которые идут в начале, в середине, но не в конце очереди. Обрабатываем в порядке очередности.
-### Если номер изменения первого сообщения в очереди равен S<sub>НБД</sub> + 1, то загружаем объект. Удаляем текущее сообщение и продолжаем обрабатывать очередь.
+### Если номер предыдущего изменения из первого сообщения в очереди равен S<sub>НБД</sub>, то загружаем объект. Удаляем текущее сообщение и продолжаем обрабатывать очередь.
-### Если номер изменения первого сообщения в очереди меньше S<sub>НБД</sub> + 1, то игнорируем такое сообщение. Удаляем его и продолжаем обрабатывать очередь. В журнал помещаем запись о несанкционированной повторной передаче уже принятого объекта.
+### Если номер предыдущего изменения из первого сообщения в очереди меньше S<sub>НБД</sub>, то игнорируем такое сообщение. Удаляем его и продолжаем обрабатывать очередь. В журнал помещаем запись о несанкционированной повторной передаче уже принятого объекта.
-### Если номер изменения первого сообщения в очереди больше S<sub>НБД</sub> + 1, то прекращаем обработку очереди. Текущее сообщение не удаляем. На АБД отсылаем сообщение '''"Запрос на передачу объекта"''', где указываем диапазон изменений, которые нас интересуют: с S<sub>НБД</sub> до номера изменения первого сообщения в очереди, не включая границы.
+### Если номер предыдущего изменения из первого сообщения в очереди больше S<sub>НБД</sub>, то прекращаем обработку очереди. Текущее сообщение не удаляем. На АБД отсылаем сообщение '''"Запрос на передачу объекта"''', где указываем диапазон изменений, которые нас интересуют: с S<sub>НБД</sub> до номера изменения первого сообщения в очереди, не включая границы.
 ## По окончании обработки очереди (не важно, полной или частичной), отсылаем на АБД сообщение '''"Подтверждение передачи объектов"''' с указанием номеров изменений, успешно записанных в НБД.
 ## При возникновении конфликта записи объекта в НБД останавливаем обработку очереди. В лог НБД заносим пометку номера изменения и ставим ему статус F. Информируем системного администратор о серьезном сбое репликации.

← Предыдущая		Версия 09:39, 9 сентября 2009
Строка 71:		Строка 71:

	В дальнейшем, символом N мы будем обозначать номер изменения, а символом М -- максимальный номер изменения в логе. М принимается равным нулю, если лог пуст.		В дальнейшем, символом N мы будем обозначать номер изменения, а символом М -- максимальный номер изменения в логе. М принимается равным нулю, если лог пуст.
		+
		+	=== Разрывность последовательности номеров изменений ===
		+
		+	Номера последовательных изменений не обязательно являются последовательными целыми числами, но всегда идут в возрастающем порядке:
		+
		+	N<sub>i + 1</sub> - N<sub>i</sub> >= 1

	=== Соответствие номера изменения ===		=== Соответствие номера изменения ===

@@ Строка 231: / Строка 231: @@
 ** '''"Передача объекта"'''
 *** Номер изменения в логе.
 *** Поток данных объекта.
 ** '''"Запрос подтверждения передачи объекта"'''

← Предыдущая		Версия 08:39, 9 сентября 2009
Строка 71:		Строка 71:

	В дальнейшем, символом N мы будем обозначать номер изменения, а символом М -- максимальный номер изменения в логе. М принимается равным нулю, если лог пуст.		В дальнейшем, символом N мы будем обозначать номер изменения, а символом М -- максимальный номер изменения в логе. М принимается равным нулю, если лог пуст.
		+
		+	=== Соответствие номера изменения ===
		+
		+	Важно отметить, что в логах обоих баз фиксация изменения состояния одного и того же объекта проходит под '''одинаковым номером'''. Например, на АБД создан объект О.
		+	# В лог АБД будет помещена запись с номером Х, состояние L.
		+	# В процессе сеанса обмена сообщениями, объект О будет подготовлен для передачи на НБД. Запись с номером Х в логе АБД, перейдет в состояние S.
		+	# НБД успешно примет объект. В логе НБД появится запись с таким же номером Х в состоянии R.
		+	# На АБД уйдет подтверждение.
		+	# По принятии подтверждения, запись с номером Х в логе АБД перейдет в состояние C.

	== Состояние базы данных ==		== Состояние базы данных ==

← Предыдущая		Версия 08:24, 9 сентября 2009
Строка 261:		Строка 261:

	Во избежание рассинхронизации реального состояния объекта с информацией в логе, изменение объекта и регистрация в логе его нового состояния должны происходить на одной транзакции.		Во избежание рассинхронизации реального состояния объекта с информацией в логе, изменение объекта и регистрация в логе его нового состояния должны происходить на одной транзакции.
		+
		+	=== Блокировка рекурсивных записей в логе ===
		+
		+	При переносе объекта с АБД необходимо предусмотреть механизм, чтобы в лог НБД не попадала запись о его изменении и не срабатывал механизм блокировки редактирования объектов на НБД.

	[[Category:Постановка]]		[[Category:Постановка]]