JP4823111B2 - IP telephone data relay program, IP telephone data relay server, and IP telephone system - Google Patents
IP telephone data relay program, IP telephone data relay server, and IP telephone system Download PDFInfo
- Publication number
- JP4823111B2 JP4823111B2 JP2007067393A JP2007067393A JP4823111B2 JP 4823111 B2 JP4823111 B2 JP 4823111B2 JP 2007067393 A JP2007067393 A JP 2007067393A JP 2007067393 A JP2007067393 A JP 2007067393A JP 4823111 B2 JP4823111 B2 JP 4823111B2
- Authority
- JP
- Japan
- Prior art keywords
- call
- call information
- data relay
- information
- relay server
- 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
Links
Images
Landscapes
- Exchange Systems With Centralized Control (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Telephonic Communication Services (AREA)
Description
本発明は、IP電話の通話データを中継する現用系及び予備系のデータ中継サーバ間の連携処理をしつつデータ中継を行う技術に関する。 The present invention relates to a technology for relaying data while performing cooperation processing between active and standby data relay servers that relay IP telephone call data.
端末間におけるIP電話を実現するIP電話システムでは、呼の確立及び解放を制御する呼制御サーバと、通話データを中継するデータ中継サーバと、を連携させて通話を実現する構成が一般的に採用されている。そして、かかるシステムでは、データ中継サーバに障害が発生した場合に備え、現用系及び予備系のデータ中継サーバによりデータ中継サーバを多重化した構成が採用されている。 In an IP telephone system that realizes an IP telephone between terminals, a configuration in which a call is realized by linking a call control server that controls call establishment and release and a data relay server that relays call data is generally adopted. Has been. Such a system employs a configuration in which the data relay servers are multiplexed by the active and standby data relay servers in case a failure occurs in the data relay server.
かかる従来のIP電話システムでは、現用系及び予備系のデータ中継サーバに、夫々IP電話端末間で確立されている呼情報を保持するための呼情報データベースを備え、特開昭59−148492号公報にも示されているように、現用系のデータ中継サーバの呼情報データベースに保持する呼情報を、所定時間毎に、予備系のデータ中継サーバの呼情報データベースに送信及び反映させている。そして、現用系のデータ中継サーバに障害が発生して予備系への切り替えが行なわれたときには、予備系のデータ中継サーバの呼情報データベースで保持している呼情報を用いて通話状態を継続させる。
しかしながら、かかる従来技術においては、現用系のデータ中継サーバに障害が発生して予備系への切り替えが行なわれるときに、次のような問題が生じていた。即ち、現用系の呼情報データベースで保持している呼情報が所定時間毎にしか予備系のデータ中継サーバに送信されないため、障害発生時に、予備系のデータ中継サーバに最新の呼情報が保持されておらず、正常にデータ中継処理を引き継ぐことができなかった。例えば、現用系のデータ中継サーバから予備系のデータ中継サーバへの呼情報の伝送が2秒毎に行なわれている場合、現用系から予備系への切り替えにより、最大で2秒間に発生した呼情報が全て失われ、これらの呼に係る通話が切断される事態が生じていた。そして、それらの呼については、一旦通話を切断して呼の再確立を行なう必要があった。 However, in the prior art, when a failure occurs in the active data relay server and the switching to the standby system is performed, the following problems occur. In other words, since the call information held in the active call information database is transmitted to the standby data relay server only at predetermined time intervals, the latest call information is held in the standby data relay server when a failure occurs. The data relay process could not be taken over normally. For example, when call information is transmitted from the active data relay server to the standby data relay server every 2 seconds, a call that has occurred for a maximum of 2 seconds due to switching from the active system to the standby system is performed. All the information was lost and the call related to these calls was disconnected. For these calls, it is necessary to disconnect the call and re-establish the call.
なお、かかる問題を解決すべく、所定時間毎に現用系の呼情報データベースの呼情報を予備系に反映させる代わりに、呼の確立要求又は解放要求が発生する毎に現用系と予備系の両方において呼情報データベースを更新した後、呼を確立又は解放させる方法も考えられる。しかしながら、この方法では呼の確立又は解放までに時間がかかるため、特に呼の確立が遅れることにより、ユーザにとって電話をかけてから通話が始まるまでの待ち時間が長くなるという不都合が発生してしまう。 In order to solve this problem, instead of reflecting the call information in the active call information database to the standby system every predetermined time, both the active system and the standby system each time a call establishment request or release request occurs. A method of establishing or releasing a call after updating the call information database in FIG. However, in this method, since it takes time to establish or release a call, in particular, a delay in the establishment of the call causes an inconvenience that the waiting time from the start of the call to the start of the call becomes long. .
そこで、本発明は以上のような従来の問題点に鑑み、データ中継サーバが多重化されたIP電話のデータ中継装置において、呼の確立又は解放を遅らせることなく、且つ、データ中継サーバに障害が発生しても通話を極力切断させないようにして高信頼性を実現することを目的とする。 Therefore, in view of the above-described conventional problems, the present invention provides a data relay server for an IP telephone in which data relay servers are multiplexed. The purpose is to realize high reliability by preventing a call from being disconnected as much as possible even if it occurs.
このため、本発明においては、IP電話端末間で確立されている呼情報を保持するための呼情報データベース及び呼情報データベースの更新情報を保持するための一時データベースを備えるとともにIP電話端末間で伝送されるデータを中継する手段を備え、現用系又は予備系のいずれかに任意に設定可能なデータ中継サーバを複数含んで構築されたネットワークコンピューティング環境において、現用系として設定したデータ中継サーバが、呼の確立要求又は削除要求の呼情報を受信したときに、その呼情報に基づいて、呼情報データベースを更新し、呼を確立又は解放することを即時許可するとともに、呼情報データベースの更新情報を、予備系として設定した他のデータ中継サーバに送信する一方、所定時間毎に、呼情報データベースの呼情報を読み込み、予備系として設定した他のデータ中継サーバに送信する。また、予備系として設定したデータ中継サーバが、更新情報を受信したときに、その更新情報に基づいて一時データベースを更新する一方、現用系のデータ中継サーバの呼情報データベースの呼情報を受信したときに、その呼情報に基づいて呼情報データベースを更新するとともに、一時データベースの更新情報を全件削除する。さらに、現用系として設定した他のデータ中継サーバに障害が発生したときに、予備系として設定したデータ中継サーバが、一時データベースの更新情報に基づいて呼情報データベースを更新し、現用系に切り替わることを特徴とする。 Therefore, in the present invention, a call information database for holding call information established between IP telephone terminals and a temporary database for holding update information of the call information database are provided and transmitted between IP telephone terminals. In a network computing environment constructed by including a plurality of data relay servers that can be arbitrarily set to either the active system or the standby system, the data relay server set as the active system is provided When the call information of the call establishment request or the deletion request is received, the call information database is updated based on the call information, and the call information database update information is immediately permitted to establish or release the call. While sending to other data relay servers set as standby system, call information database every predetermined time It reads the call information to the other data relay server set as the standby system. When the data relay server set as the standby system receives update information, it updates the temporary database based on the update information, while receiving call information from the call information database of the active data relay server. In addition, the call information database is updated based on the call information, and all the update information in the temporary database is deleted. In addition, when a failure occurs in another data relay server set as the active system, the data relay server set as the standby system updates the call information database based on the update information of the temporary database and switches to the active system. It is characterized by.
本発明によれば、現用系のデータ中継サーバの呼情報データベースで保持している呼情報を予備系のデータ中継サーバに所定時間毎に送信し、予備系のデータ中継サーバの呼情報データベースに反映させるのみならず、IP電話端末で呼の確立要求又は解放要求が発生する毎に、現用系のデータ中継サーバの呼情報データベースを更新するとともに予備系のデータ中継サーバにその更新情報を送信し、予備系のデータ中継サーバの一時データベースを更新する。このため、所定時間毎に現用系から予備系へ呼情報データベースの反映させた後に発生した呼の呼情報についても、予備系のデータ中継サーバで保持することができる。さらに、現用系のデータ中継サーバに障害が発生したときには、予備系のデータ中継サーバでは、一時データベースの更新情報を呼情報データベースに反映する。このため、現用系のデータ中継サーバに障害が発生しても、予備系の呼情報データベースを、障害発生時における現用系の呼情報データベースと同じ状態、即ち、最新の状態にすることができる。従って、障害発生時に接続されていた通話が切断され難くなり、通話データを継続して中継することができる。また、現用系のデータ中継サーバでは、呼の確立要求又は解放要求の呼情報を呼制御サーバから受信したときに、予備系のデータ中継サーバへの呼情報の反映処理を待たずに呼を確立又は解放を許可するため、呼を確立又は解放するまでの時間も短い。従って、呼の確立又は解放を遅らせることなく、高信頼性を実現することができる。 According to the present invention, call information held in the call information database of the active data relay server is transmitted to the standby data relay server every predetermined time and reflected in the call information database of the standby data relay server. In addition, every time a call establishment request or release request occurs at the IP telephone terminal, the call information database of the active data relay server is updated and the update information is transmitted to the standby data relay server, Update the temporary database on the standby data relay server. For this reason, call information of a call that occurs after the call information database is reflected from the active system to the standby system every predetermined time can be held by the standby data relay server. Further, when a failure occurs in the active data relay server, the standby data relay server reflects the update information of the temporary database in the call information database. Therefore, even if a failure occurs in the active data relay server, the standby call information database can be brought into the same state as the active call information database at the time of failure, that is, the latest state. Therefore, it is difficult to disconnect the call that was connected when the failure occurred, and the call data can be continuously relayed. The active data relay server establishes a call without waiting for the call information to be reflected on the standby data relay server when call establishment request or release request call information is received from the call control server. Or, since the release is permitted, the time until the call is established or released is also short. Therefore, high reliability can be realized without delaying call establishment or release.
以下、添付された図面を参照して本発明を詳述する。 Hereinafter, the present invention will be described in detail with reference to the accompanying drawings.
図1は、本発明を具現化したIP電話システムの構成を示す。このIP電話システムは、IP電話における呼の確立又は解放を行なう呼制御サーバ10,IP電話の通話データを中継する第1データ中継サーバ20及び第2データ中継サーバ30並びにIP電話の通話を行なうIP電話端末40を含んで構成される。ここで、第1データ中継サーバ20及び第2データ中継サーバ30は、同一のハードウェア構成を有し、設定に応じて、一方が現用系、他方が予備系として動作する。これらの呼制御サーバ10,第1データ中継サーバ20,第2データ中継サーバ30及びIP電話端末40は相互にネットワーク接続されている。そして、呼制御サーバ10及びIP電話端末40の間のネットワークを介して呼の確立及び解放が行なわれる。また、呼制御サーバ10,第1データ中継サーバ20及び第2データ中継サーバ30の間のネットワークを介して呼情報の伝送などが行なわれる。さらに、IP電話端末40と、第1データ中継サーバ20及び第2データ中継サーバ30と、の間のネットワークを介して通話データの伝送が行なわれる。なお、通話データは、単に音声が変換されたデータのみに限らず、例えば通話に伴う映像データなどを含んでもよい。
FIG. 1 shows the configuration of an IP telephone system embodying the present invention. This IP telephone system includes a
呼制御サーバ10は、SIP(Session Initiation Protocol)サーバなどで実現され、少なくとも中央処理装置(CPU)、メモリ及び外部記憶装置を備えたコンピュータで構成される。そして、IP電話端末40から呼の確立要求又は解放要求を受信すると、発呼側及び着呼側のIP電話端末40のIPアドレス及びポートを特定し、現用系のデータ中継サーバに送信する。なお、ここでは、発呼側及び着呼側のIP電話端末40の間におけるIPアドレス及びポートの変換要否情報を合わせて送信する。さらに、現用系のデータ中継サーバから、呼を確立又は解放させることを許可する応答と、必要に応じて変換後の発呼側及び着呼側のIPアドレス並びにポートと、を受信すると、発呼側及び着呼側のIP電話端末40の間で呼を確立又は解放させる。
The
第1データ中継サーバ20及び第2データ中継サーバ30は、少なくともCPU、メモリ及び外部記憶装置を備えたコンピュータで構成されたものである。図2は、第1データ中継サーバ20の機能概要を示す。第1データ中継サーバ20は、IP電話端末40において確立されている呼情報を保持するための呼情報データベース(DB)20A、呼情報DB20Aの更新情報を保持するための一時DB20B(これらのDBの詳細は後述する)を備える。また、データ中継プログラムが実行されると、当該データ中継サーバを現用系として動作させるか予備系として動作させるかの設定に応じて次の機能を実現する。即ち、現用系として動作するときにのみ、呼制御サーバ10と通信し呼情報の受信を行なう一方、呼情報に基づいて呼情報DB20Aを更新するなどの処理を行なう呼制御連携部20C,現用系として動作するときにのみ、IP電話端末40間の通話データの中継を行なうデータ中継部20D、及び、現用系として動作するときには呼情報を予備系のデータ中継サーバに送信する一方、予備系として動作するときには、現用系のデータ中継サーバから受信した呼情報などで呼情報DB20A及び一時DB20Bを更新する多重化連携部20Eの機能を実現する。
The first
呼情報DB20Aは、図3に示すように、呼情報を一意に特定するための呼情報識別子,発呼側のIP電話端末40のIPアドレス及びポートを示す発呼側端末情報,着呼側のIP電話端末40のIPアドレス及びポートを示す着呼側端末情報,IPアドレス及びポートを変換する必要があるか否かを示すアドレス変換要否,IPアドレス及びポートを変換する必要があるときに発呼側のIPアドレス及びポートが着呼側で認識できるように変換された発呼側変換情報並びに着呼側のIPアドレス及びポートが発呼側で認識できるように変換された着呼側変換情報を含んで構成される。
As shown in FIG. 3, the
一時DB20Bは、図4に示すように、呼情報が呼情報DB20Aに追加されたか呼情報DB20Aから削除されたかを示す更新種別,呼情報識別子,発呼側端末情報,着呼側端末情報,アドレス変換要否,発呼側変換情報及び着呼側変換情報を含んで構成される。
As shown in FIG. 4, the
また、第2データ中継サーバ30も同様に、呼情報データベース30A,一時DB30B,呼制御連携部30C,データ中継部30D及び多重化連携部30Eを含んで構成される。これらの機能は、夫々呼情報データベース20A,一時DB20B,呼制御連携部20C,データ中継部20D及び多重化連携部20Eと同じであるため、説明を省略する。
Similarly, the second
以下、図5を参照し、第1データ中継サーバ20が現用系、第2データ中継サーバ30が予備系として設定され、第1データ中継サーバ20が正常に動作しているときに、IP電話システムにおいて実行される処理の全体の流れについて説明する。なお、図5では、機能していない部分については表示していない(以下同様)。
Hereinafter, referring to FIG. 5, when the first
発呼側のIP電話端末40から、呼の確立要求又は解放要求が発信されると(1)、呼制御サーバ10では、発呼側及び着呼側のIP電話端末40のIPアドレス及びポートを特定し、その呼情報を第1データ中継サーバ20の呼制御連携部20Cに送信する(2)。呼制御連携部20Cでは、呼制御サーバ10から受信した呼情報に基づいて呼情報DB20Aを更新するとともに(3)、多重化連携部20Eに、呼情報DB20Aの更新情報を通知する(4)。そして、呼制御サーバ10に呼の確立又は解放を許可する応答を返信し(5)、この応答を受信した呼制御サーバ10では、呼情報を着呼側のIP電話端末40に送信する(6)。さらに、呼制御サーバ10では、着呼側のIP電話端末40から応答が返信されると(7)、この応答を発呼側のIP電話端末40に送信し(8)、呼を確立又は解放する。そして、発呼側のIP電話端末40から、通話データが第1データ中継サーバのデータ中継部20Dに送信され(9)、データ中継部20Dでは、呼情報DB20Aを参照し、受信した通話データに含まれる呼情報と一致する呼情報が、呼情報DB20Aに存在するか否かを確認する(10)。ここで、通話データに含まれる呼情報と一致する呼情報が呼情報DB20Aに存在すれば、通話データを着呼側のIP電話端末40に中継し(11)、存在しなければ、呼が確立されていないものとして当該通話データを破棄する。
When a call establishment request or release request is issued from the calling side IP telephone terminal 40 (1), the
また、(4)において多重化連携部20Eに呼情報DB20Aの更新情報が通知されると、多重化連携部20Eでは、通知された更新情報を第2データ中継サーバ30の多重化連携部30Eに送信する(12)。そして、多重化連携部30Eでは、受信した更新情報に基づいて一時DB30Bを更新する(13)。また、一方で、多重化連携部20Eでは、所定時間毎に呼情報DB20Aの呼情報を読み込み(14)、多重化連携部30Eに送信する(15)。そして、多重化連携部30Eでは、かかる呼情報DB20Aの呼情報を受信すると、その呼情報に基づいて呼情報DB30Aを更新するとともに(16)、一時DB30Bの呼情報を全て削除する。
When the update information of the
ここで、図5を用い、主に,多重化連携部20E及び多重化連携部30Eにおける具体的な処理について、呼情報DB20A,呼情報DB30A及び一時DB30Bの呼情報を示す図3,4及び図6を参照しながら説明する。
Here, with reference to FIG. 5, FIGS. 3, 4 and 4 showing call information in the
あるタイミングにおいて、呼情報DB20Aに、図3に示すように呼情報識別子が「1」,「2」及び「3」の呼情報が保持されているとする。そして、多重化連携部20Eで所定時間毎にこの呼情報を読み出し(14)、多重化連携部30Eに送信すると(15)、多重化連携部30Eにおいてこの呼情報に基づいて呼情報DB30Aを更新する(16)。すると、呼情報DB30Aの呼情報が、呼情報DB20Aの呼情報と一致する状態、即ち、図3の状態となる。ここで、この処理から所定時間が経過して次に(15)及び(16)の処理が行なわれるまでの間に、IP電話端末40において呼の確立要求が発信された場合、呼制御連携部20Cでは、この呼情報(呼情報識別子が「4」とする)を呼制御サーバ10から受信すると(2)、図6に示すように呼制御DB20Aに追加する(3)。一方、この呼情報が多重化連携部20Eに通知され(4)、多重化連携部20Eでこの呼情報を多重化連携部30Eに送信すると(13)、多重化連携部30Eでは、図4に示すように、呼情報識別子が「4」の呼情報を、呼情報DB20Aに追加されたことを示す更新種別とともに一時DB20Bに追加する。また、次に、IP電話端末40において、呼情報識別子が「1」の呼について解放要求が発信された場合にも、同様にして、図6に示すように、呼制御連携部20Cで呼情報DB20Aからこの呼情報を削除するととともに、図4に示すように、多重化連携部30Eで、一時DB30Bに、呼情報識別子が「1」の呼情報を、呼情報DB20Aから削除されたことを示す更新種別とともに追加する。ここで、呼情報DB30Aは、所定時間が経過して次に(15)及び(16)の処理が行なわれるまで図3の状態のままであり、次に(15)及び(16)の処理が行なわれると、多重化連携部30Eで、呼情報DB20Aの状態、即ち、図6の状態を呼情報DB30Aに反映するとともに、一時DB30Bの呼情報を削除することとなる。
Assume that call information having call information identifiers “1”, “2”, and “3” is held in the
次に、各処理内容について詳細に説明する。 Next, each processing content will be described in detail.
図7は、第1データ中継サーバ20の呼制御連携部20Cによって実行される呼制御連携処理の処理内容を示す。なお、この処理は、呼制御サーバ10から呼の確立要求又は削除要求の呼情報を受信する毎に実行される。呼制御サーバ10から受信する呼情報には、呼情報識別子,発呼側端末情報,着呼側端末情報及びアドレス変換可否情報が含まれる。
FIG. 7 shows the processing contents of the call control cooperation process executed by the call
ステップ1(図では「S1」と略記する。以下同様)では、呼の確立要求の呼情報であるか否かを判定する。呼の確立要求の呼情報であるときにはステップ2に進み(Yes)、呼の確立要求の呼情報でないとき(即ち、解放要求であるとき)には、ステップ3に進む(No)。 In step 1 (abbreviated as “S1” in the figure, the same applies hereinafter), it is determined whether or not the call information is a call establishment request. If it is call information of a call establishment request, the process proceeds to step 2 (Yes), and if it is not call information of a call establishment request (that is, a release request), the process proceeds to step 3 (No).
ステップ2では、受信した呼情報の呼情報識別子,発呼側端末情報,着呼側端末情報及びアドレス変換要否を呼情報DB20Aに追加する。
In
ステップ3では、呼情報DB20Aに保持されている呼情報のうち、受信した呼情報と呼情報識別子(若しくは発呼側端末情報及び着呼側端末情報)が一致する呼情報を呼情報DB20Aから削除する。
In
ステップ4では、多重化連携部20Eに、受信した呼情報に更新種別を付した更新情報を通知する。
In
ステップ5では、呼制御サーバ10に対し、呼を確立又は解放を許可する応答を返信する。なお、呼制御サーバ10では、この返信がなされると、呼を確立又は解放する。
In
かかる処理により、呼制御サーバ10から呼の確立要求又は解放要求が受信されるごとに、その呼情報が呼情報DB20Aに反映されるため、呼情報DB20Aに保持されている呼情報が、呼制御サーバ10において確立されている呼の呼情報と一致するものとなる。また、予備系としての第2データ中継サーバ30に呼情報を反映させるのを待たずに呼を確立又は解放させるため、呼の確立又は解放を迅速に行なうことができる。さらに、呼情報DB20Aが更新される毎に、その更新情報が多重化連携部20Eに通知されることにより、多重化連携部20Eでは、その更新情報を予備系としての第2データ中継サーバ30に送信することができるようになる。
With this process, every time a call establishment request or release request is received from the
ところで、IP電話端末40同士で、使用するIPアドレスの形式やポートが異なることがある。例えば、発呼側のIP電話端末40がIPv4を使用し、着呼側のIP電話端末40がIPv6を使用する場合などである。かかる場合には、呼制御サーバ10において呼情報のアドレス変換要否にアドレス変換が必要である旨の情報が付され、これを受信した呼制御連携部20Cにおいて、双方のIP電話端末40が認識可能な形式にアドレス及びポートを変換して呼情報DB20Aの発呼側変換情報及び着呼側変換情報に書き込んだ上で、これらの変換情報を多重化連携部20Eに通知するとともに、呼制御サーバ10に返信する。こうすることで、様々な種類のIP電話端末間において通話を実現することが可能となる。
By the way,
図8は、多重化連携部20Eによって実行される呼情報同期送信処理を示す。この処理は、呼制御連携部20Cから呼情報を受信する毎に実行される。
FIG. 8 shows a call information synchronous transmission process executed by the
ステップ11では、予備系としての第2データ中継サーバ30の多重化連携部30Eに対し、呼制御連携部20Cから受信した更新情報を送信する。
In
かかる呼情報同期送信処理により、IP電話端末40において呼の確立要求又は解放要求が発生し、呼情報DB20Aが更新される毎に、呼情報DB20Aの更新情報が予備系としての第2データ中継サーバに送信されることができる。
With this call information synchronous transmission process, every time a call establishment request or release request is generated in the
なお、呼制御連携処理及び呼情報同期送信処理が、現用系同期処理手段に相当する。 Note that the call control cooperation process and the call information synchronization transmission process correspond to the active system synchronization processing means.
図9は、多重化連携部20Eによって実行される呼情報DB送信処理を示す。この処理は、第1データ処理装置20が備えるタイマ(図示せず)により、所定時間毎に実行される。
FIG. 9 shows a call information DB transmission process executed by the
ステップ21では、呼情報DB20Aの呼情報を全件読み込む。
In
ステップ22では、前回の呼情報DB20Aの読み込み時に保持していた呼情報(図示せず)と、今回読み込んだ呼情報との差分情報を抽出する。
In
ステップ23では、第2データ中継サーバ30の多重化連携部30Eに対し、差分情報を送信する。
In step 23, the difference information is transmitted to the
かかる呼情報DB送信処理により、呼情報DB20Aに登録されている呼情報、即ち、呼制御サーバ10において現在確立されている呼情報を、予備系としての第2データ中継サーバ30に送信することができる。また、前回の呼情報DB20Aの読み込み時との差分情報のみを送信することで、呼情報DB20Aの呼情報を全件送信する場合に比べ、ネットワークトラフィックの負荷を低減させることができる。
By such call information DB transmission processing, call information registered in the
なお、呼情報DB送信処理が、現用系非同期処理手段に相当する。 The call information DB transmission process corresponds to the working asynchronous processing means.
図10は、データ中継部20Dによって実行されるデータ中継処理を示す。この処理は、IP電話端末40から通話データを受信する毎に実行される。
FIG. 10 shows data relay processing executed by the
ステップ31では、呼制御DB20Aを参照し、受信した通話データに含まれる呼情報の発呼側端末情報及び着呼側端末情報と発呼側端末情報及び着呼側端末情報が一致する呼情報が存在するか否か、即ち、呼制御サーバ10において呼が確立されている状態であるか否かを判定する。該当する呼情報が呼情報DB20Aに存在すれば、ステップ32に進み(Yes)、該当する呼情報が呼情報DB20Aに存在しなければ、ステップ33に進む(No)。
In step 31, with reference to the
ステップ32では、IP電話端末40間における通話データを中継する。なお、このとき、呼制御DB20Aの発呼側変換情報及び着呼側変換情報に変換情報が書き込まれていれば、これらの変換情報を用いて必要に応じてIPアドレス及びポートを変換し、通話データを中継する。
In step 32, the call data between the
ステップ33では、受信した通話データを破棄する。 In step 33, the received call data is discarded.
かかる処理により、呼制御サーバ10で確立されている呼についてのみデータ中継を行い、IP電話端末40間の通話を実現することができる。
With this process, it is possible to perform data relay only for calls established in the
なお、一般的に、呼制御サーバ10から通知される呼情報は、不完全な場合がある。例えば、発呼側のIP電話端末40の使用するポートが未定であったりする場合などである。かかる場合には、データ中継部20Dにおいて、通話データを中継する際に、通話データに含まれる呼情報に基づいて呼情報DB20Aの呼情報を補完する。
Generally, call information notified from the
図11は、第2データ中継サーバ30の多重化連携部30Eにおいて、多重化連携部20Eから呼の確立要求又は解放要求毎に送信される更新情報を受信する毎に実行される一時DB更新処理を示す。
FIG. 11 shows a temporary DB update process that is executed every time the
ステップ41では、受信した更新情報、即ち、更新種別,呼情報識別子,発呼側端末情報,着呼側端末情報,アドレス変換要否,発呼側変換情報及び着呼側変換情報を、一時DB30Bに追加する。
In step 41, the received update information, that is, update type, call information identifier, calling side terminal information, called side terminal information, necessity of address conversion, calling side conversion information, and called side conversion information are stored in the
かかる一時DB更新処理により、IP電話端末40において呼の確立要求又は解放要求が発信される毎に、その呼情報を予備系としての第2データ中継サーバで保持しておくことができる。
With this temporary DB update process, every time a call establishment request or release request is transmitted in the
なお、一時DB更新処理が、予備系同期処理手段に相当する。また、呼制御連携処理及び呼情報同期送信処理及び一時DB更新処理が、同期処理手段に相当する。 The temporary DB update process corresponds to a standby system synchronization processing unit. Further, the call control cooperation process, the call information synchronous transmission process, and the temporary DB update process correspond to the synchronization processing means.
図12は、多重化連携部30Eにおいて、多重化連携部20Eから所定時間毎に呼情報DB20Aの呼情報(差分情報)を受信する毎に実行される予備系呼情報DB更新処理を示す。
FIG. 12 shows a standby call information DB update process that is executed each time the
ステップ51では、受信した呼情報DB20Aの呼情報(差分情報)に基づいて、呼情報DB31を更新する。
In step 51, the call information DB 31 is updated based on the received call information (difference information) in the
ステップ52では、一時DB30Bの更新情報を全件削除する。ここで、この処理は、受信した呼情報で呼情報DB30Bが更新されたことで、呼情報DB20Aと呼情報DB30Aとが一致したため、一時DB30Bに登録されている更新情報が不要となることによるものである。
In
かかる予備系呼情報DB更新処理により、現用系としての第1データ中継サーバ20の呼情報DB20Aの呼情報が予備系としての第2データ中継サーバ30の呼情報DB30Aに反映されることで、呼情報DB30Aの呼情報が最新のものとなる。
With this standby call information DB update process, the call information in the
なお、予備系呼情報DB更新処理が、予備系非同期処理手段に相当する。また、呼情報DB送信処理及び予備系呼情報DB更新処理が、非同期処理手段に相当する。 The standby call information DB update processing corresponds to backup asynchronous processing means. In addition, the call information DB transmission process and the standby call information DB update process correspond to an asynchronous processing means.
次に、図13を用い、第1データ中継サーバ20に障害が発生し、第2データ中継サーバが予備系から現用系に切り替えられるときに、IP電話データ中継装置で実行される処理の全体の流れについて説明する。
Next, referring to FIG. 13, when a failure occurs in the first
多重化連携部30Eでは、一時DB30Bの呼情報を全件読み込み(17)、呼情報DB30Aに反映させる(18)。そして、呼制御連携部30Cでは、呼制御サーバ10と通信を開始する(19)一方、データ中継部30Dでは、各IP電話端末40との通信を開始し、呼情報DB20Aの呼情報が反映された呼情報DB30Aを参照して(20)、データ中継を行なう((21)及び(22))。
The
さらに、各処理内容を詳細に説明する。 Furthermore, each processing content is demonstrated in detail.
図14は、多重化連携部30Eによる切替処理を示す。この処理は、第1データ中継サーバ20に障害が発生したことを第2データ中継サーバ30において検知したときに実行される。
FIG. 14 shows a switching process by the
ステップ61では、一時DB30Bから、更新情報を1つ読み込む。
In
ステップ62では、読み込んだ更新情報の更新種別に基づいて、読み込んだ呼情報が呼情報DB20Aに追加されたものであるか否かを判別する。読み込んだ呼情報が呼情報DB20Aに追加されたものであるときには、ステップ63に進み(Yes)、読み込んだ呼情報が呼情報DB20Aに追加されたものでないときには、ステップ64に進む(No)。
In step 62, it is determined whether or not the read call information is added to the
ステップ63では、読み込んだ更新情報の呼情報識別子,発呼側端末情報,着呼側端末情報,アドレス変換要否,発呼側変換情報及び着呼側変換情報を、呼情報DB30Aに追加する。
In step 63, the call information identifier, calling side terminal information, called side terminal information, address conversion necessity / unnecessity, calling side conversion information and called side conversion information of the read update information are added to the
ステップ64では、呼情報DB20Aに保持されている呼情報のうち、読み込んだ更新情報と呼情報識別子(若しくは発呼側端末情報及び着呼側端末情報)が一致する呼情報を呼情報DB30Aから削除する。
In Step 64, call information whose call information identifier (or calling side terminal information and called side terminal information) matches with the read update information is deleted from the
ステップ65では、一時DB30Bに登録された更新情報を、全件読み終わったか否かを判定する。全件読み終わっていればステップ66に進み(Yes)、全件読み終わっていなければステップ61に戻る(No)。
In
ステップ66では、一時DB30Bに登録された更新情報を全件削除する。
In step 66, all update information registered in the
なお、かかる切替処理が、切替手段に相当する。 Such switching processing corresponds to switching means.
かかる切替処理によれば、所定時間毎に呼情報DB20Aの呼情報が反映されている呼情報DB30Aに対し、さらに、前回の予備系呼情報DB更新処理以降であって第1データ中継サーバ20の障害発生時までに発生した呼の確立要求又は削除要求の呼情報を反映させることができる。このため、第1データ中継サーバ20の障害がどんなタイミングで発生したとしても、呼情報DB30Aを、障害発生時における呼情報DB20Aと一致させることができ、呼情報DB30Aの呼情報を最新の状態にすることができる。
According to the switching process, the
さらに、呼制御連携部30Cは、切替処理が完了すると、呼制御連携部20Cに代わり、呼制御サーバ10との通信を開始する。また、データ中継部30Dも同様に、切替時呼情報反映処理が完了すると、多重化連携部20Eに代わり、IP電話端末40間におけるデータの中継を開始する。ここで、切替処理により、呼制御サーバ10で確立されている呼の呼情報が呼情報DB30Aで保持され最新の状態となっているため、データ中継を正常に行なうことができる。なお、これらの呼制御連携部30C及びデータ中継部30Dの処理は、夫々呼制御連携部20C及びデータ中継部20Dの処理と同様であるため、ここでは説明を省略する。
Furthermore, when the switching process is completed, the call
従って、従来であれば、第1データ中継サーバ20に障害が発生した場合、障害発生前における最後の呼情報DB反映処理以降であって障害発生時までに確立された呼については予備系においてその呼情報を保持できないため、呼制御サーバ10との連携ができなくなり、それらの呼による通話接続については切断せざるをえなかったが、これらの通話接続が切断され難くなるため、通話接続が安定したものとなる。また、呼情報連携部20Cでは、第2データ中継サーバ30への呼情報の反映処理を待たずに呼制御サーバに呼を確立又は解放させることを許可する応答を返信するため、呼を確立又は解放するまでの時間も短い。従って、呼の確立又は解放を遅らせることなく、通話の高信頼性を実現することができる。
Therefore, conventionally, when a failure occurs in the first
なお、本実施例では予備系のデータ中継装置を1台としているが、複数台としてもよい。 In this embodiment, one backup data relay apparatus is used, but a plurality of data relay apparatuses may be used.
10 呼制御サーバ
20 第1データ中継装置
20A 呼情報DB
20B 一時DB
20C 呼制御連携部
20D データ中継部
20E 多重化連携部
30 第2データ中継装置
30A 呼情報DB
30B 一時DB
30C 呼制御連携部
30D データ中継部
30E 多重化連携部
40 IP電話端末
10
20B Temporary DB
20C Call
30B Temporary DB
30C Call
Claims (6)
現用系として設定したデータ中継サーバを、
呼の確立要求又は削除要求の呼情報を受信したときに、該呼情報に基づいて、前記呼情報データベースを更新し、呼を確立又は解放することを即時許可するとともに、該呼情報データベースの更新情報を、予備系として設定した他のデータ中継サーバに送信する現用系同期処理手段と、
所定時間毎に、前記呼情報データベースの呼情報を読み込み、予備系として設定した他のデータ中継サーバに送信する現用系非同期処理手段と、
として機能させる一方、
予備系として設定したデータ中継サーバを、
前記現用系同期処理手段により送信された更新情報を受信したときに、該更新情報に基づいて一時データベースを更新する予備系同期処理手段と、
前記現用系非同期処理手段により送信された呼情報を受信したときに、該呼情報に基づいて呼情報データベースを更新するとともに、前記一時データベースの更新情報を全件削除する予備系非同期処理手段と、
現用系として設定した他のデータ中継サーバに障害が発生したときに、前記一時データベースの更新情報に基づいて前記呼情報データベースを更新し、現用系に切り替える切替手段と、
として機能させることを特徴とするIP電話データ中継プログラム。 A call information database for holding call information established between IP telephone terminals and a temporary database for holding update information of the call information database, and means for relaying data transmitted between IP telephone terminals In a network computing environment constructed by including a plurality of data relay servers that can be arbitrarily set to either the active system or the standby system,
The data relay server set as the active system
When call information of a call establishment request or a deletion request is received, the call information database is updated based on the call information, and the call information database is immediately permitted to be established or released, and the call information database is updated. Active system synchronization processing means for transmitting information to another data relay server set as a standby system;
Active system asynchronous processing means for reading call information in the call information database and transmitting it to another data relay server set as a standby system at predetermined time intervals;
While functioning as
The data relay server set as the standby system
When the update information transmitted by the active system synchronization processing means is received, the standby system synchronization processing means for updating the temporary database based on the update information;
When the call information transmitted by the active asynchronous processing means is received, the call information database is updated based on the call information, and the standby asynchronous processing means for deleting all the update information of the temporary database;
Switching means for updating the call information database based on the update information of the temporary database and switching to the active system when a failure occurs in another data relay server set as the active system;
An IP telephone data relay program characterized in that it functions as
前記現用系同期処理手段は、呼の確立要求の呼情報を受信したときに、前記呼情報データベースに該呼情報の発呼側端末情報及び着呼側端末情報を追加する一方、呼の解放要求の呼情報を受信したときに、前記呼情報データベースに保持された呼情報のうち、受信した呼情報と発呼側端末情報及び着呼側端末情報が一致する呼情報を削除することを特徴とする請求項1記載のIP電話データ中継プログラム。 The call information includes calling-side terminal information and called-side terminal information for specifying the calling-side and called-side IP telephone terminals, respectively.
When the active synchronization processing means receives the call information of the call establishment request, it adds the calling terminal information and the called terminal information of the call information to the call information database, while the call release request When the call information is received, call information in which the received call information matches the calling terminal information and the called terminal information is deleted from the call information held in the call information database. The IP telephone data relay program according to claim 1.
前記呼情報データベースから呼情報を読み込んだときに、前回読み込んだ呼情報との差分情報を抽出し、該差分情報のみを予備系として設定した他のデータ中継サーバに送信することを特徴とする請求項1又は請求項2に記載のIP電話データ中継プログラム。 The active asynchronous processing means is
When the call information is read from the call information database, difference information from the previously read call information is extracted, and only the difference information is transmitted to another data relay server set as a standby system. The IP telephone data relay program according to claim 1 or 2.
発呼側のIP電話端末と着呼側のIP電話端末とで認識可能なIPアドレス形式が異なるときには、発呼側のIP電話端末のIPアドレスを着呼側のIP電話端末で認識可能な形式に変換する一方、着呼側のIP電話端末のIPアドレスを発呼側のIP電話端末で認識可能な形式に変換する変換手段としてさらに機能させることを特徴とする請求項1乃至請求項3のいずれか1つに記載のIP電話データ中継プログラム。 The data relay server set as the active system
When the IP address format that can be recognized by the calling IP phone terminal is different from that of the called IP phone terminal, the IP address format of the calling IP phone terminal can be recognized by the calling IP phone terminal 4. The method according to claim 1, further comprising: converting means for converting the IP address of the called IP telephone terminal into a format recognizable by the calling IP telephone terminal. The IP telephone data relay program according to any one of the above.
現用系として設定したデータ中継サーバが、
呼の確立要求又は削除要求の呼情報を受信したときに、該呼情報に基づいて、前記呼情報データベースを更新し、呼を確立又は解放することを即時許可するとともに、該呼情報データベースの更新情報を、予備系として設定した他のデータ中継サーバに送信する現用系同期処理手段と、
所定時間毎に、前記呼情報データベースの呼情報を読み込み、予備系として設定した他のデータ中継サーバに送信する現用系非同期処理手段と、
を備えて構成され、
予備系として設定したデータ中継サーバが、
前記現用系同期処理手段により送信された更新情報を受信したときに、該更新情報に基づいて一時データベースを更新する予備系同期処理手段と、
前記現用系非同期処理手段により送信された呼情報を受信したときに、該呼情報に基づいて呼情報データベースを更新するとともに、前記一時データベースの更新情報を全件削除する予備系非同期処理手段と、
現用系として設定した他のデータ中継サーバに障害が発生したときに、前記一時データベースの更新情報に基づいて前記呼情報データベースを更新し、現用系に切り替える切替手段と、
を備えて構成されたことを特徴とするIP電話データ中継サーバ。 A call information database for holding call information established between IP telephone terminals and a temporary database for holding update information of the call information database, and means for relaying data transmitted between IP telephone terminals In a network computing environment constructed by including a plurality of data relay servers that can be arbitrarily set to either the active system or the standby system,
The data relay server set as the active system is
When call information of a call establishment request or a deletion request is received, the call information database is updated based on the call information, and the call information database is immediately permitted to be established or released, and the call information database is updated. Active system synchronization processing means for transmitting information to another data relay server set as a standby system;
Active system asynchronous processing means for reading call information in the call information database and transmitting it to another data relay server set as a standby system at predetermined time intervals;
Configured with
The data relay server set as the standby system
When the update information transmitted by the active system synchronization processing means is received, the standby system synchronization processing means for updating the temporary database based on the update information;
When the call information transmitted by the active asynchronous processing means is received, the call information database is updated based on the call information, and the standby asynchronous processing means for deleting all the update information of the temporary database;
Switching means for updating the call information database based on the update information of the temporary database and switching to the active system when a failure occurs in another data relay server set as the active system;
An IP telephone data relay server, comprising:
前記現用系及び予備系のデータ中継サーバが、前記呼制御サーバによりIP電話端末間で確立されている呼情報を保持するための呼情報データベース及び呼情報データベースの更新情報を保持するための一時データベースを備え、
前記呼制御サーバから前記現用系のデータ中継サーバに送信された呼の確立要求又は削除要求の呼情報に基づいて、該現用系のデータ中継サーバの呼情報データベースを更新し、呼を確立又は解放することを前記呼制御サーバに対し即時許可するとともに、該現用系のデータ中継サーバの呼情報データベースの更新情報に基づいて前記予備系のデータ中継サーバの一時データベースを更新する同期処理手段と、
所定時間毎に、前記現用系のデータ中継サーバの呼情報データベースの呼情報を読み込み、該呼情報に基づいて前記予備系のデータ中継サーバの呼情報データベースを更新するとともに、前記予備系のデータ中継サーバの一時データベースの更新情報を全件削除する非同期処理手段と、
前記現用系のデータ中継サーバに障害が発生したときに、前記予備系のデータ中継サーバの一時データベースの更新情報に基づいて該予備系のデータ中継サーバの呼情報データベースを更新し、該予備系のデータ中継サーバを現用系に切り替える切替手段と、
を備えて構成されたことを特徴とするIP電話システム。 A network computing environment constructed including a call control server for establishing and releasing a call between IP telephone terminals, and an active and standby data relay server for relaying data transmitted between IP telephone terminals In
A temporary database for holding the call information database for holding the call information established between the IP telephone terminals by the call control server and the update information of the call information database by the active and standby data relay servers With
Based on the call information of the call establishment request or deletion request transmitted from the call control server to the active data relay server, the call information database of the active data relay server is updated to establish or release the call. Synchronization processing means for immediately permitting the call control server to perform, and updating the temporary database of the standby data relay server based on update information of the call information database of the active data relay server;
The call information database of the active data relay server is read at predetermined time intervals, the call information database of the standby data relay server is updated based on the call information, and the standby data relay Asynchronous processing means to delete all update information of server temporary database,
When a failure occurs in the active data relay server, the call information database of the standby data relay server is updated based on the update information of the temporary database of the standby data relay server. Switching means for switching the data relay server to the active system;
An IP telephone system characterized by comprising:
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2007067393A JP4823111B2 (en) | 2007-03-15 | 2007-03-15 | IP telephone data relay program, IP telephone data relay server, and IP telephone system |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2007067393A JP4823111B2 (en) | 2007-03-15 | 2007-03-15 | IP telephone data relay program, IP telephone data relay server, and IP telephone system |
Publications (2)
Publication Number | Publication Date |
---|---|
JP2008228221A JP2008228221A (en) | 2008-09-25 |
JP4823111B2 true JP4823111B2 (en) | 2011-11-24 |
Family
ID=39846247
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
JP2007067393A Expired - Fee Related JP4823111B2 (en) | 2007-03-15 | 2007-03-15 | IP telephone data relay program, IP telephone data relay server, and IP telephone system |
Country Status (1)
Country | Link |
---|---|
JP (1) | JP4823111B2 (en) |
Families Citing this family (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
JP5621196B2 (en) * | 2009-02-27 | 2014-11-05 | 沖電気工業株式会社 | Network control system, method and program |
JP7319007B2 (en) * | 2018-07-30 | 2023-08-01 | 日本電気通信システム株式会社 | Communication system, communication device, communication method and program |
JP7047671B2 (en) * | 2018-08-29 | 2022-04-05 | 沖電気工業株式会社 | Communication equipment, synchronization program, and synchronization method |
Family Cites Families (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
JPS59148492A (en) * | 1983-02-14 | 1984-08-25 | Hitachi Ltd | Restart processing system of electronic exchange of duplicate constitution |
JPH05244261A (en) * | 1992-03-02 | 1993-09-21 | Nec Corp | Interrupting point restart system |
JP4017298B2 (en) * | 1999-09-01 | 2007-12-05 | 株式会社日立コミュニケーションテクノロジー | Private branch exchange system |
-
2007
- 2007-03-15 JP JP2007067393A patent/JP4823111B2/en not_active Expired - Fee Related
Also Published As
Publication number | Publication date |
---|---|
JP2008228221A (en) | 2008-09-25 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US8244949B2 (en) | Slot interface access unit, method thereof, and program thereof, as well as redundancy configuration of main unit, and replacing method of the same | |
CN107529229B (en) | Data transmission method, device and system | |
MX2007004127A (en) | System and methods for a survivable remote network. | |
JP4576115B2 (en) | VoIP gateway device and method for controlling call arrival and departure in VoIP gateway device | |
JP4823111B2 (en) | IP telephone data relay program, IP telephone data relay server, and IP telephone system | |
US20080056239A1 (en) | VOIP Service Over a Regular Phone | |
JP5309350B2 (en) | Mobile communication gateway apparatus and mobile communication gateway control method | |
JP4387937B2 (en) | Telephone system and switching system | |
JP2010239216A (en) | Call control method | |
JP4920637B2 (en) | SIP telephone system, data transmission method, server unit and telephone terminal | |
JP4343189B2 (en) | Server device | |
JP2011188031A (en) | REDUNDANT VoIP SYSTEM | |
US8537988B2 (en) | Message relay system with message relay server | |
US20100220655A1 (en) | Method and a mobile phone terminal enabling to merge telephony services over heterogeneous networks | |
JP5519554B2 (en) | Call control system and information redundancy method used for call control | |
JP4094474B2 (en) | Telephone network line hold recall system | |
JP4339160B2 (en) | Call back system and method for IP telephone, program, and recording medium | |
JP6136305B2 (en) | Redundant VoIP system | |
JP7047671B2 (en) | Communication equipment, synchronization program, and synchronization method | |
JP2012178659A (en) | Call control system and method of making information for use in call control redundant | |
JP7052118B1 (en) | Communication interception system, communication interception device, communication interception method, and program | |
JP4167913B2 (en) | IP communication base station | |
JP5427853B2 (en) | Data synchronization method | |
US7664024B2 (en) | VoIP network system for multicasting packets and a method of constructing the same | |
US20100014654A1 (en) | Retablissement d'appel dans un serveur d'appel d'installation de telecommunications privee |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20091208 |
|
A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20110822 |
|
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: 20110906 |
|
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: 20110906 |
|
R150 | Certificate of patent or registration of utility model |
Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
FPAY | Renewal fee payment (event date is renewal date of database) |
Free format text: PAYMENT UNTIL: 20140916 Year of fee payment: 3 |
|
LAPS | Cancellation because of no payment of annual fees |