Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP4777285B2 - Process control system - Google Patents
[go: Go Back, main page]

JP4777285B2 - Process control system - Google Patents

Process control system Download PDF

Info

Publication number
JP4777285B2
JP4777285B2 JP2007081889A JP2007081889A JP4777285B2 JP 4777285 B2 JP4777285 B2 JP 4777285B2 JP 2007081889 A JP2007081889 A JP 2007081889A JP 2007081889 A JP2007081889 A JP 2007081889A JP 4777285 B2 JP4777285 B2 JP 4777285B2
Authority
JP
Japan
Prior art keywords
physical
server
allocation table
physical server
activation
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Expired - Fee Related
Application number
JP2007081889A
Other languages
Japanese (ja)
Other versions
JP2008242766A (en
Inventor
博 高畑
孝 西口
有晃 奈良
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Nomura Research Institute Ltd
Original Assignee
Nomura Research Institute Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Nomura Research Institute Ltd filed Critical Nomura Research Institute Ltd
Priority to JP2007081889A priority Critical patent/JP4777285B2/en
Publication of JP2008242766A publication Critical patent/JP2008242766A/en
Application granted granted Critical
Publication of JP4777285B2 publication Critical patent/JP4777285B2/en
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Landscapes

  • Hardware Redundancy (AREA)

Description

本発明は、サービスリクエストを複数の物理サーバに振り分けるネットワーク分散処理技術に係り、とくに、ネットワーク分散処理環境の物理的構成または論理的構成の変更の際におけるシステム管理者の労力を軽減することができるプロセス制御システムに関する。   The present invention relates to a network distributed processing technology that distributes service requests to a plurality of physical servers, and in particular, can reduce the labor of a system administrator when changing the physical configuration or logical configuration of a network distributed processing environment. It relates to a process control system.

サービスリクエストに応じてサービスを提供する複数の物理サーバを有する分散システムとして、例えば、特許文献1記載のデータベースシステムが知られている。このシステムにおいては、データベースサービスを提供する運用系の物理サーバについて、障害発生時の切り替え先となる待機系の物理サーバがあらかじめ定義されており、運用系の物理サーバの障害発生が検知されると、その運用系の物理サーバから待機系の物理サーバへの系切り替えが行われる。
特開2001−282763号公報
As a distributed system having a plurality of physical servers that provide a service in response to a service request, for example, a database system described in Patent Document 1 is known. In this system, a standby physical server that is the switching destination in the event of a failure is defined in advance for the active physical server that provides the database service, and a failure of the active physical server is detected. Then, system switching from the active physical server to the standby physical server is performed.
JP 2001-282863 A

ところで、サービスリクエストに応じてサービスを提供する仮想サーバを論理的に構成する複数の物理サーバを有する分散システムにおいて、その物理的構成の変更(物理サーバの追加、削除)または論理的構成の変更(起動プロセスの追加、削除、起動数変更)が行われる場合、システム管理者により、物理サーバに対するプロセスの分散配置の見直しが行われる。それに伴い、システム管理者は、個々の物理サーバごとに、起動すべきプロセスを再設定する必要がある。このように、システム管理者には、システムの物理的構成または論理的構成の変更に対応するために煩雑な再設定作業が要求される。   By the way, in a distributed system having a plurality of physical servers that logically configure a virtual server that provides a service in response to a service request, the physical configuration is changed (physical server is added or deleted) or the logical configuration is changed ( When a startup process is added, deleted, or the number of startups is changed), the system administrator reviews the distributed arrangement of processes for physical servers. Accordingly, the system administrator needs to reset the process to be started for each physical server. As described above, the system administrator is required to perform complicated resetting operations in order to cope with changes in the physical configuration or logical configuration of the system.

そこで、本発明は、ネットワーク分散処理環境において、その物理的構成および論理的構成の変更に要する作業コストを軽減することができるプロセス制御システムを提供することを目的とする。   Therefore, an object of the present invention is to provide a process control system capable of reducing the work cost required for changing the physical configuration and logical configuration in a network distributed processing environment.

本発明の一実施態様に従うプロセス制御システムは、サービスを提供する仮想サーバを構成する複数の物理サーバと、前記各物理サーバが参照可能な共有データベースを備えたデータベースサーバとを備える。前記複数の物理サーバに含まれる少なくとも1つの第1の物理サーバは、前記仮想サーバを構成する1以上の物理サーバに関する物理ノード一覧情報と、仮想サーバが提供する複数のサービスを定義したサービス一覧情報を受け付ける手段と、前記受け付けた物理ノード一覧情報およびサービス一覧情報に基づいて、前記仮想サーバを構成する各物理サーバに対して、前記複数のサービスに係るプロセスのいずれかを割り当てた割り当て表を生成する割り当て表作成手段と、を備える。そして、前記共有データベースには、前記割り当て表が登録されていて、前記仮想サーバを構成する各物理サーバは、前記割り当て表を参照して各物理サーバに割り当てられたプロセスを実行する。   A process control system according to an embodiment of the present invention includes a plurality of physical servers configuring a virtual server that provides a service, and a database server including a shared database that can be referred to by each of the physical servers. The at least one first physical server included in the plurality of physical servers includes physical node list information related to one or more physical servers constituting the virtual server, and service list information defining a plurality of services provided by the virtual server. And an allocation table in which any of the processes related to the plurality of services is allocated to each physical server constituting the virtual server based on the received physical node list information and service list information. Allocation table creating means. And the said allocation table is registered into the said shared database, Each physical server which comprises the said virtual server performs the process allocated to each physical server with reference to the said allocation table.

好適な実施形態では、前記物理ノード一覧情報および前記サービス一覧情報の入力を受け付け、前記第1の物理サーバに割り当て表作成リクエストを送信するコンソール端末を、さらに備え、前記割り当て表作成手段は、前記割り当て表作成リクエストに応じて、前記コンソール端末から前記物理ノード一覧情報および前記サービス一覧情報を取得し、当該物理ノード一覧情報および当該サービス一覧情報に基づいて前記割り当て表を生成するようにしてもよい。   In a preferred embodiment, the device further comprises a console terminal that receives input of the physical node list information and the service list information and transmits an allocation table creation request to the first physical server, and the allocation table creation means includes the In response to an allocation table creation request, the physical node list information and the service list information may be acquired from the console terminal, and the allocation table may be generated based on the physical node list information and the service list information. .

好適な実施形態では、前記コンソール端末は、起動対象プロセスを特定した起動トリガを生成し、当該起動トリガを前記各物理サーバに与えるトリガ生成手段を備えてもよい。このとき、前記各物理サーバは、前記サービスに係るプロセスを実現するためのプログラムが格納されたデータ記憶手段と、前記起動トリガを受け付けると、前記割り当て表を参照して、前記起動トリガで特定されるプロセスが自物理サーバに割り当てられているか否かを判定し、自物理サーバに割り当てられていれば、前記起動トリガで特定される起動対象プロセスを実現するためのプログラムを前記データ記憶手段から読み出して前記起動対象プロセスを起動するプロセス起動手段と、さらに備えるようにしてもよい。   In a preferred embodiment, the console terminal may include a trigger generation unit that generates a start trigger specifying a process to be started and provides the start trigger to each physical server. At this time, each physical server is identified by the activation trigger with reference to the allocation table when receiving the activation trigger and the data storage means storing the program for realizing the process related to the service. A process for realizing the process to be activated specified by the activation trigger is read from the data storage means if the process is allocated to the own physical server. And a process activation means for activating the activation target process.

好適な実施形態では、前記コンソール端末は、起動対象プロセスを特定した起動トリガを生成し、当該起動トリガを前記各物理サーバに与えるトリガ生成手段を備えてもよい。このとき、前記各物理サーバは、前記サービスに係るプロセスを実現するためのプログラムが格納されたデータ記憶手段と、与えられたメッセージに自物理サーバの識別情報が含まれている場合に、当該メッセージにおいて指定されたプロセスを実現するプログラムを前記データ記憶手段から読み出し、当該プログラムの実行により前記起動対象プロセスを起動するプロセス起動手段と、をさらに備え、前記起動トリガが与えられた物理サーバのプロセス起動手段は、前記割り当て表を参照して、前記起動トリガにおいて特定される起動対象プロセスが割り当てられた物理サーバの識別情報を取得し、前記起動対象プロセスの指定および前記物理サーバの識別情報を含む前記メッセージを前記各物理サーバに与えるようにしてもよい。   In a preferred embodiment, the console terminal may include a trigger generation unit that generates a start trigger specifying a process to be started and provides the start trigger to each physical server. At this time, when each physical server includes data storage means storing a program for realizing the process related to the service, and the given message includes identification information of the own physical server, the message A process starting unit that reads a program that realizes the process specified in step 1 from the data storage unit and starts the start target process by executing the program, and starts the process of the physical server to which the start trigger is given The means acquires the identification information of the physical server to which the activation target process specified in the activation trigger is allocated with reference to the allocation table, and includes the designation of the activation target process and the identification information of the physical server A message may be given to each physical server.

好適な実施形態では、前記割り当て表作成手段は、前記各物理サーバに割り当てられたプロセスの状態の定義をさらに含む割り当て表を生成し、前記各物理サーバのプロセス起動手段は、前記割り当て表を参照して、前記起動対象プロセスの状態が起動前であるか否かを判定し、当該起動対象プロセスの状態が起動前であれば、当該起動対象プロセスを起動するとともに、前記割り当て表における当該物理サーバの当該起動対象プロセスの状態を更新させるようにしてもよい。   In a preferred embodiment, the allocation table creating unit generates an allocation table further including a definition of a state of a process allocated to each physical server, and the process activation unit of each physical server refers to the allocation table. Then, it is determined whether or not the status of the startup target process is before startup, and if the status of the startup target process is before startup, the startup target process is started and the physical server in the allocation table The state of the activation target process may be updated.

好適な実施形態では、前記割り当て表作成手段は、前記各物理サーバに割り当てられたプロセスの起動数の定義をさらに含む割り当て表を生成し、前記各物理サーバのプロセス起動手段は、前記割り当て表で定義された起動数が示す数の前記起動対象プロセスが、当該物理サーバにおいて起動中となるように、当該起動対象プロセスを起動するようにしてもよい。   In a preferred embodiment, the allocation table creating unit generates an allocation table further including a definition of the number of processes started allocated to each physical server, and the process startup unit of each physical server includes the allocation table The activation target process may be activated so that the number of activation target processes indicated by the defined activation number is being activated in the physical server.

好適な実施形態では、前記コンソール端末は、前記複数の物理サーバに含まれる第2の物理サーバであってもよい。   In a preferred embodiment, the console terminal may be a second physical server included in the plurality of physical servers.

以下、本発明の一実施形態に係るプロセス制御システムについて、図面を参照して説明する。   Hereinafter, a process control system according to an embodiment of the present invention will be described with reference to the drawings.

図1は、本実施形態に係るプロセス制御システムの概略構成図である。   FIG. 1 is a schematic configuration diagram of a process control system according to the present embodiment.

同図に示すように、このプロセス制御システムは、外部からのサービスリクエストに応じてサービスを提供する仮想サーバを論理的に構成する物理サーバ10,10Aと、各物理サーバ10上のジョブのスケジュールを管理する運用管理サーバ20と、すべての物理サーバ10,10Aから参照可能なデータベースを有するデータベースサーバ30と、システム管理者等のユーザからデータ入力を受け付けるコンソール端末40とを備える。各サーバ等の情報処理装置10,10A,20,30,40は、LAN(Local
Area Network)あるいはインターネット等のネットワーク50で相互に接続されている。
As shown in the figure, this process control system includes physical servers 10 and 10A that logically configure virtual servers that provide services in response to external service requests, and job schedules on each physical server 10. An operation management server 20 to be managed, a database server 30 having a database that can be referred to from all the physical servers 10 and 10A, and a console terminal 40 that receives data input from a user such as a system administrator are provided. The information processing apparatuses 10, 10A, 20, 30, 40 such as each server are connected to a LAN (Local
Are connected to each other via a network 50 such as an area network or the Internet.

なお、コンソール端末40は、独立のサーバマシンによる専用端末として実現してもよいし、物理サーバ10のいずれかに、その機能を搭載することによって実現してもよい。   The console terminal 40 may be realized as a dedicated terminal by an independent server machine, or may be realized by mounting the function on any of the physical servers 10.

物理サーバ10,10A、運用管理サーバ20、データベースサーバ30及びコンソール端末40は、いずれも例えば汎用的なコンピュータシステムにより構成され、以下に説明する各サーバ等10,10A,20,30,40内の個々の構成要素または機能は、例えば、コンピュータプログラムを実行することにより実現される。   Each of the physical servers 10, 10A, the operation management server 20, the database server 30, and the console terminal 40 is configured by, for example, a general-purpose computer system, and each of the servers, etc. 10, 10A, 20, 30, 40 described below Individual components or functions are realized, for example, by executing a computer program.

各物理サーバ10,10Aは、いずれも、サービスプロセスを実現するプログラムが格納されたデータ記憶部11と、自物理サーバの稼動状態を監視する監視部14と、サービスプロセスを実現するプログラムおよび監視部14を実現するプログラム等を起動するプロセス起動部13と、ネットワーク50を介してデータを送受信する送受信部12と、を有している。   Each of the physical servers 10 and 10A includes a data storage unit 11 in which a program for realizing a service process is stored, a monitoring unit 14 for monitoring the operating state of the own physical server, and a program and a monitoring unit for realizing a service process. 14 includes a process activation unit 13 that activates a program or the like that implements 14, and a transmission / reception unit 12 that transmits and receives data via the network 50.

プロセス起動部13は、詳細については後述するように、データベースサーバ30の割り当て表311を参照して、データ記憶部11から所定のプログラムを読み出して、自物理サーバに割り当てられたプロセスを起動する。   As will be described later in detail, the process activation unit 13 refers to an allocation table 311 of the database server 30 and reads a predetermined program from the data storage unit 11 to activate a process allocated to the own physical server.

監視部14は、詳細については後述するように、送受信部12を介してネットワーク50からトリガを取得する。   As will be described later in detail, the monitoring unit 14 acquires a trigger from the network 50 via the transmission / reception unit 12.

さらに、いずれか1つの物理サーバ10Aは、各物理サーバ10,10Aに対するサービスプロセスの割り当てが定義された割り当て表を生成する割り当て表生成部15を有している。   Furthermore, any one physical server 10A has an allocation table generation unit 15 that generates an allocation table in which allocation of service processes to the physical servers 10 and 10A is defined.

割り当て表生成部15は、すべての物理サーバ10,10Aから参照される割り当て表を生成し、データベースサーバ30の共用データベース31に登録する。ここでは、いずれか1つの物理サーバ10Aに割り当て表作成部15を持たせているが、同様な割り当て表生成部15をすべての物理サーバ10,10Aに持たせて、すべての物理サーバ10,10Aから、データベースサーバ30の共用データベース31に割り当て表を登録(新規登録、更新登録)できるようにしてもよい。   The allocation table generation unit 15 generates an allocation table that is referred to by all the physical servers 10 and 10 </ b> A and registers it in the shared database 31 of the database server 30. Here, any one physical server 10A has the allocation table creation unit 15. However, all the physical servers 10, 10A have the same allocation table generation unit 15 provided to all the physical servers 10, 10A. Therefore, the allocation table may be registered (new registration or update registration) in the shared database 31 of the database server 30.

データベースサーバ30は、割り当て表311が格納される共用データベース31と、外部からのリクエストに応じてデータベース処理を実行するデータベース処理部32と、を有している。   The database server 30 includes a shared database 31 in which the allocation table 311 is stored, and a database processing unit 32 that executes database processing in response to an external request.

共用データベース31は、各物理サーバ10,10Aから参照可能である。従って、各物理サーバ10,10Aは、共用データベース31に記憶されている割り当て表311を参照できる。   The shared database 31 can be referred to from each physical server 10, 10A. Therefore, each physical server 10, 10 </ b> A can refer to the allocation table 311 stored in the shared database 31.

そして、コンソール端末40は、入力装置及び出力装置を制御する入出力処理部41と、入出力処理部41が受け付けた情報などを記憶するデータ記憶部44と、各物理サーバ10,10A上における仮想サーバの稼動開始の契機となるプロセス起動トリガを生成するトリガ処理部42と、ネットワーク50を介してデータを送受信する送受信部43と、を有している。   The console terminal 40 includes an input / output processing unit 41 that controls the input device and the output device, a data storage unit 44 that stores information received by the input / output processing unit 41, and a virtual on each physical server 10 and 10A. It has a trigger processing unit 42 that generates a process activation trigger that triggers the start of server operation, and a transmission / reception unit 43 that transmits and receives data via the network 50.

入出力処理部41は、仮想サーバを構成するノードグループに属する物理サーバ10,10Aの一覧であるノード一覧情報および仮想サーバにより提供されるサービスの一覧であるサービス一覧情報等のデータの入力を受け付ける。   The input / output processing unit 41 receives input of data such as node list information that is a list of the physical servers 10 and 10A belonging to the node group that constitutes the virtual server, and service list information that is a list of services provided by the virtual server. .

データ記憶部44は、ノード一覧情報441およびサービス一覧情報442等が格納される。   The data storage unit 44 stores node list information 441, service list information 442, and the like.

トリガ処理部42は、ジョブスケジューラ21の指示などに応じて、プロセス起動トリガを生成して、送受信部43を介してネットワーク50に出力する。   The trigger processing unit 42 generates a process activation trigger according to an instruction from the job scheduler 21 and outputs the process activation trigger to the network 50 via the transmission / reception unit 43.

運用管理サーバ20は、あらかじめ定められたスケジュールにしたがってコンソール端末40にサービス開始指示を与えるジョブスケジューラ21を有している。   The operation management server 20 has a job scheduler 21 that gives a service start instruction to the console terminal 40 according to a predetermined schedule.

ジョブスケジューラ21は、プロセス起動トリガ生成の契機となるサービス開始指示をコンソール端末40へ与える。   The job scheduler 21 gives a service start instruction to the console terminal 40 as a trigger for generating a process activation trigger.

つぎに、割り当て表311のデータ構造、および、その生成に用いられるノード一覧情報441およびサービス一覧情報442のデータ構造について、それぞれ説明する。   Next, the data structure of the allocation table 311 and the data structures of the node list information 441 and the service list information 442 used for generation thereof will be described.

図2は、割り当て表311のデータ構造、図3(A)および(B)は、ノード一覧情報441およびサービス一覧情報442のデータ構造を説明するための図である。   FIG. 2 is a diagram for explaining the data structure of the allocation table 311, and FIGS. 3A and 3B are diagrams for explaining the data structure of the node list information 441 and the service list information 442.

図2に示す割り当て表311には、物理サーバごとに割り当て情報が格納されている。各割り当て情報には、物理サーバの識別情報である物理サーバ名情報3111と、物理サーバに割り当てられたサービスごとのプロセス情報3112とが含まれる。例えば、1つの物理サーバに複数のサービス(ここでは2つのサービス)が割り当てられる場合には、レコード3113に示すように、割り当て情報には、物理サーバ名情報3111に対応付けられた、サービス数分のプロセス情報(ここでは、2つのプロセス情報3112A,3112B)が含まれる。そして、プロセス情報3112には、サービスの識別情報であるサービス名情報31121と、サービスプロセスの起動数である起動プロセス数31122と、サービスプロセスの稼動状態を表す情報であるステータス情報31123と、が含まれる。   The allocation table 311 shown in FIG. 2 stores allocation information for each physical server. Each allocation information includes physical server name information 3111 which is identification information of the physical server, and process information 3112 for each service allocated to the physical server. For example, when a plurality of services (two services in this case) are allocated to one physical server, as shown in the record 3113, the allocation information includes the number of services associated with the physical server name information 3111. Process information (here, two process information 3112A and 3112B) are included. The process information 3112 includes service name information 31121 that is service identification information, an activation process number 31122 that is the activation number of the service process, and status information 31123 that is information representing the operating state of the service process. It is.

図3(A)に示すノード一覧情報441には、仮想サーバを構成するノードグループごとのグループ情報が格納される。各グループ情報には、ノードグループの識別情報であるグループ名情報4411と、そのノードグループに属する1つ以上の物理サーバの物理サーバ名情報4412と、が含まれる。   In the node list information 441 shown in FIG. 3A, group information for each node group constituting the virtual server is stored. Each group information includes group name information 4411 which is node group identification information and physical server name information 4412 of one or more physical servers belonging to the node group.

また、図3(B)に示すサービス一覧情報442には、サービスごとのサービス情報が格納されている。各サービス情報には、サービスのサービス名情報4421と、必要とされるサービスプロセスの起動数を示す起動プロセス数4422と、そのサービスが割り当てられたノードグループのグループ名情報4423と、が含まれる。   In addition, service list information 442 shown in FIG. 3B stores service information for each service. Each service information includes service name information 4421 of the service, number of activation processes 4422 indicating the number of activation of the required service processes, and group name information 4423 of the node group to which the service is allocated.

つぎに、図1のプロセス制御システムにおいて実行される処理について説明する。プロセス制御処理において実行される処理は、プロセス制御処理、および、それに先立ち実行される前処理に分けられる。これらの処理を、前処理、プロセス制御処理の順で説明する。   Next, processing executed in the process control system of FIG. 1 will be described. The process executed in the process control process is divided into a process control process and a pre-process executed prior to the process control process. These processes will be described in the order of pre-processing and process control processing.

図4は、前処理のフローチャートである。なお、ここでは、すべての物理サーバ10A,10が同等な処理性能を有することとする。   FIG. 4 is a flowchart of the preprocessing. Here, it is assumed that all the physical servers 10A and 10 have equivalent processing performance.

ユーザが、入力装置を用いて、ノードグループごとのグループ情報(グループ名情報、物理サーバ名情報)の登録をコンソール端末40に指示すると、入出力処理部41が、その指示に応じてノード一覧情報441を生成し、入力されたグループ情報を、このノード一覧情報441のレコードとして登録する。そして、入出力処理部41は、このノード一覧情報441をデータ記憶部44に格納する(S100)。   When the user instructs the console terminal 40 to register group information (group name information, physical server name information) for each node group using the input device, the input / output processing unit 41 responds to the instruction with the node list information. 441 is generated, and the inputted group information is registered as a record of the node list information 441. The input / output processing unit 41 stores the node list information 441 in the data storage unit 44 (S100).

さらに、ユーザが、入力装置を用いて、サービスごとのサービス情報(サービス名情報、起動プロセス数、グループ名情報)の登録をコンソール端末40に指示すると、入出力処理部41が、その指示に応じてサービス一覧情報442を生成し、入力されたサービス情報を、このサービス一覧情報442のレコードとして登録する。そして、入出力処理部41は、このサービス一覧情報442をデータ記憶部44に格納する(S110)。   Further, when the user instructs the console terminal 40 to register service information (service name information, number of activation processes, group name information) for each service using the input device, the input / output processing unit 41 responds to the instruction. The service list information 442 is generated, and the input service information is registered as a record of the service list information 442. The input / output processing unit 41 stores the service list information 442 in the data storage unit 44 (S110).

その後、ユーザが、入力装置を用いて、割り当て表の作成をコンソール端末40に指示すると、入出力処理部41が、その指示に応じて、割り当て表作成リクエストを、送受信部43を介して、あらかじめ定められた1つの物理サーバ10Aに送信する。   Thereafter, when the user instructs the console terminal 40 to create an allocation table using the input device, the input / output processing unit 41 sends an allocation table creation request via the transmission / reception unit 43 in advance according to the instruction. It transmits to one defined physical server 10A.

物理サーバ10Aでは、割り当て表作成部15が、送受信部12を介して、コンソール端末40からの割り当て表作成リクエストを受け付けると、ノード一覧情報441およびサービス一覧情報442の参照リクエストを、送受信部12を介してコンソール端末40に送信する。コンソール端末40の送受信部43は、その参照リクエストに応じて、ノード一覧情報441およびサービス一覧情報442をデータ記憶部44から読み出して返信する。   In the physical server 10 </ b> A, when the allocation table creation unit 15 receives an allocation table creation request from the console terminal 40 via the transmission / reception unit 12, it sends a reference request for the node list information 441 and service list information 442 to the transmission / reception unit 12. To the console terminal 40. In response to the reference request, the transmission / reception unit 43 of the console terminal 40 reads the node list information 441 and the service list information 442 from the data storage unit 44 and sends back.

その後、物理サーバ10Aでは、割り当て表作成部15が、送受信部12を介して、コンソール端末40からノード一覧情報441およびサービス一覧情報442を受け付けると、それらの情報441,442に基づき、各仮想サーバが提供するサービスを、対応するノードグループ内の物理ノードに割り振る。例えば、物理ノード一覧情報441からグループ情報を読み出し、このグループ情報のグループ名情報4411に合致するグループ名情報4423を含むすべてのサービス情報をサービス一覧情報442から抽出する。そして、物理サーバ10Aにおいてあらかじめ実施された性能テストにより得られた起動可能プロセス数を物理サーバ1台当たりの起動プロセス上限数として、各サービス情報の起動プロセス数4422に相当する数のアプリケーションプロセスを、グループ情報内の物理サーバ名情報4412に対応する物理サーバに分配する。   Thereafter, in the physical server 10A, when the allocation table creation unit 15 receives the node list information 441 and the service list information 442 from the console terminal 40 via the transmission / reception unit 12, each virtual server is based on the information 441 and 442. Allocates the service provided by the physical node in the corresponding node group. For example, group information is read from the physical node list information 441, and all service information including group name information 4423 that matches the group name information 4411 of the group information is extracted from the service list information 442. The number of application processes corresponding to the number of activation processes 4422 of each service information is determined with the number of startable processes obtained by a performance test performed in advance in the physical server 10A as the maximum number of activation processes per physical server. The physical server corresponding to the physical server name information 4412 in the group information is distributed.

そして、割り当て表作成部15は、このような割り当ての結果に基づき割り当て情報を生成する。ここで生成される各割り当て情報のプロセス情報3112のステータス情報31123には、プロセスが起動前状態であることを表す情報「SBY」が登録されている。さらに、割り当て表作成部15は、割り当て表311を生成し、このとき生成した割り当て情報を割り当て表311に登録する(S120)。   And the allocation table preparation part 15 produces | generates allocation information based on the result of such allocation. In the status information 31123 of the process information 3112 of each allocation information generated here, information “SBY” indicating that the process is in a pre-startup state is registered. Furthermore, the allocation table creation unit 15 generates an allocation table 311 and registers the allocation information generated at this time in the allocation table 311 (S120).

その後、割り当て表作成部15は、送受信部12を介して、この割り当て表311の登録リクエストをデータベースサーバ30に送信する。この登録リクエストに応じて、データベースサーバ30のデータベース処理部32は、共用データベース31に割り当て表311を登録する(S130)。これにより、共用データベース31において割り当て表311が一元的に管理され、すべての物理サーバ10A,10が共通の割り当て表311を参照可能となる。   Thereafter, the allocation table creation unit 15 transmits a registration request for the allocation table 311 to the database server 30 via the transmission / reception unit 12. In response to this registration request, the database processing unit 32 of the database server 30 registers the allocation table 311 in the shared database 31 (S130). Thereby, the allocation table 311 is centrally managed in the shared database 31, and all the physical servers 10A and 10 can refer to the common allocation table 311.

その後、物理サーバ10Aでは、割り当て表作成部15が、送受信部12を介して、データベースサーバ30からの登録成功通知を受け付けると、監視部14を実現するプロセスの起動をプロセス起動部13に指示するとともに、送受信部12を介して、他の物理サーバ10に対して監視プロセス起動リクエストを送信する。これにより、プロセス起動部13が、監視部14を実現するプロセスを起動し、同様に、他の物理サーバ10でも、プロセス起動部13が、監視部14を実現するプロセスを起動する(S140)。   Thereafter, in the physical server 10 </ b> A, when the allocation table creation unit 15 receives a registration success notification from the database server 30 via the transmission / reception unit 12, it instructs the process activation unit 13 to activate the process that implements the monitoring unit 14. At the same time, a monitoring process activation request is transmitted to another physical server 10 via the transmission / reception unit 12. Thereby, the process starting part 13 starts the process which implement | achieves the monitoring part 14, Similarly, the process starting part 13 starts the process which implement | achieves the monitoring part 14 also in the other physical server 10 (S140).

以上の前処理によって、すべての物理サーバ10A,10により参照可能な割り当て表311がデータベースサーバ30の共用データベース31に登録され、かつ、すべての物理サーバ10A,10上の監視部14が、自物理サーバの稼動状態の監視を開始する。この後、プロセス制御システムにおいては、あらかじめスケジューリングされたタイミングで、仮想サーバ上のサービスプロセスの起動を開始するためのプロセス制御処理が実行される。   Through the above preprocessing, the allocation table 311 that can be referred to by all the physical servers 10A and 10 is registered in the shared database 31 of the database server 30, and the monitoring unit 14 on all the physical servers 10A and 10 Start monitoring the operating status of the server. Thereafter, in the process control system, process control processing for starting activation of the service process on the virtual server is executed at a timing scheduled in advance.

図5は、プロセス制御処理のフローチャートである。   FIG. 5 is a flowchart of the process control process.

運用管理サーバ20のジョブスケジューラ21は、あらかじめ定められたスケジュールにしたがって、サービスプロセスの指定を含むプロセス起動メッセージをコンソール端末40に送信する。コンソール端末40では、トリガ処理部42が、送受信部43を介して、このプロセス起動メッセージを受け付けると、指定サービスプロセスに対応するサービス名情報を含むプロセス起動トリガを、すべての物理サーバ10A,10に送信する。   The job scheduler 21 of the operation management server 20 transmits a process activation message including a service process designation to the console terminal 40 according to a predetermined schedule. In the console terminal 40, when the trigger processing unit 42 receives this process activation message via the transmission / reception unit 43, a process activation trigger including service name information corresponding to the designated service process is sent to all the physical servers 10A and 10. Send.

各物理サーバ10A,10上においては、プロセス起動部13が、送受信部12を介してプロセス起動トリガを受け付けると(S200)、送受信部12を介して、このプロセス起動トリガに含まれているサービス名情報と自物理サーバの物理サーバ名情報とを含む参照リクエストをデータベースサーバ30に送信する。データベースサーバ30のデータベース処理部32は、この参照リクエストを受け付けると、それに含まれるサービス名情報および物理サーバ名情報の2つをキーとして、共用データベース31の割り当て表311から割り当て情報のプロセス情報3112を検索する(S210)。   On each physical server 10A, 10, when the process activation unit 13 receives a process activation trigger via the transmission / reception unit 12 (S200), the service name included in this process activation trigger via the transmission / reception unit 12 A reference request including the information and the physical server name information of the own physical server is transmitted to the database server 30. When the database processing unit 32 of the database server 30 receives this reference request, the process information 3112 of the allocation information is obtained from the allocation table 311 of the shared database 31 using the service name information and physical server name information included therein as keys. Search is performed (S210).

その結果、該当するプロセス情報3112(指定された物理サーバ名情報を含む割り当て情報内の、指定されたサービス名情報を含むプロセス情報)が得られなければ、すなわち、指定サービスプロセスが指定物理サーバに割り当てられていなければ(S220:No)、データベース処理部32は、検索に失敗した旨のメッセージを返信する。この返信メッセージを受け付けた物理サーバ、すなわち、指定サービスプロセスが割り当てられていない物理サーバは何も処理を行わない。   As a result, if the corresponding process information 3112 (the process information including the specified service name information in the allocation information including the specified physical server name information) is not obtained, that is, the specified service process is assigned to the specified physical server. If not assigned (S220: No), the database processing unit 32 returns a message indicating that the search has failed. The physical server that has received this reply message, that is, the physical server to which the designated service process is not assigned performs no processing.

一方、該当する割り当て情報のプロセス情報3112が得られれば、すなわち、指定サービスプロセスが指定物理サーバに割り当てられていれば(S220:Yes)、データベース処理部32は、そのプロセス情報を返信する。このプロセス情報を受け付けた物理サーバ、すなわち、指定サービスプロセスが割り当てられている物理サーバのプロセス起動部13は、このプロセス情報に含まれているステータス情報が、起動前の状態であることを表す「SBY」であるか否かを判定する(S230)。   On the other hand, if the process information 3112 of the corresponding allocation information is obtained, that is, if the designated service process is assigned to the designated physical server (S220: Yes), the database processing unit 32 returns the process information. The process activation unit 13 of the physical server that has received this process information, that is, the physical server to which the designated service process is allocated, indicates that the status information included in this process information is the state before activation. It is determined whether or not it is “SBY” (S230).

その結果、ステータス情報が「SBY」でなければ、プロセス起動部13はプロセス起動トリガを破棄する。すなわち、指定サービスプロセスが割り当てられている物理サーバであっても、そのプロセスが起動中または停止の状態であれば、プロセス起動トリガは破棄される(S260)。   As a result, if the status information is not “SBY”, the process activation unit 13 discards the process activation trigger. In other words, even if the designated service process is assigned to the physical server, if the process is being activated or stopped, the process activation trigger is discarded (S260).

また、ステータス情報が「SBY」であれば、プロセス起動部13は、プロセス起動トリガに含まれるサービス名情報に対応するプログラムを記憶部11から読み出し、S220で得たプロセス情報3112の起動プロセス数31122が示す数分のプロセスが自物理サーバ上で起動中となるように、そのプログラムを実行する(S240)。   If the status information is “SBY”, the process activation unit 13 reads a program corresponding to the service name information included in the process activation trigger from the storage unit 11, and the number of activation processes 31122 in the process information 3112 obtained in S220. The program is executed so that the processes of the number indicated by are activated on the own physical server (S240).

これにより、指定サービスプロセスが、割り当て表311の起動プロセス数31122に相当する数だけ稼動を開始すると、プロセス起動部13は、起動したプロセスに対応するサービス名情報と自物理サーバの物理サーバ名情報とをキーとする、新たなステータス情報(起動状態であることを表す「RUN」)を含む更新リクエストを、送受信部12を介してデータベースサーバ30に送信する。   As a result, when the designated service process starts operation by the number corresponding to the number of activated processes 31122 in the allocation table 311, the process activation unit 13 determines the service name information corresponding to the activated process and the physical server name information of the own physical server. An update request including new status information (“RUN” indicating the activated state) is transmitted to the database server 30 via the transmission / reception unit 12.

この更新リクエストに応じて、データベースサーバ30のデータベース処理部32は、共用データベース31の割り当て表311を更新する。これにより、一方のキーに合致する物理サーバ名情報3111を含む割り当て情報中のプロセス情報3112のうち、他方のキーに合致するサービス名情報を含むプロセス情報3112のステータス情報31123が、起動前の状態であることを表す「SBY」から、起動中の状態であることを表す「RUN」に更新される(S250)。   In response to this update request, the database processing unit 32 of the database server 30 updates the allocation table 311 of the shared database 31. As a result, among the process information 3112 in the allocation information including the physical server name information 3111 that matches one key, the status information 31123 of the process information 3112 that includes service name information that matches the other key is in a state before starting. Is updated from “SBY” representing that the current state is “RUN” representing the active state (S250).

なお、トリガ処理部42が生成するプロセス起動トリガに、サービス名情報の他にそのサービス名情報に係るプロセスが割り当てられている物理サーバ名情報を含めてもよい。これは、トリガ処理部42が、ジョブスケジューラ21からプロセス起動メッセージを受けたときに、指定サービスプロセスに対応するサービス名情報を含む参照リクエストをデータベースサーバ30へ送信して、共用データベース31の割り当て表311で、このサービス名情報が割り当てられている物理サーバ名情報を取得する。   In addition to the service name information, the process activation trigger generated by the trigger processing unit 42 may include physical server name information to which a process related to the service name information is assigned. This is because when the trigger processing unit 42 receives a process activation message from the job scheduler 21, the trigger processing unit 42 transmits a reference request including service name information corresponding to the designated service process to the database server 30, and the allocation table of the shared database 31. In 311, the physical server name information to which the service name information is assigned is acquired.

このようにすれば、プロセス起動トリガを受け付けた物理サーバ10では、上記処理のステップS210を行わず、そのプロセス起動トリガをもって、ステップS220の自物理サーバへの割り当てサービスの有無を判定できる。これにより、プロセス起動トリガを受け付けた物理サーバ10の処理性能を向上できるとともに、データベースサーバ30の処理負荷を軽減することができる。   In this way, the physical server 10 that has received the process activation trigger can determine whether or not there is a service assigned to the own physical server in step S220 by using the process activation trigger without performing step S210 of the above processing. Thereby, the processing performance of the physical server 10 that has received the process activation trigger can be improved, and the processing load on the database server 30 can be reduced.

本実施形態に係る前処理およびプロセス制御処理によれば、物理サーバに対するサービスプロセスの割り当てが定義された割り当て表が、すべての物理サーバから参照可能な共用データベースで一元的に管理されるため、各物理サーバは、その割り当て表内の割り当て情報に基づき、自己に割り当てられたプロセスを起動する。このため、例えば、システムの物理的構成の変更(物理サーバの追加および削除)および論理的構成の変更(稼動プロセスの追加、削除、起動数変更)の際には、共用データベースに登録された割り当て表のみを更新すれば足りる。すなわち、システム管理者は、共用データベースの割り当て表を更新すべく、コンソール端末40上で、ノード一覧情報およびサービス一覧情報を編集してから割り当て表の作成を指示すれば足り、それぞれの物理サーバにおいて、起動すべきプロセスをいちいち再設定する必要がない。このため、ネットワーク分散処理環境の物理的構成および論理的構成の変更に要する作業コストを軽減することができる。   According to the pre-processing and process control processing according to the present embodiment, since the allocation table in which the allocation of service processes to physical servers is defined is managed centrally in a shared database that can be referenced from all physical servers, Based on the allocation information in the allocation table, the physical server starts the process allocated to itself. For this reason, for example, when changing the physical configuration of the system (adding and deleting physical servers) and changing the logical configuration (adding and deleting active processes, changing the number of startups), the allocation registered in the shared database It is sufficient to update only the table. That is, it is sufficient for the system administrator to edit the node list information and the service list information on the console terminal 40 in order to update the shared database allocation table, and to create the allocation table. There is no need to reconfigure the process to be started. For this reason, the work cost required for changing the physical configuration and the logical configuration of the network distributed processing environment can be reduced.

なお、本実施形態においては、指定サービスプロセスに対応するサービス名情報を含むプロセス起動トリガがすべての物理サーバ10A,10に与えられ、すべての物理サーバにおいて、指定サービスプロセスが自物理サーバに割り当てられたものであるか否かを判断しているが、かならずしも、このようにする必要はない。   In this embodiment, a process activation trigger including service name information corresponding to a designated service process is given to all physical servers 10A and 10, and the designated service process is assigned to the own physical server in all physical servers. It is not always necessary to do this.

例えば、指定サービスプロセスに対応するサービス名情報を含むプロセス起動トリガが1つの物理サーバのみに与えられ、この物理サーバのプロセス起動部が、指定サービスプロセスに対応するサービス名情報を含むプロセス情報3112および対応物理サーバ名情報3111を共用データベース31の割り当て表311から取得し、それらの情報を含むメッセージをすべての物理サーバに連携通知するようにしてもよい。通知を受け付けた各物理サーバのプロセス起動部は、自己の物理サーバ名情報が連携通知メッセージに含まれていれば、当該連携通知メッセージを自己宛のものと判断し、上述の場合と同様、プロセス情報に基づき、自物理サーバ上において指定サービスプロセスが起動プロセス数分だけ起動中となるように該当プログラムを実行し、自己の物理サーバ名情報が連携通知メッセージに含まれていなければ、当該連携通知メッセージを自己宛のものではないと判断し、当該連携通知メッセージを破棄するようにすればよい。   For example, a process activation trigger including service name information corresponding to a designated service process is given to only one physical server, and the process activation unit of this physical server has process information 3112 including service name information corresponding to the designated service process and Corresponding physical server name information 3111 may be acquired from the allocation table 311 of the shared database 31 and a message including such information may be notified to all the physical servers in cooperation. If the physical server name information is included in the cooperation notification message, the process activation unit of each physical server that has received the notification determines that the cooperation notification message is addressed to itself, and the process is the same as in the above case. Based on the information, execute the corresponding program so that the specified service process is active for the number of startup processes on the local physical server, and if the physical server name information is not included in the link notification message, the link notification It may be determined that the message is not addressed to itself and the cooperation notification message is discarded.

また、本実施形態においては、共用データベース31に割り当て表が1つだけ登録される場合を例示したが、例えば、サービス一覧情報においてカレンダー情報を定義しておき、運用管理サーバ20が提供する運用カレンダーごとに割り当て表が生成および登録されるようにしてもよい。これにより、例えば、運用管理サーバ20が提供する運用カレンダーに連動して、物理サーバにより参照される割り当て表が切り替えられるようにすることもできる。   In the present embodiment, the case where only one allocation table is registered in the shared database 31 is exemplified. For example, calendar information is defined in the service list information, and the operation calendar provided by the operation management server 20 is provided. An allocation table may be generated and registered for each. Thereby, for example, the allocation table referred to by the physical server can be switched in conjunction with the operation calendar provided by the operation management server 20.

ところで、本実施の形態に係るプロセス制御システムにおいては、いずれかの物理サーバに、なんらかの障害等が発生した場合、その物理サーバに割り当てられていたサービスプロセスが、別の物理サーバに再割り当てされる。以下、これについて説明する。ここでは、物理サーバ10に障害等の停止原因事象が発生した場合を例に挙げる。   By the way, in the process control system according to the present embodiment, if any failure or the like occurs in any physical server, the service process assigned to the physical server is reassigned to another physical server. . This will be described below. Here, a case where a stop cause event such as a failure occurs in the physical server 10 is taken as an example.

物理サーバ10上の監視部14は、障害等の停止原因事象の発生を検出すると、送受信部12を介して、自物理サーバ10の物理サーバ名情報、自物理サーバ10に割り当てられたサービス(停止サービス)のサービス名情報およびそのプロセス数(停止プロセス数)を含む再割り当てリクエストを、あらかじめ定められた物理サーバ10Aに送信する。   When the monitoring unit 14 on the physical server 10 detects the occurrence of a stop cause event such as a failure, the physical server name information of the own physical server 10 and the service (stop) assigned to the own physical server 10 are transmitted via the transmission / reception unit 12. Service) and a reallocation request including the number of processes (the number of stopped processes) is transmitted to a predetermined physical server 10A.

あるいは、物理サーバ10上に他の物理サーバ10の状態を監視する監視部をさらに設けておき、この監視部が物理サーバ10の停止原因事象の発生を検出したときに、その物理サーバ10の物理サーバ名情報を含む、再割り当てリクエストを物理サーバ10Aに送信するようにしてもよい。   Alternatively, a monitoring unit that monitors the state of the other physical server 10 is further provided on the physical server 10, and when this monitoring unit detects the occurrence of a stop cause event of the physical server 10, the physical server 10 A reallocation request including server name information may be transmitted to the physical server 10A.

物理サーバ10Aでは、割り当て表生成部15が、送受信部12を介して、この再割り当てリクエストを受け付けると、そのリクエストに含まれる、停止原因事象が発生した物理サーバ名情報をキーとするステータス更新リクエストを、送受信部12を介してデータベースサーバ30に送信する。このステータス更新リクエストには、ステータス情報を更新するための情報(停止状態であることを表す「STP」)が含まれる。このステータス更新リクエストに応じて、データベースサーバ30のデータベース処理部32は、共用データベース31の割り当て表311を更新する。これにより、キーに合致する物理サーバ名情報3111を含む割り当て情報の各プロセス情報3112のステータス情報31123、すなわち、停止サービスのステータス情報31123が、起動中の状態であることを表す「RUN」から、停止中の状態であることを表す「STP」に更新される。   In the physical server 10A, when the allocation table generation unit 15 accepts the reassignment request via the transmission / reception unit 12, the status update request using the physical server name information in which the cause of the stoppage occurred included in the request as a key. Is transmitted to the database server 30 via the transmission / reception unit 12. This status update request includes information for updating the status information (“STP” indicating that the status is stopped). In response to this status update request, the database processing unit 32 of the database server 30 updates the allocation table 311 of the shared database 31. As a result, the status information 31123 of the process information 3112 of the allocation information including the physical server name information 3111 matching the key, that is, the status information 31123 of the stop service is “RUN” indicating that it is in the active state. It is updated to “STP” indicating that it is in a stopped state.

また、物理サーバ10Aでは、割り当て表生成部15が、停止プロセス数分のプロセスを、例えば、停止原因事象が発生した物理サーバ10が属するノードグループ内の他の正常稼働中の物理ノードに再割り当てする。このときの再割り当ては、どのようなルールにしたがって行われてもよいが、その一例を示すと、以下の通りである。   Further, in the physical server 10A, the allocation table generation unit 15 reallocates processes for the number of stopped processes to, for example, other normally operating physical nodes in the node group to which the physical server 10 in which the stop cause event has occurred belongs. To do. The reassignment at this time may be performed according to any rule, but an example thereof is as follows.

まず、割り当て表生成部15は、送受信部12を介して、ノード一覧情報441の参照リクエストをコンソール端末40に送信する。この参照リクエストに応じて、コンソール端末40の送受信部43は、データ記憶部44からノード一覧情報441を読み出し、それを物理サーバ10Aに返信する。   First, the allocation table generation unit 15 transmits a reference request for the node list information 441 to the console terminal 40 via the transmission / reception unit 12. In response to this reference request, the transmission / reception unit 43 of the console terminal 40 reads the node list information 441 from the data storage unit 44 and returns it to the physical server 10A.

その後、割り当て表生成部15は、送受信部12を介してノード一覧情報441を受け付けると、再割り当てリクエストの発信元と同じノードグループに属する他の物理サーバの物理サーバ名情報を、そのノード一覧情報441から読み出す。そして、それらの物理サーバのうちの正常稼働中の物理サーバの割り当て情報(ノード一覧情報441から読み出した物理サーバ名情報に合致する物理サーバ名情報を含む割り当て情報であって、それに含まれるいずれのプロセス情報のステータス情報も「STP」ではないもの)の検索リクエストを、送受信部12を介してデータベースサーバ30に送信する。この検索リクエストに応じて、データベースサーバ30のデータベース処理部32は、検索条件に該当する割り当て情報を共用データベース31の割り当て表311から読み出し、それを物理サーバ10Aに返信する。   Thereafter, when the allocation table generation unit 15 receives the node list information 441 via the transmission / reception unit 12, the allocation table generation unit 15 obtains the physical server name information of other physical servers belonging to the same node group as the source of the reallocation request, as the node list information. Read from 441. Of those physical servers, the allocation information of physical servers that are operating normally (allocation information including physical server name information that matches the physical server name information read from the node list information 441) A search request for the status information of the process information is not “STP”) is transmitted to the database server 30 via the transmission / reception unit 12. In response to this search request, the database processing unit 32 of the database server 30 reads allocation information corresponding to the search condition from the allocation table 311 of the shared database 31 and returns it to the physical server 10A.

