JP2012181803A

JP2012181803A - Transaction management system, management device, server device, transaction management method, and program

Info

Publication number: JP2012181803A
Application number: JP2011045983A
Authority: JP
Inventors: Seiji Hiyama; 誠司肥山
Original assignee: NEC Software Kyushu Ltd
Current assignee: NEC Solution Innovators Ltd
Priority date: 2011-03-03
Filing date: 2011-03-03
Publication date: 2012-09-20

Abstract

PROBLEM TO BE SOLVED: To provide a transaction management system, a transaction management method, a management device, a server device, and a program which can finalize an execution result of a transaction even when communication failure occurs between an administration device and a server device providing services during execution of the transaction.SOLUTION: An administration device 10 comprises: an identifier setting unit 12 for setting an identifier for a transaction; and a processing request unit 11 for requesting execution of a transaction by transmitting its identifier to a server device 20. The server device 20 comprises: a processing execution unit 21 for executing a transaction; a storage unit 22 for storing identifiers and execution results of transactions in association; and an execution result transmission unit 23 for, when the administration device 10 requires transmission of an execution result of a transaction by using its identifier, transmitting an execution result associated with the identifier to the administration device 10 under condition that the identifier matches one of the stored identifiers.

Description

本発明は、管理装置とサーバ装置との間でのトランザクションの管理を行うための、トランザクション管理システム、トランザクション管理方法、及びプログラムに関する。 The present invention relates to a transaction management system, a transaction management method, and a program for managing transactions between a management device and a server device.

