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
JP5886170B2 - Distributed processing system and distributed processing method - Google Patents
[go: Go Back, main page]

JP5886170B2 - Distributed processing system and distributed processing method - Google Patents

Distributed processing system and distributed processing method Download PDF

Info

Publication number
JP5886170B2
JP5886170B2 JP2012231717A JP2012231717A JP5886170B2 JP 5886170 B2 JP5886170 B2 JP 5886170B2 JP 2012231717 A JP2012231717 A JP 2012231717A JP 2012231717 A JP2012231717 A JP 2012231717A JP 5886170 B2 JP5886170 B2 JP 5886170B2
Authority
JP
Japan
Prior art keywords
packet
session
packet processing
data transfer
unit
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
JP2012231717A
Other languages
Japanese (ja)
Other versions
JP2014086756A (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.)
NTT Inc
NTT Inc USA
Original Assignee
Nippon Telegraph and Telephone Corp
NTT Inc USA
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 Nippon Telegraph and Telephone Corp, NTT Inc USA filed Critical Nippon Telegraph and Telephone Corp
Priority to JP2012231717A priority Critical patent/JP5886170B2/en
Publication of JP2014086756A publication Critical patent/JP2014086756A/en
Application granted granted Critical
Publication of JP5886170B2 publication Critical patent/JP5886170B2/en
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Landscapes

  • Data Exchanges In Wide-Area Networks (AREA)

Description

本発明は、ネットワーク上にパケット処理装置を複数台設置し、パケット処理を分散させて実行する分散処理システムおよび分散処理方法に関する。   The present invention relates to a distributed processing system and a distributed processing method in which a plurality of packet processing devices are installed on a network and packet processing is distributed and executed.

パケット処理装置の負荷分散や処理能力向上を目的とした分散処理システムが提案されている。   There has been proposed a distributed processing system for the purpose of distributing the load and improving the processing capability of the packet processing device.