そして、割り当て表作成部15は、送受信部12を介して、検索条件に合致する割り当て情報を受け付けると、これらの割り当て情報に含まれるプロセス情報の起動プロセス数に基づき、いずれの物理サーバの起動プロセス数も上述の起動プロセス上限数を超えないように、停止プロセス数分の停止サービスプロセスを、再割り当てリクエストの発信元と同じノードグループに属している正常稼働中の物理サーバに割り振る。   When the allocation table creation unit 15 receives the allocation information that matches the search condition via the transmission / reception unit 12, any allocation process of the physical server is started based on the number of startup processes of the process information included in the allocation information. The number of stop service processes corresponding to the number of stop processes is allocated to normally operating physical servers belonging to the same node group as the source of the reallocation request so that the number does not exceed the above-described upper limit of start processes.

割り当て表作成部15は、このような再割り当ての結果に基づき、停止サービスプロセスを新たに割り当てた物理ノードの割り当て情報を生成する。なお、このとき生成した割り当て情報に含まれるプロセス情報のうち、停止サービスのサービス名情報を含むプロセス情報3112のステータス情報31123には、起動前状態を表す情報「SBY」が登録されている。   The allocation table creation unit 15 generates allocation information of physical nodes to which the stop service process is newly allocated based on the result of such reallocation. Of the process information included in the allocation information generated at this time, information “SBY” indicating the pre-startup state is registered in the status information 31123 of the process information 3112 including the service name information of the stop service.