近年、企業などでは、従来からの資産を生かしつつ、システムの発展を図るため、メインフレームと呼ばれる大型のコンピュータと、オープンサーバと呼ばれる汎用のサーバコンピュータとを組み合わせることが行われている（例えば、特許文献１〜特許文献３参照。）。 In recent years, companies have been combining a large computer called a mainframe and a general-purpose server computer called an open server in order to develop a system while making use of conventional assets (for example, (See Patent Literature 1 to Patent Literature 3.)

このようなメインフレームとオープンサーバとを組み合わせたシステム（以下「複合システム」とする。）では、メインフレームが、基幹業務のための処理を実行する。一方、オープンサーバは、データベースサービス、Ｗｅｂサービスといった各種サービスを提供するための処理を実行する。 In a system in which such a mainframe and an open server are combined (hereinafter referred to as “composite system”), the mainframe executes processing for core business. On the other hand, the open server executes processing for providing various services such as a database service and a Web service.

また、複合システムでは、オープンサーバが提供するサービスは、メインフレームを介して、利用者の端末装置に提供される。メインフレームは、利用者が端末装置を介してサービスの提供を要求すると、対応するローカルトランザクションを実行し、オープンサーバにリモートトランザクションを実行させる。 In the complex system, the service provided by the open server is provided to the user terminal device via the mainframe. When a user requests provision of a service via a terminal device, the mainframe executes a corresponding local transaction and causes an open server to execute a remote transaction.

具体的には、メインフレームが、ローカルトランザクションの中で、該当するオープンサーバに、リモートトランザクションの実行を要求すると、オープンサーバはリモートトランザクションを実行する。次に、オープンサーバからメインフレームにリモートトランザクションの処理結果が返却されると、メインフレームは、オープンサーバにリモートトランザクションのコミットを要求する。その後、メインフレームは、オープンサーバから、リモートトランザクションの実行結果（コミット結果等）を受け取ると、ローカルトランザクションをコミットする。 Specifically, when the mainframe requests a corresponding open server to execute a remote transaction in a local transaction, the open server executes the remote transaction. Next, when the processing result of the remote transaction is returned from the open server to the main frame, the main frame requests the open server to commit the remote transaction. After that, when the mainframe receives the execution result (commit result or the like) of the remote transaction from the open server, the mainframe commits the local transaction.

特開平１０−３４０２１６号公報Japanese Patent Laid-Open No. 10-340216 特開２０００−２２７８６８号公報JP 2000-227868 A 特開２００２−１６９７２８号公報JP 2002-169728 A

ところで、複合システムでは、メインフレームとオープンサーバとは、ＬＡＮなどのネットワークによって接続されているため、両者の間に、通信障害が発生する場合がある。このような場合、メインフレーム側のローカルトランザクションとオープンサーバ側のリモートトランザクションとの間で不整合が生じる可能性がある。 By the way, in the complex system, since the mainframe and the open server are connected by a network such as a LAN, a communication failure may occur between them. In such a case, inconsistency may occur between the local transaction on the mainframe side and the remote transaction on the open server side.

例えば、メインフレームがリモートトランザクションのコミットを要求した後に、通信障害が発生すると、メインフレームは、オープンサーバから、リモートトランザクションの実行結果（コミット結果等）を受け取ることができない状態となる。このような場合、トランザクションの行方が不明となり、メインフレーム側のローカルトランザクションとオープンサーバ側のリモートトランザクションとの間で不整合が生じてしまう。そして、メインフレーム側には、通信障害の解消後に、オープンサーバの応答を取得する手立てはなく、再度、同じリモートトランザクションの実行を要求する必要がある。 For example, when a communication failure occurs after the mainframe requests to commit a remote transaction, the mainframe cannot receive a remote transaction execution result (commit result or the like) from the open server. In such a case, the whereabouts of the transaction becomes unknown, and inconsistency occurs between the local transaction on the mainframe side and the remote transaction on the open server side. On the mainframe side, there is no way to obtain an open server response after the communication failure is resolved, and it is necessary to request the execution of the same remote transaction again.

本発明の目的の一例は、上記問題を解消し、管理装置とサービスを提供するサーバ装置との間において、トランザクションの実行中に通信障害が発生した場合であっても、トランザクションの実行結果を確定し得る、トランザクション管理システム、トランザクション管理方法、これらに用いられる管理装置及びサーバ装置、更にはプログラムを提供することにある。 An example of the object of the present invention is to solve the above-mentioned problem and to determine the execution result of a transaction even when a communication failure occurs during the execution of a transaction between the management device and the server device that provides the service. Another object of the present invention is to provide a transaction management system, a transaction management method, a management device and a server device used for these, and a program.

上記目的を達成するため、本発明の一側面におけるトランザクション管理システムは、サーバ装置と、前記サーバ装置にトランザクションの実行を要求する管理装置とを備え、
前記管理装置は、
前記トランザクションに識別子を設定する、識別子設定部と、
前記サーバ装置に、設定された前記識別子を送信すると共に、前記トランザクションの実行を要求する、処理要求部とを備え、
前記サーバ装置は、
前記識別子を受信すると、前記管理装置が要求した前記トランザクションを実行する処理実行部と、
前記識別子及び前記トランザクションの実行結果を互いに紐付けて格納する格納部と、
前記管理装置が、前記識別子を用いて、前記トランザクションの実行結果の送信を求めた場合に、用いられた前記識別子と前記格納部が格納している識別子とが一致することを条件として、前記識別子に紐付けられた前記トランザクションの実行結果を前記管理装置に送信する、実行結果送信部とを備えている、
ことを特徴とする。 To achieve the above object, a transaction management system according to one aspect of the present invention includes a server device and a management device that requests the server device to execute a transaction,
The management device
An identifier setting unit for setting an identifier in the transaction;
A processing request unit that transmits the set identifier to the server device and requests execution of the transaction;
The server device
When the identifier is received, a process execution unit that executes the transaction requested by the management device;
A storage unit that stores the identifier and the execution result of the transaction in association with each other;
When the management device uses the identifier to request transmission of the execution result of the transaction, the identifier is used on condition that the identifier used and the identifier stored in the storage unit match. An execution result transmission unit that transmits the execution result of the transaction linked to the management device,
It is characterized by that.

上記目的を達成するため、本発明の一側面におけるサーバ装置は、管理装置が要求したトランザクションを実行するサーバ装置であって、
前記管理装置が、前記トランザクションに識別子を設定し、設定した前記識別子を当該サーバ装置に送信すると共に、前記トランザクションの実行を要求した場合に、前記トランザクションを実行する処理実行部と、
前記識別子及び前記トランザクションの実行結果を互いに紐付けて格納する格納部と、
前記管理装置が、前記識別子を用いて、前記識別子によって特定されるトランザクションの実行結果の送信を求めた場合に、用いられた前記識別子と前記格納部が格納している識別子とが一致することを条件として、前記識別子に紐付けられた前記トランザクションの実行結果を前記管理装置に送信する、実行結果送信部と、
を備えている、ことを特徴とする。 In order to achieve the above object, a server apparatus according to one aspect of the present invention is a server apparatus that executes a transaction requested by a management apparatus,
The management device sets an identifier for the transaction, transmits the set identifier to the server device, and requests execution of the transaction;
A storage unit that stores the identifier and the execution result of the transaction in association with each other;
When the management device uses the identifier to request transmission of the execution result of the transaction specified by the identifier, the identifier used and the identifier stored in the storage unit match. As a condition, an execution result transmitting unit that transmits an execution result of the transaction associated with the identifier to the management device;
It is characterized by having.

上記目的を達成するため、本発明の一側面における管理装置は、サーバ装置にトランザクションの実行を要求するための管理装置であって、
前記トランザクションに識別子を設定する、識別子設定部と、
前記サーバ装置に、設定された前記識別子を送信すると共に、前記トランザクションの実行を要求する処理要求部と、
を備えている、ことを特徴とする。 In order to achieve the above object, a management device according to one aspect of the present invention is a management device for requesting a server device to execute a transaction,
An identifier setting unit for setting an identifier in the transaction;
A processing request unit that transmits the set identifier to the server device and requests execution of the transaction;
It is characterized by having.

また、上記目的を達成するため、本発明の一側面におけるトランザクション管理方法は、サーバ装置と、前記サーバ装置にトランザクションの実行を要求する管理装置とを用いたトランザクション管理方法であって、
（ａ）前記管理装置によって、前記トランザクションに識別子を設定し、設定した前記識別子を前記サーバ装置に送信すると共に、前記トランザクションの実行を要求する、ステップと、
（ｂ）前記サーバ装置によって、前記識別子を受信し、前記管理装置が要求した前記トランザクションを実行する、ステップと、
（ｃ）前記サーバ装置によって、前記識別子及び前記トランザクションの実行結果を互いに紐付けて格納する、ステップと、
（ｄ）前記管理装置によって、前記識別子を用いて、前記トランザクションの実行結果の送信を求める、ステップと、
（ｅ）前記（ｄ）のステップで用いられた前記識別子と前記サーバ装置が前記（ｃ）のステップで格納した識別子とが一致することを条件として、前記サーバ装置によって、前記識別子に紐付けられた前記トランザクションの実行結果を前記管理装置に送信する、ステップと、
を有する、ことを特徴とする。 In order to achieve the above object, a transaction management method according to an aspect of the present invention is a transaction management method using a server device and a management device that requests the server device to execute a transaction.
(A) setting an identifier for the transaction by the management device, transmitting the set identifier to the server device, and requesting execution of the transaction;
(B) receiving the identifier by the server device and executing the transaction requested by the management device;
(C) The server device stores the identifier and the execution result of the transaction in association with each other;
(D) using the identifier to request transmission of the execution result of the transaction by the management device;
(E) The server device associates the identifier used in the step (d) with the identifier provided that the identifier stored in the step (c) matches the identifier used in the step (c). Transmitting the execution result of the transaction to the management device; and
It is characterized by having.

上記目的を達成するため、本発明の一側面における第１のプログラムは、コンピュータに、管理装置が要求したトランザクションを実行させるためのプログラムであって、
前記コンピュータに、
（ａ）前記管理装置が、前記トランザクションに識別子を設定し、設定した前記識別子を前記コンピュータに送信すると共に、前記トランザクションの実行を要求した場合に、前記トランザクションを実行する、ステップと、
（ｂ）前記識別子及び前記トランザクションの実行結果を互いに紐付けて格納する、ステップと、
（ｃ）前記管理装置が、前記識別子を用いて、前記トランザクションの実行結果の送信を求めた場合に、用いられた前記識別子と前記（ｂ）のステップで格納した識別子とが一致することを条件として、前記識別子に紐付けられたトランザクションの実行結果を前記管理装置に送信する、ステップと、
を実行させることを特徴とする。 In order to achieve the above object, a first program according to one aspect of the present invention is a program for causing a computer to execute a transaction requested by a management device,
In the computer,
(A) The management device sets an identifier for the transaction, transmits the set identifier to the computer, and executes the transaction when requested to execute the transaction; and
(B) storing the identifier and the execution result of the transaction in association with each other;
(C) When the management apparatus uses the identifier to request transmission of the execution result of the transaction, the identifier used is the same as the identifier stored in the step (b) Transmitting the execution result of the transaction associated with the identifier to the management device; and
Is executed.

また、上記目的を達成するため、本発明の一側面における第２のプログラムは、コンピュータによって、サーバ装置にトランザクションの実行を要求するためのプログラムであって、
前記コンピュータに、
（ａ）前記トランザクションに識別子を設定する、ステップと、
（ｂ）前記サーバ装置に、設定された前記識別子を送信すると共に、前記トランザクションの実行を要求する、ステップと、
を実行させることを特徴とする。 In order to achieve the above object, a second program according to one aspect of the present invention is a program for requesting a server device to execute a transaction by a computer,
In the computer,
(A) setting an identifier for the transaction;
(B) transmitting the set identifier to the server device and requesting the execution of the transaction;
Is executed.

以上のように、本発明によれば、管理装置とサービスを提供するサーバ装置との間において、トランザクションの実行中に通信障害が発生した場合であっても、トランザクションの実行結果を確定することができる。 As described above, according to the present invention, even if a communication failure occurs during the execution of a transaction between the management apparatus and the server apparatus that provides the service, the execution result of the transaction can be determined. it can.

図１は、本発明の実施の形態におけるトランザクション管理システムの構成を示すブロック図である。FIG. 1 is a block diagram showing a configuration of a transaction management system according to an embodiment of the present invention. 図２は、本発明の実施の形態におけるトランザクション管理システムの動作を示すシーケンス図である。FIG. 2 is a sequence diagram showing the operation of the transaction management system in the embodiment of the present invention. 図３は、本発明の実施の形態における管理装置又はサーバ装置を実現するコンピュータの一例を示すブロック図である。FIG. 3 is a block diagram illustrating an example of a computer that implements the management device or the server device according to the embodiment of the present invention.

（実施の形態）
以下、本発明の実施の形態におけるトランザクション管理システム、トランザクション管理方法、管理装置及びサーバ装置、更にはプログラムについて、図１〜図３を参照しながら説明する。 (Embodiment)
Hereinafter, a transaction management system, a transaction management method, a management device, a server device, and a program according to an embodiment of the present invention will be described with reference to FIGS.

［システム構成］
最初に、本実施の形態におけるトランザクション管理システム１００、これを構成する管理装置１０及びサーバ装置２０の構成について図１を用いて説明する。図１は、本発明の実施の形態におけるトランザクション管理システムの構成を示すブロック図である。 [System configuration]
First, the configuration of the transaction management system 100, the management device 10 and the server device 20 constituting the transaction management system 100 according to the present embodiment will be described with reference to FIG. FIG. 1 is a block diagram showing a configuration of a transaction management system according to an embodiment of the present invention.

図１に示すように、トランザクション管理システム１００は、管理装置１０と、サーバ装置２０とを備え、両者は、ＬＡＮ等のネットワークによって接続されている。このうち、サーバ装置２０は、管理装置１０からの要求に応じてトランザクションを実行する。本実施の形態では、サーバ装置２０は、トランザクションとして、データベース４０に対する操作を実行する。 As shown in FIG. 1, the transaction management system 100 includes a management device 10 and a server device 20, which are connected by a network such as a LAN. Among these, the server device 20 executes a transaction in response to a request from the management device 10. In the present embodiment, the server device 20 executes an operation on the database 40 as a transaction.

更に、管理装置１０には、利用者が使用する端末３０がネットワークを介して接続されている。管理装置１０は、利用者からの指示を、端末３０を介して受け付け、指示に応じて、サーバ装置２０にトランザクションの実行を要求する。本実施の形態では、利用者は、端末３０を介して、データベース４０における、検索、更新、削除等の操作を指示する。 Further, a terminal 30 used by a user is connected to the management apparatus 10 via a network. The management apparatus 10 receives an instruction from the user via the terminal 30 and requests the server apparatus 20 to execute a transaction in accordance with the instruction. In the present embodiment, the user instructs operations such as search, update, and deletion in the database 40 via the terminal 30.

また、図１に示すように、管理装置１０は、処理要求部１１と、識別子設定部１２とを備えている。識別子設定部１２は、トランザクションの実行が要求されると、トランザクションに識別子を設定する。処理要求部１１は、サーバ装置２０に、設定された識別子を送信すると共に、トランザクションの実行を要求する。 As shown in FIG. 1, the management device 10 includes a processing request unit 11 and an identifier setting unit 12. When the execution of a transaction is requested, the identifier setting unit 12 sets an identifier for the transaction. The processing request unit 11 transmits the set identifier to the server device 20 and requests execution of the transaction.

サーバ装置２０は、処理実行部２１と、格納部２２と、実行結果送信部２３とを備えている。処理実行部２１は、識別子を受信すると、管理装置１０が要求したトランザクションを実行する。そして、処理実行部２１は、トランザクションの実行から得られた「処理結果」、例えば、データベース４０における検索結果等を、管理装置１０に送信する。また、処理実行部２１は、コミット処理を行った場合は、識別子とトランザクションの実行結果とを格納部２２に送る。 The server device 20 includes a process execution unit 21, a storage unit 22, and an execution result transmission unit 23. When receiving the identifier, the process execution unit 21 executes the transaction requested by the management apparatus 10. Then, the process execution unit 21 transmits the “process result” obtained from the execution of the transaction, for example, the search result in the database 40 to the management apparatus 10. Further, when performing the commit process, the process execution unit 21 sends the identifier and the execution result of the transaction to the storage unit 22.

格納部２２は、識別子及びトランザクションの実行結果を互いに紐付けて格納する。ここで、「トランザクションの実行結果」とは、管理装置１０からのコミット要求に応じて、コミット処理を行った後の結果、例えば、「コミット結果」を意味する。 The storage unit 22 stores the identifier and the transaction execution result in association with each other. Here, “transaction execution result” means a result after commit processing is performed in response to a commit request from the management apparatus 10, for example, “commit result”.

実行結果送信部２３は、管理装置１０が、識別子を用いて、トランザクションの実行結果の送信を求めると、この用いられた識別子と格納部２２が格納している識別子とが一致するかどうかを判定する。そして、実行結果送信部２３は、一致している場合は、格納部２２に格納されており、且つ、一致した識別子と紐付けられている、トランザクションの実行結果を管理装置１０に送信する。 When the management apparatus 10 uses the identifier to request transmission of the transaction execution result, the execution result transmission unit 23 determines whether the identifier used and the identifier stored in the storage unit 22 match. To do. If they match, the execution result transmission unit 23 transmits the transaction execution result stored in the storage unit 22 and associated with the matched identifier to the management apparatus 10.

このように、本実施の形態におけるトランザクション管理システム１００は、管理装置１０側から、サーバ装置２０側に、トランザクションの実行結果を問い合わせることができるようになっている。このため、トランザクションの実行中に通信障害が発生した場合であっても、管理装置１０は、トランザクションの実行結果を取得することができるので、管理装置１０における処理とサーバ装置２０における処理との間で、不整合が生じる事態が回避される。結果、管理装置１０は、このような場合であっても、トランザクションの実行結果を確定できる。 As described above, the transaction management system 100 according to the present embodiment can inquire the execution result of the transaction from the management apparatus 10 side to the server apparatus 20 side. For this reason, even when a communication failure occurs during the execution of a transaction, the management apparatus 10 can acquire the execution result of the transaction, and therefore, between the process in the management apparatus 10 and the process in the server apparatus 20. Thus, a situation in which inconsistency occurs is avoided. As a result, the management apparatus 10 can determine the execution result of the transaction even in such a case.

ここで、本実施の形態におけるトランザクション管理システム１００について、更に具体的に説明する。本実施の形態では、管理装置１０は、メインフレームとよばれる汎用のコンピュータによって構築されている。サーバ装置２０は、各種Ｗｅｂサービスなどを提供するサーバコンピュータである。 Here, the transaction management system 100 in the present embodiment will be described more specifically. In the present embodiment, the management apparatus 10 is constructed by a general-purpose computer called a main frame. The server device 20 is a server computer that provides various Web services.

図１に示すように、管理装置１０は、処理要求部１１及び識別子設定部１２に加えて、処理管理部１３を備えている。また、サーバ装置２０は、処理実行部２１、格納部２２、及び実行結果送信部２３に加えて、通信部２４を備えている。 As illustrated in FIG. 1, the management apparatus 10 includes a process management unit 13 in addition to the process request unit 11 and the identifier setting unit 12. The server device 20 includes a communication unit 24 in addition to the process execution unit 21, the storage unit 22, and the execution result transmission unit 23.

管理装置１０において、処理管理部１３は、サーバ装置２０との間に通信経路を設定する。具体的には、処理管理部１３は、端末３０を介して利用者からの指示を受け付けると、サーバ装置２０の通信部２４にアクセスし、通信経路の設定を要求する。そして、サーバ装置２０において、通信部２４は、通信経路の設定を許可する場合は、応答信号を送信する。これにより、通信経路が設定される。また、この場合、処理要求部１１は、設定された通信経路を介してトランザクションクの実行を要求する。 In the management device 10, the process management unit 13 sets a communication path with the server device 20. Specifically, when receiving an instruction from the user via the terminal 30, the process management unit 13 accesses the communication unit 24 of the server device 20 and requests setting of a communication path. And in the server apparatus 20, the communication part 24 transmits a response signal, when setting of a communication path is permitted. Thereby, a communication path is set. In this case, the processing request unit 11 requests execution of a transaction via the set communication path.

また、処理管理部１３は、トランザクションの完了前に、設定した通信経路が切断されると、新たな通信経路を設定する。そして、処理管理部１３は、新たな通信経路を介して、サーバ装置２０に、識別子を用いて、トランザクションの実行結果の送信を求める。サーバ装置２０においては、実行結果送信部２３は、この用いられた識別子と格納部２２が格納している識別子とが一致する場合、この新たな通信経路を介して、格納部２２に格納されており、且つ、識別子に紐付けられているトランザクションの実行結果を送信する。 Further, when the set communication path is disconnected before the transaction is completed, the process management unit 13 sets a new communication path. Then, the process management unit 13 requests the server apparatus 20 to transmit a transaction execution result through the new communication path using the identifier. In the server device 20, the execution result transmission unit 23 stores the execution result transmission unit 23 in the storage unit 22 via the new communication path when the identifier used and the identifier stored in the storage unit 22 match. And the execution result of the transaction associated with the identifier is transmitted.

また、本実施の形態では、サーバ装置２０において、通信部２４は、識別子設定部２５を備えることができる。識別子設定部２５は、管理装置１０の処理管理部１３から接続が要求されると、第２の識別子（以下「ＳＩＤ」とする。）を設定する。 In the present embodiment, in the server device 20, the communication unit 24 can include an identifier setting unit 25. The identifier setting unit 25 sets a second identifier (hereinafter referred to as “SID”) when a connection is requested from the process management unit 13 of the management apparatus 10.

更に、本実施の形態では、管理装置１０において、識別子設定部１２は、それが設定した識別子（以下「ＣＩＤ」とする。）と、サーバ装置２０の識別子設定部２５が設定したＳＩＤとから、新たな識別子（以下「ＴＸＣＩＤ」とする。）を生成することができる。 Further, in the present embodiment, in the management device 10, the identifier setting unit 12 includes the identifier set by the identifier setting unit 12 (hereinafter referred to as “CID”) and the SID set by the identifier setting unit 25 of the server device 20. A new identifier (hereinafter referred to as “TXCID”) can be generated.

このように、識別子設定部１２がＴＸＣＩＤを生成する場合、処理要求部１１は、サーバ装置２０に、ＴＸＣＩＤを送信する。更に、処理管理部１３は、通信経路が切断された場合、ＴＸＣＩＤを用いて、サーバ装置２０に、トランザクションの実行結果の送信を求める。 As described above, when the identifier setting unit 12 generates the TXCID, the processing request unit 11 transmits the TXCID to the server device 20. Furthermore, when the communication path is disconnected, the process management unit 13 requests the server apparatus 20 to transmit a transaction execution result using the TXCID.

また、サーバ装置２０においては、処理実行部２１は、ＴＸＣＩＤを受信したことを条件に、トランザクションを実行する。更に、格納部２２は、ＴＸＣＩＤを、トランザクションの実行結果と紐付けて格納する。実行結果送信部２３は、管理装置１０から、トランザクションの実行結果の送信が求められると、その時に使用されたＴＸＣＩＤと格納部２２が格納しているＴＸＣＩＤとが一致するかどうかを判定する。一致する場合、実行結果送信部２３は、管理装置１０に、ＴＸＣＩＤと紐付けられているトランザクションの実行結果を送信する。 Moreover, in the server apparatus 20, the process execution part 21 performs a transaction on condition that TXCID is received. Furthermore, the storage unit 22 stores the TXCID in association with the transaction execution result. When the management result is requested by the management apparatus 10 to transmit the execution result of the transaction, the execution result transmission unit 23 determines whether the TXCID used at that time matches the TXCID stored in the storage unit 22. If they match, the execution result transmission unit 23 transmits the execution result of the transaction associated with the TXCID to the management apparatus 10.

このように、サーバ装置２０側の識別子と管理装置１０側の識別子とによって、新たな識別子が生成される態様とした場合は、トランザクションの実行結果が外部から不正に取得される可能性が低減される。この態様は、管理装置１０と、サーバ２０とが、別々の組織（企業等）に配置されている場合に有効である。 As described above, when a new identifier is generated based on the identifier on the server device 20 side and the identifier on the management device 10 side, the possibility that the execution result of the transaction is illegally acquired from the outside is reduced. The This aspect is effective when the management apparatus 10 and the server 20 are arranged in different organizations (such as companies).

次に、本発明の実施の形態におけるトランザクション管理システム１００の動作について図２を用いて説明する。図２は、本発明の実施の形態におけるトランザクション管理システムの動作を示すシーケンス図である。また、本実施の形態では、トランザクション管理システム１００を動作させることによって、トランザクション管理方法が実施される。よって、本実施の形態におけるトランザクション管理方法の説明は、以下のトランザクション管理システム１００の動作説明に代える。 Next, the operation of the transaction management system 100 in the embodiment of the present invention will be described with reference to FIG. FIG. 2 is a sequence diagram showing the operation of the transaction management system in the embodiment of the present invention. In the present embodiment, the transaction management method is implemented by operating the transaction management system 100. Therefore, the description of the transaction management method in the present embodiment is replaced with the following description of the operation of the transaction management system 100.

図２に示すように、まず、利用者が、端末３０から、管理装置１０に対してデータベース４０の操作を指示すると、管理装置１０において、処理管理部１３が、サーバ装置２０に対して接続を要求する（ステップＳ１）。 As shown in FIG. 2, first, when the user instructs the management apparatus 10 to operate the database 40 from the terminal 30, the process management unit 13 connects to the server apparatus 20 in the management apparatus 10. Request (step S1).

次に、サーバ装置２０において、通信部２４は、接続要求を許可する場合は、識別子設定部２５にＣＩＤを設定させると共に、ＣＩＤを管理装置１０に送信する（ステップＳ２）。 Next, in the server device 20, when permitting the connection request, the communication unit 24 causes the identifier setting unit 25 to set the CID and transmits the CID to the management device 10 (step S2).

ステップＳ２が実行されると、管理装置１０において、処理管理部１３は、サーバ装置２０との間に通信経路を設定する。また、処理管理部１３は、受信したＣＩＤを識別子設定部１２に出力する（ステップＳ３）。 When step S <b> 2 is executed, in the management device 10, the process management unit 13 sets a communication path with the server device 20. In addition, the process management unit 13 outputs the received CID to the identifier setting unit 12 (step S3).

次に、識別子設定部１２は、トランザクションに識別子（ＳＩＤ）を設定し、更に、ステップＳ３で処理管理部１３が出力したＣＩＤと、設定したＳＩＤとから、ＴＸＣＩＤを生成する（ステップＳ４）。また、ステップＳ４では、識別子設定部１２は、生成したＴＸＣＩＤを処理要求部１１に出力する。 Next, the identifier setting unit 12 sets an identifier (SID) for the transaction, and further generates a TXCID from the CID output by the process management unit 13 in step S3 and the set SID (step S4). In step S <b> 4, the identifier setting unit 12 outputs the generated TXCID to the processing request unit 11.

そして、処理要求部１１は、ステップＳ１及びＳ２によって設定された通信経路を介して、サーバ装置２０に対して、ＴＸＣＩＤを送信すると共に、トランザクションの実行を要求する（ステップＳ５）。 Then, the processing request unit 11 transmits TXCID to the server device 20 via the communication path set in steps S1 and S2, and requests execution of the transaction (step S5).

ステップＳ５が実行されると、サーバ装置２０においては、処理実行部２１が、要求されたトランザクションを実行する。そして、処理実行部２１は、トランザクションから得られた処理結果、例えば、トランザクションがデータベース４０に対する検索であれば、検索結果情報を、管理装置１０に送信する（ステップＳ６）。 When step S5 is executed, in the server device 20, the process execution unit 21 executes the requested transaction. And the process execution part 21 will transmit search result information to the management apparatus 10 if the process result obtained from the transaction, for example, if a transaction is a search with respect to the database 40 (step S6).

次に、管理装置１０において、処理管理部１３は、トランザクションから得られた処理結果を受信すると、サーバ措置２０に対してコミットを要求する（ステップＳ７）。 Next, in the management device 10, when the processing management unit 13 receives the processing result obtained from the transaction, the processing management unit 13 requests the server measure 20 to commit (step S7).

次に、管理装置１０からコミットが要求されると、サーバ装置１０において、処理実行部２１は、コミット処理を実行し、更に、ＴＸＣＩＤ及びトランザクションの実行結果を互いに紐付けて格納部２２に格納させる（ステップＳ８）。 Next, when a commit is requested from the management device 10, in the server device 10, the process execution unit 21 executes the commit process, and further stores the TXCID and the transaction execution result in association with each other in the storage unit 22. (Step S8).

続いて、処理実行部２１は、ステップＳ１及びＳ２で設定された通信経路を介して、トランザクションの実行結果（コミット結果）を管理装置１０に送信する（ステップＳ９）。 Subsequently, the process execution unit 21 transmits the transaction execution result (commit result) to the management apparatus 10 via the communication path set in steps S1 and S2 (step S9).

ここで、ステップＳ９の実行後、ステップＳ１及びＳ２で設定された通信経路に何らかの障害が発生し、通信経路が切断されてしまったとする。この場合、従来であれば、管理装置１０における処理と、サーバ装置２０における処理との間で不整合が生じてしまう。 Here, after execution of step S9, it is assumed that some failure occurs in the communication path set in steps S1 and S2, and the communication path is disconnected. In this case, conventionally, inconsistency occurs between the process in the management apparatus 10 and the process in the server apparatus 20.

これに対して、本実施の形態では、このような事態が生じた場合、管理装置１０の処理管理部１３は、新たな通信経路を設定するため、ステップＳ１と同様に、サーバ装置２０に対して接続を要求する（ステップＳ１０）。 On the other hand, in this embodiment, when such a situation occurs, the process management unit 13 of the management apparatus 10 sets a new communication path, so that the server apparatus 20 is in the same manner as in step S1. Connection is requested (step S10).

次に、サーバ装置２０の通信部２４は、接続要求を許可する場合は、そのことを管理装置１０に通知する（ステップＳ１１）。そして、通知を受けると、管理装置１０の処理管理部１３は、新たな通信経路を介して、サーバ装置２０に、ＴＸＣＩＤを送信すると共に、トランザクションの実行結果（コミット結果）の送信を要求する（ステップＳ１２）。 Next, when permitting a connection request, the communication unit 24 of the server device 20 notifies the management device 10 of this (step S11). Upon receiving the notification, the process management unit 13 of the management apparatus 10 transmits TXCID to the server apparatus 20 via a new communication path, and requests transmission of a transaction execution result (commit result) ( Step S12).

次に、サーバ装置２０において、実行結果送信部２３は、ステップＳ１２で送信されたＴＸＣＩＤと格納部２２が格納しているＴＸＣＩＤとが一致するかどうかを判定する。そして、判定の結果、一致する場合は、実行結果送信部２３は、ステップＳ１０及びＳ１１で設定された通信経路を介して、格納部２２に格納されており、且つ、ＴＸＣＩＤと紐付けられている、トランザクションの実行結果（コミット結果）を、管理装置１０に送信する（ステップＳ１３）。 Next, in the server device 20, the execution result transmission unit 23 determines whether the TXCID transmitted in step S12 matches the TXCID stored in the storage unit 22. If the results of the determination match, the execution result transmission unit 23 is stored in the storage unit 22 via the communication path set in steps S10 and S11, and is associated with the TXCID. The transaction execution result (commit result) is transmitted to the management apparatus 10 (step S13).

ステップＳ１３が実行されると、管理装置１０は、通信経路での障害発生によって受け取ることができなかったトランザクションの実行結果（コミット結果）を、受け取ることができる。この結果、管理装置１０における処理と、サーバ装置２０における処理との間での不整合の発生は抑制される。本実施の形態によれば、トランザクションの実行中に通信障害が発生した場合であっても、トランザクションの実行結果を確定することが可能となる。 When step S13 is executed, the management apparatus 10 can receive the execution result (commit result) of the transaction that could not be received due to the occurrence of a failure in the communication path. As a result, the occurrence of inconsistency between the process in the management apparatus 10 and the process in the server apparatus 20 is suppressed. According to this embodiment, even if a communication failure occurs during execution of a transaction, it is possible to determine the execution result of the transaction.

また、本発明の実施の形態における第１のプログラムは、コンピュータに、図２に示すステップＳ１、Ｓ３、Ｓ４、Ｓ５、Ｓ８、Ｓ１０、Ｓ１２を実行させるプログラムであれば良い。このプログラムをコンピュータにインストールし、実行することによって、本実施の形態における管理装置１０を実現することができる。この場合、コンピュータのＣＰＵ（Central Processing Unit）は、処理要求部１１、識別子設定部１２、及び処理管理部１３として機能し、処理を行なう。 Further, the first program in the embodiment of the present invention may be a program that causes a computer to execute steps S1, S3, S4, S5, S8, S10, and S12 shown in FIG. The management apparatus 10 according to the present embodiment can be realized by installing and executing this program on a computer. In this case, a CPU (Central Processing Unit) of the computer functions as the processing request unit 11, the identifier setting unit 12, and the processing management unit 13, and performs processing.

更に、本発明の実施の形態における第２のプログラムは、コンピュータに、図２に示すステップＳ２、Ｓ６、Ｓ７、Ｓ９、Ｓ１１、Ｓ１３を実行させるプログラムであれば良い。このプログラムをコンピュータにインストールし、実行することによって、本実施の形態におけるサーバ装置２０を実現することができる。この場合、コンピュータのＣＰＵ（Central Processing Unit）は、処理実行部２１、実行結果送信部２３、及び通信部２４として機能し、処理を行なう。また、コンピュータに備えられたハードディスク等の記憶装置が、格納部２２として機能する。 Furthermore, the second program in the embodiment of the present invention may be a program that causes a computer to execute steps S2, S6, S7, S9, S11, and S13 shown in FIG. By installing and executing this program in a computer, the server device 20 in the present embodiment can be realized. In this case, a CPU (Central Processing Unit) of the computer functions as the processing execution unit 21, the execution result transmission unit 23, and the communication unit 24 to perform processing. A storage device such as a hard disk provided in the computer functions as the storage unit 22.

ここで、本実施の形態における第１のプログラム及び第２のプログラムのいずれかを実行することによって、管理装置１０又はサーバ装置２０を実現するコンピュータについて図３を用いて説明する。図３は、本発明の実施の形態における管理装置又はサーバ装置を実現するコンピュータの一例を示すブロック図である。 Here, a computer that realizes the management apparatus 10 or the server apparatus 20 by executing either the first program or the second program in the present embodiment will be described with reference to FIG. FIG. 3 is a block diagram illustrating an example of a computer that implements the management device or the server device according to the embodiment of the present invention.

図３に示すように、コンピュータ１１０は、ＣＰＵ１１１と、メインメモリ１１２と、記憶装置１１３と、入力インターフェイス１１４と、表示コントローラ１１５と、データリーダ／ライタ１１６と、通信インターフェイス１１７とを備える。これらの各部は、バス１２１を介して、互いにデータ通信可能に接続される。 As shown in FIG. 3, the computer 110 includes a CPU 111, a main memory 112, a storage device 113, an input interface 114, a display controller 115, a data reader / writer 116, and a communication interface 117. These units are connected to each other via a bus 121 so that data communication is possible.

ＣＰＵ１１１は、記憶装置１１３に格納された、本実施の形態におけるプログラム（コード）をメインメモリ１１２に展開し、これらを所定順序で実行することにより、各種の演算を実施する。メインメモリ１１２は、典型的には、ＤＲＡＭ（Dynamic Random Access Memory）等の揮発性の記憶装置である。また、本実施の形態におけるプログラムは、コンピュータ読み取り可能な記録媒体１２０に格納された状態で提供される。なお、本実施の形態におけるプログラムは、通信インターフェイス１１７を介して接続されたインターネット上で流通するものであっても良い。 The CPU 111 performs various calculations by developing the program (code) in the present embodiment stored in the storage device 113 in the main memory 112 and executing them in a predetermined order. The main memory 112 is typically a volatile storage device such as a DRAM (Dynamic Random Access Memory). Further, the program in the present embodiment is provided in a state of being stored in a computer-readable recording medium 120. Note that the program in the present embodiment may be distributed on the Internet connected via the communication interface 117.

また、記憶装置１１３の具体例としては、ハードディスクの他、フラッシュメモリ等の半導体記憶装置が挙げられる。入力インターフェイス１１４は、ＣＰＵ１１１と、キーボード及びマウスといった入力機器１１８との間のデータ伝送を仲介する。表示コントローラ１１５は、ディスプレイ装置１１９と接続され、ディスプレイ装置１１９での表示を制御する。データリーダ／ライタ１１６は、ＣＰＵ１１１と記録媒体１２０との間のデータ伝送を仲介し、記録媒体１２０からのプログラムの読み出し、及びコンピュータ１１０における処理結果の記録媒体１２０への書き込みを実行する。通信インターフェイス１１７は、ＣＰＵ１１１と、他のコンピュータとの間のデータ伝送を仲介する。 Specific examples of the storage device 113 include a hard disk and a semiconductor storage device such as a flash memory. The input interface 114 mediates data transmission between the CPU 111 and an input device 118 such as a keyboard and a mouse. The display controller 115 is connected to the display device 119 and controls display on the display device 119. The data reader / writer 116 mediates data transmission between the CPU 111 and the recording medium 120, and reads a program from the recording medium 120 and writes a processing result in the computer 110 to the recording medium 120. The communication interface 117 mediates data transmission between the CPU 111 and another computer.

また、記録媒体１２０の具体例としては、ＣＦ（Compact Flash）及びＳＤ（Secure Digital）等の汎用的な半導体記憶デバイス、フレキシブルディスク（Flexible Disk）等の磁気記憶媒体、又はＣＤ−ＲＯＭ（Compact Disk Read Only Memory）などの光学記憶媒体が挙げられる。 Specific examples of the recording medium 120 include general-purpose semiconductor storage devices such as CF (Compact Flash) and SD (Secure Digital), magnetic storage media such as a flexible disk, or CD-ROM (Compact Disk). Optical storage media such as Read Only Memory).