図6に示す従来の分散処理システムは、N(Nは2以上の自然数)台のパケット処理装置(#1〜#N)10−1〜10−Nと、パケット処理装置(#1〜#N)10−1〜10−Nに接続される振り分け装置20−A,20−Bと、パケット処理装置(#1〜#N)10−1〜10−Nに接続されるデータベース60と、から構成される。   The conventional distributed processing system shown in FIG. 6 includes N (N is a natural number of 2 or more) packet processing devices (# 1 to #N) 10-1 to 10-N and packet processing devices (# 1 to #N). ) Consists of distribution devices 20-A and 20-B connected to 10-1 to 10-N and a database 60 connected to packet processing devices (# 1 to #N) 10-1 to 10-N Is done.

振り分け装置20−Aは、パケット受信部21と、振り分け先決定部22と、パケット送信部23と、から構成される。   The distribution device 20 -A includes a packet reception unit 21, a distribution destination determination unit 22, and a packet transmission unit 23.

パケット受信部21は、パケットを受信して、パケットを解析後、自装置内の適切な構成要素に転送する機能を備える。   The packet receiving unit 21 has a function of receiving a packet, analyzing the packet, and transferring the packet to an appropriate component in the own device.

振り分け先決定部22は、受信したパケットを解析し、その解析結果と予め設定された振り分けアルゴリズムとに従って、パケットの振り分け先のパケット処理装置10を決定する機能を備える。   The distribution destination determination unit 22 has a function of analyzing the received packet and determining the packet processing apparatus 10 to which the packet is distributed according to the analysis result and a predetermined distribution algorithm.

パケット送信部23は、受け取ったパケットを適切なインタフェースから送出する機能を備える。   The packet transmission unit 23 has a function of transmitting the received packet from an appropriate interface.

なお、振り分け装置20−Bの構成は、振り分け装置20−Aと同じである。   The configuration of the sorting device 20-B is the same as that of the sorting device 20-A.

パケット処理装置(#1)10−1は、パケット受信部11と、パケット処理部12と、パケット送信部13と、から構成される。   The packet processing device (# 1) 10-1 includes a packet reception unit 11, a packet processing unit 12, and a packet transmission unit 13.

パケット受信部11は、パケットを受信して、パケットを解析後、自装置内の適切な構成要素に転送する機能を備える。   The packet receiving unit 11 has a function of receiving a packet, analyzing the packet, and transferring the packet to an appropriate component in the own device.

パケット処理部12は、データベース60に格納された情報を参照し、パケットに対してパケット処理を実行する機能を備える。   The packet processing unit 12 has a function of referring to information stored in the database 60 and executing packet processing on the packet.

パケット送信部13は、受け取ったパケットを適切なインタフェースから送出する機能を備える。   The packet transmission unit 13 has a function of transmitting the received packet from an appropriate interface.

なお、パケット処理装置(#2〜#N)10−2〜10−Nの構成は、パケット処理装置(#1)10−1と同じである。   The configuration of the packet processing devices (# 2 to #N) 10-2 to 10-N is the same as that of the packet processing device (# 1) 10-1.

以下、従来の分散処理システムの概略動作の流れを説明する。   The general operation flow of the conventional distributed processing system will be described below.

振り分け装置20−Aにおいては、端末40−1からのパケットが到着すると、振り分け先決定部22が、予め設定された振り分けアルゴリズムに従って、パケットの振り分け先のパケット処理装置10を決定し、パケット送信部23が、パケットを振り分け先のパケット処理装置10に送信する。   In distribution device 20-A, when a packet from terminal 40-1 arrives, distribution destination determination unit 22 determines a packet processing device 10 that is a packet distribution destination according to a predetermined distribution algorithm, and packet transmission unit 23 transmits the packet to the packet processing apparatus 10 that is the distribution destination.

振り分け方法は、セッション単位で処理を行うパケット処理装置の分散処理に適用する場合、パケットのヘッダの5−tuple(送信元・送信先IPアドレス、プロトコルタイプ、送信元・送信先ポート番号)情報から、ハッシュ値を算出し、ハッシュ値に対応するパケット処理装置に振り分ける方法(特許文献1)などがある。   When the distribution method is applied to distributed processing of a packet processing device that performs processing in session units, the 5-tuple (source / destination IP address, protocol type, source / destination port number) information in the packet header is used. There is a method of calculating a hash value and distributing the hash value to a packet processing device corresponding to the hash value (Patent Document 1).

パケット処理装置(#1〜#N)10−1〜10−Nにおいては、パケットが到着すると、パケット処理部12が、パケット処理に用いる情報をデータベース60からダウンロードし、パケットに対してアドレス変換処理やトランスコーデック変換処理等のパケット処理を実行し、パケット送信部13が、パケットを振り分け装置20−Bへ送信する。また、パケット処理部12が、パケット処理の結果データをデータベース60に格納する。   In the packet processing devices (# 1 to #N) 10-1 to 10-N, when a packet arrives, the packet processing unit 12 downloads information used for packet processing from the database 60 and performs address conversion processing on the packet. And packet processing such as transcodec conversion processing is executed, and the packet transmission unit 13 transmits the packet to the sorting device 20-B. In addition, the packet processing unit 12 stores the result data of the packet processing in the database 60.

振り分け装置20−Bにおいては、パケット送信部23が、パケット処理装置(#1〜#N)10−1〜10−Nからのパケットを多重して出力する。   In distribution device 20-B, packet transmission unit 23 multiplexes and outputs packets from packet processing devices (# 1 to #N) 10-1 to 10-N.

特開2005−64882号公報JP 2005-64882 A

しかしながら、従来の分散処理システムにおいては、パケット処理装置(#1〜#N)10−1〜10−NがSBC(Session Border Controller)のような装置である場合に課題が生じる。   However, in the conventional distributed processing system, a problem occurs when the packet processing devices (# 1 to #N) 10-1 to 10-N are devices such as SBC (Session Border Controller).

そこで、まず、SBCの概要を説明する。   First, an overview of SBC will be described.

図7に示すように、SBCは、異なるIP電話サービス網間(図7では、IP電話サービス網A,B間)の境界に設置される装置である。   As shown in FIG. 7, SBC is a device installed at the boundary between different IP telephone service networks (in FIG. 7, between IP telephone service networks A and B).

複数のキャリアにより運営されるIP電話サービス網では、各々の網で規定されるアドレス体系、管理運営条件等が一致しない。そのため、SBCは、これらの網間の差分の吸収と隠ぺい、セキュリティの確保を目的として、導入される。   In an IP telephone service network operated by a plurality of carriers, the address system defined in each network, management operation conditions, etc. do not match. For this reason, SBC is introduced for the purpose of absorbing and concealing differences between these networks and ensuring security.

SBCの代表的な機能として、アドレス変換機能、セキュリティ機能(ファイアウォール機能)、およびトランスコーディング(TC)機能がある。   Typical functions of the SBC include an address translation function, a security function (firewall function), and a transcoding (TC) function.

図7に示すようなIP電話システムにおいては、まず、他のセッションの設定を行う制御用セッションであるSIPセッション(セッション1−1)によって、SIPパケットのペイロード部分に記載されたユーザ情報を基に、SBCに対して、アドレス変換設定や、ファイアウォール設定が行われる。   In the IP telephone system as shown in FIG. 7, first, based on the user information described in the payload portion of the SIP packet by the SIP session (session 1-1) which is a control session for setting another session. The address conversion setting and the firewall setting are performed for the SBC.

また、SIPセッション(セッション1−1)によって、通信相手のSIPサーバとのネゴシエーションが行われ、通信方式(トランスコーディング機能や使用帯域)が決定され、その通信方式がSBCに対して設定される。   In addition, the SIP session (session 1-1) is negotiated with the SIP server of the communication partner, a communication method (transcoding function and band used) is determined, and the communication method is set for the SBC.

上記の設定がSBCに対して行われると、続いて、データを転送するデータ転送用セッションであるRTPセッション(セッション1−2)によって、ユーザの音声・映像データがRTPパケットにより運ばれる。SBCでは、上記で設定された情報に基づき、アドレス変換処理、ファイアウォール処理、トランスコーディング処理を行う。   When the above setting is performed on the SBC, the user's audio / video data is subsequently carried by the RTP packet by the RTP session (session 1-2) which is a data transfer session for transferring data. In SBC, address conversion processing, firewall processing, and transcoding processing are performed based on the information set above.

続いて、従来の分散処理システムにおいて、パケット処理装置(#1〜#N)10−1〜10−NがSBCである場合に生じる課題を説明する。   Next, a problem that occurs when the packet processing apparatuses (# 1 to #N) 10-1 to 10-N are SBCs in the conventional distributed processing system will be described.

図8に示すように、パケット処理装置(#1〜#N)10−1〜10−NがSBCである場合、まず、SIPセッション(セッション1−1)によって、通信相手のSIPサーバとのネゴシエーションが行われ、セッション1−1と連携するRTPセッション(セッション1−2)の通信方式が決定される。その後、セッション1−2によって、上記で決定された通信方式により、データパケットを転送する。   As shown in FIG. 8, when the packet processing devices (# 1 to #N) 10-1 to 10-N are SBCs, first, negotiation with the SIP server of the communication partner is performed through the SIP session (session 1-1). And the communication method of the RTP session (session 1-2) linked with the session 1-1 is determined. Thereafter, the data packet is transferred by the session 1-2 by the communication method determined above.

しかし、振り分け装置20−Aは、上述したように、予め設定された5−tuple等の振り分けアルゴリズムに従って、パケットを振り分けるため、通信相手のSIPサーバとのネゴシエーションにより決定した通信方式に基づいて振り分け先のパケット処理装置10を決定することができない。   However, as described above, the distribution device 20-A distributes packets in accordance with a predetermined distribution algorithm such as 5-tuple, so that the distribution destination is based on the communication method determined by negotiation with the SIP server of the communication partner. Cannot be determined.

すなわち、従来の分散処理システムにおいては、通信方式に応じた動的なパケットの振り分けを行うことができず、そのため、アドレスが異なるセッション1−1,1−2のパケットが、異なるパケット処理装置10に振り分けられる可能性もある。   In other words, in the conventional distributed processing system, dynamic packet distribution according to the communication method cannot be performed. Therefore, the packets of the sessions 1-1 and 1-2 having different addresses are different from each other. There is also a possibility that it will be distributed to.

その結果、例えば、以下のような課題がある。
(A)全ての種類のトランスコーディング機能(図8では、トランスコーディングA,B,C:TC−A,TC−B,TC−C)を、予め各パケット処理装置10に実装しておかなければならない。
(B)帯域確保の際、全てのパケット処理装置10において、当該帯域を確保しなければならない。
(C)2者通話の途中で3者通話となった際に、新たに加わったセッションのパケットは、別のパケット処理装置10に振り分けられる可能性がある。
As a result, for example, there are the following problems.
(A) All types of transcoding functions (in FIG. 8, transcoding A, B, C: TC-A, TC-B, TC-C) must be implemented in each packet processing apparatus 10 in advance. Don't be.
(B) When securing the bandwidth, the bandwidth must be secured in all the packet processing devices 10.
(C) When a three-party call is made in the middle of a two-party call, a packet of a newly added session may be distributed to another packet processing apparatus 10.

そこで、本発明の目的は、上述した課題を解決することができる分散処理システムおよび分散処理方法を提供することにある。   Therefore, an object of the present invention is to provide a distributed processing system and a distributed processing method capable of solving the above-described problems.

本発明の分散処理システムは、
複数のパケット処理装置と、前記複数のパケット処理装置にパケットを振り分ける複数の振り分け装置と、を有してなる分散処理システムであって、
制御装置をさらに有し、
前記制御装置は、
制御用セッションに属するパケットが到着すると、通信相手とのネゴシエーションを行い、当該制御用セッションと連携するデータ転送用セッションの通信方式を決定する通信方式決定部と、
前記通信方式決定部で決定された通信方式に応じて、前記データ転送用セッションに属するパケットの振り分け先のパケット処理装置を決定し、決定された振り分け先のパケット処理装置を前記複数の振り分け装置の各々に通知すると共に、前記データ転送用セッションに属するパケットのパケット処理に用いる設定情報を前記振り分け先のパケット処理装置に通知するセッション連携部と、を有する。
The distributed processing system of the present invention
A distributed processing system comprising a plurality of packet processing devices and a plurality of distribution devices that distribute packets to the plurality of packet processing devices,
A control device;
The controller is
When a packet belonging to the control session arrives, a communication method determining unit that negotiates with the communication partner and determines the communication method of the data transfer session in cooperation with the control session;
According to the communication method determined by the communication method determination unit, a packet processing device to which a packet belonging to the data transfer session is distributed is determined, and the determined packet processing device is assigned to the plurality of distribution devices. And a session cooperation unit for notifying each of them and notifying the distribution destination packet processing device of setting information used for packet processing of packets belonging to the data transfer session.

本発明の分散処理方法は、
複数のパケット処理装置と、前記複数のパケット処理装置にパケットを振り分ける複数の振り分け装置と、を有してなる分散処理システムによる分散処理方法であって、
前記分散処理システムに制御装置を設け、
前記制御装置が、制御用セッションに属するパケットが到着すると、通信相手とのネゴシエーションを行い、当該制御用セッションと連携するデータ転送用セッションの通信方式を決定し、
前記制御装置が、前記決定された通信方式に応じて、前記データ転送用セッションに属するパケットの振り分け先のパケット処理装置を決定し、決定された振り分け先のパケット処理装置を前記複数の振り分け装置の各々に通知すると共に、前記データ転送用セッションに属するパケットのパケット処理に用いる設定情報を前記振り分け先のパケット処理装置に通知する。
The distributed processing method of the present invention
A distributed processing method by a distributed processing system comprising: a plurality of packet processing devices; and a plurality of distribution devices that distribute packets to the plurality of packet processing devices,
A control device is provided in the distributed processing system,
When a packet belonging to the control session arrives, the control device negotiates with the communication partner, determines the communication method of the data transfer session to cooperate with the control session,
The control device determines a packet processing device to which a packet belonging to the data transfer session is distributed according to the determined communication method, and determines the determined packet processing device to be assigned to the plurality of distribution devices. In addition to notifying each, setting information used for packet processing of a packet belonging to the data transfer session is notified to the packet processing apparatus of the distribution destination.

本発明によれば、データ転送用セッションのパケットの振り分け先を、制御用セッションで決定した通信方式に応じて動的に設定することが可能となるという効果が得られる。   According to the present invention, it is possible to dynamically set the packet transfer destination of the data transfer session according to the communication method determined in the control session.

本発明の一実施形態の分散処理システムの概要を説明する図である。It is a figure explaining the outline | summary of the distributed processing system of one Embodiment of this invention. 本発明の一実施形態の分散処理システムの詳細構成を示すブロック図である。It is a block diagram which shows the detailed structure of the distributed processing system of one Embodiment of this invention. 本発明の一実施形態の分散処理システムの具体的な動作の流れを説明する図である。It is a figure explaining the flow of a specific operation | movement of the distributed processing system of one Embodiment of this invention. 本発明の一実施例の分散処理システムの処理シーケンスを説明するシーケンス図である。It is a sequence diagram explaining the processing sequence of the distributed processing system of one Example of this invention. 本発明の一実施例の分散処理システムの処理シーケンスを説明するシーケンス図である。It is a sequence diagram explaining the processing sequence of the distributed processing system of one Example of this invention. 従来の分散処理システムの構成を示すブロック図である。It is a block diagram which shows the structure of the conventional distributed processing system. SBCの概要を説明する図である。It is a figure explaining the outline | summary of SBC. 従来の分散処理システムの課題を説明する図である。It is a figure explaining the subject of the conventional distributed processing system.

以下に、本発明を実施するための形態について図面を参照して説明する。
(1)実施形態の概要
まず、本実施形態の分散処理システムの概要を説明する。
EMBODIMENT OF THE INVENTION Below, the form for implementing this invention is demonstrated with reference to drawings.
(1) Overview of Embodiment First, an overview of the distributed processing system of this embodiment will be described.

図1に示すように、本実施形態の分散処理システムは、図6に示した従来の分散処理システムと比較して、データベース60の代わりに制御装置30を設けた点と、パケット処理装置(#1〜#N)10−1〜10−Nの各々にデータ保存部(第1データ保存部)14を追加した点と、振り分け装置20−A,20−Bの各々にデータ保存部(第2データ保存部)24を追加した点と、制御装置30と振り分け装置20−A,20−Bとの間に通信用の回線を用意した点と、が異なる。   As shown in FIG. 1, the distributed processing system of this embodiment is different from the conventional distributed processing system shown in FIG. 6 in that a control device 30 is provided instead of the database 60, and the packet processing device (# 1 to #N) 10-1 to 10-N, a data storage unit (first data storage unit) 14 is added to each of the distribution devices 20-A and 20-B. The difference is that a data storage unit) 24 is added and a communication line is prepared between the control device 30 and the distribution devices 20-A and 20-B.

以下、本実施形態の分散処理システムの概略動作の流れを説明する。   The schematic operation flow of the distributed processing system of this embodiment will be described below.

ここでは、振り分け装置20−Aが、端末40−1からの制御用セッション(セッション1−1)のパケットをパケット処理装置(#1)10−1に振り分けたとする。   Here, it is assumed that distribution device 20-A distributes the packet of the control session (session 1-1) from terminal 40-1 to packet processing device (# 1) 10-1.

この場合、ステップS1において、パケット処理装置(#1)10−1は、セッション1−1のパケットを制御装置30に転送する。   In this case, in step S1, the packet processing device (# 1) 10-1 transfers the packet of the session 1-1 to the control device 30.

次に、ステップS2において、制御装置30は、セッション1−1のパケットの情報を基に、セッション1−1と連携するデータ転送用セッション(セッション1−2)を特定すると共に、通信相手とのネゴシエーションにより、セッション1−2の通信方式(トランスコーディング機能や使用帯域等)を決定し、決定した通信方式に応じて、その通信方式に対応可能なパケット処理装置10を、セッション1−2のパケットの振り分け先に決定する。この例では、振り分け先をパケット処理装置(#1)10−1に決定する。   Next, in step S2, the control device 30 specifies a data transfer session (session 1-2) linked to the session 1-1 based on the packet information of the session 1-1, and communicates with the communication partner. The communication method (transcoding function, bandwidth used, etc.) of the session 1-2 is determined by negotiation, and the packet processing device 10 that can support the communication method is determined according to the determined communication method. Determine the distribution destination. In this example, the distribution destination is determined to be the packet processing device (# 1) 10-1.

次に、ステップS3において、制御装置30は、振り分け先のパケット処理装置(#1)10−1のデータ保存部14に、セッション1−2のパケット処理に用いる設定情報(セッション1−2のパケットのアドレスと当該パケットに対するパケット処理とを対応付けた情報)を格納する。   Next, in step S3, the control device 30 sends setting information (packet of session 1-2) used for packet processing of the session 1-2 to the data storage unit 14 of the packet processing device (# 1) 10-1 that is the distribution destination. Information in which the address of the packet and the packet processing for the packet are associated).

次に、ステップS4において、制御装置30は、振り分け装置20−A,20−Bに対し、セッション1−2のパケットの振り分け先(この例では、パケット処理装置(#1)10−1)を通知する。この振り分け先は、データ保存部24に格納される。   Next, in step S4, the control device 30 assigns the packet distribution destination of the session 1-2 (in this example, the packet processing device (# 1) 10-1) to the distribution devices 20-A and 20-B. Notice. This distribution destination is stored in the data storage unit 24.

その後、ステップS5において、制御装置30は、セッション1−1のパケットを、パケット処理装置(#1)10−1から振り分け装置20−Bを介して、端末40−2に転送する。   Thereafter, in step S5, the control device 30 transfers the packet of the session 1-1 from the packet processing device (# 1) 10-1 to the terminal 40-2 via the distribution device 20-B.

以降、振り分け装置20−Aは、端末40−1からのセッション1−2のパケットが到着すると、データ保存部24に格納された情報を参照して、当該パケットを、パケット処理装置(#1)10−1に振り分ける。   Thereafter, when the packet of the session 1-2 from the terminal 40-1 arrives, the distribution device 20-A refers to the information stored in the data storage unit 24 and sends the packet to the packet processing device (# 1). Assign to 10-1.

パケット処理装置(#1)10−1は、セッション1−2のパケットが到着すると、データ保存部14に格納された設定情報を参照して、当該パケットのパケット処理を実行する。   When the packet of the session 1-2 arrives, the packet processing device (# 1) 10-1 refers to the setting information stored in the data storage unit 14 and executes packet processing of the packet.

上述のように、本実施形態の分散処理システムにおいては、セッション1−2のパケットの振り分け先を、セッション1−1で決定した通信方式に応じて動的に設定することが可能となる。   As described above, in the distributed processing system of this embodiment, it is possible to dynamically set the packet distribution destination of the session 1-2 according to the communication method determined in the session 1-1.

そのため、パケット処理装置(#1〜#N)10−1〜10−Nの各々に、全ての種類の機能を実装したり、リソースを確保したりする必要がなくなる。   Therefore, it is not necessary to mount all kinds of functions or secure resources in each of the packet processing devices (# 1 to #N) 10-1 to 10-N.

これにより、パケット処理装置(#1〜#N)10−1〜10−Nの簡素化を実現することができる。   Thereby, simplification of the packet processing devices (# 1 to #N) 10-1 to 10-N can be realized.

また、例えば、以下のような効果も得られる。
(A)通信方式に応じて、振り分け先を動的に決定可能なため、全てのパケット処理装置10に、全ての種類のトランスコーディング機能(図1では、トランスコーディングA,B,C:TC−A,TC−B,TC−C)を実装する必要がなくなる。
(B)確保する帯域に合わせて、パケット処理装置10を選択することが可能となる。そのため、例えば、テレビ電話の場合には帯域の大きいパケット処理装置10、音声通話の場合には帯域の小さいパケット処理装置10というように、振り分け先を決定することが可能となる。
(C)2者通話の途中で、3者通話に切り替わる際、新たに加わったセッションを、同じパケット処理装置10で処理することが可能となる。
(D)セッション1−1でセッション1−2のパケットの振り分け先を決定し、その振り分け先にセッション1−2のパケット処理に用いる設定情報を先送りしておくため、振り分け先のパケット処理装置10は、セッション1−2のパケットが到着した時に、すぐにパケット処理を開始することが可能となる。
(2)実施形態の詳細
続いて、本実施形態の分散処理システムの詳細構成を説明する。
For example, the following effects can also be obtained.
(A) Since the distribution destination can be dynamically determined according to the communication method, all types of transcoding functions (in FIG. 1, transcoding A, B, C: TC− A, TC-B, TC-C) need not be mounted.
(B) The packet processing device 10 can be selected in accordance with the reserved bandwidth. Therefore, for example, it is possible to determine a distribution destination such as a packet processing device 10 having a large bandwidth in the case of a videophone and a packet processing device 10 having a small bandwidth in the case of a voice call.
(C) When switching to a three-party call during a two-party call, a newly added session can be processed by the same packet processing device 10.
(D) In order to determine the distribution destination of the packet of session 1-2 in session 1-1 and to postpone the setting information used for the packet processing of session 1-2 to the distribution destination, the packet processing apparatus 10 of the distribution destination Can start packet processing immediately when a packet of session 1-2 arrives.
(2) Details of Embodiment Next, a detailed configuration of the distributed processing system of this embodiment will be described.

図2に示すように、振り分け装置20−Aには、上述のように、データ保存部24が追加されている。   As shown in FIG. 2, the data storage unit 24 is added to the sorting device 20-A as described above.

データ保存部24は、情報を保存する機能を備える。   The data storage unit 24 has a function of storing information.

なお、振り分け装置20−Bの構成は、振り分け装置20−Aと同じである。   The configuration of the sorting device 20-B is the same as that of the sorting device 20-A.

パケット処理装置(#1)10−1には、上述のように、データ保存部14が追加される他、パケット識別部15が追加されている。   As described above, in addition to the data storage unit 14 added to the packet processing device (# 1) 10-1, a packet identification unit 15 is added.

データ保存部14は、情報を保存する機能を備える。   The data storage unit 14 has a function of storing information.

パケット識別部15は、パケット処理装置(#1)10−1にパケットが到着した際、予め設定された方法(例えば、パケットのポート番号を、制御装置30に転送すべきパケットのポート番号リストと照合する方法等)により、当該パケットが制御用セッションに属すると判定した場合、当該パケットを制御装置30に転送する機能を備える。   When the packet arrives at the packet processing device (# 1) 10-1, the packet identification unit 15 uses a preset method (for example, the port number of the packet and the port number list of the packet to be transferred to the control device 30). A function of transferring the packet to the control device 30 when it is determined that the packet belongs to the control session.

なお、パケット処理装置(#2〜#N)10−2〜10−Nの構成は、パケット処理装置(#1)10−1と同じである。   The configuration of the packet processing devices (# 2 to #N) 10-2 to 10-N is the same as that of the packet processing device (# 1) 10-1.

制御装置30は、パケット受信部31と、通信方式決定部32と、セッション連携部33と、パケット送信部34と、から構成される。   The control device 30 includes a packet reception unit 31, a communication method determination unit 32, a session cooperation unit 33, and a packet transmission unit 34.

パケット受信部31は、パケットを受信して、パケットを解析後、自装置内の適切な構成要素に転送する機能を備える。   The packet receiving unit 31 has a function of receiving a packet, analyzing the packet, and transferring the packet to an appropriate component in its own device.

通信方式決定部32は、制御用セッションのパケットが到着すると、通信相手とのネゴシエーションを行い、当該制御用セッションと連携するデータ転送用セッションの通信方式(トランスコーデック機能や使用帯域等)を決定し、セッション連携部33に通知する機能を備える。   When the control session packet arrives, the communication method determination unit 32 negotiates with the communication partner, and determines the communication method (transcodec function, bandwidth used, etc.) of the data transfer session linked to the control session. A function of notifying the session cooperation unit 33 is provided.

セッション連携部33は、以下の機能を備える。
・制御用セッションのパケットの情報から、パケットの振り分け先を指定したいデータ転送用セッションを特定(データ転送用セッションのパケットのsrc(送信元)アドレス、dst(送信先)アドレス等を特定)する機能
・振り分け先を指定したいデータ転送用セッションについて、通信方式決定部32で決定された通信方式に応じて、当該データ転送用セッションのパケットの振り分け先を決定し、当該データ転送用セッションの識別子(5−tuple等)と振り分け先とを対応付けて振り分け装置20−A,20−Bのデータ保存部24に格納する機能
・振り分け先を指定したいデータ転送用セッションについて、通信方式決定部32で決定された通信方式に応じて、当該データ転送用セッションのパケット処理に用いる設定情報(当該データ転送用セッションのパケットのsrcアドレスおよびdstアドレスと当該パケットに対するパケット処理とを対応付けた情報)を、振り分け先のパケット処理装置10のデータ保存部14に格納する機能
パケット送信部34は、受け取ったパケットを適切なインタフェースから送出する機能を備える。
The session cooperation unit 33 has the following functions.
A function for specifying a data transfer session for which a packet distribution destination is to be specified from the control session packet information (specifying a src (source) address, dst (destination) address, etc. of a data transfer session packet) For a data transfer session for which a distribution destination is desired to be specified, the packet transfer destination of the data transfer session is determined according to the communication method determined by the communication method determination unit 32, and the identifier (5 -Tuple etc.) and the distribution destination are associated with the distribution destination, and the data transfer session for which the function / distribution destination to be stored in the data storage unit 24 of the distribution apparatuses 20-A and 20-B is determined by the communication method determination unit 32 Depending on the communication method used, the setting information used for packet processing of the data transfer session A function for transmitting the packet storage unit 34 in the data storage unit 14 of the distribution destination packet processing device 10 (information that associates the src address and dst address of the packet of the data transfer session with the packet processing for the packet) And a function of transmitting the received packet from an appropriate interface.

なお、振り分け装置20−A,20−Bの振り分け先決定部22は、自装置に到着したパケットの5−tupleが、制御装置30によってデータ保存部24に格納された情報に含まれていれば、それに対応付けられている振り分け先を決定し、含まれていなければ、予め設定された振り分けアルゴリズムに従って振り分け先を決定する。   Note that the distribution destination determination unit 22 of the distribution devices 20 -A and 20 -B determines that the 5-tuple of the packet that has arrived at its own device is included in the information stored in the data storage unit 24 by the control device 30. Then, a distribution destination associated therewith is determined, and if it is not included, a distribution destination is determined according to a preset distribution algorithm.

また、パケット処理装置(#1〜#N)10−1〜10−Nのパケット処理部12は、自装置がデータ転送用セッションのパケットの振り分け先になった場合、制御装置30によってデータ保存部14に格納された設定情報を参照し、当該データ転送用セッションのパケットのsrcアドレスおよびdstアドレスと対応付けられているパケット処理を実行する。   Further, the packet processing units 12 of the packet processing devices (# 1 to #N) 10-1 to 10-N are configured to store the data storage unit by the control device 30 when the own device becomes a packet transfer destination of the data transfer session. 14, the packet processing associated with the src address and dst address of the packet of the data transfer session is executed.

以下、本実施形態の分散処理システムの具体的な動作の流れを説明する。   Hereinafter, a specific operation flow of the distributed processing system of this embodiment will be described.

図3に示すように、まず、端末40−1からの制御用セッション(セッション1−1)のパケットが、振り分け装置20−Aに到着したとする。   As illustrated in FIG. 3, first, assume that a packet of a control session (session 1-1) from the terminal 40-1 has arrived at the distribution device 20-A.

すると、振り分け装置20−Aの振り分け先決定部22は、セッション1−1のパケットの5−tupleがデータ保存部24に格納された情報に含まれているかを判定する。ここでは、含まれていないため、振り分け先決定部22は、予め設定された振り分けアルゴリズムに従って、セッション1−1のパケットの振り分け先(この例では、パケット処理装置(#1)10−1)を決定し、当該パケットを振り分け先のパケット処理装置(#1)10−1に送信する。   Then, the distribution destination determination unit 22 of the distribution apparatus 20 -A determines whether the 5-tuple of the packet of the session 1-1 is included in the information stored in the data storage unit 24. Here, since it is not included, the distribution destination determination unit 22 selects the packet distribution destination of the session 1-1 (in this example, the packet processing device (# 1) 10-1) according to a predetermined distribution algorithm. Then, the packet is transmitted to the packet processing apparatus (# 1) 10-1 as a distribution destination.

次に、パケット処理装置(#1)10−1のパケット識別部15は、セッション1−1のパケットが到着すると、セッション1−1が制御用セッションであるかを判定する。ここでは、制御用セッションであるため、パケット識別部15は、当該パケットを制御装置30に転送する。   Next, when the packet of the session 1-1 arrives, the packet identification unit 15 of the packet processing device (# 1) 10-1 determines whether the session 1-1 is a control session. Here, since it is a control session, the packet identification unit 15 transfers the packet to the control device 30.

次に、ステップS11において、制御装置30の通信方式決定部32は、セッション1−1のパケットが到着すると、通信相手とのネゴシエーションを行い、セッション1−1と連携するデータ転送用セッションの通信方式(トランスコーデック機能や使用帯域等)を決定し、セッション連携部33に通知する。   Next, in step S11, when the packet of the session 1-1 arrives, the communication method determination unit 32 of the control device 30 negotiates with the communication partner and communicates with the session 1-1 for the data transfer session. (Transcodec function, bandwidth used, etc.) are determined and notified to the session cooperation unit 33.

次に、制御装置30のセッション連携部33は、セッション1−1のパケットの情報から、セッション1−1と連携するデータ転送用セッション(この例では、セッション1−2)を特定する。   Next, the session cooperation unit 33 of the control device 30 specifies a data transfer session (session 1-2 in this example) that cooperates with the session 1-1 from the packet information of the session 1-1.

次に、制御装置30のセッション連携部33は、通信方式決定部32で決定された通信方式に応じて、セッション1−2のパケットの振り分け先(この例では、パケット処理装置(#1)10−1)を決定する。   Next, the session cooperation unit 33 of the control device 30 distributes the packets of the session 1-2 according to the communication method determined by the communication method determination unit 32 (in this example, the packet processing device (# 1) 10). -1) is determined.

次に、ステップS12において、制御装置30のセッション連携部33は、通信方式決定部32で決定された通信方式に応じて、セッション1−2のパケット処理に用いる設定情報を、振り分け先のパケット処理装置(#1)10−1のデータ保存部14に格納する。   Next, in step S12, the session cooperation unit 33 of the control device 30 converts the setting information used for the packet processing of the session 1-2 according to the communication method determined by the communication method determination unit 32 to the packet processing of the distribution destination. The data is stored in the data storage unit 14 of the device (# 1) 10-1.

次に、ステップS13において、制御装置30のセッション連携部33は、セッション1−2を示す識別子(例えば5−tuple)と振り分け先とを対応付けて、振り分け装置20−A,20−Bのデータ保存部24に格納する。   Next, in step S13, the session cooperation unit 33 of the control device 30 associates the identifier (for example, 5-tuple) indicating the session 1-2 with the distribution destination, and the data of the distribution devices 20-A and 20-B. Store in the storage unit 24.

その後、セッション1−1のパケットは、再び、パケット処理装置(#1)10−1に戻され、パケット処理装置(#1)10−1のパケット処理部12でパケット処理が実行された後、宛先の端末40−2に転送される。   Thereafter, the packet of the session 1-1 is again returned to the packet processing device (# 1) 10-1, and after the packet processing is executed by the packet processing unit 12 of the packet processing device (# 1) 10-1, It is transferred to the destination terminal 40-2.

以降に、端末40−1からのセッション1−2のパケットが、振り分け装置20−Aに到着したとする。   Thereafter, it is assumed that the packet of the session 1-2 from the terminal 40-1 arrives at the distribution device 20-A.

すると、振り分け装置20−Aの振り分け先決定部22は、セッション1−2のパケットの5−tupleがデータ保存部24に格納された情報に含まれているかを判定する。ここでは、制御装置30によってデータ保存部24に格納された情報に、セッション1−2のパケットの5−tupleが含まれているため、振り分け先決定部22は、それに対応付けられている振り分け先(この例では、パケット処理装置(#1)10−1)を決定し、セッション1−2のパケットを振り分け先のパケット処理装置(#1)10−1に転送する。   Then, the distribution destination determination unit 22 of the distribution apparatus 20 -A determines whether the 5-tuple of the packet of the session 1-2 is included in the information stored in the data storage unit 24. Here, since the information stored in the data storage unit 24 by the control device 30 includes the 5-tuple of the packet of the session 1-2, the distribution destination determination unit 22 determines the distribution destination associated therewith. (In this example, the packet processing device (# 1) 10-1) is determined, and the packet of the session 1-2 is transferred to the distribution destination packet processing device (# 1) 10-1.

次に、パケット処理装置(#1)10−1のパケット識別部15は、セッション1−2のパケットが到着すると、セッション1−2が制御用セッションであるかを判定する。ここでは、セッション1−2が制御用セッションでないため、パケット処理部12は、制御装置30によってデータ保存部14に格納された設定情報を参照し、セッション1−2のパケットのsrcアドレスおよびdstアドレスと対応付けられているパケット処理を実行する。   Next, when the packet of the session 1-2 arrives, the packet identification unit 15 of the packet processing device (# 1) 10-1 determines whether the session 1-2 is a control session. Here, since the session 1-2 is not a control session, the packet processing unit 12 refers to the setting information stored in the data storage unit 14 by the control device 30, and the src address and dst address of the packet of the session 1-2. The packet processing associated with is executed.

その後、セッション1−2のパケットは、宛先の端末40−2に転送される。   Thereafter, the packet of the session 1-2 is transferred to the destination terminal 40-2.

続いて、本実施形態の分散処理システムの具体的な実施例を説明する。   Next, a specific example of the distributed processing system according to this embodiment will be described.

本実施例は、本実施形態の分散処理システムをIP電話システムに適用した例である。   In this example, the distributed processing system of this embodiment is applied to an IP telephone system.

本実施例においては、パケット処理装置(#1〜#N)10−1〜10−NがSBCの機能を、制御装置30がSIPサーバの機能を含み、SIPセッションにより設定された情報を基に、RTPセッションの処理を行うものとする。   In this embodiment, the packet processing devices (# 1 to #N) 10-1 to 10-N include the SBC function, and the control device 30 includes the SIP server function, based on information set by the SIP session. Assume that RTP session processing is performed.

また、本実施例においては、SBCおよびSIPサーバの処理の一部を説明することとし、制御装置30の処理として、SIPセッションのパケットに基づくアドレス変換設定および相手SIPサーバとの通信方式のネゴシエーションのみを、パケット処理装置(#1〜#N)10−1〜10−Nの処理として、アドレス変換処理およびコーデック変換処理のみを説明する。ただし、実際には、アドレス変換処理およびコーデック変換処理以外にも多くのパケット処理がある。   In the present embodiment, a part of the processing of the SBC and the SIP server will be described, and the processing of the control device 30 includes only the address translation setting based on the SIP session packet and the negotiation of the communication method with the partner SIP server. As the processing of the packet processing devices (# 1 to #N) 10-1 to 10-N, only address conversion processing and codec conversion processing will be described. However, in practice, there are many packet processes other than the address conversion process and the codec conversion process.

以下、本実施例の分散処理システムの具体的な動作の流れを、図4および図5を参照して説明する。なお、図4および図5において、各装置のパケット受信部・パケット送信部は省略している。   Hereinafter, a specific operation flow of the distributed processing system according to the present embodiment will be described with reference to FIGS. 4 and 5. 4 and 5, the packet receiver and packet transmitter of each device are omitted.

図4に示すように、まず、端末40−1は、ステップS101において、SIPセッションのINVITEパケット(SIPパケット)を送信する。   As shown in FIG. 4, first, in step S101, the terminal 40-1 transmits an INVITE packet (SIP packet) of the SIP session.

次に、振り分け装置20−Aの振り分け先決定部22は、ステップS102において、予め設定された振り分けアルゴリズムに従って、INVITEパケットの振り分け先を決定する。ここでは、振り分け先決定部22は、パケット処理装置(#1)10−1を振り分け先に決定し、ステップS103において、INVITEパケットをパケット処理装置(#1)10−1に転送する。   Next, in step S102, the distribution destination determining unit 22 of the distribution device 20-A determines the distribution destination of the INVITE packet according to a predetermined distribution algorithm. Here, the distribution destination determination unit 22 determines the packet processing device (# 1) 10-1 as the distribution destination, and transfers the INVITE packet to the packet processing device (# 1) 10-1 in step S103.

次に、パケット処理装置(#1)10−1のパケット識別部15は、ステップS104において、INVITEパケットがSIPセッションに属するSIPパケットと判定し、ステップS105において、INVITEパケットを制御装置30に転送する。   Next, the packet identification unit 15 of the packet processing device (# 1) 10-1 determines that the INVITE packet is a SIP packet belonging to the SIP session in step S104, and transfers the INVITE packet to the control device 30 in step S105. .

次に、制御装置30のセッション連携部33は、ステップS106において、INVITEパケットを通信方式決定部32に転送し、通信方式決定部32は、ステップS107において、INVITEパケットをパケット処理装置(#1)10−1に戻す。   Next, the session cooperation unit 33 of the control device 30 transfers the INVITE packet to the communication method determining unit 32 in step S106, and the communication method determining unit 32 transmits the INVITE packet to the packet processing device (# 1) in step S107. Return to 10-1.

次に、パケット処理装置(#1)10−1のパケット処理部12は、ステップS108において、INVITEパケットを、振り分け装置20−Bを介して、通信相手のSIPサーバ50に送信する。通信相手のSIPサーバ50には、このINVITEパケットによって、制御装置30側の通信方式が通知されることになる。   Next, in step S108, the packet processing unit 12 of the packet processing device (# 1) 10-1 transmits the INVITE packet to the communication partner SIP server 50 via the distribution device 20-B. The communication system on the control device 30 side is notified to the SIP server 50 of the communication partner by this INVITE packet.

次に、通信相手のSIPサーバ50は、ステップS109において、INVITEパケットを端末40−2に転送し、ステップS110において、端末40−2から、Ringing/200OKパケット(SIPパケット)を受信する。なお、Ringingパケットと200OKパケットは別パケットであるが、図4では簡略化のため、1シーケンスで記述している。   Next, the communication partner SIP server 50 transfers the INVITE packet to the terminal 40-2 in step S109, and receives the Ringing / 200 OK packet (SIP packet) from the terminal 40-2 in step S110. Note that the Ringing packet and the 200 OK packet are separate packets, but are illustrated in one sequence in FIG. 4 for simplicity.

次に、通信相手のSIPサーバ50は、ステップS111において、Ringing/200OKパケットを振り分け装置20−Bに転送する。通信相手のSIPサーバ50は、このRinging/200OKパケットによって、SIPサーバ50側の通信方式を応答として返すことになる。   Next, in step S111, the communication partner SIP server 50 transfers the Ringing / 200 OK packet to the distribution device 20-B. The SIP server 50 of the communication partner returns the communication method on the SIP server 50 side as a response by this Ringing / 200 OK packet.

次に、振り分け装置20−Bは、ステップS112において、予め設定された振り分けアルゴリズムに従って、Ringing/200OKパケットの振り分け先を決定する。ここでは、振り分け装置20−Bは、パケット処理装置(#1)10−1を振り分け先に決定し、ステップS113において、Ringing/200OKパケットをパケット処理装置(#1)10−1に転送する。   Next, in step S112, the distribution device 20-B determines the distribution destination of the Ringing / 200 OK packet according to a predetermined distribution algorithm. Here, distribution apparatus 20-B determines packet processing apparatus (# 1) 10-1 as the distribution destination, and transfers the Ringing / 200 OK packet to packet processing apparatus (# 1) 10-1 in step S113.

次に、パケット処理装置(#1)10−1のパケット識別部15は、ステップS114において、Ringing/200OKパケットがSIPセッションに属するSIPパケットと判定し、ステップS115において、Ringing/200OKパケットを制御装置30に転送する。   Next, in step S114, the packet identification unit 15 of the packet processing device (# 1) 10-1 determines that the Ringing / 200 OK packet is a SIP packet belonging to the SIP session. Forward to 30.

次に、制御装置30のセッション連携部33は、ステップS116において、Ringing/200OKパケットを通信方式決定部32に転送し、通信方式決定部32は、ステップS117において、Ringing/200OKパケットに示される通信方式に決定し、ステップS118において、セッション連携部33に通知する。   Next, in step S116, the session cooperation unit 33 of the control device 30 transfers the Ringing / 200 OK packet to the communication method determining unit 32, and the communication method determining unit 32 performs the communication indicated by the Ringing / 200 OK packet in step S117. The method is determined, and the session cooperation unit 33 is notified in step S118.

次に、制御装置30のセッション連携部33は、ステップS119において、通信方式決定部32で決定された通信方式に応じて、RTPセッションのパケットの振り分け先決定する。ここでは、セッション連携部33は、パケット処理装置(#1)10−1を振り分け先に決定する。また、セッション連携部33は、RTPセッションのパケットのアドレス変換方法を決定する。そして、セッション連携部33は、ステップS120において、RTPセッションの識別子と振り分け先とを対応付けて、振り分け装置20−A,20−Bのデータ保存部24にテーブルとして格納する。また、セッション連携部33は、ステップS121において、上記で決定された通信方式とアドレス変換方法とに応じて、RTPセッションのパケット処理に用いる設定情報を、振り分け先のパケット処理装置(#1)10−1のデータ保存部14にテーブルとして格納する。   Next, in step S119, the session cooperation unit 33 of the control device 30 determines the distribution destination of the RTP session packet according to the communication method determined by the communication method determination unit 32. Here, the session cooperation unit 33 determines the packet processing device (# 1) 10-1 as a distribution destination. In addition, the session cooperation unit 33 determines the address translation method of the RTP session packet. In step S120, the session cooperation unit 33 associates the identifier of the RTP session with the distribution destination and stores them in the data storage unit 24 of the distribution devices 20-A and 20-B as a table. In step S121, the session cooperation unit 33 assigns the setting information used for packet processing of the RTP session according to the communication method and address conversion method determined above to the packet processing device (# 1) 10 that is the distribution destination. -1 is stored in the data storage unit 14 as a table.

次に、制御装置30の通信方式決定部32は、ステップS122において、Ringing/200OKパケットをパケット処理装置(#1)10−1に転送し、パケット処理装置(#1)10−1のパケット処理部12は、ステップS123において、Ringing/200OKパケットを、振り分け装置20−Aを介して、端末40−1に転送する。   Next, in step S122, the communication method determining unit 32 of the control device 30 transfers the Ringing / 200 OK packet to the packet processing device (# 1) 10-1, and packet processing of the packet processing device (# 1) 10-1. In step S123, the unit 12 transfers the Ringing / 200 OK packet to the terminal 40-1 via the distribution device 20-A.

次に、図5に示すように、端末40−1は、Ringing/200OKパケットを受信すると、ステップS124において、SIPセッションのAckパケット(SIPパケット)を送信する。   Next, as illustrated in FIG. 5, when receiving the Ringing / 200 OK packet, the terminal 40-1 transmits an Ack packet (SIP packet) of the SIP session in step S124.

次に、振り分け装置20−Aの振り分け先決定部22は、ステップS125において、予め設定された振り分けアルゴリズムに従って、Ackパケットの振り分け先を決定する。ここでは、振り分け先決定部22は、パケット処理装置(#1)10−1を振り分け先に決定し、ステップS126において、Ackパケットをパケット処理装置(#1)10−1に転送する。   Next, in step S125, the distribution destination determining unit 22 of the distribution device 20-A determines the distribution destination of the Ack packet according to a predetermined distribution algorithm. Here, the distribution destination determination unit 22 determines the packet processing device (# 1) 10-1 as the distribution destination, and transfers the Ack packet to the packet processing device (# 1) 10-1 in step S126.

次に、パケット処理装置(#1)10−1のパケット識別部15は、ステップS127において、AckパケットがSIPセッションに属するSIPパケットと判定し、ステップS128において、Ackパケットを制御装置30に転送する。   Next, the packet identification unit 15 of the packet processing device (# 1) 10-1 determines that the Ack packet is a SIP packet belonging to the SIP session in step S127, and transfers the Ack packet to the control device 30 in step S128. .

次に、制御装置30のセッション連携部33は、ステップS129において、Ackパケットを通信方式決定部32に転送し、通信方式決定部32は、ステップS130において、Ackパケットをパケット処理装置(#1)10−1に戻す。   Next, the session cooperation unit 33 of the control device 30 transfers the Ack packet to the communication method determination unit 32 in step S129, and the communication method determination unit 32 transmits the Ack packet to the packet processing device (# 1) in step S130. Return to 10-1.

次に、パケット処理装置(#1)10−1のパケット処理部12は、ステップS131において、Ackパケットを、振り分け装置20−Bを介して、通信相手のSIPサーバ50に転送し、通信相手のSIPサーバ50は、ステップS132において、Ackパケットを端末40−2に転送する。   Next, in step S131, the packet processing unit 12 of the packet processing device (# 1) 10-1 transfers the Ack packet to the communication partner's SIP server 50 via the distribution device 20-B. In step S132, the SIP server 50 transfers the Ack packet to the terminal 40-2.

以降に、端末40−1は、ステップS133において、RTPセッションのRTPパケットを送信する。   Thereafter, the terminal 40-1 transmits the RTP packet of the RTP session in step S133.

次に、振り分け装置20−Aの振り分け先決定部22は、ステップS134において、制御装置30によってデータ保存部24にテーブルとして格納された情報に従って、RTPパケットの振り分け先を決定する。ここでは、振り分け先決定部22は、パケット処理装置(#1)10−1を振り分け先に決定し、ステップS135において、RTPパケットをパケット処理装置(#1)10−1に転送する。   Next, in step S134, the distribution destination determination unit 22 of the distribution device 20-A determines an RTP packet distribution destination according to the information stored as a table in the data storage unit 24 by the control device 30. Here, the distribution destination determination unit 22 determines the packet processing device (# 1) 10-1 as the distribution destination, and transfers the RTP packet to the packet processing device (# 1) 10-1 in step S135.

次に、パケット処理装置(#1)10−1のパケット識別部15は、ステップS136において、RTPパケットがRTPセッションに属するパケットと判定し、ステップS137において、RTPパケットをパケット処理部12に転送する。   Next, the packet identification unit 15 of the packet processing apparatus (# 1) 10-1 determines that the RTP packet belongs to the RTP session in step S136, and transfers the RTP packet to the packet processing unit 12 in step S137. .

次に、パケット処理装置(#1)10−1のパケット処理部12は、ステップS138において、制御装置30によってデータ保存部24にテーブルとして格納された設定情報を基に、RTPパケットに対してアドレス変換処理およびコーデック変換処理を行う。   Next, the packet processing unit 12 of the packet processing device (# 1) 10-1 addresses the RTP packet based on the setting information stored as a table in the data storage unit 24 by the control device 30 in step S138. Performs conversion processing and codec conversion processing.

その後、パケット処理装置(#1)10−1のパケット処理部12は、ステップS139において、RTPパケットを、振り分け装置20−Bを介して、通信相手のSIPサーバ50に転送する。   Thereafter, in step S139, the packet processing unit 12 of the packet processing device (# 1) 10-1 transfers the RTP packet to the communication partner SIP server 50 via the distribution device 20-B.

10−1〜10−N パケット処理装置
11 パケット受信部
12 パケット処理部
13 パケット送信部
14 データ保存部
15 パケット識別部
20−A,20−B 振り分け装置
21 パケット受信部
22 振り分け先決定部
23 パケット送信部
24 データ保存部
30 制御装置
31 パケット受信部
32 通信方式決定部
33 セッション連携部
34 パケット送信部
40−1,40−2 端末
50 SIPサーバ(通信相手)
10-1 to 10-N packet processing device 11 packet receiving unit 12 packet processing unit 13 packet transmission unit 14 data storage unit 15 packet identification unit 20-A, 20-B distribution device 21 packet reception unit 22 distribution destination determination unit 23 packet Transmission unit 24 Data storage unit 30 Control device 31 Packet reception unit 32 Communication method determination unit 33 Session cooperation unit 34 Packet transmission unit 40-1, 40-2 Terminal 50 SIP server (communication partner)

Claims (3)

複数のパケット処理装置と、前記複数のパケット処理装置にパケットを振り分ける複数の振り分け装置と、を有してなる分散処理システムであって、
制御装置をさらに有し、
前記複数のパケット処理装置の各々は、前記振り分け装置から振り分けられたパケットを受信すると、当該パケットが属するセッションを判定し、当該パケットが前記制御用セッションに属すると判定された場合、当該パケットを前記制御装置に転送するパケット識別部を有し、
前記制御装置は、
制御用セッションに属するパケットが到着すると、通信相手とのネゴシエーションを行い、当該制御用セッションと連携するデータ転送用セッションの通信方式を決定する通信方式決定部と、
前記通信方式決定部で決定された通信方式に応じて、前記データ転送用セッションに属するパケットの振り分け先のパケット処理装置を決定し、前記データ転送用セッションを識別するための5−tupleと、決定された振り分け先のパケット処理装置と、を前記複数の振り分け装置の各々に通知すると共に、前記データ転送用セッションに属するパケットのパケット処理に用いる設定情報を前記振り分け先のパケット処理装置に通知するセッション連携部と、を有し、
前記複数の振り分け装置の各々は、
前記制御装置から通知された、前記データ転送用セッションの5−tupleと、当該データ転送用セッションに属するパケットの振り分け先のパケット処理装置と、を対応付けて格納する第2データ保存部と、
パケットが到着し、当該パケットが属するセッションの5−tupleが前記第2データ保存部にて格納されている場合、当該5−tupleに対応付けられている振り分け先のパケット処理装置に当該パケットを振り分け、当該パケットが属するセッションの5−tupleが前記第2データ保存部にて格納されていない場合、予め設定されたアルゴリズムを基に、当該パケットを前記複数のパケット処理装置のいずれかに振り分ける振り分け先決定部と、を有する、分散処理システム。
A distributed processing system comprising a plurality of packet processing devices and a plurality of distribution devices that distribute packets to the plurality of packet processing devices,
A control device;
Each of the plurality of packet processing devices determines a session to which the packet belongs when receiving a packet distributed from the distribution device, and determines that the packet belongs to the control session when the packet belongs to the control session. A packet identification unit for transfer to the control device;
The controller is
When a packet belonging to the control session arrives, a communication method determining unit that negotiates with the communication partner and determines the communication method of the data transfer session in cooperation with the control session;
In accordance with the communication method determined by the communication method determination unit, a packet processing device to which a packet belonging to the data transfer session is allocated is determined, and 5-tuple for identifying the data transfer session is determined. A session for notifying each of the plurality of distribution devices of the distribution destination packet processing device and the setting information used for packet processing of packets belonging to the data transfer session to the distribution destination packet processing device and cooperation unit, the possess,
Each of the plurality of sorting devices includes:
A second data storage unit that stores the 5-transfer of the data transfer session notified from the control device and the packet processing device to which packets belonging to the data transfer session are allocated in association with each other;
When a packet arrives and a 5-tuple of a session to which the packet belongs is stored in the second data storage unit, the packet is distributed to a packet processing apparatus that is a distribution destination associated with the 5-tuple. When the 5-tuple of the session to which the packet belongs is not stored in the second data storage unit, the distribution destination that distributes the packet to one of the plurality of packet processing devices based on a preset algorithm A distributed processing system comprising: a determination unit ;
前記複数のパケット処理装置の各々は、
前記制御装置から通知された、前記データ転送用セッションに属するパケットのパケット処理に用いる設定情報を格納する第1データ保存部と、
パケットが到着し、前記パケット識別部にて当該パケットが前記データ転送用セッションに属すると判定された場合、前記第1データ保存部にて格納された設定情報を基に、当該パケットのパケット処理を実行するパケット処理部と、をさらに有する、請求項1に記載の分散処理システム。
Each of the plurality of packet processing devices includes:
A first data storage unit that stores setting information used for packet processing of packets belonging to the data transfer session notified from the control device;
When a packet arrives and the packet identification unit determines that the packet belongs to the data transfer session, the packet processing of the packet is performed based on the setting information stored in the first data storage unit. The distributed processing system according to claim 1, further comprising: a packet processing unit to be executed.
複数のパケット処理装置と、前記複数のパケット処理装置にパケットを振り分ける複数の振り分け装置と、を有してなる分散処理システムによる分散処理方法であって、
前記分散処理システムに制御装置を設け、
前記複数のパケット処理装置の各々は、前記振り分け装置から振り分けられたパケットを受信すると、当該パケットが属するセッションを判定し、当該パケットが前記制御用セッションに属すると判定された場合、当該パケットを前記制御装置に転送し、
前記制御装置が、制御用セッションに属するパケットが到着すると、通信相手とのネゴシエーションを行い、当該制御用セッションと連携するデータ転送用セッションの通信方式を決定し、
前記制御装置が、前記決定された通信方式に応じて、前記データ転送用セッションに属するパケットの振り分け先のパケット処理装置を決定し、前記データ転送用セッションを識別するための5−tupleと、決定された振り分け先のパケット処理装置を前記複数の振り分け装置の各々に通知すると共に、前記データ転送用セッションに属するパケットのパケット処理に用いる設定情報を前記振り分け先のパケット処理装置に通知し、
前記複数の振り分け装置の各々は、
前記制御装置から通知された、前記データ転送用セッションの5−tupleと、当該データ転送用セッションに属するパケットの振り分け先のパケット処理装置と、を対応付けて第2データ保存部に格納し、
パケットが到着し、当該パケットが属するセッションの5−tupleが前記第2データ保存部にて格納されている場合、当該5−tupleに対応付けられている振り分け先のパケット処理装置に当該パケットを振り分け、当該パケットが属するセッションの5−tupleが前記第2データ保存部にて格納されていない場合、予め設定されたアルゴリズムを基に、当該パケットを前記複数のパケット処理装置のいずれかに振り分ける、分散処理方法。
A distributed processing method by a distributed processing system comprising: a plurality of packet processing devices; and a plurality of distribution devices that distribute packets to the plurality of packet processing devices,
A control device is provided in the distributed processing system,
Each of the plurality of packet processing devices determines a session to which the packet belongs when receiving a packet distributed from the distribution device, and determines that the packet belongs to the control session when the packet belongs to the control session. Transfer to the control unit,
When a packet belonging to the control session arrives, the control device negotiates with the communication partner, determines the communication method of the data transfer session to cooperate with the control session,
The control apparatus determines a packet processing apparatus to which a packet belonging to the data transfer session is distributed according to the determined communication method, and determines 5-tuple for identifying the data transfer session. together we have been the distribution destination and a packet processing device to notify each of the plurality of sorting devices, and notifies the setting information to be used for packet processing for packets belonging to the data transfer session to the packet processing apparatus of the distribution destination,
Each of the plurality of sorting devices includes:
The 5-tuple of the data transfer session notified from the control device and the packet processing device to which packets belonging to the data transfer session are allocated are stored in the second data storage unit in association with each other,
When a packet arrives and a 5-tuple of a session to which the packet belongs is stored in the second data storage unit, the packet is distributed to a packet processing apparatus that is a distribution destination associated with the 5-tuple. If the 5-tuple session to which the packet belongs is not stored in the second data storage unit, based on a preset algorithm, Ru distributes the packet to one of the plurality of packet processing devices, Distributed processing method.
JP2012231717A 2012-10-19 2012-10-19 Distributed processing system and distributed processing method Expired - Fee Related JP5886170B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2012231717A JP5886170B2 (en) 2012-10-19 2012-10-19 Distributed processing system and distributed processing method

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2012231717A JP5886170B2 (en) 2012-10-19 2012-10-19 Distributed processing system and distributed processing method

Publications (2)

Publication Number Publication Date
JP2014086756A JP2014086756A (en) 2014-05-12
JP5886170B2 true JP5886170B2 (en) 2016-03-16

Family

ID=50789477

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2012231717A Expired - Fee Related JP5886170B2 (en) 2012-10-19 2012-10-19 Distributed processing system and distributed processing method

Country Status (1)

Country Link
JP (1) JP5886170B2 (en)

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP6476806B2 (en) * 2014-12-09 2019-03-06 沖電気工業株式会社 Communication relay device and relay method of communication relay device

Family Cites Families (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP3633546B2 (en) * 2001-11-19 2005-03-30 日本電気株式会社 Signaling relay system and signaling relay method
JP2007288711A (en) * 2006-04-20 2007-11-01 Nec Corp Gateway apparatus, setting controller, and load distribution method and program for gateway apparatus
JP2011029703A (en) * 2009-07-21 2011-02-10 Oki Networks Co Ltd Sip server device, and call connection system
JP5405415B2 (en) * 2010-08-18 2014-02-05 日本電信電話株式会社 Service distribution method and service distribution apparatus

Also Published As

Publication number Publication date
JP2014086756A (en) 2014-05-12

Similar Documents

Publication Publication Date Title
US8086709B2 (en) Method and apparatus for distributing load on application servers
US10027496B2 (en) Method for distributing identifiers of multicast sources
US10855539B2 (en) Configuration of forwarding rules using the address resolution protocol
EP3175580B1 (en) System, gateway and method for an improved quality of service, qos, in a data stream delivery
US7957279B2 (en) Session border control using multiple processors
US12591449B2 (en) Merging streams for call enhancement in virtual desktop infrastructure
CN110460641A (en) Data transmission method, apparatus and system
JP5405415B2 (en) Service distribution method and service distribution apparatus
EP1820318B1 (en) A method for identifying real-time traffic hop by hop in an internet network
JP2016213604A (en) Communication apparatus and management method
CN102904761B (en) The method of a kind of NVR stacking and NVR
JP5886170B2 (en) Distributed processing system and distributed processing method
KR101478232B1 (en) Sip message transmission and receiving system and method
JP2019518382A5 (en)
US20140075038A1 (en) Communication device, computer-readable storage medium, and communication system
CN103428028B (en) Service quality maintenance method and system for heterogeneous network
JP5127729B2 (en) Packet relay method and gateway device
US8165126B2 (en) Method, apparatus and system for selecting VMG
WO2022258199A1 (en) Instance-affine service scheduling
JP5868824B2 (en) Distributed processing system and distributed processing method
JP6102274B2 (en) Network device, distribution control method, distribution control program, and distribution destination notification device
CN103814553B (en) Communication device method and system
KR100920327B1 (en) Service processing systems
JP2010147730A (en) Network device, ip network system, and call control method
WO2023283104A1 (en) Merging streams in virtual channel for call enhancement in virtual desktop infrastructure

Legal Events

Date Code Title Description
RD03 Notification of appointment of power of attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7423

Effective date: 20141027

RD04 Notification of resignation of power of attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7424

Effective date: 20141031

A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20150202

RD02 Notification of acceptance of power of attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7422

Effective date: 20151001

RD04 Notification of resignation of power of attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7424

Effective date: 20151005

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20151016

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20151208

A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20160121

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: 20160209

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20160210

R150 Certificate of patent or registration of utility model

Ref document number: 5886170

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150

LAPS Cancellation because of no payment of annual fees