その後、割り当て表作成部15は、停止サービスプロセスを新たに割り当てた物理ノードの物理ノード名情報をキーとする割り当て情報更新リクエストを、送受信部12を介してデータベースサーバ30に送信する。この割り当て情報更新リクエストには、停止サービスプロセスを新たに割り当てた物理ノードの割り当て情報が含まれている。   Thereafter, the allocation table creation unit 15 transmits an allocation information update request using the physical node name information of the physical node to which the stop service process is newly allocated as a key to the database server 30 via the transmission / reception unit 12. This allocation information update request includes allocation information of the physical node to which the stop service process is newly allocated.

この割り当て情報更新リクエストに応じて、データベースサーバ30のデータベース処理部32は、共用データベース31の割り当て表311を更新する。これにより、キーに合致する物理サーバ名情報3111を含む割り当て情報が、新たな割り当て情報で更新される。   In response to this allocation information update request, the database processing unit 32 of the database server 30 updates the allocation table 311 of the shared database 31. As a result, the allocation information including the physical server name information 3111 that matches the key is updated with new allocation information.

このようにして割り当て表の更新が行われると、割り当て表作成部15は、送受信部12を介して、停止サービスプロセスを起動対象として指定したプロセス起動メッセージをコンソール端末40に送信する。コンソール端末40では、トリガ処理部42が、送受信部43を介して、このプロセス起動メッセージを受け付けると、前述の場合と同様、指定されたサービスプロセスに対応するサービス名情報を含むプロセス起動トリガを、すべての物理サーバ10A,10に送信する。   When the allocation table is updated in this way, the allocation table creation unit 15 transmits a process activation message specifying the stop service process as an activation target to the console terminal 40 via the transmission / reception unit 12. In the console terminal 40, when the trigger processing unit 42 receives this process activation message via the transmission / reception unit 43, the process activation trigger including the service name information corresponding to the designated service process, as described above, It transmits to all the physical servers 10A and 10.