以上のように、本発明によれば、管理装置とサービスを提供するサーバ装置との間において、トランザクションの実行中に通信障害が発生した場合であっても、トランザクションの実行結果を確定することができる。本発明は、例えば、メインフレームとサーバ装置とが接続される環境において有効である。 As described above, according to the present invention, even if a communication failure occurs during the execution of a transaction between the management apparatus and the server apparatus that provides the service, the execution result of the transaction can be determined. it can. The present invention is effective, for example, in an environment where a mainframe and a server device are connected.

１０管理装置
１１処理要求部
１２識別子設定部
１３処理管理部
２０サーバ装置
２１処理実行部
２２格納部
２３実行結果送信部
２４通信部
２５識別子設定部
３０端末
４０データベース
１００トランザクション管理システム
１１０コンピュータ
１１１ＣＰＵ
１１２メインメモリ
１１３記憶装置
１１４入力インターフェイス
１１５表示コントローラ
１１６データリーダ／ライタ
１１７通信インターフェイス
１１８入力機器
１１９ディスプレイ装置
１２０記録媒体
１２１バス DESCRIPTION OF SYMBOLS 10 Management apparatus 11 Process request part 12 Identifier setting part 13 Process management part 20 Server apparatus 21 Process execution part 22 Storage part 23 Execution result transmission part 24 Communication part 25 Identifier setting part 30 Terminal 40 Database 100 Transaction management system 110 Computer 111 CPU
112 Main Memory 113 Storage Device 114 Input Interface 115 Display Controller 116 Data Reader / Writer 117 Communication Interface 118 Input Device 119 Display Device 120 Recording Medium 121 Bus

