JP5798523B2 - Communication control system, aggregation server, and communication control method - Google Patents
Communication control system, aggregation server, and communication control method Download PDFInfo
- Publication number
- JP5798523B2 JP5798523B2 JP2012138490A JP2012138490A JP5798523B2 JP 5798523 B2 JP5798523 B2 JP 5798523B2 JP 2012138490 A JP2012138490 A JP 2012138490A JP 2012138490 A JP2012138490 A JP 2012138490A JP 5798523 B2 JP5798523 B2 JP 5798523B2
- Authority
- JP
- Japan
- Prior art keywords
- content
- server
- access frequency
- user terminal
- acquisition request
- 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
- Information Transfer Between Computers (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
本発明は、インターネット上のコンテンツのキャッシュを行う通信制御システム、集約サーバおよび通信制御技術に関する。 The present invention relates to a communication control system, an aggregation server, and a communication control technique for caching content on the Internet.
従来、複数のユーザ端末が同一のコンテンツの取得を要求する場合、キャッシュ技術を用い、物理的にユーザ端末に近い位置の装置(キャッシュサーバ)からコンテンツを配信する技術がある。この技術によって、ネットワーク内のトラヒックを抑制し、リクエストに対する応答を高速化することが可能と考えられる。ここで、非常に多くのユーザ端末を収容する大規模なネットワークにおいて大量のコンテンツを保存し、リクエスト(コンテンツの取得要求)を処理することが必要になる場合、通常はネットワーク内に複数のキャッシュサーバを分散的に配備する。 Conventionally, when a plurality of user terminals request acquisition of the same content, there is a technology for distributing content from a device (cache server) physically located near the user terminal using a cache technology. With this technology, it is considered possible to suppress traffic in the network and speed up response to requests. Here, when it is necessary to store a large amount of content and process a request (content acquisition request) in a large-scale network that accommodates a very large number of user terminals, usually a plurality of cache servers in the network Are distributed in a distributed manner.
このように複数のキャッシュサーバを分散配備したシステムにおいて、他網とのゲートウェイ装置に接続された制御サーバが、データ要求頻度の高いコンテンツを判別し、分散配備されたキャッシュサーバに、そのデータ要求頻度の高いコンテンツを予め配信しておく技術がある(特許文献1)。このような技術によれば、ユーザ端末はキャッシュサーバに蓄積されたコンテンツを閲覧する可能性が高くなる。よって、ネットワーク内のトラヒックを抑制し、リクエストに対する応答をさらに高速化できる。 In a system in which a plurality of cache servers are distributed in this way, a control server connected to a gateway device with another network discriminates content with a high data request frequency, and the data request frequency is distributed to the distributed cache servers. There is a technology that distributes high content in advance (Patent Document 1). According to such a technique, the user terminal is more likely to browse the content stored in the cache server. Therefore, traffic in the network can be suppressed and the response to the request can be further speeded up.
しかし、従来技術において、キャッシュサーバに配信されたコンテンツは、制御サーバにおいてデータ要求頻度が高いと判別されたコンテンツに過ぎず、実際にはユーザ端末から閲覧されない可能性がある。このため、実際にはユーザ端末に閲覧されないコンテンツの保存のために、キャッシュサーバのリソース(データ蓄積容量やCPU(Central Processing Unit)使用率)が逼迫するおそれがある。また、閲覧されないコンテンツの配信のためにネットワーク内に無駄なトラヒックが発生するおそれがある。 However, in the prior art, the content distributed to the cache server is only the content determined as having a high data request frequency by the control server, and may not actually be viewed from the user terminal. For this reason, there is a possibility that the resources (data storage capacity and CPU (Central Processing Unit) usage rate) of the cache server may be tight for storing content that is not actually browsed by the user terminal. Moreover, there is a possibility that useless traffic may occur in the network due to the distribution of content that is not browsed.
そこで、本発明は、前記した問題を解決し、ネットワークに分散配備された複数のキャッシュサーバのリソースを有効活用し、ネットワーク内の無駄なトラヒックの発生を抑制することができる通信制御システム、集約サーバおよび通信制御方法を提供することを目的とする。 Therefore, the present invention solves the above-described problem, effectively utilizes resources of a plurality of cache servers distributed and deployed in the network, and can suppress the occurrence of useless traffic in the network. It is another object of the present invention to provide a communication control method.
前記した課題を解決するため、本発明の通信制御システムは、コンテンツごとのアクセス頻度を解析する集約サーバと、ユーザ端末に接続されるエッジ装置と、エッジ装置に接続されるコンテンツのキャッシュサーバとを備える。この通信制御システムの集約サーバは、ネットワーク経由でユーザ端末からコンテンツサーバへのコンテンツの取得要求を取得し、所定期間ごとに、取得要求に基づきコンテンツごとのアクセス頻度を解析する解析部と、解析されたアクセス頻度が所定値以上であるコンテンツのコンテンツ識別子を、エッジ装置へ送信する集約部とを備える。また、エッジ装置は、集約サーバから送信されるコンテンツ識別子を記憶する記憶部と、コンテンツ識別子を含むコンテンツの取得要求をユーザ端末から受信したとき、取得要求を、自身のエッジ装置に接続されるキャッシュサーバへリダイレクトするDPI(Deep Packet Inspection)処理部とを備える。さらに、キャッシュサーバは、コンテンツを記憶する記憶部と、リダイレクトされた取得要求を受信した場合において、取得要求の対象のコンテンツが記憶部にあるとき、コンテンツをユーザ端末へ配信し、取得要求の対象のコンテンツが記憶部にないとき、コンテンツサーバからコンテンツを取得して、記憶部に記憶し、ユーザ端末へ配信する通信処理部と、記憶部に記憶されるコンテンツのうち、前回のユーザ端末への配信から所定時間経過したコンテンツを消去するキャッシュ処理部とを備える。 In order to solve the above-described problems, a communication control system of the present invention includes an aggregation server that analyzes an access frequency for each content, an edge device connected to a user terminal, and a content cache server connected to the edge device. Prepare. The aggregation server of this communication control system acquires a content acquisition request from the user terminal to the content server via the network, and analyzes the access frequency for each content based on the acquisition request for each predetermined period. And an aggregation unit that transmits the content identifier of the content whose access frequency is equal to or higher than a predetermined value to the edge device. The edge device also has a storage unit for storing the content identifier transmitted from the aggregation server, and a cache connected to the edge device when the acquisition request for the content including the content identifier is received from the user terminal. And a DPI (Deep Packet Inspection) processing unit for redirecting to the server. Furthermore, when the cache server receives the redirected acquisition request and the storage unit that stores the content, the cache server distributes the content to the user terminal and the acquisition request target when the acquisition request target content is in the storage unit. When the content is not in the storage unit, the content is acquired from the content server, stored in the storage unit, and delivered to the user terminal. Among the content stored in the storage unit, A cache processing unit for erasing content that has passed a predetermined time from distribution.
このように集約サーバは、エッジ装置に対し、アクセス頻度の高いコンテンツ(人気コンテンツ)のコンテンツ識別子を送信し、ユーザ端末が人気コンテンツへアクセスする際にはキャッシュサーバを経由するようにする。そして、キャッシュサーバに既にアクセス対象(取得要求の対象)のコンテンツが記憶されていれば、自身に記憶されるコンテンツを配信する。一方、キャッシュサーバにアクセス対象のコンテンツが記憶されていなければ、コンテンツサーバから取得し、保存してから配信する。これにより、人気コンテンツの保存および配信をキャッシュサーバが行うようになるので、ネットワーク内に無駄なトラヒックが発生することを抑制できる。また、キャッシュサーバに人気コンテンツが保存されることになるので、キャッシュサーバのリソースを効率的に利用することになる。 As described above, the aggregation server transmits the content identifier of the frequently accessed content (popular content) to the edge device so that the user terminal goes through the cache server when accessing the popular content. If the access target (acquisition request target) content is already stored in the cache server, the content stored in itself is distributed. On the other hand, if the access target content is not stored in the cache server, the content is acquired from the content server, stored, and then distributed. As a result, the cache server performs storage and distribution of popular content, so that it is possible to prevent unnecessary traffic from occurring in the network. In addition, since popular contents are stored in the cache server, the resources of the cache server are efficiently used.
また、本発明の通信制御システムの集約サーバにおける集約部は、さらに、解析されたアクセス頻度の増加の割合が所定値以上のコンテンツのコンテンツ識別子をエッジ装置へ送信する。 In addition, the aggregation unit in the aggregation server of the communication control system of the present invention further transmits a content identifier of content whose analyzed access frequency increase rate is a predetermined value or more to the edge device.
このようにすることで、キャッシュサーバは今後アクセス頻度が上昇する可能性のあるコンテンツの保存および配信を行うことができる。 In this way, the cache server can store and distribute content that may increase in access frequency in the future.
また、本発明の通信制御システムの集約サーバにおける集約部は、さらに、所定期間ごとにアクセス頻度が上昇するコンテンツを、キャッシュサーバにおける非消去対象コンテンツとして選択し、選択した非消去対象コンテンツのコンテンツ識別子をキャッシュサーバへ送信する。また、キャッシュサーバにおけるキャッシュ処理部は、さらに、記憶部に記憶されるコンテンツのうち、非消去対象コンテンツのコンテンツ識別子に示されるコンテンツ以外のコンテンツを消去する。 The aggregation unit in the aggregation server of the communication control system of the present invention further selects content whose access frequency increases every predetermined period as the non-erasable content in the cache server, and the content identifier of the selected non-erasable content Is sent to the cache server. Further, the cache processing unit in the cache server further erases content other than the content indicated by the content identifier of the non-erasable content among the content stored in the storage unit.
このようにすることで、キャッシュサーバは、所定期間ごとアクセス頻度が上昇するコンテンツを選択し、記憶部に保存するようにするので、記憶部の記憶容量を有効活用できる。 By doing so, the cache server selects content whose access frequency increases every predetermined period and stores it in the storage unit, so that the storage capacity of the storage unit can be used effectively.
また、本発明の通信制御システムのキャッシュサーバは、自身のキャッシュサーバのコンテンツごとに、ユーザ端末からのアクセス頻度を集計するキャッシュアクセス頻度集計部をさらに備え、通信処理部は、集計したアクセス頻度を集約サーバへ送信する。また、集約サーバの集約部は、解析部により解析されたアクセス頻度と、キャッシュサーバから受信したアクセス頻度とに基づき、アクセス頻度が所定値以上であるコンテンツのコンテンツ識別子を、エッジ装置へ送信する。 In addition, the cache server of the communication control system of the present invention further includes a cache access frequency counting unit that counts the access frequency from the user terminal for each content of its own cache server, and the communication processing unit calculates the total access frequency. Send to the aggregation server. Further, the aggregation unit of the aggregation server transmits the content identifier of the content whose access frequency is a predetermined value or more to the edge device based on the access frequency analyzed by the analysis unit and the access frequency received from the cache server.
このようにすることで、集約サーバは、各キャッシュサーバにおけるコンテンツのアクセス頻度(キャッシュの利用頻度)を加味して、コンテンツのアクセス頻度を解析するので、集約サーバが各エッジ装置へ送信するコンテンツ識別子に、各キャッシュサーバからの配信頻度が高いコンテンツ識別子を含めることができる。これにより、各キャッシュサーバのキャッシュヒット率(自身のキャッシュサーバに保存しているコンテンツのうち、ユーザ端末へ当該コンテンツを配信する率)を向上させることができるので、キャッシュサーバのリソースをより効率的に利用することができる。また、ネットワーク内に無駄なトラヒックが発生することをさらに抑制できる。 In this way, the aggregation server analyzes the content access frequency in consideration of the content access frequency (cache usage frequency) in each cache server, so the content identifier transmitted by the aggregation server to each edge device The content identifier having a high distribution frequency from each cache server can be included. As a result, the cache hit rate of each cache server (the rate of delivering the content to the user terminal among the content stored in its own cache server) can be improved, so the resources of the cache server are more efficient. Can be used. In addition, it is possible to further suppress the occurrence of useless traffic in the network.
本発明によれば、ネットワークに分散配備された複数のキャッシュサーバのリソースを有効活用し、ネットワーク内の無駄なトラヒックの発生を抑制することができる。 According to the present invention, it is possible to effectively use resources of a plurality of cache servers distributed and deployed in a network, and to suppress the generation of useless traffic in the network.
<概要>
図面を参照しながら、本発明の実施の形態を説明する。まず、図1を参照しながら、実施の形態の通信制御システム(以下、システムと略す)の構成および概要を説明する。システムは、ユーザ端末10、パケットをコピーするコピー装置20、コンテンツ識別子ごとのアクセス頻度を解析する集約サーバ30、通信キャリアによるIP(Internet Protocol)網40、IP網40外の網である他網50、このIP網40と他網50との間に設置されるゲートウェイ装置60、コンテンツを配信するコンテンツサーバ70、IP網40に設置されユーザ端末10を収容するエッジ装置80(80A,80B)およびキャッシュサーバ90(90A,90B)を備える。各サーバ、装置の台数は、図1に示した台数に限定されない。なお、以下の説明においてコンテンツ識別子とは、例えば、コンテンツのURL(Uniform Resource Locator)やIPアドレス等である。
<Overview>
Embodiments of the present invention will be described with reference to the drawings. First, the configuration and outline of a communication control system (hereinafter abbreviated as a system) according to an embodiment will be described with reference to FIG. The system includes a
ユーザ端末10は、各エッジ装置80を介してIP網40に接続され、エッジ装置80およびIP網40、ゲートウェイ装置60を経由し、他網50に配置された様々なサーバ(例えば、コンテンツサーバ70等)へアクセスする。例えば、ユーザ端末10はコンテンツサーバ70に対しコンテンツを取得要求を送信して、コンテンツを取得する。
The
ここで、コピー装置20はIP網40から他網50へのパケットをコピーする。そして、集約サーバ30は、コピー装置20でコピーされたパケットから、所定のコンテンツサーバ70に対する取得要求を抽出する。集約サーバ30は、所定期間ごとに各コンテンツのアクセス頻度を集計し、アクセス頻度の高い人気コンテンツのURL等を識別する。その後、集約サーバ30は、エッジ装置80のDPI(Deep Packet Inspection)処理部811に対して、その識別された人気コンテンツの取得にかかる通信をキャッシュサーバ90へリダイレクトするよう指示する。これにより、エッジ装置80において、人気コンテンツの取得要求を識別し、その識別された取得要求をキャッシュサーバ90へリダイレクトする。キャッシュサーバ90は、リダイレクトされた取得要求に示される取得対象コンテンツがなければ、コンテンツサーバ70から取得して保存しユーザ端末10へ配信し、既に取得対象コンテンツがあれば、そのコンテンツをユーザ端末10へ配信する(コンテンツの保存および配信)。このようにすることで、集約サーバ30は、キャッシュサーバ90に人気コンテンツを保存させ、以降、この人気コンテンツについてはキャッシュサーバ90からユーザ端末10へ配信させることができる。
Here, the
次に、図2を用いて、システムの各構成要素を詳細に説明する。 Next, each component of the system will be described in detail with reference to FIG.
<コピー装置>
コピー装置20は、ゲートウェイ装置60とIP網40との間に配置され、IP網40から他網50へのパケットをコピーし、集約サーバ30へ送信する。コピー方法としては、光TAPを用いて物理的にコピーする方法、5tuple(送信元IPアドレス、送信先IPアドレス、送信元ポート、送信先ポートおよびプロトコルの組み合わせ)をベースにパケットを識別して特定のパケットをコピーする方法等が挙げられる。また、コピー装置20が、パケットを集約サーバ30へリダイレクトさせることで、パケットを集約サーバ30へ引き込んでもよい。
<Copy device>
The
<集約サーバ>
集約サーバ30は、コピー装置20によりユーザ端末10からコンテンツの取得要求を取得し、所定期間ごとに、コンテンツごとのアクセス頻度を解析する。そして、集約サーバ30は、アクセス頻度が高い(例えば、アクセス頻度が所定値以上である)コンテンツ識別子をエッジ装置80へ送信する。その後、そのコンテンツ識別子を受信したエッジ装置80は、ユーザ端末10からのパケットのうち、そのコンテンツ識別子のコンテンツの取得要求をキャッシュサーバ90へリダイレクトする。つまり、集約サーバ30は、エッジ装置80に対し、ユーザ端末10からのアクセス頻度の高いコンテンツの取得要求をキャッシュサーバ90へリダイレクトするよう指示する。
<Aggregation server>
The
この集約サーバ30は、振分部31、複数の解析部32、集約部33およびアクセス頻度記憶部34を備える。
The
振分部31は、コピー装置20から受信したパケットを解析部32のいずれかへ送信する。
The
解析部32は、振分部31より受信したパケットから、所定のサイトに対するコンテンツ要求(コンテンツの取得要求)パケットを選択する。解析部32は、選択したコンテンツ要求パケットからIPアドレスやURL等のコンテンツ識別子を取得し、コンテンツ識別子ごとのアクセス回数を記録する。そして、解析部32は、所定期間ごとに集約部33にコンテンツ識別子ごとのアクセス回数(アクセス頻度)を通知する。ここで、解析部32はアクセス頻度の通知後、解析部32がメモリ等に保持するアクセス頻度を消去するのが好ましい。このようにすることで、解析部32の用いるメモリの記憶容量を有効活用できる。ここで、多数のユーザ端末10が収容されるIP網40においては、ゲートウェイ装置60とIP網40と間に非常に多くのパケットが流通すると想定される。このため、集約サーバ30に解析部32を複数配置し、振分部31を用いて分散処理をするのが好ましい。この場合、振分部31は、例えば、パケットの宛先IPアドレス等をもとにしたハッシュ計算によりいずれかの解析部32にパケットを振り分ける。
The
集約部33は、解析部32から通知されたアクセス頻度を集計し、コンテンツ識別子ごとのアクセス頻度を示したコンテンツアクセス頻度情報(アクセス頻度情報)を作成する。このコンテンツアクセス頻度情報は、アクセス頻度情報記憶部34に記憶される。また、集約部33は、作成したアクセス頻度情報に基づき、アクセス頻度の高いコンテンツ識別子を選択し、選択したコンテンツ識別子をエッジ装置80へ送信する。
The
この集約部33は、コンテンツアクセス頻度集計部331とコンテンツ選択部332とを備える。コンテンツアクセス頻度集計部331は、解析部32より通知されるコンテンツ識別子ごとのアクセス頻度を示したアクセス頻度情報を作成する。このアクセス頻度情報は、例えば、図3に示すように、各コンテンツの各日時におけるアクセス頻度を示した情報である。
The
コンテンツ選択部332は、所定期間ごとに、アクセス頻度情報に基づき、各キャッシュサーバ90で保存および配信するコンテンツを選択する。例えば、コンテンツ選択部332は、アクセス頻度情報に基づき、1日や1時間等の所定期間ごとにアクセス頻度の高いコンテンツを選択する。そして、コンテンツ選択部332は、選択したコンテンツのコンテンツ識別子をエッジ装置80へ送信する。ここで、選択方法としては、アクセス頻度が所定値以上のものを選択する方法や、最近のアクセス頻度が高いものから順に所定数選択する方法、また、アクセス頻度の増加割合が大きいのものを選択する等、今後アクセス頻度が高くなるコンテンツを予想し選択する方法、またはこれらを加味して総合的に選択する方法等が挙げられる。このような選択方法によれば、コンテンツ選択部332は、直近のアクセス頻度が高くキャッシュサーバ90への保存によりトラヒック抑制およびユーザの体感品質向上への効果が高いと想定されるコンテンツを選択することができる。このように直近のアクセス頻度が高いコンテンツを選択する方法は、人気コンテンツの変動が大きくライフサイクルの短いインターネット上のコンテンツに対して特に適用効果が高いと考えられる。
The
このような集約サーバ30は、CPU、通信インタフェース、記憶媒体を備えるコンピュータにより実現される。振分部31、解析部32および集約部33は、通信インタフェースおよびCPUによるプログラム実行処理や、専用回路等により実現される。さらに、アクセス頻度記憶部34は、RAM(Random Access Memory)、ROM(Read Only Memory)、HDD(Hard Disk Drive)、フラッシュメモリ等の記憶媒体から構成される。
Such an
<エッジ装置>
エッジ装置80(80A,80B)は、集約サーバ30の集約部33から通知されるコンテンツ識別子のコンテンツの取得にかかる通信を識別し、その通信をキャッシュサーバ90へリダイレクトする。このエッジ装置80は、CPU、通信インタフェース、記憶媒体を備えるコンピュータにより実現される。エッジ装置80の機能は、大きく通信処理部81と、記憶部82とに分けられる。通信処理部81は、ユーザ端末10がIP網40経由で通信を行うときの経路制御等を行う。この通信処理部81は、DPI処理部811を備える。
<Edge device>
The edge device 80 (80A, 80B) identifies the communication related to the acquisition of the content with the content identifier notified from the
DPI処理部811は、集約サーバ30から送信されるコンテンツ識別子を記憶部82に記憶し、この記憶部82に記憶されたコンテンツ識別子のコンテンツの取得要求をユーザ端末10から受信した際に、その取得要求を、キャッシュサーバ90へリダイレクトする。なお、DPI処理部811は、集約サーバ30から、所定期間ごとにコンテンツ識別子を受信するが、そのうち最新のコンテンツ識別子をリダイレクトに用いるようにする。
The
これにより、エッジ装置80は、ユーザ端末10からのアクセス頻度の高いコンテンツの取得にかかる通信はキャッシュサーバ90を経由させ、その他のアクセス頻度が低いコンテンツ取得にかかる通信はキャッシュサーバ90を経由させない処理動作を行うことができる。また、キャッシュサーバ90においてアクセス頻度の低いコンテンツが保存されることを防ぐことになるので、キャッシュサーバ90のリソースを有効利用することができる。
As a result, the
<キャッシュサーバ>
キャッシュサーバ90は、エッジ装置80からリダイレクトされてきたユーザ端末10からのコンテンツの取得要求に基づき、コンテンツの保存および配信を行う。このキャッシュサーバ90は、図4に示すように、通信処理部91と、キャッシュ処理部92と、記憶部93とを備える。なお、破線で示すキャッシュアクセス頻度情報、キャッシュアクセス頻度集計部93およびキャッシュアクセス頻度情報送信部94については、装備する場合と装備しない場合とがあり、装備する場合については後記する。
<Cache server>
The
通信処理部91は、記憶部93へのコンテンツの保存およびユーザ端末10(図2参照)および配信を行う。すなわち、通信処理部91は、ユーザ端末10からのコンテンツの取得要求を受信した場合において、取得要求の対象のコンテンツが記憶部93にあるとき、このコンテンツをユーザ端末10へ送信する。一方、通信処理部91は、取得要求の対象のコンテンツが記憶部93にないとき、このコンテンツをコンテンツサーバ70から取得して、記憶部93に保存する。そして、保存したコンテンツをユーザ端末10へ送信する。
The communication processing unit 91 stores content in the
キャッシュ処理部92は、記憶部93における保存コンテンツの総量がデータ蓄積容量に近い場合、記憶部93に保存されるコンテンツのうち、前回のユーザ端末10への送信から(つまり、前回のコンテンツの閲覧から)所定時間経過したコンテンツを消去する。これにより、記憶部93の限られた記憶容量を有効活用できる。
When the total amount of content stored in the
<動作手順>
次に、図5および図6を用いて、図2に示すシステムの動作手順を説明する。ここでは、ユーザ端末10がゲートウェイ装置60を介してコンテンツサーバ70に保存されているコンテンツAを取得する場合を例に説明する。
<Operation procedure>
Next, the operation procedure of the system shown in FIG. 2 will be described with reference to FIGS. Here, a case where the
<アクセス頻度集計>
まず、図5を参照して、集約サーバ30によるコンテンツのアクセス頻度の集計処理について説明する。エッジ装置80Aの配下のユーザ端末10は、ゲートウェイ装置60を介し、他網50のコンテンツサーバ70に保存されたコンテンツA(図5の「A」)を取得する(S11)。つまり、ユーザ端末10は、コンテンツAの取得のためのパケットを送信する。このときゲートウェイ装置60とIP網40との間に配備されたコピー装置20にてパケットをコピーし、集約サーバ30へ送信する(S12)。集約サーバ30ではパケットを受信した後、集約サーバ30内の振分部31にて解析部32へのパケット振り分けを行う(S13)。例えば、振分部31は、パケットのIPアドレス等をもとに複数の解析部32から1つの解析部32を選択し、選択した解析部32にパケットを送信する。
<Access frequency count>
First, with reference to FIG. 5, the aggregation processing of the content access frequency by the
解析部32では、受信したパケットからコンテンツ識別子を抽出する(S14)。つまり、解析部32は、振分部31から受信したパケットが所定のWebサイトやサーバ等へのコンテンツ要求パケットであることを判別すると、そのパケットが要求するコンテンツのコンテンツ識別子(IPアドレスやURL等)を抽出する。そして、解析部32は、このコンテンツ識別子ごとのアクセス回数を記録する。解析部32は、所定期間ごとに集約部33にコンテンツ識別子ごとのアクセス頻度を通知し、解析部32が保持するアクセス頻度は消去する。
The
集約部33は、コンテンツアクセス頻度集計部331(図2参照)により、解析部32から通知されるコンテンツ識別子ごとのアクセス回数に基づき、アクセス頻度情報(図3参照)を作成する(S15)。すなわち、コンテンツアクセス頻度集計部331は、各コンテンツ識別子について、所定期間ごと(例えば、1日ごとや1時間ごと)のアクセス回数を記録したアクセス頻度情報を作成する。
The
<コンテンツの保存および配信>
次に、図6を参照して、キャッシュサーバ90によるコンテンツの保存および配信について説明する。図5のS15の後、集約サーバ30の集約部33のコンテンツ選択部332(図2参照)は、キャッシュサーバ90への保存コンテンツを所定期間ごとに、所定数選択し、各エッジ装置80のDPI処理部811へ通知する(S16)。つまり、集約部33のコンテンツ選択部332は、アクセス頻度情報を参照して、キャッシュサーバ90へリダイレクトすべきパケットの要求コンテンツのコンテンツ識別子を所定数選択し、エッジ装置80のDPI処理部811へ送信する。破線で示したS17については、その他の実施の形態の項で後記する。
<Storage and distribution of content>
Next, content storage and distribution by the
エッジ装置80のDPI処理部811は、集約サーバ30から通知されたコンテンツ識別子を記憶部82に記憶し、通知されたコンテンツ識別子のコンテンツ取得にかかる通信を、キャッシュサーバ90を経由させるようにリダイレクトする(S18)。
The
ここで、DPI処理部811による通信の判別においては、例えば、以下の方法が考えられる。すなわち、DPI処理部811は、受信したIPパケットのヘッダにおける固定長の特定のフィールドに記載されているIPアドレス等により一次識別した後に、URL等のIPパケットの中で記載位置が変動する情報から二次識別する方法が挙げられる。このように、DPI処理部811がIPアドレス等により一次識別を行うことによって、URL等の高位レイヤの情報識別が一部の通信のみとなる。よって、URL等のパケットの固定長のヘッダには記載されていない情報をもとに通信を識別する場合に比べ、DPI処理部811におけるリダイレクト判定にかかる時間を低減できる。
Here, in the discrimination of communication by the
キャッシュサーバ90の通信処理部91(図4参照)は、エッジ装置80からリダイレクトされた通信に対し、自サーバへの未保存コンテンツへの要求である場合、要求コンテンツをコンテンツサーバ70から取得し、記憶部93に保存し、ユーザ端末10へ配信する(S19)。一方、リダイレクトされた通信が、自サーバの保存コンテンツへの要求である場合、要求コンテンツをユーザ端末10へ配信する(S20)。破線で示したS21については、その他の実施の形態の項で後記する。
The communication processing unit 91 (see FIG. 4) of the
このようなシステムによれば、キャッシュサーバ90にはアクセス頻度の高いコンテンツが保存されることになるので、キャッシュサーバ90のリソースを効率的に利用することになる。また、アクセス頻度の高いコンテンツの配信をキャッシュサーバ90が行うようになるので、ネットワーク内に無駄なトラヒックが発生することを抑制することができる。
According to such a system, content with high access frequency is stored in the
<その他の実施の形態>
前記したシステムにおいて、集約サーバ30は、キャッシュサーバ90に対し、キャッシュサーバ90における非消去対象コンテンツを指示するようにしてもよい。
<Other embodiments>
In the system described above, the
例えば、集約サーバ30のコンテンツ選択部332は、所定の間隔をおいてアクセス頻度が高くなる(例えば、昼間帯にアクセス頻度が高くなる)コンテンツを選択し、選択したコンテンツのコンテンツ識別子を非消去対象のコンテンツ識別子としてキャッシュサーバ90に通知する(図6のS17)。そして、キャッシュサーバ90の記憶部93の保存済コンテンツの総量がデータ蓄積容量に近い場合、キャッシュ処理部92は、集約サーバ30から通知された非消去対象のコンテンツ以外の中からコンテンツを選択し消去する(図6のS21)。
For example, the
これにより、キャッシュサーバ90が自身のサーバへのアクセス頻度から消去対象コンテンツを選択する場合に比べ、定期的にアクセス頻度が高くなるコンテンツをキャッシュサーバ90上に残すことができる。よって、キャッシュサーバ90から消去したコンテンツを再度キャッシュ保存する間の無駄なトラヒック疎通を防ぐことができる。
As a result, it is possible to leave on the
また、集約サーバ30のコンテンツ選択部332は、各キャッシュサーバ90におけるコンテンツのアクセス頻度を考慮して、各キャッシュサーバ90で保存および配信すべきコンテンツを選択するようにしてもよい。この場合、キャッシュサーバ90は、図4の破線で示すキャッシュアクセス頻度集計部94とキャッシュアクセス頻度情報送信部95とをさらに備える。記憶部93には、キャッシュアクセス頻度集計部94が作成したキャッシュアクセス頻度情報が記憶される。キャッシュアクセス頻度集計部94は、記憶部93のコンテンツごとに、自身のキャッシュサーバ90からユーザ端末10への配信回数を記録する。そして、キャッシュアクセス頻度集計部94は所定の期間(例えば、1日や1時間〜12時間)ごとにその期間アクセスのあったコンテンツ識別子とアクセス回数を示したキャッシュアクセス頻度情報を作成し、キャッシュアクセス頻度情報送信部95は、このキャッシュアクセス頻度情報を集約サーバ30へ送信する。そして、集約サーバ30のコンテンツアクセス頻度集計部331は、各キャッシュサーバ90から送信されたキャッシュアクセス頻度情報と、コンテンツアクセス頻度情報とに基づき、キャッシュサーバ90で保存および配信すべきコンテンツを選択する。つまり、集約サーバ30のコンテンツ選択部332は、各キャッシュサーバ90で保存および配信すべきコンテンツとして、各キャッシュサーバ90における配信回数が多いコンテンツも選択できる。これにより各キャッシュサーバ90におけるキャッシュヒット率を向上させることができる。
Further, the
また、集約サーバ30のコンテンツアクセス頻度集計部331(図2参照)が、アクセス頻度情報(図3参照)を作成する際、直近のアクセス記録については細かく記録し、古い記録については記録を集約し、また所定期間より前の情報は消去することでサイズが増大することを防ぐようにしてもよい。例えば、図3に示すアクセス頻度情報のように、1時間ごとにアクセス頻度を記録し、6時間より以前の記録は0時から5時の早朝帯、6時から17時の昼間帯、18時から23時の夜間帯のような時間帯別に記録を集約し、3日以前の記録は消去してもよい。また、コンテンツアクセス頻度集計部331は、アクセス頻度情報(図3参照)の作成にあたり、IPアドレス等のユーザ識別子とユーザ端末10の収容位置情報をもとに、流行のコンテンツの発信元となる東京等の大都市からのアクセスに対し重みづけすることや、地域ごとのアクセス頻度情報を作成する等、地域性を考慮してもよい。このようにすることで、キャッシュサーバ90のキャッシュヒット率を向上させることができる。
Further, when the content access frequency totaling unit 331 (see FIG. 2) of the
10 ユーザ端末
20 コピー装置
30 集約サーバ
31 振分部
32 解析部
33 集約部
34 アクセス頻度記憶部
40 IP網
50 他網
60 ゲートウェイ装置
70 コンテンツサーバ
80(80A,80B) エッジ装置
81,91 通信処理部
82,93 記憶部
90 キャッシュサーバ
92 キャッシュ処理部
94 キャッシュアクセス頻度集計部
95 キャッシュアクセス頻度情報送信部
331 コンテンツアクセス頻度集計部
332 コンテンツ選択部
811 DPI処理部
DESCRIPTION OF
Claims (6)
前記集約サーバは、
ネットワーク経由で前記ユーザ端末からコンテンツサーバへのコンテンツの取得要求を取得し、所定期間ごとに、前記取得要求に基づき前記コンテンツごとのアクセス頻度を解析する解析部と、前記解析されたアクセス頻度が所定値以上であるコンテンツのコンテンツ識別子を、前記エッジ装置へ送信する集約部とを備え、
前記エッジ装置は、
前記集約サーバから送信される前記コンテンツ識別子を記憶する記憶部と、前記コンテンツ識別子を含むコンテンツの取得要求を前記ユーザ端末から受信したとき、前記取得要求を、自身のエッジ装置に接続される前記キャッシュサーバへリダイレクトするDPI(Deep Packet Inspection)処理部とを備え、
前記キャッシュサーバは、
前記コンテンツを記憶する記憶部と、前記リダイレクトされた取得要求を受信した場合において、前記取得要求の対象のコンテンツが前記記憶部にあるとき、前記コンテンツを前記ユーザ端末へ配信し、前記取得要求の対象のコンテンツが前記記憶部にないとき、前記コンテンツサーバから前記コンテンツを取得して、前記記憶部に記憶し、前記ユーザ端末へ配信する通信処理部と、前記記憶部に記憶されるコンテンツのうち、前回の前記ユーザ端末への配信から所定時間経過したコンテンツを消去するキャッシュ処理部と、
を備えることを特徴とする通信制御システム。 An aggregation server for analyzing the access frequency for each content, an edge device connected to a user terminal, and a cache server for the content connected to the edge device;
The aggregation server is
An acquisition unit that acquires a content acquisition request from the user terminal to the content server via the network and analyzes the access frequency for each content based on the acquisition request for each predetermined period; and the analyzed access frequency is predetermined An aggregation unit that transmits a content identifier of content that is greater than or equal to a value to the edge device;
The edge device is
The storage unit that stores the content identifier transmitted from the aggregation server, and the cache that is connected to its edge device when the acquisition request for the content including the content identifier is received from the user terminal A DPI (Deep Packet Inspection) processing unit that redirects to the server,
The cache server is
In the case where the storage unit that stores the content and the redirected acquisition request is received, when the content targeted for the acquisition request is in the storage unit, the content is delivered to the user terminal, and the acquisition request When the target content is not in the storage unit, the content is acquired from the content server, stored in the storage unit, and delivered to the user terminal; among the content stored in the storage unit A cache processing unit for erasing content that has passed a predetermined time since the previous delivery to the user terminal;
A communication control system comprising:
さらに、前記解析されたアクセス頻度の増加の割合が所定値以上のコンテンツのコンテンツ識別子を前記エッジ装置へ送信すること
を特徴とする請求項1に記載の通信制御システム。 The aggregation unit is
The communication control system according to claim 1, further comprising: transmitting to the edge device a content identifier of a content whose analyzed access frequency increase rate is a predetermined value or more.
所定期間ごとに前記アクセス頻度が上昇するコンテンツを、前記キャッシュサーバにおける非消去対象コンテンツとして選択し、前記選択した非消去対象コンテンツのコンテンツ識別子を前記キャッシュサーバへ送信するコンテンツ選択部を備え、
前記キャッシュ処理部は、
さらに、前記記憶部に記憶されるコンテンツのうち、前記非消去対象コンテンツのコンテンツ識別子に示されるコンテンツ以外のコンテンツを消去すること
を特徴とする請求項1または請求項2に記載の通信制御システム。 The aggregation unit is
A content selection unit that selects content whose access frequency increases every predetermined period as non-erasable content in the cache server and transmits a content identifier of the selected non-erasable content to the cache server,
The cache processing unit
The communication control system according to claim 1 or 2, wherein content other than the content indicated by a content identifier of the non-erasable content is erased from the content stored in the storage unit.
自身のキャッシュサーバのコンテンツごとに、前記ユーザ端末からのアクセス頻度を集計するキャッシュアクセス頻度集計部をさらに備え、
前記通信処理部は、
前記集計したアクセス頻度を前記集約サーバへ送信し、
前記集約部は、
前記解析部により解析されたアクセス頻度と、前記キャッシュサーバから受信したアクセス頻度とに基づき、前記アクセス頻度が所定値以上であるコンテンツのコンテンツ識別子を、前記エッジ装置へ送信すること
を特徴とする請求項1ないし請求項3のいずれか1項に記載の通信制御システム。 The cache server is
For each content of its own cache server, it further comprises a cache access frequency counting unit that counts the access frequency from the user terminal,
The communication processing unit
Sending the aggregated access frequency to the aggregation server;
The aggregation unit is
The content identifier of the content whose access frequency is a predetermined value or more is transmitted to the edge device based on the access frequency analyzed by the analysis unit and the access frequency received from the cache server. The communication control system according to any one of claims 1 to 3.
ネットワーク経由で前記ユーザ端末から前記コンテンツサーバへのコンテンツの取得要求を取得し、所定期間ごとに、前記取得した取得要求に基づき前記コンテンツごとのアクセス頻度を解析する解析部と、前記解析されたアクセス頻度が前記所定値以上であるコンテンツのコンテンツ識別子を、前記エッジ装置へ送信する集約部とを備えること
を特徴とする集約サーバ。 When receiving an acquisition request including the content identifier from the user terminal, the access frequency to the content server identifies the acquisition request including the content identifier of the content of the predetermined value or more, the identification and acquisition request, storing the content An aggregation server used in a communication control system including an edge device that redirects to a cache server,
Get the acquisition request of content from the user terminal via the network to the content server for each predetermined time period, an analysis unit for analyzing the access frequency of each of the contents based on the obtained acquisition request, the analyzed access aggregation server that frequency content identifier of the content is the predetermined value or more, characterized in that it comprises a collection portion to be transmitted to the edge device.
前記集約サーバが、
所定期間ごとに、前記取得要求に基づき前記コンテンツごとのアクセス頻度を解析するステップと、
前記解析されたアクセス頻度が所定値以上であるコンテンツのコンテンツ識別子を、前記ユーザ端末に接続されるエッジ装置へ送信するステップとを実行し、
前記エッジ装置が、
前記コンテンツ識別子を含むコンテンツの取得要求を前記ユーザ端末から受信したとき、前記取得要求を、自身のエッジ装置に接続される前記キャッシュサーバへリダイレクトするステップを実行し、
前記キャッシュサーバが、
前記リダイレクトされた取得要求を受信した場合において、
前記取得要求の対象のコンテンツが記憶部にあるとき、前記コンテンツを前記ユーザ端末へ配信するステップを実行し、
前記取得要求の対象のコンテンツが前記記憶部にないとき、前記コンテンツサーバから前記コンテンツを取得して、前記記憶部に記憶し、前記ユーザ端末へ配信するステップを実行し、
前記記憶部に記憶されるコンテンツのうち、前回の前記ユーザ端末への配信から所定時間経過したコンテンツを消去するステップを実行すること
を特徴とする通信制御方法。 A communication control system comprising an aggregation server that acquires a content acquisition request from a user terminal to a content server via a network, an edge device connected to the user terminal, and a cache server for the content connected to the edge device A communication control method in
The aggregation server is
Analyzing the access frequency for each content based on the acquisition request for each predetermined period;
Transmitting the content identifier of the content whose analyzed access frequency is a predetermined value or more to an edge device connected to the user terminal,
The edge device is
When receiving an acquisition request for content including the content identifier from the user terminal, the step of redirecting the acquisition request to the cache server connected to its edge device,
The cache server is
In the case of receiving the redirected acquisition request,
When the content of the acquisition request target is in a storage unit, the step of delivering the content to the user terminal is executed,
When the content subject of the acquisition request is not in the storage unit, it acquires the content from the content server, stored in the storage unit, executes the steps to be distributed to the user terminal,
The communication control method characterized by performing the step which deletes the content which predetermined time passed from the delivery to the said user terminal last time among the contents memorize | stored in the said memory | storage part.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2012138490A JP5798523B2 (en) | 2012-06-20 | 2012-06-20 | Communication control system, aggregation server, and communication control method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2012138490A JP5798523B2 (en) | 2012-06-20 | 2012-06-20 | Communication control system, aggregation server, and communication control method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2014002634A JP2014002634A (en) | 2014-01-09 |
| JP5798523B2 true JP5798523B2 (en) | 2015-10-21 |
Family
ID=50035734
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2012138490A Expired - Fee Related JP5798523B2 (en) | 2012-06-20 | 2012-06-20 | Communication control system, aggregation server, and communication control method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5798523B2 (en) |
Families Citing this family (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2015165632A (en) * | 2014-03-03 | 2015-09-17 | 日本電気株式会社 | Information transfer device, information transfer method, and program |
| EP2963894A1 (en) * | 2014-07-04 | 2016-01-06 | Thomson Licensing | Method for operating a cache arranged along a transmission path between client terminals and at least one server, and corresponding cache. |
| JP6772794B2 (en) * | 2016-11-30 | 2020-10-21 | 富士通株式会社 | Distributed data management device, distributed data management program and distributed data management method |
| EP3851971B1 (en) * | 2018-09-11 | 2025-05-14 | Hitachi Kokusai Electric Inc. | Verification system and verification server |
| KR102249697B1 (en) * | 2019-11-25 | 2021-05-11 | 동국대학교 산학협력단 | System and method for communicating using content delivery network and edge computing in a complex network environment |
| CN113901335A (en) * | 2021-10-14 | 2022-01-07 | 浙江省科技信息研究院 | Dynamic sensing and routing method for technical resources |
Family Cites Families (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CA2415888C (en) * | 2000-08-04 | 2008-10-21 | Avaya Technology Corporation | Intelligent demand driven recognition of url objects in connection oriented transactions |
| JP4025034B2 (en) * | 2001-07-26 | 2007-12-19 | 日本電信電話株式会社 | Information caching method on the Internet |
| JP2005010970A (en) * | 2003-06-18 | 2005-01-13 | Hitachi Ltd | Distributed cache control method, network system, and control server or router used in the network |
| US9762692B2 (en) * | 2008-04-04 | 2017-09-12 | Level 3 Communications, Llc | Handling long-tail content in a content delivery network (CDN) |
| US8417816B2 (en) * | 2009-02-20 | 2013-04-09 | Alcatel Lucent | Topology aware cache cooperation |
| EP2532137B1 (en) * | 2010-02-05 | 2015-08-12 | Telefonaktiebolaget L M Ericsson (PUBL) | Method and node entity for enhancing content delivery network |
-
2012
- 2012-06-20 JP JP2012138490A patent/JP5798523B2/en not_active Expired - Fee Related
Also Published As
| Publication number | Publication date |
|---|---|
| JP2014002634A (en) | 2014-01-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US10666522B2 (en) | Server side content delivery network quality of service | |
| US8370520B2 (en) | Adaptive network content delivery system | |
| US8612668B2 (en) | Storage optimization system based on object size | |
| EP2359536B1 (en) | Adaptive network content delivery system | |
| US11252211B2 (en) | Managing content on an ISP cache | |
| JP5798523B2 (en) | Communication control system, aggregation server, and communication control method | |
| US8463846B2 (en) | File bundling for cache servers of content delivery networks | |
| US6990526B1 (en) | Method and apparatus for web caching | |
| US7287136B2 (en) | Cache device, and method and computer program for controlling cached data | |
| CN101741730B (en) | Method and equipment for downloading file and method and system for providing file downloading service | |
| US9906590B2 (en) | Intelligent predictive stream caching | |
| US20110055386A1 (en) | Network analytics management | |
| US20100235329A1 (en) | System and method of embedding second content in first content | |
| CN109600437B (en) | Downloading method of streaming media resource and cache server | |
| CN106664592A (en) | Efficient content delivery with guaranteed prefetch at selected times over the wireless network | |
| JP2007510224A (en) | A method for determining the segment priority of multimedia content in proxy cache | |
| WO2017025052A1 (en) | Resource caching method and device | |
| Akhtar et al. | Avic: a cache for adaptive bitrate video | |
| CN107277125A (en) | File prefetched instruction method for pushing, device and file pre-fetching system | |
| JP5192506B2 (en) | File cache management method, apparatus, and program | |
| CN114651433B (en) | Method and system for storing data in a distributed network | |
| JP2006139398A (en) | Cache server and content selection holding method | |
| JP4688312B2 (en) | Communication proxy device | |
| WO2024125208A1 (en) | File aggregation method, file aggregation apparatus, and server | |
| JP2014157405A (en) | Communication control method and system, and cache server |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| RD02 | Notification of acceptance of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: A7422 Effective date: 20140502 |
|
| RD04 | Notification of resignation of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: A7424 Effective date: 20140528 |
|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20140627 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20150423 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20150428 |
|
| A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20150622 |
|
| 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: 20150818 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20150821 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5798523 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| LAPS | Cancellation because of no payment of annual fees |