これにより、各物理サーバ10A,10が、前述の場合と同様な処理によって、共用データベース31の割り当て表311を参照し、起動前状態の停止サービスプロセスが割り当てられているときだけ、割り当てられた起動プロセス数分の停止サービスプロセスが自物理サーバ上において起動状態となるように、停止サービスプロセスに対応するプログラムを実行する。   As a result, each physical server 10A, 10 refers to the allocation table 311 of the shared database 31 by the same processing as described above, and the allocated activation is performed only when the stop service process in the pre-activation state is allocated. The program corresponding to the stop service process is executed so that the stop service processes for the number of processes are activated on the local physical server.

本実施形態に係るプロセス制御システムによれば、ネットワーク分散処理環境の物理的構成および論理的構成の変更の際に、システム管理者が、個々の物理サーバごとに、起動すべきプロセスを再設定する必要がないため、ネットワーク分散処理環境の物理的構成および論理的構成の変更に要する作業コストを軽減することができる。   According to the process control system according to the present embodiment, the system administrator resets the process to be started for each physical server when the physical configuration and logical configuration of the network distributed processing environment are changed. Since it is not necessary, the work cost required for changing the physical configuration and logical configuration of the network distributed processing environment can be reduced.

上述した本発明の実施形態は、本発明の説明のための例示であり、本発明の範囲をそれらの実施形態にのみ限定する趣旨ではない。当業者は、本発明の要旨を逸脱することなしに、他の様々な態様で本発明を実施することができる。   The above-described embodiments of the present invention are examples for explaining the present invention, and are not intended to limit the scope of the present invention only to those embodiments. Those skilled in the art can implement the present invention in various other modes without departing from the gist of the present invention.