Claims

A server device, and a management device that requests the server device to execute a transaction,
The management device
An identifier setting unit for setting an identifier in the transaction;
A processing request unit that transmits the set identifier to the server device and requests execution of the transaction;
The server device
When the identifier is received, a process execution unit that executes the transaction requested by the management device;
A storage unit that stores the identifier and the execution result of the transaction in association with each other;
When the management device uses the identifier to request transmission of the execution result of the transaction, the identifier is used on condition that the identifier used and the identifier stored in the storage unit match. An execution result transmission unit that transmits the execution result of the transaction linked to the management device,
A transaction management system characterized by that.

The management device further includes a processing management unit for setting a communication path with the server device,
The processing request unit requests execution of the transaction via the set communication path,
The processing management unit sets a new communication path when the set communication path is disconnected before the completion of the transaction, and uses the identifier to the server device via the new communication path. Requesting transmission of the execution result of the transaction,
The transaction management system according to claim 1.

The server device further comprises an identifier setting unit for setting a second identifier when a connection is requested from the management device;
The identifier setting unit of the management device generates a new identifier from the identifier set by the identifier and the second identifier,
The processing request unit transmits the new identifier to the server device,
When the process execution unit of the server device receives the new identifier, it executes the transaction,
The storage unit of the server device stores the new identifier in association with the execution result of the transaction,
The execution result transmission unit of the server device stores the new identifier used and the storage unit when the management device requests transmission of the execution result of the transaction using the new identifier. The execution result of the transaction associated with the new identifier is transmitted to the management device on condition that the new identifier matches.
The transaction management system according to claim 1 or 2.

