Система обработки данных
Изобретение относится к вычислительной технике. Технический результат заключается в обеспечении высокоскоростной обработки. Система обработки данных содержит множество серверов AP и множество серверов DB. Каждый сервер DB включает в себя общую таблицу для хранения коммерческих данных. Каждая таблица имеет ограничение для запрета удаления и обновления записей. Каждый сервер AP соединен со всеми серверами DB, выполняет общую коммерческую обработку, отправляет коммерческие данные в качестве результата обработки каждому серверу DB и запрашивает добавление в соответствующую таблицу. ID, включающий в себя код идентификации сервера AP, выполнившего обработку, присваивается каждым коммерческим данным. Каждый сервер DB хранит таблицу определения ответственной AP для определения сервера AP, ответственного за конкретную коммерческую обработку, которая требует исключительного управления. В случае обработки, которая требует исключительного управления, каждый сервер AP задает ответственный сервер AP посредством обращения к таблице определения ответственной AP и делегирует обработку этому серверу AP. Ответственный сервер AP сохраняет коммерческую обработку в очереди и затем последовательно выполняет обработку в соответствии с правилом FIFO. 2 з.п. ф-лы, 11 ил.
Область техники, к которой относится изобретение
[0001] Изобретение относится к системе обработки данных, и в частности, относится к технологии администрирования с перекрытием, посредством множества серверов DB, коммерческих данных, генерируемых множеством серверов AP.
Уровень техники
[0002] Для того, чтобы подготовиться к случаю физического повреждения базы данных от крупномасштабных катастроф, таких как землетрясение, цунами, и извержение, или от техногенных катастроф, таких как авария на АЭС или терроризм, базовая система в компании заблаговременно регистрирует с перекрытием коммерческие данные в базе данных для резервного дублирования, установленной в удаленном месте.
Например, Патентный Документ 1 раскрывает технологию в виде, после регистрации данных на дисковом устройстве основного устройства управления, отправки точно таких же данных вспомогательному устройству управления, установленному в удаленном месте, и запроса ее регистрации.
Патентный Документ 1: Японский Выложенный Патент № 11-85408
Непатентный Документ 1: Guide of Web system/First Structure of Web Site and J2EE Server
Интернет URL: http://www.atmarkit.co.jp/fjava/rensai2/websys01/websys01.html
Дата поиска: 10 марта 2015г.
Непатентный Документ 2: Two-phase Commitment
Интернет URL: http://e-words.jp/w/2%E3%83%95%E3%82%A7%E3%83%BC%E3%82%BA%E3%82%B3%E3%83%9F%E3%83%83%E3%83%88.html
Дата поиска: 10 марта 2015г.
Сущность изобретения
Задачи, решаемые изобретением
[0003] Как упомянуто выше, данные дважды удерживаются двумя устройствами управления: основным и вспомогательным. Как следствие, даже в случае, когда происходит землетрясение в одной зоне и дисковое устройство физически разрушается, используются данные на другом оставшемся работоспособным дисковом устройстве, тем самым гарантируя непрерывность коммерческой обработки.
Кроме того, предполагается сбой или неисправность самого серверного компьютера. Вследствие этого, желательно подготовиться к непредвиденной ситуации посредством дублирования сервера базы данных на регулярной основе не только в удаленном месте, но также и на том же самом месте.
[0004] К тому же, когда обработка обновления исполняется для множества баз данных, между данными генерируется противоречие, если не создается фиксация всех баз данных. Вследствие этого, сохраняется согласованность между базами данных посредством постоянного применения системы регулирования, именуемой двухфазной фиксацией интерфейса XA.
[0005] С помощью двухфазной фиксации, главный сервер, который первым выполняет всю обработку, выдает запрос касательно того, может ли быть исполнена фиксация, каждому серверу DB как целевому. Сервер DB, для которого подготовка обновления закончена, отправляет ответ, указывающий «завершение подготовки», главный сервер, после проверки того, что все серверы DB закончили подготовку, выдает уведомление для запуска фиксации, и все базы данных разом перезаписываются. В случае, когда происходит нарушение в любой базе данных во время перезаписи, сервер DB, в котором произошло нарушение выдает уведомление о сбое, и главный сервер выдает уведомление об аннулировании обработки всем серверам и дополнительно выдает инструкции на выполнение «отката» обработки, чтобы восстановить данные (см. Непатентный Документ 2).
[0006] Применение такой двухфазной фиксации позволяет гарантировать согласованность данных среди серверов DB и надежно избегать возникновение недопустимых данных.
Тем не менее, необходимо часто повторять обмен данными между главным сервером и сервером DB, установленным в удаленном месте. Вследствие этого, неизбежно жертвуют высокоскоростной обработкой. Следовательно, это эффективно для коммерческой обработки, такой как транзакция ATM, при которой время ожидания в несколько секунд неважно. Тем не менее, существует проблема в том, что это неприменимо для коммерческой обработки, такой как онлайн-торговля, при которой недопустима задержка менее одной секунды.
[0007] Настоящее изобретение разработано в обстановке, и его цель состоит в реализации технологии для обеспечения гарантии высокоскоростной обработки, при этом предполагая закрепление тех же самых данных во множестве серверов DB.
Средство для решения задачи
[0008] Для того чтобы добиться цели, система обработки данных по пункту 1 формулы изобретения является системой обработки данных, включающей в себя множество серверов AP и множество серверов DB, при этом каждый из серверов DB включает в себя таблицу для хранения коммерческих данных, которые являются общими по отношению друг к другу, причем каждая таблица имеет ограничение, допускающее только обращение к и добавление записи и запрещающее ее удаление и обновление, причем каждый из серверов AP соединен с каждым из серверов DB и имеет функцию для выполнения общей коммерческой обработки по запросу, отправленному с клиентского терминала, и функцию для отправки коммерческих данных, сгенерированных в результате обработки, каждому из серверов DB и запрашивания дополнительной регистрации в соответствующей таблице, причем каждому фрагменту коммерческих данных присваивается уникальный ID, включающий в себя код идентификации для указания сервера AP, который сгенерировал этот фрагмент коммерческих данных, причем каждый из серверов DB дополнительно хранит таблицу определения ответственной AP, которая определяет, для каждой коммерческой обработки, сервер AP, ответственный за конкретную коммерческую обработку, которая требует исключительного управления, причем каждый из серверов AP самостоятельно выполняет коммерческую обработку, когда запрос коммерческой обработки, отправленный с клиентского терминала, не требует исключительного управления, и, напротив, когда запрос требует исключительного управления, обращается к таблице определения ответственной AP, задает сервер AP, который должен брать на себя ответственность за коммерческую обработку, и затем делегирует соответствующую обработку ответственному серверу AP, и ответственный сервер AP, который принял это, сразу сохраняет делегированную коммерческую обработку в очереди и затем последовательно выполняет каждую коммерческую обработку в очереди в соответствии с правилом FIFO.
[0009] Система обработки данных по пункту 2 формулы изобретения является системой пункта 1 формулы изобретения, и дополнительно, не только ответственный основной сервер AP, но также ответственный вспомогательный сервер AP, который должен брать на себя ответственность за обработку, когда ответственный основной сервер AP не функционирует, определяется в таблице определения ответственной AP для каждой коммерческой обработки.
[0010] Система обработки данных по пункту 3 формулы изобретения является системой пункта 1 или 2 формулы изобретения, и дополнительно, отметка времени, когда коммерческая обработка исполняется, проставляется в каждом фрагменте коммерческих данных, и сервер AP, когда требуется обновить существующие коммерческие данные, вновь генерирует коммерческие данные, включающие в себя возрастающий ID, отличный от коммерческих данных, данные после коррекции, и отметку времени во время коррекции, и по существу обновляет существующие коммерческие данные дополнительно регистрируя коммерческие данные для обновления в соответствующей таблице, предоставленной в каждом сервере DB.
[0011] Система обработки данных по пункту 4 формулы изобретения является системой пунктов с 1 по 3 формулы изобретения, и дополнительно, сервер AP, когда требуется удалить существующие коммерческие данные, генерирует коммерческие данные для аннулирования данных с элементом данных, который хранит ID коммерческих данных в качестве цели аннулирования, и по существу удаляет существующие коммерческие данные дополнительно регистрируя коммерческие данные для аннулирования данных в таблице, предназначенной для аннулирования, предоставленной в каждом сервере DB.
Осуществление изобретения
[0012] С помощью системы обработки данных по пункту 1 формулы изобретения, коммерческие данные, генерируемые сервером AP, одновременно отправляются множеству серверов DB, и регистрируются с перекрытием в соответствующих таблицах. Вследствие этого, может быть повышено удобство сопровождения коммерческих данных.
В дополнение, в отношении регистрации коммерческих данных, когда происходит сбой, запрещены удаление и обновление данных, которые требуют сложной обработки для восстановления данных. Просто разрешены только копирование недостающих данных с другого сервера DB и только добавление для обеспечения восстановления данных. Вследствие этого, не требуется применения системы строгого регулирования, такой как двухфазная фиксация, и можно допускать завершение регистрации, когда уведомление приема просто возвращается от каждого сервера DB.
[0013] Кроме того, также подготавливается множество серверов AP. Если коммерческая обработка не требует исключительного управления, каждый сервер AP может свободно выполнять обработку. Вследствие этого, эффективность обработки всей системы может быть улучшена с помощью распределения нагрузки.
С другой стороны, в отношении части коммерческой обработки, которая требует исключительного управления, обработка консолидируется на предварительно заданном сервере AP в таблице определения ответственной AP, и обработка выполняется в соответствии с правилом FIFO. Вследствие этого, можно эффективно избегать генерирования взаимно противоречащих данных разными серверами AP.
Уникальный ID, включающий в себя код идентификации каждого сервера AP, присваивается коммерческим данным, сгенерированным в каждом сервере AP. Вследствие этого, даже если коммерческие данные раздельно отправляются серверу DB от каждого сервера AP, ID не перекрываются и сохраняется абсолютная уникальность.
[0014] В случае системы обработки данных по пункту 2 формулы изобретения, ответственный вспомогательный сервер AP также определяется в таблице определения ответственной AP в дополнение к ответственному основному серверу AP. Вследствие этого, даже если ответственный основной сервер не функционирует по некоторым причинам, коммерческая обработка может быть быстро делегирована ответственному вспомогательному серверу AP.
[0015] В изобретении, предусматривается ограничение для запрета удаления и обновления записей в таблице сервера DB. Тем не менее, посредством использования системы по пункту 3 и 4 формулы изобретения, можно реализовать существенное обновление и удаление коммерческих данных.
Предпочтительный вариант осуществления изобретения
[0016] Фиг. 1 является схемой, показывающей полную конфигурацию системы 10 обработки данных в соответствии с изобретением.
Во-первых, в первом центре 12 хранения и обработки данных (датацентре), размещенном в Токио, установлены первый сервер 14 AP, первый сервер 16 DB, и второй сервер 18 DB.
Затем, во втором центре 20 хранения и обработки данных, размещенном в Осаке, установлены второй сервер 22 AP, третий сервер 24 DB и четвертый сервер 26 DB.
[0017] Первый сервер 14 AP и второй сервер 22 AP имеют одну и ту же прикладную программу, и обладают функциональными возможностями для исполнения одной и той же коммерческой обработки в ответ на запрос, отправляемый от клиентского терминала 28 через сеть 27 связи, такую как Интернет.
[0018] Для удобства иллюстрации, нарисованы только первый сервер 14 AP и второй сервер 22 AP, но фактически, множество серверов AP с одинаковыми функциональными возможностями установлены в соответствующих центрах хранения и обработки данных, и нагрузка может быть распределена через балансировщик нагрузки (не показан).
Как упомянуто выше, предоставление множества серверов AP в одном и том же центре хранения и обработки данных делает возможным замену оставшегося сервера AP в том же самом центре хранения и обработки данных на любой из серверов AP в его запланированное время остановки или также в незапланированное время остановки без переключения на сервер AP в другом центре хранения и обработки данных, тем самым сводя к минимуму время простоя.
Количество серверов DB также не ограничивается, и три или более серверов DB могут быть установлены в каждом центре хранения и обработки данных.
[0019] Каждый из первого сервера 16 DB, второго сервера 18 DB, третьего сервера 24 DB и четвертого сервера 26 DB имеет общую таблицу, и каждая таблица хранит одни и те же данные.
Здесь, как показано на Фиг. 2, каждый сервер DB, как правило, включает в себя таблицу 50 добавления балла, таблицу 51 аннулирования добавления, таблицу 52 применения балла, таблицу 53 аннулирования применения и таблицу 54 определения ответственной AP.
[0020] Элементы данных, такие как ID добавления, счет, количество баллов и отметка времени, задаются в таблице 50 добавления балла.
Кроме того, элементы данных, такие как цель аннулирования и отметка времени, задаются в таблице 51 аннулирования добавления.
Элементы данных, такие как ID применения, счет, количество баллов, и отметка времени, задаются в таблице 52 применения балла.
Кроме того, элементы данных, такие как цель аннулирования и отметка времени, задаются в таблице 53 аннулирования применения.
Элементы данных, такие как ID определения ответственной AP, счет, основная манипулирующая AP и вспомогательная манипулирующая AP, задаются в таблице 54 определения ответственной AP.
Уникальные коды идентификации с суррогатным ключом сохраняются в ID добавления и ID применения (подробности будут описаны позже).
[0021] Первый сервер 14 AP соединен с первым сервером 16 DB и вторым сервером 18 DB через LAN, и также соединен с третьим сервером 24 DB и четвертым сервером 26 DB, установленными во втором центре 20 хранения и обработки данных, через линию 29 связи.
Кроме того, второй сервер 22 AP соединен с третьим сервером 24 DB и четвертым сервером 26 DB через LAN, и также соединен с первым сервером 16 DB и вторым сервером 18 DB, установленными в первом центре 12 хранения и обработки данных, через линию 29 связи.
[0022] В обычное время, клиентский терминал 28, установленный в восточной Японии, соединяется с первым сервером 14 AP, установленным в первом центре 12 хранения и обработки данных, и клиентский терминал 28, установленный в западной Японии, соединяется со вторым сервером 22 AP, установленным во втором датацентре 20.
[0023] С другой стороны, когда происходит крупномасштабное землетрясение в столичной зоне Токио и первый центр 12 хранения и обработки данных сильно повреждается, например, посредством изменения установки сервера DNS (не показано), получатель соединения клиентского терминала 28, установленного в восточной Японии, переключается на второй сервер 22 AP, установленный во втором центре 20 хранения и обработки данных. Вследствие этого, гарантируется неразрывность услуг для пользователя в восточной Японии.
Сходным образом, когда страдает второй центр 20 хранения и обработки данных, получатель соединения клиентского терминала 28, установленного в западной Японии, переключается на первый сервер 14 AP, установленный в первом центре 12 хранения и обработки данных.
[0024] Как упомянуто выше, каждый центр хранения и обработки данных предоставляет услуги ближайшему клиентскому терминалу 28 в нормальное время. С другой стороны, услуги также предоставляются клиентским терминалам 28 по всей Японии во время бедствия. Вследствие этого, как упомянуто выше, каждому серверу DB требуется взаимно фиксировать данные с одним и тем же содержимым на регулярной основе.
Кроме того, поскольку множество серверов DB с одними и теми же данными также установлены в одном и том же центре хранения и обработки данных, сервер AP может запрашивать извлечение данных у произвольного сервера DB, при обращении к данным, и нагрузка может быть распределена.
[0025] Количество центров хранения и обработки данных не ограничивается двумя, предпочтительно, как можно большее количество центров хранения и обработки данных предоставляется местам. Множество серверов AP с одинаковой функцией установлено в каждом месте, и серверы AP предпочтительно соединены со всеми серверами DB, установленными в каждом центре хранения и обработки данных через сеть связи.
[0026] Фиг. 3 показывает внутренние конфигурации первого сервера 14 AP и второго сервера 22 AP, и каждый включает в себя блок 30 коммерческой обработки, блок 32 администрирования суррогатного ключа, блок 34 управления данными и множество блоков 38 соединения DB.
[0027] Блок 30 коммерческой обработки исполняет обработку по генерированию и обработку по вычислению данных в ответ на запрос от клиентского терминала 28, обработку регистрации на сервере DB и подобное. CPU у сервера AP работает в соответствии со специализированной прикладной программой, тем самым реализуя блок 30 коммерческой обработки.
[0028] Блок 32 администрирования суррогатного ключа обладает функцией для выдачи суррогатного ключа в ответ на запрос от блока 30 коммерческой обработки (подробности будут описаны позже).
CPU у сервера AP работает в соответствии со специализированным межплатформенным программным обеспечением, тем самым реализуя блок 32 администрирования суррогатного ключа.
[0029] Блок 34 управления данными копирует данные некоторое количество раз, соответствующее количеству серверов DB, при приеме команды на регистрацию данных от блока 30 коммерческой обработки, и обладает функцией пропуска каждых скопированных данных к блоку 38 соединения DB. CPU у сервера AP работает в соответствии со специализированным межплатформенным программным обеспечением, тем самым реализуя блок 34 управления данными.
Кроме того, блок 34 управления данными также обладает функцией для предписания обновления данных администрирования суррогатного ключа ответственному блоку 38 соединения DB каждого сервера DB, установленного в одном и том же центре хранения и обработки данных, в ответ на команду блока 32 администрирования суррогатного ключа (подробности будут описаны позже).
[0030] Каждый блок 38 соединения DB обладает функцией для выдачи оператора SQL серверу DB, который заранее присвоен блоку 38 соединения DB и предписывает дополнительную регистрацию и обращение к данным. CPU у сервера AP работает в соответствии со специализированным межплатформенным программным обеспечением, тем самым реализуя блок 38 соединения DB.
[0031] Здесь, будет приведено описание системы для предоставления суррогатного ключа в системе 10, на основании блок-схемы на Фиг. 4.
Сначала, блок 30 коммерческой обработки, в котором требуется сгенерировать данные в результате коммерческой обработки, объявляет таблицу и запрашивает выдачу суррогатного ключа у блока 32 администрирования суррогатного ключа (S10). В случае генерирования данных, хранящихся в таблице 50 добавления балла, запрашивается выдача суррогатного ключа для 'ID добавления'.
[0032] Блок 32 администрирования суррогатного ключа, приняв это, обращается к таблице 56 администрирования суррогатного ключа, хранящейся на сервере DB, установленном в том же самом центре хранения и обработки данных (S12), и уведомляет блок 30 коммерческой обработки о последнем суррогатном ключе, который относится к таблице 50 добавления балла (S14).
[0033] Как показано на Фиг. 5, таблица 56 администрирования суррогатного ключа включает в себя элементы данных из 'ID таблицы', 'ID сервера AP', и 'следующее значение ключа', и осуществляет администрирование последнего суррогатного ключа (следующее значение ключа) с помощью единицы из 'ID таблицы'+'сервер AP'.
[0034] Здесь, «суррогатный ключ» включает в себя цифровое значение предварительно определенной длины (например, 32-битное или 64-битное).
Кроме того, код идентификации (любое из цифровых значений от 0 до 9) для указания сервера AP, который генерирует данные, устанавливается в последнюю цифру (конец) цифровых значений.
[0035] В частности, в таблице 57 администрирования последней цифры суррогатных ключей, определяется соответствие между ID соответствующих серверов AP и цифровыми значениями от 0 до 9.
Кроме того, в таблице 58 администрирования сервера AP и таблице 59 администрирования центра обработки данных, определяется соответствие между каждым сервером AP и центром обработки данных.
Таблица 57 администрирования последней цифры суррогатных ключей, таблица 58 администрирования сервера AP и таблица 59 администрирования центра обработки данных также хранятся на сервере DB в одном и том же центре хранения и обработки данных, сходно с таблицей 56 администрирования суррогатного ключа.
[0036] Блок 32 администрирования суррогатного ключа, который закончил уведомление о последнем значении суррогатного ключа блока 30 коммерческой обработки, обновляет значение каждой записи таблицы 56 администрирования суррогатного ключа (S16).
В частности, блок 32 администрирования суррогатного ключа устанавливает 'значение, полученное добавлением единицы к цифровому значению с частью, исключающей код идентификации в последней цифре среди непосредственно-перед значений (последнее значение)' в 'следующее значение ключа' в таблице 50 добавления балла, которая относится к серверу AP.
[0037] Тем не менее, способ обновления последнего значения суррогатного ключа не ограничивается 'возрастающим', и может быть 'убывающим' для установки 'значения, полученного вычитанием единицы из цифрового значения с частью, исключающей код идентификации в последней цифре среди непосредственно-перед значений (последнее значение)'. Код идентификации сервера AP также не ограничивается цифровыми значениями 'от 0 до 9', и может использовать другие виды символов. Кроме того, код идентификации может быть вставлен в головную часть суррогатного ключа.
Кроме того, только цифровое значение, исключающее код идентификации сервера AP, сохраняется в 'следующем значении ключа' таблицы 56 администрирования суррогатного ключа, и блок 32 администрирования суррогатного ключа также может добавлять соответствующий код идентификации к последней цифре числового значения и выдавать результат блоку 30 коммерческой обработки, в момент времени выдачи суррогатного ключа.
[0038] Блок 30 коммерческой обработки, который принял последний суррогатный ключ от блока 32 администрирования суррогатного ключа, генерирует данные, полученные посредством установки суррогатного ключа в качестве ID в первичный ключ или внешний ключ (S18).
Данные отправляются всем серверам DB через блок 34 управления данными и блок 38 соединения DB, и дополнительно регистрируются в соответствующей таблице (таблица 50 добавления балла) предоставленной в каждом сервере DB.
[0039] Как упомянуто выше, уникальность обеспечивается для суррогатного ключа на основании единицы в виде 'сервер AP ×таблица', и каждый сервер AP связан с конкретным центром обработки данных в таблице 59 администрирования центра обработки данных. Вследствие этого, даже если суррогатный ключ уникальным образом выдается в каждом сервере AP, уникальность гарантируется цифровым значением последней цифры. Поскольку отсутствует опасность того, что выдаются перекрывающийся суррогатный ключ, вследствие этого надежно обеспечивается уникальность каждых данных.
[0040] Следует отметить, что запрос на выдачу суррогатного ключа, выдаваемый блоком 30 коммерческой обработки сервера AP, сразу сохраняется в очереди и затем в дальнейшем обрабатывается в соответствии с правилом FIFO (первым пришел, первым обслужен). Вследствие этого, отсутствует опасность того, что суррогатный ключ с небольшим значением ошибочно выдается данным, генерируемым позже, и обеспечивается очередность.
[0041] Данные, сгенерированные блоком 30 коммерческой обработки каждого сервера AP, сохраняются в таблице на сервере DB, как упомянуто выше. Тем не менее, ограничение для запрета удаления и запрета обновления налагается заранее на каждую таблицу.
Вкратце, в системе 10, для каждой таблицы разрешено только добавление (вставка) или обращение (выбор).
[0042] Вследствие этого, в случае, когда возникает необходимость в том, чтобы сделать недействительными существующие данные, то вместо удаления записи, новая запись добавляется в другую таблицу, тем самым реализуя равное состояние.
Например, для того, чтобы сделать недействительными данные добавления балла, показанные на Фиг. 2, данные аннулирования добавления добавляются в таблицу 51 аннулирования добавления.
ID добавления у данных добавления балла, которые должны быть сделаны недействительными, заполняется в «цели аннулирования» данных аннулирования добавления. Вследствие этого, блок 30 коммерческой обработки задает данные добавления балла, чей ID добавления зарегистрирован в таблице 51 аннулирования добавления среди данных добавления балла, зарегистрированных в таблице 50 добавления балла, в качестве данных цели-вне-подсчета.
[0043] Сходным образом, в случае когда делаются недействительными данными применения балла, данные аннулирования применения добавляются в таблицу 53 аннулирования применения.
Поскольку ID применения у данных применения балла, которые должны быть сделаны недействительными, заполняется в «цели аннулирования» данных аннулирования применения, блок 30 коммерческой обработки устанавливает данные применения балла, чей ID применения зарегистрирован в таблице 53 аннулирования применения среди данных применения балла, зарегистрированных в таблице 52 применения балла, как данные цели-вне-подсчета.
[0044] Кроме того, в случае, когда требуется коррекция зарегистрированных данных в системе 10, вместо обновления существующей записи, выполняется такое соответствие, что запись с данными после коррекции является вновь регистрируемой.
Например, в случае коррекции количества баллов у данных добавления балла, ID добавления в порядке по возрастанию отличном от ID добавления данных добавления балла вновь доставляется и данные добавления балла, полученные посредством изменения количества баллов с тем же самым счетом, добавляются в таблицу 50 добавления балла.
Отметки времени с точностью в миллисекунду проставляются в данные до коррекции и данные после коррекции, и добавляются ID добавления в другом порядке по возрастанию. Вследствие этого, блок 30 коммерческой обработки может указывать последние данные без сбоя при подсчете времени.
[0045] Как упомянуто выше, одни и те же данные хранятся на каждом сервере DB, и каждый сервер AP обладает функцией для исполнения одной и той же коммерческой обработки. Вследствие этого, услуги могут одновременно предоставляться параллельно большому количеству клиентских терминалов 28, и нагрузка всей системы 10 может быть распределена.
[0046] Тем не менее, в зависимости от содержания коммерческой обработки, существует коммерческая обработка, которая требует исключительного управления между соответствующими серверами AP.
Во-первых, исключительное управление не требуется для обработки для добавления баллов для пользователя, который купил продукты или услуги. Например, когда множество сотрудников в компании одновременно генерируют запрос на добавление балла на счет компании, то даже если выполняется одновременная параллельная обработка на множестве серверов AP, никакой проблемы не возникает.
Сходным образом, исключительного управления не требуется для обработки проверки баланса баллов для одного и того же счета.
С другой стороны, в ситуации покупки продукта посредством использования баллов, хранящихся на счету, количество хранящихся баллов ограничено. Вследствие этого, в случае одновременного запроса применения баллов параллельно, требуется исполнение исключительного управления.
[0047] Ниже, будет приведено описание системы исключительного управления после объяснения общей процедуры обработки в случае применения системы 10 к бизнесу администрирования баллов в соответствии с принципиальной схемой на Фиг. 6 и блок-схемами на Фиг. с 7 по 10.
Во-первых, когда пользователь покупает продукт в магазине и представляет карту баллов, счет (номер карты) у карты баллов и количество баллов (количество добавленных баллов), сгенерированное посредством покупки продукта, отправляются второму серверу 22 AP от клиентского терминала 28A в магазине.
[0048] Блок 30 коммерческой обработки второго сервера 22 AP, который принял запрос добавления балла (S10 на Фиг. 7), принимает выдачу ID добавления от блока 32 администрирования суррогатного ключа, и затем генерирует данные добавления балла (S12).
Далее, блок 30 коммерческой обработки запрашивает дополнительно зарегистрировать данные добавления балла в c первого сервера 14 DB по четвертый сервер 26 DB через каждый блок 38 соединения DB (S14).
С первого сервера 14 DB по четвертый сервер 26 DB, которые приняли это, сразу добавляют данные добавления балла в соответствующие таблицы 50 добавления балла.
[0049] Впоследствии, блок 30 коммерческой обработки вычисляет баланс баллов пользователя (S16).
В частности, все фрагменты данных добавления балла, ассоциированные со счетом, получаются от любого из серверов DB (S16-01 на Фиг. 8), и ID добавления извлекается из каждых данных добавления балла (S16-02).
Впоследствии, ID добавления отправляется произвольному серверу DB, и получаются соответствующие данные аннулирования добавления (S16-03).
Затем, за исключением данных добавления балла, для которых зарегистрированы данные аннулирования добавления, количества баллов оставшихся и действующих фрагментов данных добавления балла суммируются (S16-04), и тем самым фиксируется количество баллов добавления пользователя.
[0050] Впоследствии, все фрагменты данных применения балла, ассоциированные со счетом, получаются от любого из серверов DB (S16-05), и ID применения извлекается из каждых данных применения балла (S16-06).
Впоследствии, ID применения отправляется произвольному серверу DB, и получаются соответствующие данные аннулирования применения (S16-07).
Затем, за исключением данных применения балла, для которых зарегистрированы данные аннулирования применения, количества баллов оставшихся и действительных фрагментов данных применения балла суммируются (S16-08), и тем самым фиксируется количество баллов применения пользователя.
[0051] Впоследствии, все действительные баллы применения вычитаются из всех действительных баллов добавления (S16-09), и тем самым фиксируется баланс баллов на текущий выбор времени.
Баланс баллов отправляется клиентскому терминалу (S18 на Фиг. 7), и распечатывается в чеке.
[0052] С другой стороны, когда пользователь желает применить баллы в магазине, счет (номер карты) у карты баллов и количество баллов применения, соответствующих цене покупаемого продукта, отправляются второму серверу 22 AP от клиентского терминала 28B.
[0053] Блок 30 коммерческой обработки второго сервера 22 AP, который принял запрос применения балла (S30 на Фиг. 9), обращается к таблице определения ответственной AP на любом из серверов DB, и указывает ответственный сервер AP обработки применения балла у счета (S32). Затем, когда сам сервер AP случайно указывается в качестве ответственного основного сервера AP, обработка применения балла, которая будет описан позже, исполняется как есть. Тем не менее, когда другой сервер AP (например, первый сервер 14 AP) указывается в качестве ответственного сервера AP, запрос (счет, количество баллов применения, и т.д.) переносится к соответствующему серверу AP, и обработка применения балла делегируется (S34).
[0054] Первый сервер 14 AP, который принял делегирование обработки, сразу сохраняет данный запрос в очереди FIFO (S36), и последовательно исполняет обработку применения балла (S38).
Обработка применения балла в частности соблюдает следующую процедуру.
Во-первых, первый сервер 14 AP вычисляет баланс баллов счета с помощью сходной процедуры (S38-01 на Фиг. 10).
[0055] Впоследствии, данные применения балла генерируются в рамках диапазона баланса баллов (S38-02).
Например, когда баланс баллов на текущий выбор времени выше количества баллов применения на данный выбор времени, блок 30 коммерческой обработки принимает выдачу ID применения от блока 32 администрирования суррогатного ключа, и затем генерирует данные применения балла (ID применения, счет, количество баллов, и отметка времени).
Затем, запрашивается дополнительная регистрация данных применения балла во всех серверах DB (S38-03).
С другой стороны, когда баланс баллов ниже количества баллов применения на данный выбор времени, блок 30 коммерческой обработки генерирует данные применения балла, соответствующие количеству оставшихся баллов, и запрашивает дополнительную регистрацию его во всех серверах DB. В результате, баланс баллов счета соответствует нулю.
[0056] Первый сервер 14 AP, который завершил делегированную обработку применения балла, уведомляет второй сервер 22 AP о результате обработки (количество баллов применения и баланс баллов) (S40 на Фиг. 9).
[0057] Блок 30 коммерческой обработки второго сервера AP, который принял это, отправляет результат обработки клиентскому терминалу 28B (S42).
Т.е., когда балл может быть применен к общей сумме покупки, клиентский терминал 28B уведомляется о таком факте и балансе баллов.
С другой стороны, когда балл применяется только к части суммы покупки, клиентский терминал 28B уведомляется о таком факте и величине нехватки денег. В данном случае, нехватка оплачивается наличными в магазине.
[0058] Как упомянуто выше, на стадии обработки применения балла, которая требует исключительного управления, полномочия обработки делегируются от второго сервера 22 AP первому серверу 14 AP. В первом сервере 14 AP, обработка применения балла исполняется в соответствии с правилом FIFO. Вследствие этого, даже если запрос применения балла, относящийся к одному и тому же счету, отправляется от клиентского терминала 28C к первому серверу 14 AP примерно в тот же период, урегулирование конкурентных запросов осуществляется в соответствии с правилом FIFO (первым пришел, первым обслужен). Вследствие этого, можно эффективно избегать генерирования недопустимой обработки (например, фактически, несмотря на то, что баланс баллов соответствует нулю, выполняется применение баллов).
[0059] С другой стороны, в случае обработки по добавлению балла на тот же самый счет или обработки для вычисления баланса баллов, параллельная обработка выполняется множеством серверов AP. Вследствие этого, может быть улучшена эффективность с помощью распределения обработки.
[0060] Следует отметить, что не только ответственная основная AP, но также и ответственная вспомогательная AP хранится в таблице 54 определения ответственной AP. Вследствие этого, если сервер AP, предназначенный для ответственной основной AP, не функционирует, полномочия могут быть сразу делегированы ответственному вспомогательному серверу AP.
Если есть страх из-за только подготовки ответственного вспомогательного сервера AP, более низкий сервер AP, такой как ответственный вспомогательный сервер, может быть предварительно установлен.
Таблица 54 определения ответственной AP хранится на всех серверах DB. Вследствие этого, если любой из серверов DB временно не функционирует, сервер AP может точно задавать ответственный основной сервер AP или подобное из другого сервера DB.
[0061] Для того, чтобы делать исключительное управление эффективным, в прикладной программе для блока коммерческой обработки необходимо определять заранее обработку (обработку по применению балла), которая требует исключительного управления, и необязательную обработку (обработка по добавлению балла, обработка по проверке баланса баллов или подобное), которая не требует исключительного управления.
Кроме того, особая информация (URL, и т.д.) ответственного основного AP и ответственного вспомогательного AP определяется для каждого счета (или для каждой группы счетов) в таблице 54 определения ответственной AP.
[0062] Тем не менее, как описано выше, изобретение не ограничивается системой, в которой тип (обработка применения балла) коммерческой обработки, которая требует исключительного управления, определяется в прикладной программе, и соответствующее отношение между целью обработки (счетом) и сервером AP определяется на стороне таблицы 54 определения ответственной AP.
[0063] Например, как будет упомянуто ниже, в отношении множества типов коммерческой обработки, требуемое исключительное управление определяется в прикладной программе. Кроме того, ответственный основной сервер AP и ответственный вспомогательный сервер AP могут быть заданы для каждого типа коммерческой обработки в таблице определения ответственной AP.
[Установка на Стороне Прикладной Программы]
Обработка, требующая исключительного управления -> Обработка A, обработка B, обработка C
[Установка на Стороне таблицы определения ответственной AP]
Обработка A -> Ответственная Основная AP, сервер a1, Ответственная вспомогательная AP, сервер a2
Обработка B -> Ответственная Основная AP, сервер b1, Ответственная вспомогательная AP, сервер b2
Обработка C -> Ответственная Основная AP, сервер c1, Ответственная вспомогательная AP, сервер c2
[0064] В вышеприведенном, бизнес администрирования баллов показан в качестве примера. Тем не менее, сходное исключительное управление также может быть применено к другой коммерческой обработке.
Например, в случае применения к системе администрирования запасов, как показано на Фиг. 11, таблица 60 поступления, таблица 61 аннулирования поступления, таблица 62 отгрузки, таблица 63 аннулирования отгрузки, и таблица 64 определения ответственной AP предоставляются в каждом сервере DB.
[0065] Элементы данных, такие как ID поступления, код продукта, количество продуктов, и отметка времени задаются в таблице 60 поступления.
Кроме того, элементы данных, такие как цель аннулирования и отметка времени, устанавливаются в таблице 61 аннулирования поступления.
Элементы данных, такие ка ID отгрузки, код продукта, количество продуктов, и отметка времени, задаются в таблице 62 отгрузки.
Кроме того, элементы данных, такие как цель аннулирования и отметка времени, задаются в таблице 63 аннулирования отгрузки.
Элементы данных, такие как ID определения ответственной AP, код продукта, ответственная основная AP, и ответственная вспомогательная AP, задаются в таблице 64 определения ответственной AP.
Уникальные коды идентификации, использующие суррогатный ключ, хранятся в ID поступления и ID отгрузки.
[0066] Здесь, когда запрос поступления продукта принимается от клиентского терминала 28, данные поступления могут быть просто добавлены в таблицу 60 поступления. Поскольку исключительного управления не требуется, полномочия обработки также допускаются для любого сервера AP.
Кроме того, когда запрос проверки количества запасов принимается от клиентского терминала 28, количество запасов может быть вычислено посредством «количество не аннулированного поступления - количество не аннулированной отгрузки». Вследствие этого, исключительного управления между серверами AP не требуется.
[0067] С другой стороны, когда запрос заказа (отгрузки) продукта отправляется от клиентского терминала 28, заказ количества запасов или более не может быть принят. Вследствие этого, исключительное управление требуется между серверами AP.
В частности, на стадии, на которой генерируется запрос заказа продукта, полномочия обработки делегируются ответственному за обработку отгрузки продукта серверу AP (код продукта).
[0068] Ответственный основной сервер AP, который принял это, сразу сохраняет запрос заказа в очереди FIFO, и исполняет обработку в более раннем заказе.
Т.е., блок 30 коммерческой обработки ответственного основного сервера AP, после вычисления запасов продукта, относящегося к коду продукта, включенному в запрос заказа, генерирует соответствующие данные отгрузки, если количество продуктов, включенных в запрос заказа находится в пределах диапазона запасов, и запрашивает дополнительную регистрацию в таблице 62 отгрузки во всех серверах DB. Затем, уведомление о результате обработки осуществляется от сервера AP, как получателя консигнации, к серверу AP, как источнику консигнации.
Кроме того, когда запас продукта ниже количества заказов, сервер AP, как получатель консигнации, уведомляет сервер AP, как источник консигнации, о результате нехватки запаса без генерирования данных отгрузки.
[0069] Также, в данном случае, для того, чтобы сделать эффективным исключительное управление, необходимо определить заранее обработку (обработку приема заказа), которая требует исключительного управления, и обработку (обработка приема поступления и обработка проверки запаса), которая не требует исключительного управления, в прикладной программе для блока 30 коммерческой обработки.
Кроме того, так как программное обеспечение и цифровая книга продаются в формате загрузки, не требуется уделять внимание количеству запасов, в зависимости от цели продаж.
В данном случае, определяется, требуется или нет исключительное управление для каждого целевого продукта (для каждого кода продукта) даже если обработка, является одной и той же обработкой приема заказа.
[0070] Каждый сервер DB системы 10, когда принял данные, которые должны быть добавлены, от блока 38 соединения DB, и сохранил данные в своей самостоятельной памяти, отправляет уведомление завершения приема блоку 38 соединения DB, и затем сохраняет соответствующую запись в таблице, предоставленной на внешнем запоминающем устройстве, таком как жесткий диск или SSD.
[0071] Уведомление о завершении приема, отправленное от сервера DB, собирается в блоке 34 управления данными через каждый блок 38 соединения DB.
Когда уведомление о завершении приема возвращается от всех блоков 38 соединения DB, блок 34 управления данными выводит уведомление о завершении регистрации блоку 30 коммерческой обработки.
[0072] Когда уведомление о завершении регистрации принимается от блока 34 управления данными, блок 30 коммерческой обработки распознает данные в качестве цели чтения.
Говоря наоборот, блок 30 коммерческой обработки устанавливает данные в качестве цели не для чтения до тех пор, пока не возвращается уведомление о завершении регистрации, и следовательно, исключают такую опасность, что выбор времени регистрации в каждом сервере DB смещен и считываются недопустимые данные.
[0073] Тем не менее, когда уведомление о завершении приема не возвращается от любого из серверов DB по прошествии предварительно определенного времени, блок 34 управления данными допускает, что произошел сбой связи или неприятность с машиной, и перемещает сервер DB в офлайновый режим.
В частности, сервер DB временно отсоединяется от системы 10 и перемещается в режим работы, основанный только на оставшихся серверах DB.
Т.е., когда уведомление о завершении приема принимается от всех серверов DB, отличных от отсоединенного сервера DB, уведомление о завершении регистрации выводится блоку 30 коммерческой обработки от блока 34 управления данными, и данные регистрации являются целью чтения.
[0074] В течение срока, отсоединенный сервер DB инспектируется и выполняется необходимая контрмера восстановления. Например, когда определяется, что уведомление о завершении регистрации не принимается из-за сбоя устройства связи, сервер DB задает режим записи (в состоянии разрешения только записи данных и запрета обращения к данным) после замены на новое устройство связи. Затем, отличающиеся данные копируются с другого сервера DB, установленного в центре хранения и обработки данных.
[0075] Затем, когда данные хранения достигают самого последнего состояния, сервер DB устанавливается в режим чтения/записи (в состояние разрешения записи и обращения к данным) и повторно соединяется с системой 10.
Затем, блок 34 управления данными перезапускает отправку и прием данных через ответственный блок 38 соединения DB у сервера DB.
[0076] В случае системы 10, как упомянуто выше, применяется правило, что разрешается только добавление каждых коммерческих данных, а их удаление и обновление не допускается. Вследствие этого, восстановление данных чрезвычайно простое.
Т.е., когда предполагается, что разрешено удаление и обновление данных, необходимо последовательно воссоздавать добавление, удаление и обновление данных с предварительно определенного выбора времени, на основании информации об истории обновления, хранимой сервером DB, для того чтобы восстановить данные, и это отнимает много времени и создает большую нагрузку. Кроме того, необходимо обеспечить системе надежное хранение журнала обновления на стороне сервера DB.
[0077] С другой стороны, когда предполагается, что разрешено только добавление данных, подобно системе 10, в удаление и обновление запрещены, то данные, зарегистрированные на другом нормальном сервере DB, сравниваются в данными, зарегистрированными на сервере DB, на котором произошел сбой, и просто могут быть скопированы недостающие данные. Следовательно, нет необходимости в рассмотрении очередности (зависимости после/до) данных.
[0078] Кроме того, в системе 10, когда данные, отправленные от блока 38 соединения DB, сохраняются в памяти сервера DB, как упомянуто выше, уведомление о завершении приема выдается серверу AP от сервера DB. Вследствие этого, блок 30 коммерческой обработки может устанавливать данные в цель чтения в чрезвычайно короткое время.
[0079] В соответствии с обычным здравым смыслом, память является энергозависимым запоминающим блоком таким, что данные теряются при остановке подачи питания, и уведомление о завершении должно быть возвращено, когда данные сохраняются в энергонезависимом запоминающем блоке (жесткий диск и т.д.).
С другой стороны, в случае системы 10, даже если данные повреждены на одном сервере DB, сопровождение возможно только посредством простого копирования недостающих данных из смежного сервера DB. Вследствие этого, ожидание того, пока данные не будут сохранены на жестком диске или подобном, не является необходимым.
[0080] Кроме того, поскольку восстановление данных легкое, то когда одни и те же данные сохраняются на множестве серверов DB, обычная трудная процедура, именуемая 'двухфазной фиксацией', не требуется. Просто, регистрация запрашивается у каждого сервера DB. Когда возвращается уведомление о завершении приема от каждого сервера DB, данные могут быть считаны (реализация так называемой авто-фиксации).
Как следствие, сильно уменьшается обмен сообщениями между сервером AP и сервером DB, и может быть повышена скорость обработки в целом.
[0081] Поскольку блок 30 коммерческой обработки проставляет отметку времени в разнообразных коммерческих данных (данные добавления балла, данные аннулирования добавления, данные применения балла, данные аннулирования применения и подобное) с точностью в миллисекунду, значение суррогатного ключа достигает MAX. Даже в случае повторной выдачи (повторного использования) ID перекрывающегося с выданным ID, блок 30 коммерческой обработки сравнивает отметку времени, тем самым обеспечивая определение новых или старых данных.
[0082] В вышеприведенном описании, показан пример размещения множества серверов AP и множества серверов DB во множестве центров обработки данных. Тем не менее, изобретение этим не ограничивается.
Т.е., эффективное применение также возможно в случае, когда, в среде, где множество серверов AP и множество серверов DB, установлено в одном центре хранения и обработки данных, и каждый сервер AP соединен со всеми серверами DB через сеть, каждый сервер AP уникальным образом выполняет параллельную обработку коммерческой обработки без исключительного управления и полномочия обработки у коммерческой обработки, которая требует исключительного управления, концентрируются у предварительно заданного сервера AP.
Краткое описание чертежей
[0083] [Фиг. 1] Фиг. 1 является схемой полной конфигурации системы обработки данных в соответствии с изобретением.
[Фиг. 2] Фиг. 2 является схемой, показывающей пример таблицы, хранящейся в каждом сервере DB.
[Фиг. 3] Фиг. 3 является структурной схемой, показывающей внутренние конфигурации первого сервера AP и второго сервера AP.
[Фиг. 4] Фиг. 4 является блок-схемой, показывающей процедуру выдачи суррогатного ключа.
[Фиг. 5] Фиг. 5 является схемой, показывающей структуру таблицы администрирования суррогатного ключа или подобного.
[Фиг. 6] Фиг. 6 является блок-схемой, показывающей процедуру обработки в случае применения системы к бизнесу администрирования баллов.
[Фиг. 7] Фиг. 7 является блок-схемой, показывающей процедуру обработки по добавлению балла.
[Фиг. 8] Фиг. 8 является блок-схемой, показывающей последовательность обработки по вычислению баланса.
[Фиг. 9] Фиг. 9 является блок-схемой, показывающей процедуру обработки, которая относится к исключительному управлению между серверами AP.
[Фиг. 10] Фиг. 10 является блок-схемой, показывающей процедуру обработки по применению балла.
[Фиг. 11] Фиг. 11 является схемой, показывающей другой пример таблицы, хранящейся в каждом сервере DB.
Объяснение обозначений
[0084] 10: система обработки данных
12: первый центр обработки данных
14: первый сервер AP
16: первый сервер DB
18: второй сервер DB
20: второй центр обработки данных
22: второй сервер AP
24: третий сервер DB
26: четвертый сервер DB
27: сеть связи
28: клиентский терминал
29: линия связи
30: блок коммерческой обработки
32: блок администрирования суррогатного ключа
34: блок управления данными
38: блок соединения DB
50: таблица добавления балла
51: таблица аннулирования добавления
52: таблица применения балла
53: таблица аннулирования применения
54: таблица определения ответственной AP
56: таблица администрирования суррогатного ключа
57: таблица администрирования последней цифры суррогатного ключа
58: таблица администрирования сервера AP
59: таблица администрирования центра обработки данных
60: таблица поступления
61: таблица аннулирования поступления
62: таблица отгрузки
63: таблица аннулирования отгрузки
64: таблица определения ответственной AP
1. Система обработки данных, содержащая множество серверов AP и множество серверов DB, при этом
каждый из серверов DB включает в себя общую таблицу для хранения коммерческих данных, и каждая таблица хранит одни и те же данные, причем каждая таблица имеет ограничение, допускающее только обращение к и добавление записи и запрещающее ее удаление и обновление,
при этом каждый из серверов AP соединен с каждым из серверов DB и имеет функцию для выполнения общей коммерческой обработки по запросу, отправленному с клиентского терминала, и функцию для отправки коммерческих данных, сгенерированных в результате этой обработки, на каждый из серверов DB и запрашивания дополнительной регистрации в соответствующей таблице,
при этом каждому фрагменту коммерческих данных присваивается уникальный ID, включающий в себя код идентификации для указания сервера AP, который сгенерировал этот фрагмент коммерческих данных,
при этом каждый из серверов DB дополнительно хранит таблицу определения ответственной AP, которая определяет, для каждой коммерческой обработки, сервер AP, ответственный за конкретную коммерческую обработку, которая требует исключительного управления,
причем каждый из серверов AP самостоятельно выполняет коммерческую обработку, когда запрос коммерческой обработки, отправленный с клиентского терминала, не требует исключительного управления, и, напротив, когда запрос требует исключительного управления, обращается к таблице определения ответственной AP, задает сервер AP, который должен брать на себя ответственность за коммерческую обработку, и затем делегирует соответствующую обработку ответственному серверу AP, и
ответственный сервер AP, который принял это, сразу сохраняет делегированную коммерческую обработку в очереди и затем последовательно выполняет каждую коммерческую обработку в очереди в соответствии с правилом FIFO,
при этом отметка времени, когда коммерческая обработка выполняется, проставляется в каждом фрагменте коммерческих данных, причем сервер AP, когда требуется обновить существующие коммерческие данные,
вновь генерирует коммерческие данные, включающие в себя увеличенный в порядке возрастания ID, отличный от ID коммерческих данных, данные после коррекции и отметку времени во время коррекции и,
по существу, обновляет существующие коммерческие данные путем дополнительной регистрации коммерческих данных для обновления в соответствующей таблице, предусмотренной в каждом сервере DB.
2. Система обработки данных по п. 1, в которой не только ответственный основной сервер AP, но также ответственный вспомогательный сервер AP, который должен брать на себя ответственность за обработку, когда ответственный основной сервер AP не функционирует, определен в таблице определения ответственной AP для каждой коммерческой обработки.
3. Система обработки данных по п. 1 или 2, в которой сервер AP, когда требуется удалить существующие коммерческие данные,
генерирует коммерческие данные для аннулирования данных, имеющих элемент данных, который хранит ID коммерческих данных в качестве цели аннулирования, и,
по существу, удаляет существующие коммерческие данные путем дополнительной регистрации коммерческих данных для аннулирования данных в назначенной для аннулирования таблице, предусмотренной в каждом сервере DB.