本発明の一実施形態に係るプロセス制御システムの概略構成図である。1 is a schematic configuration diagram of a process control system according to an embodiment of the present invention. 割り当て表のデータ構造の概念図である。It is a conceptual diagram of the data structure of an allocation table. (A)は、ノード一覧情報のデータ構造の概念図、(B)は、サービス一覧情報のデータ構造の概念図である。(A) is a conceptual diagram of the data structure of node list information, (B) is a conceptual diagram of the data structure of service list information. プロセス制御処理に先立ち行われる前処理のフローチャートである。It is a flowchart of the pre-process performed prior to a process control process. プロセス制御処理のフローチャートである。It is a flowchart of a process control process.

符号の説明Explanation of symbols

10,10A 物理サーバ
11 データ記憶部
12 送受信部
13 プロセス起動部
14 監視部
15 割り当て表生成部
20 運用管理サーバ
21 ジョブスケジューラ
30 データベースサーバ
31 共用データベース
32 データベース処理部
40 コンソール端末
41 入出力処理部
44 データ記憶部
42 トリガ処理部
43 送受信部
50 ネットワーク
10, 10A Physical server 11 Data storage unit 12 Transmission / reception unit 13 Process activation unit 14 Monitoring unit 15 Assignment table generation unit 20 Operation management server 21 Job scheduler 30 Database server 31 Shared database 32 Database processing unit 40 Console terminal 41 Input / output processing unit 44 Data storage unit 42 Trigger processing unit 43 Transmission / reception unit 50 Network