A server device that executes a transaction requested by a management device,
The management device sets an identifier for the transaction, transmits the set identifier to the server device, and requests execution of the transaction;
A storage unit that stores the identifier and the execution result of the transaction in association with each other;
When the management device uses the identifier to request transmission of the execution result of the transaction specified by the identifier, the identifier used and the identifier stored in the storage unit match. As a condition, an execution result transmitting unit that transmits an execution result of the transaction associated with the identifier to the management device;
The server apparatus characterized by the above-mentioned.

A management device for requesting the server device to execute a transaction,
An identifier setting unit for setting an identifier in the transaction;
A processing request unit that transmits the set identifier to the server device and requests execution of the transaction;
A management device characterized by comprising:

A transaction management method using a server device and a management device that requests the server device to execute a transaction,
(A) setting an identifier for the transaction by the management device, transmitting the set identifier to the server device, and requesting execution of the transaction;
(B) receiving the identifier by the server device and executing the transaction requested by the management device;
(C) The server device stores the identifier and the execution result of the transaction in association with each other;
(D) using the identifier to request transmission of the execution result of the transaction by the management device;
(E) The server device associates the identifier used in the step (d) with the identifier provided that the identifier stored in the step (c) matches the identifier used in the step (c). Transmitting the execution result of the transaction to the management device; and
A transaction management method characterized by comprising:

