Однонаправленная репликация между двумя базами (постановка)
SYSDBA (обсуждение | вклад) |
SYSDBA (обсуждение | вклад) |
||
| Строка 1: | Строка 1: | ||
| − | Рассмотрим вариант однонаправленной репликации между двумя базами A и B. База B работает в режиме только для чтения | + | Рассмотрим вариант однонаправленной репликации между двумя базами A и B. Все изменения осуществляются на базе A. База B работает в режиме только для чтения. В дальнейшем, мы будем использовать термины "Удаленная база данных (УБД)" для базы А и "Центральная база данных (ЦБД)" для B. |
Базы обмениваются между собой сообщениями. Канал связи между базами может быть непостоянным. Т.е. база A может посылать сообщения в тот момент, когда база B недоступна и наоборот. Порядок выполнения действий над объектами на базе A должен сохраняться при переносе на базу B. Транспорт передачи сообщений не гарантирует нам ни сохранности и целости конкретного сообщения, ни сохранения порядка при передаче нескольких сообщений. | Базы обмениваются между собой сообщениями. Канал связи между базами может быть непостоянным. Т.е. база A может посылать сообщения в тот момент, когда база B недоступна и наоборот. Порядок выполнения действий над объектами на базе A должен сохраняться при переносе на базу B. Транспорт передачи сообщений не гарантирует нам ни сохранности и целости конкретного сообщения, ни сохранения порядка при передаче нескольких сообщений. | ||
| − | |||
| − | |||
Фиксирование изменений, произведенных в базе A, осуществляется в логе, специальной таблице. В логе фиксируется: | Фиксирование изменений, произведенных в базе A, осуществляется в логе, специальной таблице. В логе фиксируется: | ||
| Строка 12: | Строка 10: | ||
Заполнение лога осуществляется с помощью системы триггеров. | Заполнение лога осуществляется с помощью системы триггеров. | ||
| − | + | Мы будем называть целое число S состоянием базы данных. Базы данных А и B находятся в идентичном состоянии, если S<sub>a</sub>=S<sub>b</sub> и очередь сообщений пуста. | |
| + | |||
| + | В начальный момент времени базы данных находятся в идентичном состоянии. | ||
Первоначальное состояние -- L (Logged). Записи с таким статусом считаются подготовленными к отправке. | Первоначальное состояние -- L (Logged). Записи с таким статусом считаются подготовленными к отправке. | ||
| − | Объект может быть заблокирован, состояние B (Blocked) | + | Объект может быть заблокирован, состояние B (Blocked). В этом случае он не передается, а так как мы не можем нарушать последовательность выполнения операций на конечной базе данных, то нет смысла передавать операции после заблокированной записи. Пользователь должен быть уведомлен о том, какая именно заблокированная запись вызвала остановку процедуры передачи данных. |
Поскольку мы не храним полного состояния объекта в логе, а только ссылку на него, то любое последующее изменение объекта должно быть заблокировано, пока предыдущие изменения не будут успешно переданы на конечную базу данных. Исключение составляют два и более последовательных изменения одного и того же объекта. | Поскольку мы не храним полного состояния объекта в логе, а только ссылку на него, то любое последующее изменение объекта должно быть заблокировано, пока предыдущие изменения не будут успешно переданы на конечную базу данных. Исключение составляют два и более последовательных изменения одного и того же объекта. | ||
| Строка 26: | Строка 26: | ||
Последовательность обмена сообщениями между исходной и конечной базами данных выглядит следующим образом: | Последовательность обмена сообщениями между исходной и конечной базами данных выглядит следующим образом: | ||
| − | # | + | # База А проверяет очередь сообщений, поступивших от базы B. |
| + | ## Если очередь пуста проверяется лог. При наличии записей в состоянии L для каждой из них формируется отдельное сообщение для передачи на базу B. | ||
# Конечная база данных проверяет наличие сообщений в очереди. При наличии сообщений они сортируются в порядке возрастания номера. Проверяется номер первого сообщения. | # Конечная база данных проверяет наличие сообщений в очереди. При наличии сообщений они сортируются в порядке возрастания номера. Проверяется номер первого сообщения. | ||
## Если он соответствует ожидаемому, то происходит считывание и обработка сообщения. | ## Если он соответствует ожидаемому, то происходит считывание и обработка сообщения. | ||
Версия 21:02, 16 августа 2009
Рассмотрим вариант однонаправленной репликации между двумя базами A и B. Все изменения осуществляются на базе A. База B работает в режиме только для чтения. В дальнейшем, мы будем использовать термины "Удаленная база данных (УБД)" для базы А и "Центральная база данных (ЦБД)" для B.
Базы обмениваются между собой сообщениями. Канал связи между базами может быть непостоянным. Т.е. база A может посылать сообщения в тот момент, когда база B недоступна и наоборот. Порядок выполнения действий над объектами на базе A должен сохраняться при переносе на базу B. Транспорт передачи сообщений не гарантирует нам ни сохранности и целости конкретного сообщения, ни сохранения порядка при передаче нескольких сообщений.
Фиксирование изменений, произведенных в базе A, осуществляется в логе, специальной таблице. В логе фиксируется:
- тип и идентификатор объекта,
- вид операции (создание, изменение, удаление),
- порядковый номер изменения,
- состояние записи.
Заполнение лога осуществляется с помощью системы триггеров.
Мы будем называть целое число S состоянием базы данных. Базы данных А и B находятся в идентичном состоянии, если Sa=Sb и очередь сообщений пуста.
В начальный момент времени базы данных находятся в идентичном состоянии.
Первоначальное состояние -- L (Logged). Записи с таким статусом считаются подготовленными к отправке.
Объект может быть заблокирован, состояние B (Blocked). В этом случае он не передается, а так как мы не можем нарушать последовательность выполнения операций на конечной базе данных, то нет смысла передавать операции после заблокированной записи. Пользователь должен быть уведомлен о том, какая именно заблокированная запись вызвала остановку процедуры передачи данных.
Поскольку мы не храним полного состояния объекта в логе, а только ссылку на него, то любое последующее изменение объекта должно быть заблокировано, пока предыдущие изменения не будут успешно переданы на конечную базу данных. Исключение составляют два и более последовательных изменения одного и того же объекта.
На конечной базе данных также ведется лог принятых сообщений. Как и в случае с базой А, каждая запись в логе имеет определенное состояние.
Запись об успешно принятом объекте имеет состояние R (Received).
Последовательность обмена сообщениями между исходной и конечной базами данных выглядит следующим образом:
- База А проверяет очередь сообщений, поступивших от базы B.
- Если очередь пуста проверяется лог. При наличии записей в состоянии L для каждой из них формируется отдельное сообщение для передачи на базу B.
- Конечная база данных проверяет наличие сообщений в очереди. При наличии сообщений они сортируются в порядке возрастания номера. Проверяется номер первого сообщения.
- Если он соответствует ожидаемому, то происходит считывание и обработка сообщения.
- Если номер первого сообщения в очереди меньше ожидаемого, то просто игнорируем его (удаляем).
- Если номер первого сообщения в очереди больше ожидаемого, то посылаем запрос на пересылку сообщений с нужными номерами. Останавливаем дальнейшую обработку очереди. Ждем ответа от исходной базы.