Claims (9)

サービスを提供する仮想サーバを構成する複数の物理サーバと、
前記各物理サーバが参照可能な共有データベースを備えたデータベースサーバとを備え、
前記複数の物理サーバに含まれる少なくとも1つの第1の物理サーバは、
前記仮想サーバを構成する1以上の物理サーバに関する物理ノード一覧情報と、前記仮想サーバが提供する複数のサービスを定義したサービス一覧情報を受け付ける手段と、
前記受け付けた物理ノード一覧情報およびサービス一覧情報に基づいて、前記仮想サーバを構成する各物理サーバに対して、前記複数のサービスに係るプロセスのいずれかを割り当てた割り当て表を生成する割り当て表作成手段と、を備え、
前記共有データベースには、前記割り当て表が登録されていて、
前記仮想サーバを構成する各物理サーバは、前記割り当て表を参照して各物理サーバに割り当てられたプロセスを特定し、前記特定されたプロセスを実行することを特徴とするプロセス制御システム。
A plurality of physical servers constituting a virtual server that provides services;
A database server having a shared database that can be referred to by each of the physical servers,
At least one first physical server included in the plurality of physical servers includes:
Means for receiving physical node list information relating to one or more physical servers constituting the virtual server, and service list information defining a plurality of services provided by the virtual server;
Allocation table creating means for generating an allocation table in which any of the processes related to the plurality of services is allocated to each physical server constituting the virtual server based on the received physical node list information and service list information And comprising
In the shared database, the allocation table is registered,
Each physical server that constitutes the virtual server specifies a process assigned to each physical server with reference to the assignment table , and executes the specified process.
前記物理ノード一覧情報および前記サービス一覧情報の入力を受け付け、前記第1の物理サーバに割り当て表作成リクエストを送信するコンソール端末を、さらに備え、
前記割り当て表作成手段は、前記割り当て表作成リクエストに応じて、前記コンソール端末から前記物理ノード一覧情報および前記サービス一覧情報を取得し、当該物理ノード一覧情報および当該サービス一覧情報に基づいて前記割り当て表を生成する、ことを特徴とする請求項1記載のプロセス制御システム。
A console terminal that accepts input of the physical node list information and the service list information and transmits an allocation table creation request to the first physical server;
The allocation table creating means acquires the physical node list information and the service list information from the console terminal in response to the allocation table creation request, and the allocation table is created based on the physical node list information and the service list information. The process control system according to claim 1, wherein:
前記コンソール端末は、
起動対象プロセスを特定した起動トリガを生成し、当該起動トリガを前記各物理サーバに与えるトリガ生成手段を備え、
前記各物理サーバは、
前記サービスに係るプロセスを実現するためのプログラムが格納されたデータ記憶手段と、
前記起動トリガを受け付けると、前記割り当て表を参照して、前記起動トリガで特定されるプロセスが自物理サーバに割り当てられているか否かを判定し、自物理サーバに割り当てられていれば、前記起動トリガで特定される起動対象プロセスを実現するためのプログラムを前記データ記憶手段から読み出して前記起動対象プロセスを起動するプロセス起動手段と、さらに備えることを特徴とする請求項2記載のプロセス制御システム。
The console terminal is
A trigger generation unit that generates a start trigger that identifies a process to be started and provides the start trigger to each physical server;
Each physical server is
Data storage means storing a program for realizing the process related to the service;
When the activation trigger is received, it is determined whether or not the process specified by the activation trigger is allocated to the own physical server with reference to the allocation table. If the process is allocated to the own physical server, the activation is performed. 3. The process control system according to claim 2, further comprising: a process activation unit that reads out a program for realizing the activation target process specified by the trigger from the data storage unit and activates the activation target process.
前記コンソール端末は、
起動対象プロセスを特定した起動トリガを生成し、当該起動トリガを前記各物理サーバに与えるトリガ生成手段を備え、
前記各物理サーバは、
前記サービスに係るプロセスを実現するためのプログラムが格納されたデータ記憶手段と、
与えられたメッセージに自物理サーバの識別情報が含まれている場合に、当該メッセージにおいて指定されたプロセスを実現するプログラムを前記データ記憶手段から読み出し、当該プログラムの実行により前記起動対象プロセスを起動するプロセス起動手段と、をさらに備え、
前記起動トリガが与えられた物理サーバのプロセス起動手段は、
前記割り当て表を参照して、前記起動トリガにおいて特定される起動対象プロセスが割り当てられた物理サーバの識別情報を取得し、前記起動対象プロセスの指定および前記物理サーバの識別情報を含む前記メッセージを前記各物理サーバに与える、ことを特徴とする請求項2記載のプロセス制御システム。
The console terminal is
A trigger generation unit that generates a start trigger that identifies a process to be started and provides the start trigger to each physical server;
Each physical server is
Data storage means storing a program for realizing the process related to the service;
When the given message includes identification information of the own physical server, the program that realizes the process specified in the message is read from the data storage unit, and the process to be started is started by executing the program And a process starting means,
The process starting means of the physical server to which the start trigger is given,
Referring to the allocation table, the identification information of the physical server to which the activation target process specified in the activation trigger is allocated is acquired, and the message including the designation of the activation target process and the identification information of the physical server is The process control system according to claim 2, wherein the process control system is provided to each physical server.
前記割り当て表作成手段は、前記各物理サーバに割り当てられたプロセスの状態の定義をさらに含む割り当て表を生成し、
前記各物理サーバのプロセス起動手段は、前記割り当て表を参照して、前記起動対象プロセスの状態が起動前であるか否かを判定し、当該起動対象プロセスの状態が起動前であれば、当該起動対象プロセスを起動するとともに、前記割り当て表における当該物理サーバの当該起動対象プロセスの状態を更新させることを特徴とする請求項3または4に記載のプロセス制御システム。
The allocation table creating means generates an allocation table further including a definition of a state of a process allocated to each physical server;
The process activation means of each physical server refers to the allocation table to determine whether or not the state of the activation target process is pre-activation, and if the state of the activation target process is pre-activation, 5. The process control system according to claim 3, wherein the process to be started is started and the state of the process to be started of the physical server in the allocation table is updated.
前記割り当て表作成手段は、前記各物理サーバに割り当てられたプロセスの起動数の定義をさらに含む割り当て表を生成し、
前記各物理サーバのプロセス起動手段は、前記割り当て表で定義された起動数が示す数の前記起動対象プロセスが、当該物理サーバにおいて起動中となるように、当該起動対象プロセスを起動することを特徴とする請求項3、4および5のいずれか1項に記載のプロセス制御システム。
The allocation table creating means generates an allocation table further including a definition of the number of processes started allocated to each physical server,
The process activation unit of each physical server activates the activation target process so that the number of activation target processes indicated by the activation number defined in the allocation table is activated in the physical server. The process control system according to any one of claims 3, 4, and 5.
前記コンソール端末は、前記複数の物理サーバに含まれる第2の物理サーバであることを特徴とする請求項2〜6のいずれか1項に記載のプロセス制御システム。   The process control system according to claim 2, wherein the console terminal is a second physical server included in the plurality of physical servers. サービスを提供する仮想サーバを構成する複数の物理サーバと、前記各物理サーバが参照可能な共有データベースを備えたデータベースサーバとを備えたプロセス制御システムにおいて、
前記複数の物理サーバに含まれる少なくとも1つの第1の物理サーバが、
前記仮想サーバを構成する1以上の物理サーバに関する物理ノード一覧情報と、前記仮想サーバが提供する複数のサービスを定義したサービス一覧情報を受け付け、
前記受け付けた物理ノード一覧情報およびサービス一覧情報に基づいて、前記仮想サーバを構成する各物理サーバに対して、前記複数のサービスに係るプロセスのいずれかを割り当てた割り当て表を生成し、
前記データベースサーバが、前記共有データベースに前記割り当て表を登録し、
前記仮想サーバを構成する各物理サーバが、前記割り当て表を参照して各物理サーバに割り当てられたプロセスを特定し、前記特定されたプロセスを実行させることを特徴とするプロセス制御方法。
In a process control system comprising a plurality of physical servers constituting a virtual server providing a service, and a database server comprising a shared database that can be referred to by each of the physical servers,
At least one first physical server included in the plurality of physical servers includes:
Receiving physical node list information on one or more physical servers constituting the virtual server and service list information defining a plurality of services provided by the virtual server;
Based on the received physical node list information and service list information, generate an allocation table in which any of the processes related to the plurality of services is allocated to each physical server constituting the virtual server,
The database server registers the allocation table in the shared database;
A process control method, characterized in that each physical server constituting the virtual server identifies a process allocated to each physical server with reference to the allocation table and executes the identified process.
サービスを提供する仮想サーバを構成する複数の物理サーバと、前記各物理サーバが参照可能な共有データベースを備えたデータベースサーバとを備えたプロセス制御システムのためのコンピュータプログラムであって、
前記コンピュータプログラムが実行されると、
前記複数の物理サーバに含まれる少なくとも1つの第1の物理サーバが、
前記仮想サーバを構成する1以上の物理サーバに関する物理ノード一覧情報と、前記仮想サーバが提供する複数のサービスを定義したサービス一覧情報を受け付け、
前記受け付けた物理ノード一覧情報およびサービス一覧情報に基づいて、前記仮想サーバを構成する各物理サーバに対して、前記複数のサービスに係るプロセスのいずれかを割り当てた割り当て表を生成し、
前記データベースサーバが、前記共有データベースに前記割り当て表を登録し、
前記仮想サーバを構成する各物理サーバが、前記割り当て表を参照して各物理サーバに割り当てられたプロセスを特定し、前記特定されたプロセスを実行させることを特徴とするコンピュータプログラム。
A computer program for a process control system comprising a plurality of physical servers constituting a virtual server that provides a service, and a database server comprising a shared database that can be referred to by each of the physical servers,
When the computer program is executed,
At least one first physical server included in the plurality of physical servers includes:
Receiving physical node list information on one or more physical servers constituting the virtual server and service list information defining a plurality of services provided by the virtual server;
Based on the received physical node list information and service list information, generate an allocation table in which any of the processes related to the plurality of services is allocated to each physical server constituting the virtual server,
The database server registers the allocation table in the shared database;
A computer program characterized in that each physical server constituting the virtual server specifies a process assigned to each physical server with reference to the assignment table and executes the specified process .
JP2007081889A 2007-03-27 2007-03-27 Process control system Expired - Fee Related JP4777285B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2007081889A JP4777285B2 (en) 2007-03-27 2007-03-27 Process control system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2007081889A JP4777285B2 (en) 2007-03-27 2007-03-27 Process control system