(F) further comprising the step of setting a communication path with the server device by the management device;
In the step (a), the execution of the transaction is requested via the communication path set in the step (f).
When the communication path set in the step (f) is disconnected before the transaction is completed, the step (d) is executed.
In the step (d), a new communication path is set by the management apparatus, and the server apparatus is requested to transmit the execution result of the transaction using the identifier via the new communication path. ,
The transaction management method according to claim 6.

(G) further comprising a step of setting a second identifier by the server device when a connection is requested from the management device to the server device;
In the step (a), the management device generates a new identifier from the identifier set by the management device and the second identifier, and further transmits the new identifier to the server device,
In the step (b), the server device receives the new identifier, executes the transaction,
In the step (c), the server device stores the new identifier in association with the execution result of the transaction,
In the step (d), the management device requests transmission of the execution result of the transaction using the new identifier,
In the step (e), on the condition that the server device matches the new identifier used in the step (d) and the new identifier stored in the step (c). Sending the execution result of the transaction associated with the new identifier to the management device;
The transaction management method according to claim 6 or 7.

A program for causing a computer to execute a transaction requested by a management device,
In the computer,
(A) The management device sets an identifier for the transaction, transmits the set identifier to the computer, and executes the transaction when requested to execute the transaction; and
(B) storing the identifier and the execution result of the transaction in association with each other;
(C) When the management apparatus uses the identifier to request transmission of the execution result of the transaction, the identifier used is the same as the identifier stored in the step (b) Transmitting the execution result of the transaction associated with the identifier to the management device; and
A program that executes

A program for requesting a server device to execute a transaction by a computer,
In the computer,
(A) setting an identifier for the transaction;
(B) transmitting the set identifier to the server device and requesting the execution of the transaction;
A program that executes