Publications (2)

Publication Number Publication Date
JP2008242766A JP2008242766A (en) 2008-10-09
JP4777285B2 true JP4777285B2 (en) 2011-09-21

Family

ID=39914043

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2007081889A Expired - Fee Related JP4777285B2 (en) 2007-03-27 2007-03-27 Process control system

Country Status (1)

Country Link
JP (1) JP4777285B2 (en)

Families Citing this family (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2011083673A1 (en) 2010-01-08 2011-07-14 日本電気株式会社 Configuration information management system, configuration information management method, and configuration information management-use program
JP5549374B2 (en) * 2010-05-24 2014-07-16 富士通株式会社 Load balancing apparatus and load balancing control method
JP4852734B1 (en) * 2010-09-22 2012-01-11 株式会社Csk Service control system
JP4743726B1 (en) * 2010-09-28 2011-08-10 株式会社Csk Server recovery system
WO2023032103A1 (en) * 2021-09-01 2023-03-09 楽天モバイル株式会社 Job control system and job control method
JP7720892B2 (en) * 2023-11-06 2025-08-08 株式会社日立製作所 Dependency understanding system, dependency understanding method, and dependency understanding program

Family Cites Families (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2508589B2 (en) * 1993-05-25 1996-06-19 日本電気株式会社 Server operation method
JPH10262044A (en) * 1997-03-19 1998-09-29 Mitsubishi Electric Corp Relay device and relay method by relay device
JP3550503B2 (en) * 1998-11-10 2004-08-04 インターナショナル・ビジネス・マシーンズ・コーポレーション Method and communication system for enabling communication
JP2001075933A (en) * 1999-09-01 2001-03-23 Nec Corp Distributed processing system
JP4038147B2 (en) * 2003-04-17 2008-01-23 株式会社日立製作所 Information processing system
JP4266786B2 (en) * 2003-11-19 2009-05-20 株式会社日立製作所 Information processing system and information processing apparatus
JP4469306B2 (en) * 2004-04-30 2010-05-26 株式会社日立製作所 Computer system, management server

Also Published As

Publication number Publication date
JP2008242766A (en) 2008-10-09

Similar Documents

Publication Publication Date Title
JP4777285B2 (en) Process control system
CN112910937B (en) Object scheduling method, device, server and container cluster in container cluster
CN112003728B (en) Kubernetes cluster-based application master and standby implementation method and device
CN102521044A (en) Distributed task scheduling method and system based on messaging middleware
CN111090495B (en) Node management methods, devices, equipment, storage media and systems
CN108958949B (en) Calling method and system of application program
JPWO2014171130A1 (en) Information processing system, deployment method, processing device, and deployment device
JP2013171301A (en) Device, method, and program for job continuation management
CN107819632A (en) A kind of dynamic load leveling group system based on performance monitoring system and Docker Swarm
JP2015005218A (en) Network device management apparatus, network device management method, and program for executing network device management method
CN108418863B (en) Management method of controller cluster, SDN controller and storage medium
JP2023130667A (en) Monitoring equipment, network devices, monitoring equipment control methods, network device control methods and programs
CN111835797A (en) A data processing method, device and equipment
JP2017027166A (en) Operation management apparatus, operation management program, and information processing system
CN114443059A (en) Deployment method, device and equipment of Kubernetes cluster
JP2006323526A (en) Cluster management program, recording medium recording the program, cluster management method, node, and cluster
CN108234215B (en) Gateway creating method and device, computer equipment and storage medium
US8036105B2 (en) Monitoring a problem condition in a communications system
KR100700608B1 (en) Interaction method with user in device management and terminal
CN110764882B (en) Distributed management method, distributed management system and device
JP5158153B2 (en) Module update program
JP4608964B2 (en) Module update program
JP2022092156A (en) Inter-application communication control method and inter-application communication control program
JP2006139649A (en) Method and system for changing port numbers of monitored machines and agents
JP2000293375A (en) Object-oriented computer system and computer-readable storage medium storing program

Legal Events

Date Code Title Description
A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20090907

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20101112

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20101124

A02 Decision of refusal

Free format text: JAPANESE INTERMEDIATE CODE: A02

Effective date: 20110323

A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20110525

A911 Transfer to examiner for re-examination before appeal (zenchi)

Free format text: JAPANESE INTERMEDIATE CODE: A911

Effective date: 20110530

TRDD Decision of grant or rejection written
A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

Effective date: 20110622

A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20110629

R150 Certificate of patent or registration of utility model

Ref document number: 4777285

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150

Free format text: JAPANESE INTERMEDIATE CODE: R150

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20140708

Year of fee payment: 3

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

LAPS Cancellation because of no payment of annual fees