JP2010148118A - Routing method, routing apparatus, routing/caching method, routing/caching apparatus, and network - Google Patents

Abstract

<P>PROBLEM TO BE SOLVED: To provide a distribution service of digital content, such as video, music and software, after guaranteeing the quality of service at routers in a core of a distributed network. <P>SOLUTION: The routers 12 store filters corresponding to subscriptions to content. Upon receiving a packet, a router 12 inspects the payload section of the packet containing an attribute and applies the filter to the attribute for content subscription. If the attribute satisfies the filter, the packet is routed to the next link. If the attribute does not satisfy the filter, the router discards the packet. This routing decision is distributed among routers 12 in the network core 10. The router 12 locally caches the data in the network core 10. <P>COPYRIGHT: (C)2010,JPO&INPIT

Description

Translated fromJapanese

関連出願Related applications

本発明は、引用により本願に援用される、２００２年７月８日に出願された、米国仮出願番号６０／３９４，６３１号、発明の名称「サービス品質管理のためのペイロード検査によるパケットルーティング（Packet Routing Via Payload Inspection for Quality of Service Management）」に対する優先権を主張する。また、本出願は、２００２年７月１９日に出願され、引用により本願に援用される、米国特許出願番号１０／１９９，３５６号、発明の名称「ペイロード検査によるパケットルーティング（Packet Routing Via Payload Inspection）」、米国特許出願番号１０／１９９，３６８号、発明の名称「チャンネルを用いたルータにおけるコンテンツベースの経路選択及びフィルタリングの用の方法及び装置（Method And Apparatus For Content-Based Routing And Filtering At Routers Using Channels）」、米国特許出願番号１０／１９９，４３９号、発明の名称「ネットワークを介して、論理関数を送受する方法（Method for Sending And Receiving A Boolean Function Over A Network）」、米国特許出願番号１０／１９９，３６９号、発明の名称「ネットワークを介して評価、変更、再利用及び配信を可能にするのための論理関数を保存する方法（Method For Storing Boolean Functions To Enable Evaluation, Modification, Reuse, And Delivery Over A Network）」、米国特許出願番号１０／１９９，３８８号、発明の名称「接続ベースのルーティングにおける可変長フィールドを照合するワイルドカードを効率的な実行する方法（Efficient Implementation of Wildcard Matching On Variable-Sized Fields In Connect-Based Routing）」の一部継続出願である。  The present invention is a US Provisional Application No. 60 / 394,631, filed July 8, 2002, incorporated herein by reference, entitled “Packet Routing with Payload Inspection for Quality of Service Control”. Claims priority over “Packet Routing Via Payload Inspection for Quality of Service Management”. This application is also filed on Jul. 19, 2002, which is incorporated herein by reference, US patent application Ser. No. 10 / 199,356, entitled “Packet Routing Via Payload Inspection”. US patent application Ser. No. 10 / 199,368, entitled “Method and Apparatus For Content-Based Routing And Filtering At Routers”. Using Channels ”, US Patent Application No. 10 / 199,439, title of invention“ Method for Sending And Receiving A Boolean Function Over A Network ”, USPatent Application Number 10 / 199,369, title of invention “allows evaluation, modification, reuse and distribution via network (Method For Storing Boolean Functions To Enable Evaluation, Modification, Reuse, And Delivery Over A Network) ”, US Patent Application No. 10 / 199,388,“ Invention of connection-based This is a continuation-in-part application of “Efficient Implementation of Wildcard Matching On Variable-Sized Fields In Connect-Based Routing”.

また、上述した出願の一部継続出願である、２００３年３月２８日に出願された、米国特許出願番号１０／４００，６７１号、発明の名称「信頼性が低いネットワークにおける信頼性が高い発行−購読システムアーキテクチャ（Reliable Publish/Subscribe System Architecture over Unreliable Networks）」、米国特許出願番号１０／４００，４６５号、発明の名称「コンパクトフィルタストレージ及びオフラインの事前計算を用いたコンテンツベースのパケットルーティングのための方法及び装置（Method and Apparatus for Content-Based Packet Routing Using Compact Filter Storage and Off-Line Pre-computation）」、米国特許出願番号１０／４００，４５３号、発明の名称「発行−購読ネットワークにおいて、問合せ−応答インタラクションを実行する方法及び装置（Method and Apparatus for Implementing Query-Response Interactions in a Publish-Subscribe Network）」、米国特許出願番号１０／４００，４６２号、発明の名称「持続的で信頼できるメッセージ配信を実行する方法及び装置（Method and Apparatus for Implementing Persistent and Reliable Message DELIVERY）」、米国特許出願番号１０／４００，４４４号、発明の名称「発行−購読ネットワークにおいて、コンテンツベースを伝搬する方法及び装置（Method and Apparatus for Propagating Content Filters for a Publish-Subscribe Network）」も引用により本願に援用されるものとする。  In addition, US Patent Application No. 10 / 400,671, filed on March 28, 2003, which is a continuation-in-part of the above-mentioned application, is entitled “Highly reliable issuance in networks with low reliability”. -Reliable Publish / Subscribe System Architecture over Unreliable Networks ", US Patent Application No. 10 / 400,465, Title of Invention" For content-based packet routing using compact filter storage and off-line precomputation " Method and Apparatus for Content-Based Packet Routing Using Compact Filter Storage and Off-Line Pre-computation ”, US Patent Application No. 10 / 400,453, Name of Invention“ Issuance-Subscription Network, Inquiry -Method and Apparatus for Impleme nting Query-Response Interactions in a Publish-Subscribe Network), US patent application Ser. No. 10 / 400,462, title of invention “Method and Apparatus for Implementing Persistent and Reliable Message DELIVERY), US Patent Application No. 10 / 400,444, Title of Invention “Method and Apparatus for Propagating Content Filters for a Publish-Subscribe Network” Is also incorporated herein by reference.

本発明は、ネットワークコアにおいて、警告サービス（alert service）を提供するためのパケット内のペイロードの検査（inspection）に基づいて、パケットをルーティングする方法及び装置に関する。  The present invention relates to a method and apparatus for routing a packet in a network core based on inspection of a payload in the packet for providing an alert service.

ネットワークの帯域幅は、指数関数的に拡大している。しかしながら、ネットワークインフラストラクチャ（ルータ、サーバ、デーモン、プロトコル等を含む。）は、未だに比較的古い技術を用いている。この結果、インターネットアプリケーション及びネットワークルータは、帯域幅の拡大の速度に対応することができない。同時に、ネットワークに対応する機器及びアプリケーションも増加している。これらの機器及びアプリケーションによるネットワークノードへの負荷は、著しく大きくなっている。また、ネットワーク負荷及びアプリケーションの数の増加のために、ネットワークアプリケーションを実行し、保守するための複雑性がより高まっている。この結果、ネットワークの帯域幅の増加、及びネットワーク機器及びアプリケーションの偏在的な（ubiquitous）使用により、古いネットワークインフラストラクチャにおけるデータの経路選択及び伝送に、特に、コンテンツを購読者（subscriber）に発行（publishing）するときに、問題が生じている。  Network bandwidth is growing exponentially. However, the network infrastructure (including routers, servers, daemons, protocols, etc.) still uses relatively old technology. As a result, Internet applications and network routers cannot cope with the speed of bandwidth expansion. At the same time, devices and applications corresponding to the network are increasing. The load on the network node by these devices and applications is significantly increased. Also, the complexity of running and maintaining network applications has increased due to the increased network load and number of applications. This results in increased network bandwidth and the ubiquitous use of network equipment and applications for data routing and transmission in older network infrastructures, especially for publishing content to subscribers ( publishing), there is a problem.

ネットワークにおいてサーバからクライアント装置に情報をプッシュするモデルは、発行−購読型（publish-subscribe style）と呼ばれる。このモデルでは、サーバは、どのクライアントが情報に興味を持ち、又はクライアントがネットワーク内のどこに位置するかに拘わらず、その情報の単純化された発行者装置（publisher）として機能する。クライアント装置は、情報の購読者装置（subscriber）となり、潜在的には、その情報がネットワークのどこで利用可能となったかに関する詳細に拘わらず、その情報が利用可能になると、その情報が配信される。そして、ネットワークは、発行された情報を購読者装置に効率的にルーティングし、情報を能動的な購読に適合させ、これらの処理を発行者装置及び購読者装置に対して透過的な方法で実行する責務を負う。  A model for pushing information from a server to a client device in a network is called a publish-subscribe style. In this model, the server acts as a simplified publisher of that information regardless of which clients are interested in the information or where the client is located in the network. The client device becomes an information subscriber device, potentially delivering the information as it becomes available, regardless of the details of where the information was made available on the network . The network then efficiently routes the published information to the subscriber device, adapts the information to the active subscription, and performs these processes in a manner that is transparent to the publisher device and the subscriber device. To take responsibility.

発行−購読モデルにおいては、サーバの構成が著しく簡略化されるので、大型のサーバ（heavyweight server）と小型のクライアント（lightweight client）といった区別はなくなり、これらは、発行者装置、購読者装置又はその両方にもなり得るピアという呼称に統合される。様々な種類のアプリケーションは、ピア間の発行−購読型のインタラクションに近い性質を兼ね備えている。これらの多くのアプリケーションの基底に存在する課題では、発行及び購読される情報は、イベントの形式で提供される。例えば、投資家が株式を購入又は売却することにより、株価が変動する。また、高速道路上で交通事故が発生すると、交通が渋滞する。ソフトウェアシステムのセキュリティホールが発見されると、ソフトウェアのユーザのためにパッチが開発される。インターネットゲームのプレーヤが武器を使用すると、他のプレーヤのアバタが死ぬ。これらの例示的な現象は、全て、多数の購読者が潜在的に興味を有するイベントであり、このようなイベントが生じたことをこれらの購読者に通知するために、ネットワーク内で伝搬（propagate）させることができる。すなわち、イベントは、ある時刻に、ネットワーク上のある場所で発生した、潜在的に興味が持たれる何かに関する、自己充足的（self-contained）で簡潔な情報片（succinct piece of information）である。  In the publish-subscribe model, the server configuration is greatly simplified, so there is no distinction between a heavyweight server and a lightweight client, which can be an issuer device, a subscriber device or its It is integrated into the designation of a peer that can be both. Various types of applications combine properties close to publish-subscribe interactions between peers. In the issues that exist at the base of many of these applications, published and subscribed information is provided in the form of events. For example, the stock price fluctuates as an investor purchases or sells stock. In addition, when a traffic accident occurs on a highway, traffic is congested. When a security hole in the software system is discovered, a patch is developed for the software user. When an internet game player uses a weapon, the other player's avatar dies. These exemplary phenomena are all events that are potentially of interest to a large number of subscribers and are propagated within the network to inform these subscribers that such events have occurred. ). That is, an event is a self-contained and succinct piece of information about something of potential interest that occurred at some point on the network at a certain time. .

発行−購読モデルにおいて、発行されたコンテンツをどこに送信するかをネットワークに指示するための経路決定（routing decision）は、通常、サーバ又は発行者装置が行う。発行者装置は、それが発行したコンテンツに関する購読予約（subscription）を保存している。発行者装置は、新たなコンテンツを受信又は生成すると、そのコンテンツと各購読予約とを比較し、何らかの一致がないかを調べる。コンテンツ（イベント）がいずれかの購読予約を満たす場合、発行者装置は、ネットワークを介して、対応する購読者装置にコンテンツをプッシュする。この従来の発行−購読モデルでは、特に、より多くの機器がネットワークに対応し、購読予約の数が増加すると、発行者装置に大きな負担がかかる。  In the publish-subscribe model, a routing decision for instructing the network where to send the published content is usually performed by a server or issuer device. The issuer device stores a subscription for the content it issues. When the issuer device receives or generates new content, the issuer device compares the content with each subscription reservation and checks whether there is any match. If the content (event) satisfies any subscription reservation, the publisher device pushes the content to the corresponding subscriber device over the network. In this conventional publish-subscribe model, particularly when more devices are compatible with the network and the number of subscription reservations is increased, the issuer device is heavily burdened.

インターネットにおける無数のアプリケーションの集中度が高まることにより、事象通知（event notification）を利用する可能性も無限になる。ここで、これらの可能性のために、経路決定を効率的に行い、イベントがいつ購読予約を充足するかを効率的に判定して、発行者装置の負担を軽減する手法を実現することが必要である。したがって、普遍的で持続的な事象通知サービス（event notification service）を実現すれば、インターネットアプリケーション並びに他のアプリケーションに、及びそれらの実行に大きな付加価値を与えることができる。  As the myriad of applications on the Internet increase in concentration, the possibilities for using event notifications are infinite. Here, because of these possibilities, it is possible to efficiently determine the route, efficiently determine when the event satisfies the subscription, and realize a technique to reduce the burden on the issuer device is necessary. Thus, the realization of a universal and persistent event notification service can provide great added value to Internet applications and other applications and to their execution.

本発明に係るルーティング方法は、プロセッサによって実行され、ネットワークにおいて、サービス品質保証に基づいてパケットをルーティングするルーティング方法において、ヘッダ部と、ペイロード部とを有するパケットを受信する受信ステップと、ネットワークコアにおいて、パケットをルーティングする前に、パケットのペイロード部を検査する検査ステップと、パケットの確保された帯域幅に関するサービス品質保証を判定する判定ステップと、検査及びサービス品質保証に基づいて、パケットを選択的にルーティングするルーティングステップとを有する。検査ステップは、ペイロード部からデータ属性を抽出するステップと、抽出したデータ属性を２つ以上の属性フィルタと比較するステップと、２つ以上の属性フィルタのそれぞれが満たされる場合、１組の機能を実行するステップとを有する。各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述している。  A routing method according to the present invention is executed by a processor, and in a routing method for routing a packet based on service quality assurance in a network, a receiving step for receiving a packet having a header portion and a payload portion, and a network core Before routing the packet, an inspection step that inspects the payload portion of the packet, a determination step that determines a quality of service guarantee regarding the reserved bandwidth of the packet, and a packet based on the inspection and the quality of service guarantee. Routing step for routing to the network. The inspection step includes a step of extracting a data attribute from the payload portion, a step of comparing the extracted data attribute with two or more attribute filters, and a set of functions when each of the two or more attribute filters is satisfied. Performing steps. Each attribute filter describes a set of events the subscriber is interested in received from the publisher.

本発明に係るルーティング方法は、プロセッサによって実行され、ネットワークにおいて、メッセージをルーティングするルーティング方法において、ヘッダ部と、少なくとも１つの主語と、複数のデータ属性とを有するメッセージを受信する受信ステップと、メッセージから、主語及びデータ属性を読み出す主語／属性読出ステップと、主語に基づいて、複数の属性フィルタを指定する購読予約を読み出す購読予約読出ステップと、メッセージの確保された帯域幅に関するサービス品質保証を判定するステップと、メッセージをどのようにルーティングするかを決定するために、ネットワークコアにおいて、購読予約にデータ属性を適用する適用ステップと、適用及びサービス品質保証に基づいて、メッセージを選択的にルーティングするステップとを有する。適用ステップは、パケットからデータ属性を抽出するステップと、抽出したデータ属性を２つ以上の属性フィルタと比較するステップと、２つ以上の属性フィルタのそれぞれが満たされる場合、１組の機能を実行するステップとを有する。各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述している。  A routing method according to the present invention is executed by a processor, and in a routing method for routing a message in a network, a receiving step for receiving a message having a header part, at least one subject, and a plurality of data attributes; A subject / attribute read step for reading the subject and data attributes, a subscription read step for reading a subscription reservation specifying a plurality of attribute filters based on the subject, and a service quality guarantee for the reserved bandwidth of the message And, in the network core, to apply data attributes to the subscription, and to selectively route the message based on the application and quality of service guarantee to determine how to route the message. And a step. The applying step performs a set of functions if each of the step of extracting data attributes from the packet, comparing the extracted data attributes to two or more attribute filters, and two or more attribute filters are satisfied. A step of performing. Each attribute filter describes a set of events the subscriber is interested in received from the publisher.

本発明に係るルーティング装置は、プロセッサ及びメモリを有し、ネットワークにおいて、サービス品質保証に基づいてパケットをルーティングするルーティング装置において、ヘッダ部と、ペイロード部とを有するパケットを受信する受信手段と、ネットワークコアにおいて、上記パケットのペイロード部を検査する検査手段と、パケットの確保された帯域幅に関する上記サービス品質保証を判定する判定手段と、検査手段及び判定手段による判定の結果得られた検査結果及びサービス品質保証に基づいて、パケットを選択的にルーティングするルーティング手段とを備える。検査手段は、ペイロード部からデータ属性を抽出し、抽出したデータ属性を２つ以上の属性フィルタと比較し、２つ以上の属性フィルタのそれぞれが満たされる場合、パケットをどのようにルーティングするかを決定し、各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述している。  A routing device according to the present invention includes a processor and a memory, and in a routing device for routing a packet based on service quality assurance in a network, a receiving means for receiving a packet having a header portion and a payload portion, and a network In the core, an inspection means for inspecting the payload portion of the packet, a determination means for determining the service quality guarantee relating to the reserved bandwidth of the packet, and an inspection result and a service obtained as a result of the determination by the inspection means and the determination means Routing means for selectively routing packets based on quality assurance. The inspection means extracts the data attribute from the payload portion, compares the extracted data attribute with two or more attribute filters, and determines how to route the packet when each of the two or more attribute filters is satisfied. Determine, each attribute filter describes a set of events that the subscriber is interested in received from the publisher.

本発明に係るルーティング装置は、プロセッサ及びメモリを有し、ネットワークにおいて、メッセージをルーティングするルーティング装置において、ヘッダ部と、少なくとも１つの主語と、複数のデータ属性とを有するメッセージを受信する受信手段と、メッセージから、主語及びデータ属性を読み出す主語／属性読出手段と、主語に基づいて、購読予約を読み出す購読予約読出手段と、メッセージを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、購読予約を複数のフィルタに照合する照合手段と、パケットの確保された帯域幅に関するサービス品質保証を判定する判定手段とを備える。主語／属性読出手段は、購読予約に対応した複数のフィルタを読み出す手段を備え、各フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述している。  A routing device according to the present invention includes a processor and a memory, and a receiving device for receiving a message having a header part, at least one subject, and a plurality of data attributes in a routing device for routing a message in a network. In order to determine a subject / attribute reading means for reading a subject and data attributes from a message, a subscription reading means for reading a subscription reservation based on the subject, and how to route the message to a subscriber device, The network core includes a matching unit that matches a subscription reservation with a plurality of filters, and a determination unit that determines a quality of service guarantee regarding a bandwidth in which a packet is secured. The subject / attribute reading means includes means for reading a plurality of filters corresponding to the subscription reservation, and each filter describes a set of events that the subscriber has received from the publisher.

本発明に係るルーティング／キャッシング方法は、マルチキャストネットワークにおいて、データのパケットをルーティング及びキャッシングするルーティング／キャッシング方法において、ヘッダ部と、ペイロード部とを有するパケットを受信する受信ステップと、パケットを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、パケットのペイロード部を検査する検査ステップと、検査に基づいて、パケットを選択的にルーティングするルーティングステップと、パケットに対応するチャンネルを判定するステップと、チャンネルのチャンネル特性を読み出すステップと、チャンネル特性から、チャンネルが持続的なチャンネルであるか否かを判定するステップと、チャンネルが持続的なチャンネルである場合、パケットからデータを、ネットワークコアのコアルーティングノードで局所的にキャッシングするステップとを有する。コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置する。  A routing / caching method according to the present invention is a routing / caching method for routing and caching data packets in a multicast network. In the routing / caching method, a reception step of receiving a packet having a header portion and a payload portion; In the network core, an inspection step for inspecting the payload portion of the packet, a routing step for selectively routing the packet based on the inspection, and a channel corresponding to the packet are determined in the network core. Determining, reading the channel characteristics of the channel, determining whether the channel is a persistent channel from the channel characteristics, and determining whether the channel is a persistent channel. If it is, the data from the packet, and a step of locally caching core routing nodes in the network core. The core routing node is located away from the subscriber device upstream of the edge routing node.

本発明に係るネットワークは、データのパケットをルーティング及びキャッシングするネットワークにおいて、ヘッダ部と、ペイロード部とを有するパケットを受信して、ルーティングするエッジルーティングノードであって、受信したパケットをルーティングするインテリジェントルータを含むエッジルーティングノードと、ネットワークコア内に位置するコアルーティングノードと、コアルーティングノード内に位置し、インテリジェントルータに動作可能に接続されたキャッシュマネージャとを備える。インテリジェントルータは、パケットを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、パケットのペイロード部を検査する命令と、検査に基づいて、パケットを選択的にルーティングする命令とを有し、キャッシュマネージャは、パケットのそれぞれに対応するチャンネルを判定する命令と、チャンネルのチャンネル特性を読み出す命令と、チャンネル特性から、各チャンネルが持続的なチャンネルであるか否かを判定する命令と、チャンネルが持続的なチャンネルである場合、対応するパケットからデータを、コアルーティングノードのローカルキャッシュで局所的にキャッシングする命令とを有する。コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置する。  The network according to the present invention is an edge routing node that receives and routes a packet having a header portion and a payload portion in a network that routes and caches a packet of data, and is an intelligent router that routes the received packet An edge routing node, a core routing node located in the network core, and a cache manager located in the core routing node and operably connected to the intelligent router. The intelligent router has instructions for inspecting the payload portion of the packet at the network core and instructions for selectively routing the packet based on the inspection to determine how to route the packet to the subscriber device. The cache manager has an instruction to determine a channel corresponding to each of the packets, an instruction to read the channel characteristics of the channel, and an instruction to determine whether each channel is a persistent channel from the channel characteristics And, if the channel is a persistent channel, instructions for caching data from the corresponding packet locally in the local cache of the core routing node. The core routing node is located away from the subscriber device upstream of the edge routing node.

本発明に係るルーティング／キャッシング装置は、マルチキャストネットワークにおいて、データのパケットをルーティング及びキャッシングするルーティング／キャッシング装置において、複数のプロセッサと、複数のプロセッサによって実行される命令とを備える。命令は、ヘッダ部と、ペイロード部とを有するパケットを受信する命令と、パケットを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、パケットのペイロード部を検査する命令と、検査に基づいて、パケットを選択的にルーティングする命令と、パケットに対応するチャンネルを判定する命令と、チャンネルのチャンネル特性を読み出す命令と、チャンネル特性から、上記チャンネルが持続的なチャンネルであるか否かを判定する命令と、チャンネルが持続的なチャンネルである場合、パケットからデータを、ネットワークコアのコアルーティングノードで局所的にキャッシングする命令とを有する。コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置する。  The routing / caching apparatus according to the present invention includes a plurality of processors and instructions executed by the plurality of processors in the routing / caching apparatus for routing and caching data packets in a multicast network. The instructions include an instruction for receiving a packet having a header portion and a payload portion, and an instruction for examining the payload portion of the packet at the network core to determine how to route the packet to a subscriber device. Based on the inspection, whether the channel is a persistent channel, an instruction to selectively route the packet, an instruction to determine a channel corresponding to the packet, an instruction to read the channel characteristic of the channel, and the channel characteristic An instruction to determine whether or not, and if the channel is a persistent channel, an instruction to locally cache data from the packet at the core routing node of the network core. The core routing node is located away from the subscriber device upstream of the edge routing node.

ネットワークコアにおけるこのインテリジェントルーティングを概念的に示すブロック図である。It is a block diagram which shows notionally this intelligent routing in a network core.発行者装置及び購読者装置用のインテリジェントルータを示すネットワーク図である。FIG. 3 is a network diagram showing intelligent routers for issuer devices and subscriber devices.インテリジェントルータ及びバックボーンルータの例示的なネットワークインフラストラクチャの構成を示す図である。1 is a diagram illustrating an exemplary network infrastructure configuration of intelligent routers and backbone routers. FIG.インテリジェントルータのハードウェア構成を示す図である。It is a figure which shows the hardware constitutions of an intelligent router.発行者装置及び購読者装置の構成を示す図である。It is a figure which shows the structure of an issuer apparatus and a subscriber apparatus.インテリジェントルータのチャンネルマネージャの構成を示す図である。It is a figure which shows the structure of the channel manager of an intelligent router.インテリジェントルータを有するネットワークに接続するためのユーザ装置のソフトウェアコンポーネントの構成を示す図である。It is a figure which shows the structure of the software component of the user apparatus for connecting to the network which has an intelligent router.インテリジェントルータのためのソフトウェアコンポーネントの構成を示す図である。It is a figure which shows the structure of the software component for intelligent routers.メッセージのパケット構造を示す図である。It is a figure which shows the packet structure of a message.発行方法のフローチャートである。It is a flowchart of the issuing method.購読方法のフローチャートである。It is a flowchart of the subscription method.チャンネル及び購読者装置の画面を示す図である。It is a figure which shows the screen of a channel and a subscriber apparatus.コンテンツベースの経路選択方法のフローチャートである。3 is a flowchart of a content-based route selection method.キャッシング方法のフローチャートである。It is a flowchart of a caching method.キャッシュインデックスを示す図である。It is a figure which shows a cache index.送信メッセージのためのエージェント方法のフローチャートである。3 is a flowchart of an agent method for a transmission message.受信メッセージのためのエージェント方法のフローチャートである。Figure 5 is a flowchart of an agent method for received messages.メッセージの符号化の具体例を説明する図である。It is a figure explaining the specific example of encoding of a message.購読予約を保存するためのデータベース構造を示す図である。It is a figure which shows the database structure for preserve | saving a subscription reservation.ワイルドカード方法のフローチャートである。It is a flowchart of the wild card method.デジタルビデオ監視システムの構成を示す図である。It is a figure which shows the structure of a digital video surveillance system.２段階法による、デジタルビデオ監視システムのためにプロキシを示す図である。FIG. 2 shows a proxy for a digital video surveillance system according to a two-stage method.デジタルコンテンツ配信のためのアーキテクチャを示す図である。1 is a diagram illustrating an architecture for digital content distribution. FIG.デジタルコンテンツ配信のための第１の段階のアーキテクチャを示す図である。FIG. 2 illustrates a first stage architecture for digital content distribution.デジタルコンテンツ配信のための第２の段階のアーキテクチャを示す図である。FIG. 2 illustrates a second stage architecture for digital content distribution.サービス品質管理のための複数のアウトリンクを示す図である。It is a figure which shows several outlinks for service quality management.サービス品質管理のための単一のアウトリンクを示す図である。FIG. 6 illustrates a single outlink for quality of service management.ＩＳＰの外部におけるフィルタリング及びキャッシングを説明する図である。It is a figure explaining the filtering and caching outside ISP.ネットワーク内のキャッシュを示す図である。It is a figure which shows the cache in a network.上流ルータにおけるバックアップキャッシングを説明する図である。It is a figure explaining backup caching in an upstream router.プロキシを有するキャッシュとルータのとの間のインタラクションを示す図である。FIG. 3 illustrates an interaction between a cache having a proxy and a router.購読予約に対するキャッシュの作成を説明する図である。It is a figure explaining creation of the cache to a subscription reservation.インデックスツリーを示す図である。It is a figure which shows an index tree.複数のキャッシュからの検索を示す図である。It is a figure which shows the search from several caches.キャッシュマネージャと、システム内の他のモジュールとのインタラクションを示す図である。It is a figure which shows interaction with a cache manager and the other module in a system.キャッシュのためのファイルディレクトリ構造を示す図である。It is a figure which shows the file directory structure for a cache.

概観
インターネット規模又は他の分散ネットワーク規模においては、事象通知システム（event notification system）により、アプリケーションにおいて、強力で柔軟な発行−購読ネットワーク（publish-subscribe networking）が実現される。この事象通知システムでは、アプリケーションプログラムは、通知アプリケーションプログラムインタフェース（application program interface：以下、ＡＰＩという。）を用いて、ネットワーク内で発生するイベントに関する通知を発行し及び／又は通知を購読又は受信する。Overview At the Internet scale or other distributed network scale, the event notification system provides a powerful and flexible publish-subscribe networking for applications. In this event notification system, an application program uses a notification application program interface (hereinafter referred to as API) to issue a notification regarding an event that occurs in the network and / or subscribe to or receive the notification.

この事象通知システムにおける通知には、主語（subject）が与えられており、主語は、文字列（string）、又は通知がカプセル化している情報の種類を分類する（classify）他のデータ構造として示される。また、通知には、その通知に特有の情報を含む１組の属性によって完結されている。例えば、アプリケーションは、subject quotes.nyse（ニューヨーク証券取引所における主語の株価）と、属性シンボル及び価格とを用いて、ニューヨーク証券取引所における取引に関する通知を発行してもよい。例えば、アプリケーションは、ＳＮＥ（ソニー株式会社（商標）の株価表示板のシンボル）に等しいシンボルと、８５．２５ドルの株価とを含む特定の属性値を有する個々の通知を発行する。通知の全ての属性ではなく、殆どの属性は、主語が同じファミリに関する全ての通知において見出されるという意味で、予め定義されている。なお、発行者は、イベント固有の情報を追加するために、通知毎に又は他の単位で、通知に任意の属性を加えることができる。したがって、一部又は全ての属性は、予め定義されている必要はない。  Notifications in this event notification system are given a subject, which is shown as a string or other data structure that classifies the type of information that the notification encapsulates (classify). It is. Further, the notification is completed by a set of attributes including information specific to the notification. For example, an application may issue a notification regarding a transaction on the New York Stock Exchange using subject quotes.nyse (the subject stock price on the New York Stock Exchange), attribute symbols and prices. For example, the application issues individual notifications with specific attribute values that include a symbol equal to SNE (a symbol of a stock price display board of Sony Corporation (trademark)) and a stock price of $ 85.25. Most but not all attributes of notifications are predefined in the sense that the subject is found in all notifications for the same family. Note that the issuer can add any attribute to the notification for each notification or in other units to add event specific information. Thus, some or all of the attributes need not be predefined.

この事象通知システムでは、購読者は、主語又は全チャンネルの購読のみに制限されるわけではない。チャンネルについては、後に説明し、定義する。チャンネルは、例えば主語フィールド及び関連したサブフィールド（サブ主語）の１つ以上のレベルを指定する階層構造を含むことができる。したがって、購読者は、通知の属性に対して、コンテンツベースのフィルタを指定することによって、興味に応じてより精密に調整された表現を指定することができる。例えば、購読者は、ＳＮＥに等しいシンボルと、９０．００ドルより高い価格（例えば、購読者が所有している株式の売りの指値）とを有するsubject quotes.nyseに対する全ての通知を購読予約してもよい。購読予約に一致する全ての通知は、コールバック、あるいは購読者が購読予約を登録したときの又は他の時点における他の種類の機能によって、購読者に配信される。１つの購読予約は、複数のフィルタに分割することができる。  In this event notification system, subscribers are not limited to subject or all channel subscriptions. Channels will be described and defined later. A channel can include, for example, a hierarchical structure that specifies one or more levels of subject fields and associated sub-fields (sub-subjects). Thus, the subscriber can specify a more precisely tailored expression according to interest by specifying a content-based filter for the notification attribute. For example, a subscriber subscribes to all notifications for subject quotes.nyse with a symbol equal to SNE and a price higher than $ 90.00 (eg, the limit of selling shares held by the subscriber). May be. All notifications matching a subscription are delivered to the subscriber by a callback or other type of function when the subscriber registers a subscription or at some other time. One subscription can be divided into multiple filters.

コールバックは、多くの計算（computation）を実行することができ、これらには、例えば端末機器にメッセージを書き込む又は電子メールを送信する等の単純な処理から、例えば株式の売却を開始する等のより複雑な処理、新たな発行−購読活動を開始する（例えば、既存の購読予約を７５．００ドルの買いの指値とする新たな購読予約に置き換え、又は購読者のポートフォリオが手直しされた新たな通知を発行する）等の更に複雑な処理までの処理が含まれる。  Callbacks can perform many computations, such as starting a sale of stock from a simple process, such as writing a message to a terminal or sending an email. Initiate more complex processing, new publish-subscribe activities (e.g., replace existing subscriptions with new subscriptions with a bid limit of $ 75.00, or new subscriber portfolios reworked) Processing up to more complicated processing such as issuing a notification).

アプリケーションにおける発行及び購読活動は、例えば、エージェントによって支援してもよい。エージェントは、プロキシを使用することができ、又はプロキシによって実現することができる。エージェントは、それが用いられるときには、通知及び購読予約を出力するネットワーク接続性と、照合通知（matching notification）を購読者装置に入力する配信とを提供する。通知がネットワークに出されると、この事象通知システムのルータのネットワークは、その通知に購読予約が一致する全ての購読者装置に通知を伝搬（propagate）する。この処理を実現する一手法は、ネットワーク内の全ての点に通知を同報通信し、アプリケーションエージェントに、対応する購読者装置にその通知が関連するか否かを判定させる手法がある。しかしながら、これは必ずしも拡張性がある手法であるというわけではなく、通常、ネットワークは、特に多数の活発で冗長な購読者装置がある場合、メッセージトラヒックの負荷によって、急速に機能しなくなる（overwhelmed）。更に、帯域幅が十分な場合でさえも、購読者装置は、大量の通知を処理しきれなくなると考えられる。  Publishing and subscription activities in the application may be supported by an agent, for example. The agent can use a proxy or can be realized by a proxy. The agent, when it is used, provides network connectivity to output notifications and subscriptions, and delivery to input matching notifications to subscriber devices. When a notification is sent to the network, the network of routers in this event notification system propagates the notification to all subscriber devices whose subscription reservation matches the notification. One technique for implementing this process is to broadcast notifications to all points in the network and have the application agent determine whether the notification is relevant to the corresponding subscriber device. However, this is not necessarily a scalable approach, and the network usually overwhelmed rapidly due to message traffic load, especially if there are a large number of active and redundant subscriber devices. . Furthermore, even if the bandwidth is sufficient, the subscriber device will not be able to handle a large amount of notifications.

本発明に基づくシステムの一例として示すネットワークは、非常に効率的に通知をルーティングする。まず、このネットワークは、マルチキャストルーティングを用いて、例えば、ネットワーク内の全てのリンクにおいて最大で１回、通知を伝搬させることができる。次に、このネットワークは、フィルタに対して多数の高度な最適化処理を採用して、通知の伝搬の回数を可能な限り削減することができる。  The network shown as an example of a system according to the present invention routes notifications very efficiently. First, the network can propagate notifications using multicast routing, for example, at most once on all links in the network. The network can then employ a number of advanced optimization processes for the filter to reduce the number of notification propagations as much as possible.

図１は、ネットワークコア１０におけるこのインテリジェントルーティングを概念的に示す図である。発行者装置１４は、エッジルータ（edge router）１６を介して、発行−購読ネットワークにおいて用いられているネットワークコア１０にメッセージのコンテンツを送信する。発行−購読ネットワークは、発行者装置１４から購読者装置２４にデータ又はコンテンツをルーティングするためのあらゆる種類のネットワークであってもよい。コンテンツは、ルータ間又は他の機器間の論理的接続を表す１つ以上のチャンネル１８を介して伝送される。ネットワークコア１０におけるインテリジェントルータ１２は、メッセージをルーティング又は転送するか否かを判定する。特に、インテリジェントルータ１２は、メッセージが購読者装置２４によって購読予約されているコンテンツを含んでいるか否かを判定することができる。  FIG. 1 is a diagram conceptually showing this intelligent routing in thenetwork core 10. Theissuer device 14 transmits the content of the message via theedge router 16 to thenetwork core 10 used in the issue-subscription network. The publish-subscribe network may be any type of network for routing data or content from thepublisher device 14 to thesubscriber device 24. Content is transmitted over one ormore channels 18 that represent logical connections between routers or other devices. Theintelligent router 12 in thenetwork core 10 determines whether to route or forward the message. In particular, theintelligent router 12 can determine whether the message includes content that is subscribed to by thesubscriber device 24.

各購読予約は、主語フィルタ（subject filter）と属性フィルタ（attribute filter）とをカプセル化している。ルータは、主語フィルタを一致する主語の集合に拡張し、又は主語毎に属性フィルタを併合することができる。インテリジェントルータは、通知の主語に対して主語フィルタを評価し、通知における属性値に対して属性フィルタを評価する。主語フィルタの構文では、ワイルドカードを用いることができ、属性フィルタの構文では、論理式（Boolean expression）を用いることができ、これらについては、後に更に詳細に説明する。「フィルタ」という用語は、購読者装置が発行者装置から受信を望んでいる１組のイベントを意味する。経路選択規則（routing rule）は、フィルタから生成され、インテリジェントルータは、この規則を用いて経路決定を行う。  Each subscription reservation encapsulates a subject filter and an attribute filter. The router can extend the subject filter to a set of matching subjects or merge attribute filters for each subject. The intelligent router evaluates the subject filter for the subject of the notification and evaluates the attribute filter for the attribute value in the notification. Wildcards can be used in the subject filter syntax, and Boolean expressions can be used in the attribute filter syntax, which will be described in more detail later. The term “filter” refers to a set of events that a subscriber device wants to receive from an issuer device. A routing rule is generated from the filter, and the intelligent router performs route determination using this rule.

したがって、メッセージ２６がフィルタ集合の全部を充足していない場合、例えば、インテリジェントルータ１２は、メッセージ２６をドロップ（破棄）し、これは、メッセージ２６が転送されないことを意味する。主語フィルタ及び属性フィルタの評価に基づき、メッセージ２０がフィルタの集合の一部又は全部を充足していると判定された場合、例えば、インテリジェントルータ１２は、エッジルータ２２及び他の機器を介して、購読者装置にメッセージ２０をルーティング（転送）し、又は、一致したフィルタについて規定されている全ての経路選択及び／又は動作規則（action rule）に基づいて、インテリジェントルータ１２内でメッセージ２０に対する他の機能を実行する。検索は、フィルタの集合全体に対する処理が完了するまで、又は全ての規則に関する判定が得られるまで続けられ、どちらが最初であってもよい。この２つの条件のいずれか１つが満たされると終了する。  Thus, if the message 26 does not satisfy the entire filter set, for example, theintelligent router 12 drops (discards) the message 26, which means that the message 26 is not forwarded. If it is determined that themessage 20 satisfies part or all of the set of filters based on the evaluation of the subject filter and the attribute filter, for example, theintelligent router 12 passes through theedge router 22 and other devices. Route (forward)message 20 to the subscriber device, or other message formessage 20 withinintelligent router 12 based on all routing and / or action rules defined for matched filters. Perform the function. The search continues until processing on the entire set of filters is complete, or until all rules have been determined, whichever may be the first. The process ends when one of these two conditions is satisfied.

ネットワークコア内のこの種類のインテリジェントなコンテンツベースの経路選択は、例えば警告及び更新のためのリアルタイムデータ配信を実現する。警告のためのリアルタイムデータ配信の具体例としては、以下に限定されるものではないが、例えば、株価速報（stock quot）、交通情報、ニュース、旅行、天気、不正検出（fraud detection）、セキュリティ、テレマティックス、ファクトリオートメーション、サプライチェーン管理（supply chain management）及びネットワーク管理等がある。更新のためのリアルタイムデータ配信の具体例としては、以下に限定されるものではないが、例えば、ソフトウェアの更新、アンチウイルスの更新、映画及び音楽配信、ワークフロー、保管管理（storage management）及びキャッシュコンシステンシ（cache consistency）等がある。購読予約された情報を配信するシステムは、他の様々な分野に応用することができる。  This type of intelligent content-based routing within the network core provides real-time data delivery for alerts and updates, for example. Specific examples of real-time data delivery for warnings include, but are not limited to, stock quotes, traffic information, news, travel, weather, fraud detection, security, Telematics, factory automation, supply chain management and network management. Specific examples of real-time data delivery for updates are not limited to the following, but include, for example, software updates, antivirus updates, movie and music delivery, workflow, storage management and cache consistency. There are tensi (cache consistency). The system for distributing subscribed information can be applied to various other fields.

表１は、フィルタ用の主語（subject）及び述語（predicate）によって保存される購読予約を示している。購読予約は、希望されれば、又は必要に応じて、ネットワークの如何なる場所に、あらゆる種類のデータ構造を用いて保存してもよい。後述するように、述語は、購読予約の構成要素である。購読予約は、如何なる形式で表現してもよく、その具体例を以下に示す。  Table 1 shows the subscriptions stored by the filter subject and predicate. Subscription subscriptions may be stored using any kind of data structure anywhere on the network, if desired or necessary. As will be described later, the predicate is a component of a subscription reservation. The subscription reservation may be expressed in any format, and a specific example is shown below.

表２は、株価速報サーバ（quote server）用の発行及び購読予約の具体例を示している。この具体例は、説明を目的とする例示的な具体例に過ぎず、購読予約は、あらゆる種類のデータ又はコンテンツに対するあらゆる数の及び種類のパラメータを含むことができる。  Table 2 shows specific examples of issuance and subscription reservations for a quote server. This example is merely an illustrative example for purposes of illustration, and subscriptions can include any number and type of parameters for any type of data or content.

述語は、購読予約用の論理式を提供し、主語は、購読予約用のチャンネルの指標（indication）を提供する。購読予約は、他の様々な手法で表現することができる。論理式は、このような手法の一例であり、論理式を用いることにより、購読予約を主語フィルタと属性フィルタに容易に変換する機能を、コンテンツベースの経路選択に提供する。これに代えて、主語を参照することなく、購読予約を表現することもできるが、主語又はチャンネル（後に詳細に説明する。）を用いることにより、フィルタを解釈して、属性に適用するコンテキスト（context）を提供する。  The predicate provides a logical expression for subscription reservation, and the subject provides an indication of the channel for subscription reservation. Subscription reservations can be expressed in various other ways. A logical expression is an example of such a technique, and by using the logical expression, a function for easily converting a subscription reservation into a subject filter and an attribute filter is provided for content-based route selection. Alternatively, a subscription can be expressed without referring to the subject, but by using the subject or channel (discussed in detail later), the context to interpret the filter and apply to the attribute ( context).

経路決定は、ネットワークコアで行って、ネットワークを介して配信することができるので、発行者装置及び購読者装置の機器の負担を軽減し、ネットワーク効率を大幅に高めることができる。図１では、説明を目的として、単一の発行者装置１４、単一の購読者装置２４及び単一のインテリジェントルータ１２のみを示しているが、実際には、発行者装置、購読者装置及びインテリジェントルータは、それぞれ複数設けることができる。インテリジェントルータという用語は、ネットワークコア又は他の位置において、パケット又はメッセージのペイロードを検査することによって経路を決定する能力を有するルータ又は他のエンティティ（entity）を意味する。  Since the route determination can be performed at the network core and distributed via the network, the burden on the issuer device and the subscriber device can be reduced, and the network efficiency can be greatly increased. Although only asingle issuer device 14, asingle subscriber device 24, and a singleintelligent router 12 are shown in FIG. 1 for illustrative purposes, in practice, the issuer device, subscriber device and A plurality of intelligent routers can be provided. The term intelligent router means a router or other entity that has the ability to determine a route by examining the payload of a packet or message at the network core or other location.

ネットワークインフラストラクチャ
図２は、発行者装置及び購読者装置用のインテリジェントルータを示すネットワーク図である。例えば、チャンネルサービスを提供する経路選択エンティティ（以下、チャンネルサービスともいう。）３０は、後述するように、インテリジェントルータ３８、４０、４２、４４、４６、４８間でメッセージをルーティングするために、ネットワークインフラストラクチャ上に効果的に階層化されている。例えば、発行者装置３２は、概念的に、発行されたコンテンツの指標、例えばコンテンツを検索するためのポインタを受信するアプリケーション３４と、チャンネルサービス３０を介したネットワーク伝送のためにコンテンツを符号化するエージェント３６とを含む。論理的に互いに接続されたインテリジェントルータ３８、４０、４２、４４、４６、４８の集合は、購読予約の主語フィルタ及び属性フィルタから生成された経路選択規則を用いて、発行者装置３２からのコンテンツをルーティングする。複数のリンク３９、４１、４３、４５は、インテリジェントルータ３８、４０、４２、４４、４６、４８間を論理的に接続する。他のリンク３７、４７は、それぞれ、発行者装置３２とインテリジェントルータ３８間及び購読者装置５４とインテリジェントルータ４６間を論理的に接続する。購読者装置５４は、購読するコンテンツを検出して、受信するエージェント５０と、コンテンツを表示するアプリケーション５２とを備えている。Network Infrastructure FIG. 2 is a network diagram showing intelligent routers for issuer and subscriber devices. For example, a routing entity (hereinafter also referred to as a channel service) 30 that provides a channel service may be used to route messages betweenintelligent routers 38, 40, 42, 44, 46, 48 as described below. It is effectively layered on the infrastructure. For example,issuer device 32 conceptually encodes content for network transmission viaapplication 34 that receives an indicator of published content, eg, a pointer to search for content, andchannel service 30.Agent 36. A set ofintelligent routers 38, 40, 42, 44, 46, 48 that are logically connected to each other uses content selected from thepublisher device 32 using routing rules generated from the subject filter and attribute filter of the subscription. To route. The plurality oflinks 39, 41, 43, 45 logically connect theintelligent routers 38, 40, 42, 44, 46, 48. The other links 37 and 47 logically connect between theissuer device 32 and the intelligent router 38 and between thesubscriber device 54 and theintelligent router 46, respectively. Thesubscriber device 54 includes anagent 50 that detects and receives content to be subscribed to, and anapplication 52 that displays the content.

チャンネルは、例えば、分散方式によって実行される論理的なマルチキャスト接続の関連した集合を含むことができる。この例示的な実施例におけるチャンネルは、コンテンツを交換する発行者装置と購読者装置のコミュニティとして機能する論理的に関連したネットワークリソースの集合である。コンテンツは、チャンネル主語名前空間（channel subject namespace）に従って分類され、ネットワークリソースは、チャンネルマネージャ（channel manager）によって提供されるチャンネルサービス３０を介して、管理され、制御され、供給される。複数のチャンネルが同じネットワークリソースを共有してもよい。チャンネルは、非常に拡張性があるディレクトリサービス、例えば、以下に限定されるものではないが、発行者及び購読者の情報、認証（authentication）及び許可（authorization）情報、メッセージの種類、管理情報、会計及び課金情報（accounting and billing information）が含まれる。また、チャンネルは、例えば、キャッシングによる持続性（persistence through caching）、高速データ配信機構、セキュリティ、ユーザ及びネットワーク管理等を提供することができる。また、チャンネルは、他の如何なる目的にも利用することができる。  A channel can include, for example, an associated set of logical multicast connections performed by a distributed scheme. A channel in this exemplary embodiment is a collection of logically related network resources that function as a community of publisher and subscriber devices that exchange content. Content is classified according to a channel subject namespace, and network resources are managed, controlled, and supplied via achannel service 30 provided by a channel manager. Multiple channels may share the same network resource. Channels are highly extensible directory services such as, but not limited to, issuer and subscriber information, authentication and authorization information, message types, management information, Includes accounting and billing information. Channels can also provide, for example, persistence through caching, high-speed data delivery mechanisms, security, user and network management, and the like. The channel can also be used for any other purpose.

インテリジェントルータによるフィルタリングをネットワークコアで行って、経路決定をネットワーク内に配信することができる。更に、インテリジェントルータは、発行者装置又は購読者装置等のユーザ機器をネットワークコアに接続するエッジルータとして機能することができる。また、ネットワークに接続された同じ機器が、ネットワークにおける経路決定に基づいて、購読者装置にコンテンツをプッシュする発行者装置と、プッシュされたコンテンツを受信する購読者装置との両方として機能することができる。インテリジェントルータ及びチャンネルは、特定の実施例における必要又は要望に応じて、如何なる構成で接続してもよく、図２の構成は例示的に示しているに過ぎない。  Filtering by intelligent routers can be performed at the network core and routing can be distributed within the network. Furthermore, the intelligent router can function as an edge router that connects a user device such as an issuer device or a subscriber device to the network core. Also, the same device connected to the network can function as both an issuer device that pushes content to the subscriber device and a subscriber device that receives the pushed content based on routing in the network. it can. The intelligent routers and channels may be connected in any configuration as needed or desired in a particular embodiment, and the configuration of FIG. 2 is only shown by way of example.

図３は、インテリジェントルータ及び従来のバックボーンルータの例示的なネットワークインフラストラクチャの構成を示しており、チャンネルの論理的接続も示している。この実施例におけるインテリジェントルータ６１〜７０は、インターネット又は他の分散ネットワーク等のネットワークの既存のバックボーンルータを用いており、したがって、インテリジェントルータ６１〜７０は、バックボーンルータ上に効果的に階層化されている。この実施例では、インターネットサービスプロバイダ（Internet Service Provider：以下、ＩＳＰという。）ネットワーク５８、５９、６０は、メッセージ又はパケットの従来の経路選択を行う幾つかのバックボーンルータをそれぞれ備えている。複数のインテリジェントルータ６１〜７０は、ＩＳＰネットワーク５８、５９、６０内の１つ以上のバックボーンルータによって接続されている。また、インテリジェントルータ６１〜７０は、実際のリンクを例示的に示す複数のリンク７３〜８５によって、互いに接続されており、また、これらのリンク７３〜８５を介して、エンドユーザ機器にも接続することができる。インテリジェントルータ６１〜７０は、例えばエンティティ７１等の１つ以上の管理装置（administrator machine）及び例えばエンティティ７２等の１つ以上の仮想私設ネットワーク（virtual private network：以下、ＶＰＮという。）コントローラによって制御される。ＩＳＰネットワーク５８、５９、６０は、発行者装置及び購読者装置（図３には示していない。）に接続してもよい。ＩＳＰネットワーク５８、５９、６０内及び間のバックボーンルータは、既存のネットワークインフラストラクチャにおいて、従来の如何なる手法で互いに接続してもよい。  FIG. 3 shows an exemplary network infrastructure configuration of intelligent routers and conventional backbone routers, and also shows the logical connection of channels. The intelligent routers 61-70 in this embodiment use existing backbone routers in networks such as the Internet or other distributed networks, and therefore the intelligent routers 61-70 are effectively layered on the backbone routers. Yes. In this embodiment, Internet Service Provider (ISP)networks 58, 59, 60 each include several backbone routers that perform conventional routing of messages or packets. The plurality ofintelligent routers 61 to 70 are connected by one or more backbone routers in the ISP networks 58, 59, 60. In addition, theintelligent routers 61 to 70 are connected to each other by a plurality oflinks 73 to 85 exemplarily showing actual links, and are also connected to end user devices via thelinks 73 to 85. be able to. Theintelligent routers 61 to 70 are controlled by one or more administrator machines such as theentity 71 and one or more virtual private network (hereinafter referred to as VPN) controllers such as theentity 72. The The ISP networks 58, 59, 60 may be connected to issuer devices and subscriber devices (not shown in FIG. 3). The backbone routers within and between the ISP networks 58, 59, 60 may be connected to each other in any conventional manner in the existing network infrastructure.

図３に示すように、既存のネットワークインフラストラクチャを用いて、インテリジェントルータ６１〜７０及びリンク７３〜８５を実現することができ、これらは、ネットワークコアにおけるコンテンツベースの経路選択を提供する。リンク７３〜８５は、インテリジェントルータ６１〜７０間の論理的接続を表し、例えば、既存のネットワークインフラストラクチャ又は他の機器を用いて実現することができる。リンクは、例えば、トンネル（tunnel）と呼ばれる論理的接続を用いて実現することができる。トンネルは、ハードウェアと、ソフトウェアと、リンクを実現するためのネットワークインフラストラクチャとを含み、１つのトンネルは、複数のチャンネルの一要素であってもよい。チャンネルは、特定の種類のコンテンツのための論理的な構成を提供することによって、インテリジェントルータにおけるコンテンツベースの経路選択を容易にし、したがって、チャンネルを介して伝送される属性にコンテキストを提供する。インテリジェントルータは、チャンネルを用いることなく、経路決定を行うこともできるが、チャンネルは、ネットワークコアにおけるインテリジェントルータによるコンテンツベースの経路選択の効率を高める。  As shown in FIG. 3, the existing network infrastructure can be used to implement intelligent routers 61-70 and links 73-85, which provide content-based routing at the network core. Links 73-85 represent logical connections between intelligent routers 61-70 and may be implemented using, for example, existing network infrastructure or other equipment. The link can be realized by using a logical connection called a tunnel, for example. The tunnel includes hardware, software, and network infrastructure for realizing the link, and one tunnel may be an element of a plurality of channels. A channel facilitates content-based routing in an intelligent router by providing a logical configuration for a particular type of content and thus provides context for attributes transmitted over the channel. Although intelligent routers can also make routing without using channels, channels increase the efficiency of content-based routing by intelligent routers in the network core.

この例示的な実施例は、チャンネルとリンクの使用を含んでいる。リンクは、例えばインテリジェントルータである２つのルータ間の接続を表す。チャンネルは、ルータの（通常は大きな）集合を含むネットワークエンティティであり、相互接続リンク（interconnecting link）によって静的又は動的に構成されており、１対多又は多対多の論理的接続を実現する。特に、チャンネルは、チャンネルの本質的特徴を記述する最上位レベルの論理的エンティティである。１つのチャンネルには、多くの主語が存在することができる。各主語は、互いに接続されたルータの集合を含むサブネットワーク（例えばマルチキャストツリー）を形成する。これらの主語ベースのサブネットワークは、様々な手法で、割当、適応化及び構成を行うことができる。全てのサブネットワークの集合であり、その下に主語を形成するチャンネルは、例えばネットワークのメッシュ（mesh of networks）に似ている。  This exemplary embodiment includes the use of channels and links. A link represents a connection between two routers, for example intelligent routers. A channel is a network entity that contains a (usually large) collection of routers, configured statically or dynamically by interconnecting links, to provide one-to-many or many-to-many logical connections To do. In particular, a channel is the highest level logical entity that describes the essential characteristics of a channel. There can be many subjects in one channel. Each subject forms a subnetwork (eg, a multicast tree) that includes a collection of routers connected to each other. These subject-based sub-networks can be allocated, adapted and configured in various ways. The set of all sub-networks, under which the subject is formed, resembles, for example, a mesh of networks.

図４は、インテリジェントルータ９２のハードウェア構成要素を示しており、インテリジェントルータ９２は、符号が付された他の如何なるインテリジェントルータに対応させることができる。ネットワークノード９０は、従来のバックボーンルータ９５に接続されたインテリジェントルータ９２を備えている。インテリジェントルータ９２は、メモリ９４及び補助記憶装置９７（例えば、独立した装置として実現してもよい。）に接続されたプロセッサ９３を備え、メモリ９４及び補助記憶装置９７は、いずれも、キャッシュデータを含むデータを保存し、及びプロセッサ９３によって実行されるアプリケーションプログラムを保存する。補助記憶装置９７は、データの不揮発性記憶装置である。後述するように、プロセッサ９３は、ソフトウェアによって制御され、バックボーンルータ９５にインストラクション（instruction）を発行し、このインストラクションに応じて、バックボーンルータ９５は、購読予約の主語フィルタ及び属性フィルタから生成された経路選択規則に基づいて、メッセージ又はパケットをルーティング（転送）し又はルーティングしない（破棄する）。ここでは、インテリジェントルータ９２をプロセッサによって制御される独立した装置として示しているが、インテリジェントルータ９２は、ソフトウェアを組み込むことによって、ハードウェアにインテリジェント経路選択機能を提供する特定用途向け集積回路（application specific integrated circuit：ＡＳＩＣ）９１によって実現することができる。また、これに代えて、インテリジェント経路選択機能は、１つ又は複数の経路選択機器において、ソフトウェアとハードウェアの組合せとして実現することができる。  FIG. 4 shows the hardware components of theintelligent router 92, which can be associated with any other intelligent router that is labeled. The network node 90 includes anintelligent router 92 connected to aconventional backbone router 95. Theintelligent router 92 includes aprocessor 93 connected to a memory 94 and an auxiliary storage device 97 (for example, may be realized as an independent device). Both the memory 94 and the auxiliary storage device 97 store cache data. The data to be stored is saved, and the application program executed by theprocessor 93 is saved. The auxiliary storage device 97 is a non-volatile storage device for data. As will be described later, theprocessor 93 is controlled by software and issues an instruction to thebackbone router 95. In response to this instruction, thebackbone router 95 generates a route generated from the subject filter and the attribute filter of the subscription reservation. The message or packet is routed (forwarded) or not routed (discarded) based on the selection rules. Although theintelligent router 92 is shown here as an independent device controlled by a processor, theintelligent router 92 incorporates software to provide an application specific integrated circuit that provides intelligent routing functions to the hardware. integrated circuit (ASIC) 91 can be realized. Alternatively, the intelligent route selection function can be realized as a combination of software and hardware in one or a plurality of route selection devices.

図５は、発行者装置及び購読者装置の具体的な構成を示している。発行者装置１００、１１８は、例えば、１つ以上の発行者アプリケーション１０４及びエージェントアプリケーション１０６を記憶するメモリ１０２と、データの不揮発性記憶装置である補助記憶装置１１２と、情報又はコマンドを入力する入力装置１０８と、メモリ１０２に記憶されている又は他の記憶装置から受け取ったアプリケーションを実行するプロセッサ１１４と、情報を出力する出力装置１１０と、情報を視覚的に表示する表示装置１１６とを備えている。  FIG. 5 shows a specific configuration of the issuer device and the subscriber device. Theissuer devices 100 and 118, for example, amemory 102 that stores one or more issuer applications 104 and an agent application 106, an auxiliary storage device 112 that is a nonvolatile storage device of data, and an input for inputting information or commands.Device 108;processor 114 for executing an application stored inmemory 102 or received from another storage device;output device 110 for outputting information; and display device 116 for visually displaying information. Yes.

購読者装置１２２、１４０は、例えば、１つ以上のアプリケーション１２６及びエージェントアプリケーション１２８を記憶するメモリ１２４と、データの不揮発性記憶装置である補助記憶装置１３０と、情報又はコマンドを入力する入力装置１３２と、メモリ１２４に記憶されている又は他の記憶装置から受け取ったアプリケーションを実行するプロセッサ１３４と、情報を出力する出力装置１３６と、情報を視覚的に表示する表示装置１３８とを備えている。発行者装置１００、１１８及び購読者装置１２２、１４０は、如何なる構成であってもよく、上述したものとは異なる構成要素を備えていてもよく、構成要素は、上述したものより多くても少なくてもよい。  Thesubscriber devices 122 and 140 include, for example, amemory 124 that stores one ormore applications 126 and anagent application 128, anauxiliary storage device 130 that is a nonvolatile storage device for data, and an input device 132 that inputs information or commands. And aprocessor 134 for executing an application stored in thememory 124 or received from another storage device, an output device 136 for outputting information, and adisplay device 138 for visually displaying information.Issuer devices 100, 118 andsubscriber devices 122, 140 may have any configuration, may include different components than those described above, and may include more or fewer components than those described above. May be.

発行者装置１００、１１８は、上述したネットワーク等のネットワーク１２０を介して購読者装置１２２、１４０に接続されている。ネットワーク１２０は、ネットワークコアにおいて、パケット又はメッセージを介して、データ又はコンテンツの分散経路選択（distributed routing）を行うインテリジェントルータを含んでいる。ここでは、それぞれ２つの発行者装置１００、１１８及び購読者装置１２２、１４０のみを示しているが、より多くの発行者装置及び購読者装置を含むようにネットワーク１２０を拡張することができる。発行者装置１００、１１８及び購読者装置１２２、１４０は、プロセッサによって制御される如何なる装置、例えば、以下に限定されるものではないが、サーバ、パーソナルコンピュータ、ノートブックコンピュータ、携帯情報端末、電話機、携帯電話機、ページャ又は他の機器によって実現することができる。また、インテリジェントルータを有するネットワーク１２０は、有線機器、無線機器又はその両方を接続する如何なる有線又は無線分散ネットワークを含むことができる。また、ネットワーク１２０は、潜在的には、既存の又は従来のネットワークインフラストラクチャを用いることができる。  The issuer apparatuses 100 and 118 are connected to thesubscriber apparatuses 122 and 140 via thenetwork 120 such as the network described above. Thenetwork 120 includes intelligent routers that perform distributed routing of data or content via packets or messages at the network core. Here, only twoissuer devices 100, 118 andsubscriber devices 122, 140 are shown, respectively, but thenetwork 120 can be expanded to include more issuer devices and subscriber devices.Issuer devices 100, 118 andsubscriber devices 122, 140 are any devices controlled by a processor, such as, but not limited to, servers, personal computers, notebook computers, personal digital assistants, telephones, It can be realized by a mobile phone, pager or other device. Thenetwork 120 with intelligent routers can also include any wired or wireless distributed network that connects wired devices, wireless devices, or both. Also, thenetwork 120 can potentially use existing or conventional network infrastructure.

図６は、インテリジェントルータのためのチャンネルマネージャ（channel manager）１５０の構成を示している。この実施例では、チャンネルマネージャ１５０は、複数のサーバ１５２、１５４、１５６によって実現されている。各サーバ１５２、１５４、１５６は、それ自体の局部記憶装置（local storage）１５８、１６０、１６２を備えている。インテリジェントルータ１６４、１６６、１６８は、特定のチャンネルに関する情報を得るために、チャンネルマネージャ１５０に接触する。また、チャンネルマネージャ１５０は、データ持続性（data persistence）、フェイルオーバ機能（fail over function）及び他の機能を提供することができる。したがって、チャンネルマネージャ１５０は、ネットワークの任意の場所において、例えばチャンネル関連情報、データ持続性の属性、発行者及び購読者のユーザ情報、及びインフラストラクチャ情報を指定するデータベース又はデータベースの集合を含むチャンネルサービスを提供する。インフラストラクチャ情報は、例えば、インテリジェントルータ１６４、１６６、１６８及びこれらを接続するトンネルの識別情報、チャンネルの主語、及びチャンネルの属性（各属性の名称と種類）を含むことができる。また、パケット又はメッセージは、固定の属性及び可変の属性の識別情報を含むチャンネル関連情報を搬送することができる。  FIG. 6 shows the configuration of achannel manager 150 for the intelligent router. In this embodiment, thechannel manager 150 is realized by a plurality ofservers 152, 154 and 156. Eachserver 152, 154, 156 has its ownlocal storage 158, 160, 162. Theintelligent routers 164, 166, 168 contact thechannel manager 150 to obtain information about a particular channel. Thechannel manager 150 may also provide data persistence, fail over function, and other functions. Accordingly, thechannel manager 150 includes a database or collection of databases that specify, for example, channel related information, data persistence attributes, publisher and subscriber user information, and infrastructure information anywhere in the network. I will provide a. The infrastructure information can include, for example, identification information ofintelligent routers 164, 166, and 168 and tunnels that connect them, channel subject, and channel attributes (name and type of each attribute). Also, the packet or message can carry channel related information including identification information of fixed attributes and variable attributes.

ユーザは、オンラインのとき、経路情報（channel information）をダウンロードすることができる。例えば、ユーザは、ユーザ名とパスワードを用いて、自らを登録することができる。ユーザのログオンが認証されると、ユーザは、チャンネルを開き（呼び出し）、チャンネルマネージャ１５０からチャンネルに関する情報を検索することができる。発行者装置は、コンテンツを発行する際に、この情報を用いることができ、購読者装置は、購読予約を入力及び登録するために、この情報を用いることができる。  The user can download channel information when online. For example, a user can register himself using a user name and password. Once the user's logon is authenticated, the user can open (call) the channel and retrieve information about the channel from thechannel manager 150. The publisher device can use this information when publishing content, and the subscriber device can use this information to enter and register subscription subscriptions.

この実施例では、チャンネルマネージャ１５０の各サーバ１５２、１５４、１５６は、各インテリジェントルータ１６４、１６６、１６８のためのプライマリ（primary）として機能する。特に、この実施例では、各インテリジェントルータ１６４、１６６、１６８は、２つのインターネットプロトコル（Internet Protocol：以下、ＩＰという。）アドレスが供給され、一方のＩＰアドレスは、プライマリチャンネルマネージャ用であり、他方のＩＰアドレスは、バックアップチャンネルマネージャ用である。インテリジェントルータ１６４、１６６、１６８は、これらのＩＰアドレスを用いて、チャンネルマネージャ１５０の各サーバ１５２、１５４、１５６に接触し、経路情報を検索する。プライマリチャンネルマネージャに障害が発生すると、インテリジェントルータ１６４、１６６、１６８は、バックアップチャンネルマネージャと接触することができる。したがって、チャンネルマネージャ１５０のサーバ１５２、１５４、１５６は、これらを繋ぐ線によって示すように、チャンネル属性及び他の情報に関するデータを共有する。また、各サーバ１５２、１５４、１５６は、所定のバックアップチャンネルマネージャを有し、プライマリチャンネルマネージャに障害が生じた場合、他のバックアップチャンネルマネージャに処理を引き継がせることができる。ネットワーク内の機器は、コマンド、例えば経路情報を検索するコマンドを用いることができ、表３は、コマンドの具体例を示している。これに代えて、インテリジェントルータ１６４、１６６、１６８は、プライマリチャンネルマネージャのみを有していてもよく、あるいは３つ以上のチャンネルマネージャを有していてもよい。  In this embodiment, eachserver 152, 154, 156 of thechannel manager 150 functions as a primary for eachintelligent router 164, 166, 168. In particular, in this embodiment, eachintelligent router 164, 166, 168 is supplied with two Internet Protocol (IP) addresses, one for the primary channel manager and the other for the other. The IP address is for the backup channel manager. Using these IP addresses, theintelligent routers 164, 166, and 168 contact theservers 152, 154, and 156 of thechannel manager 150 to search for route information. If the primary channel manager fails, theintelligent routers 164, 166, 168 can contact the backup channel manager. Thus, theservers 152, 154, 156 of thechannel manager 150 share data regarding channel attributes and other information, as indicated by the connecting lines. Each of theservers 152, 154, and 156 has a predetermined backup channel manager, and when a failure occurs in the primary channel manager, the other backup channel manager can take over the processing. A device in the network can use a command, for example, a command for retrieving route information, and Table 3 shows a specific example of the command. Alternatively, theintelligent routers 164, 166, 168 may have only a primary channel manager, or may have more than two channel managers.

図７は、ユーザ装置又は機器をインテリジェントルータを有するネットワークに接続するためのユーザ装置又は機器内の具体的なソフトウェアコンポーネントのスタック１８０を示している。ユーザ装置は、発行者装置、購読者装置又はこれらの両方として用いることができ、ユーザ装置は、具体例として上述した様々な機器を含むことができる。スタック１８０は、１つ以上のユーザアプリケーション１８２を含むことができ、ユーザアプリケーション１８２は、ユーザからの購読予約の受信、発行者装置からの経路情報の受信又は発行するコンテンツ又はデータの受信に用いることができる。また、ユーザアプリケーション１８２は、ユーザ装置又は機器によって実行される他のあらゆる種類のアプリケーションを含んでいてもよい。  FIG. 7 illustrates a specificsoftware component stack 180 in a user device or device for connecting the user device or device to a network having an intelligent router. The user device can be used as an issuer device, a subscriber device, or both, and the user device can include the various devices described above as specific examples. Thestack 180 can include one ormore user applications 182 that are used to receive subscriptions from users, receive route information from issuer devices, or receive content or data to be issued. Can do.User application 182 may also include any other type of application that is executed by a user device or device.

また、スタック１８０は、例えば、エージェント１８４と、イベントライブラリ１８６と、キャッシュライブラリ１８８と、チャンネルライブラリ１９０と、メッセージングライブラリ１９２と、ディスパッチャライブラリ１９４とを含んでいてもよい。エージェント１８４は、ネットワーク接続の確立又は他の機能を提供し、表３は、エージェント１８４によって実行されるコマンドの具体例を示しており、エージェント１８４は、プロキシコマンド又は他の種類のコマンドを用いることができる。イベントライブラリ１８６は、ユーザ装置に関するイベント又は他のイベント又は情報を記録する。キャッシュライブラリ１８８は、データのローカルキャッシングを行う。チャンネルライブラリ１９０は、チャンネルの識別情報と、それらのチャンネルに関する情報とを保存する。ディスパッチャライブラリ１９４は、制御パス１９６、チャンネルマネージャ１９８、１つ以上のインテリジェントルータ２００への接続を提供し、ディスパッチャライブラリ１９４は、表４に示す例示的な機能を含むことができる。メッセージングライブラリ１９２は、データパス２０４への接続を提供する。  Further, thestack 180 may include, for example, anagent 184, anevent library 186, a cache library 188, a channel library 190, amessaging library 192, and a dispatcher library 194.Agent 184 provides network connection establishment or other functions, and Table 3 shows specific examples of commands executed byagent 184, which uses proxy commands or other types of commands. Can do. Theevent library 186 records events relating to user equipment or other events or information. The cache library 188 performs local caching of data. The channel library 190 stores channel identification information and information regarding those channels. The dispatcher library 194 provides a connection to thecontrol path 196, the channel manager 198, one or moreintelligent routers 200, and the dispatcher library 194 can include the exemplary functions shown in Table 4.Messaging library 192 provides a connection todata path 204.

Ｃプログラミング言語で書かれたメッセージングＡＰＩ（以下、単にＡＰＩという。）の具体例を表５〜表９に示す。表５及び表６は、メッセージを送信及び検索するＡＰＩの具体例を示している。表７及び表８は、通知を送信及び検索するＡＰＩの具体例を示している。表９は、制御メッセージを送信及び検索するＡＰＩの具体例を示している。ここに示す特定の機能又は特徴を実現するＡＰＩ及び他のＡＰＩ、プログラム及びデータ構造は、例示的に示しているに過ぎず、これらの機能は、如何なるプログラミング言語で書かれたあらゆる種類のＡＰＩ又は他のソフトウェアエンティティとして実現してもよい。  Specific examples of messaging APIs (hereinafter simply referred to as APIs) written in the C programming language are shown in Tables 5 to 9. Tables 5 and 6 show specific examples of APIs for transmitting and retrieving messages. Tables 7 and 8 show specific examples of APIs for sending and retrieving notifications. Table 9 shows a specific example of an API for transmitting and retrieving a control message. The APIs and other APIs, programs and data structures that implement the particular functions or features shown here are merely exemplary, and these functions can be any kind of API or any other written in any programming language. It may be realized as another software entity.

図８は、上述したようなインテリジェントルータ及び図４に示すインテリジェントルータ９２等のインテリジェントルータの例示的なソフトウェアコンポーネント２１０を示している。ソフトウェアコンポーネント２１０は、例えば、インテリジェントルータ９２のメモリ９４に格納されており、プロセッサ９３によって実行することができる。ソフトウェアコンポーネント２１０は、例えば、フィルタリングデーモン２１２と、ディスパッチャ２１４と、経路選択デーモン２１６と、キャッシュマネージャ２１８とを含んでいる。フィルタリングデーモン２１２は、後述するように、購読予約のコンテンツを経路選択規則に基づいて処理するフィルタリングを、コンテンツベースの経路選択に提供する。ディスパッチャ２１４は、パス２２０を介してフィルタを伝搬するために必要な制御メッセージの通信を行い、また、ディスパッチャ２１４は、ユーザのエントリの単一点及びチャンネルマネージャを有する１つの安全なソケット（one secure socket）を提供することができ、ネットワークのセキュリティを向上させる。換言すれば、この具体例では、ユーザは、チャンネルマネージャに直接接触しないが、他の実施例において、ユーザは、チャンネルマネージャと直接接触してもよい。ディスパッチャ２１４は、制御メッセージを用いて、チャンネルマネージャから属性（名称−値の対）を得る。  FIG. 8 illustrates anexemplary software component 210 of an intelligent router such as the intelligent router as described above and theintelligent router 92 shown in FIG. Thesoftware component 210 is stored, for example, in the memory 94 of theintelligent router 92 and can be executed by theprocessor 93. Thesoftware component 210 includes, for example, afiltering daemon 212, adispatcher 214, aroute selection daemon 216, and acache manager 218. Thefiltering daemon 212 provides content-based route selection with filtering that processes subscription content based on route selection rules, as described below. Thedispatcher 214 communicates the control messages necessary to propagate the filter via thepath 220, and thedispatcher 214 has a single secure socket with a single point of entry for the user and a channel manager. ) To improve network security. In other words, in this embodiment, the user does not contact the channel manager directly, but in other embodiments, the user may contact the channel manager directly. Thedispatcher 214 obtains attributes (name-value pairs) from the channel manager using control messages.

経路選択デーモン２１６は、データパス２２２による通信を行い、データパス２２２は、図４に示すような従来のバックボーンルータ９５又は他の経路選択機器によって形成することができる。キャッシュマネージャ２１８は、対応するインテリジェントルータを含むネットワークノードにおけるデータのローカルキャッシングを行う。キャッシュマネージャ２１８の動作は、後に詳細に説明するが、キャッシュマネージャ２１８は、ネットワークコアを介したデータの分散キャッシングを行う。  Theroute selection daemon 216 communicates via thedata path 222, which can be formed by aconventional backbone router 95 or other route selection device as shown in FIG. Thecache manager 218 performs local caching of data at the network node that includes the corresponding intelligent router. The operation of thecache manager 218 will be described in detail later, but thecache manager 218 performs distributed caching of data via the network core.

コンテンツベースの経路選択は、アプリケーションレベルではなく、カーネルレベルにおいて実行することができる。カーネルによってアクセス可能なメモリは、アプリケーション層におけるメモリから独立している。アプリケーションにおいて、コンテンツベースの経路選択を実行するためには、例えば、メッセージデータをカーネルメモリ領域からアプリケーション領域にコピーし、アプリケーションのコンテキスト（context）をカーネルのコンテキストから、経路選択アプリケーションのコンテキストに切り換える必要がある。これらの処理は、いずれもかなりのオーバヘッドを引き起こす。ここで、コンテンツベースの経路選択をサポートするようにカーネルを変更すれば、上述したオーバヘッドが取り除かれ、経路選択をより高速に行うことができるようになる。  Content-based routing can be performed at the kernel level rather than at the application level. The memory accessible by the kernel is independent of the memory in the application layer. To perform content-based routing in an application, for example, it is necessary to copy message data from the kernel memory area to the application area and switch the application context from the kernel context to the routing application context. There is. Both of these processes cause considerable overhead. Here, if the kernel is changed to support content-based route selection, the overhead described above is removed, and route selection can be performed at higher speed.

このようなカーネルにおけるコンテンツベースの経路選択機能により、経路選択デーモン２１６は、実装例に応じて、データパス２２２を介してデータを直接又は間接的に送信又は受信することができる。経路選択デーモン２１６は、アプリケーション層において実行されるプロセスであり、カーネルに導入する（inject）コンテンツベースの経路選択テーブル（content-based routing table）を予め計算する（pre-computing）プロセスである。なお、カーネルは、経路選択テーブルが一旦導入されると、経路選択テーブルを用いて、経路決定を行うことができる。同様に、フィルタリングデーモン２１２は、フィルタリングテーブル（filtering table）を予め計算し、フィルタリングテーブルをカーネルに導入する。このカーネルの実行において、経路選択デーモン２１６もフィルタリングデーモン２１２もデータパス２２２とは直接インタラクトしない。  Such a content-based routing function in the kernel allows therouting daemon 216 to send or receive data directly or indirectly via thedata path 222, depending on the implementation. Therouting daemon 216 is a process executed in the application layer, and is a process that pre-computes a content-based routing table to be introduced into the kernel (inject). The kernel can determine a route by using the route selection table once the route selection table is introduced. Similarly, thefiltering daemon 212 pre-calculates a filtering table and introduces the filtering table into the kernel. In this kernel execution, neither therouting daemon 216 nor thefiltering daemon 212 interacts directly with thedata path 222.

図９は、購読予約のコンテンツを含むことができるメッセージのパケット構造２３０の具体例を示している。コンテンツベースの経路選択に用いられるパケット又はメッセージは、例えば、ヘッダ部とペイロード部を含んでいる。ヘッダ部は、経路選択又は他の情報を指定する。ペイロード部は、データ又はコンテンツ、あるいはデータ又はコンテンツの指標（indication）を指示する。パケット構造２３０は、ＩＰヘッダ２３２と、ユーザデータグラムプロトコル（User Datagram Protocol：以下、ＵＤＰという。）の伝送制御プロトコル（Transmission Control Protocol：以下、ＴＣＰという。）ヘッダ２３４と、長さの値２３８と、１つ以上の主語フィールド２４０と、１つ以上の属性２４２とを含んでいる。パケット構造２３０は、長さの値、主語及び属性のための基本構造を示している。また、コンテンツベースの経路選択で用いられるパケットは、例えば、後述する図１８の実施例に示すように、他の又は異なる要素を含むことができ、コンテンツベースの経路選択のためのパケットは、如何なる手法で構成してもよい。また、属性は、例えば、メッセージの最後に付加される任意の属性を含むことができる。これらの任意の属性は、例えば発行者装置（又はルータ）によって追加される特別の情報（ad-hoc information）であり、必ずしもチャンネルに対して定められたメッセージフォーマットを用いて搬送する必要はない情報である。  FIG. 9 shows an example of apacket structure 230 of a message that can include subscription content. A packet or message used for content-based route selection includes, for example, a header portion and a payload portion. The header portion specifies route selection or other information. The payload portion indicates data or content, or an indication of data or content. Thepacket structure 230 includes anIP header 232, a user datagram protocol (hereinafter referred to as UDP) transmission control protocol (hereinafter referred to as TCP)header 234, alength value 238, and the like. One or moresubject fields 240 and one ormore attributes 242 are included. Thepacket structure 230 shows the basic structure for length values, subjects, and attributes. Also, the packet used for content-based routing can include other or different elements, as shown in the example of FIG. 18 to be described later, and any packet for content-based routing can be used. You may comprise by the method. The attribute can include an arbitrary attribute added to the end of the message, for example. These optional attributes are, for example, special information (ad-hoc information) added by the issuer device (or router) and do not necessarily have to be carried using the message format defined for the channel. It is.

発行者装置及び購読者装置における方法（Publisher and Subscriber Methodologies ）
図１０は、発行者装置によって、チャンネルを設定し、コンテンツを発行する例示的な発行方法２５０のフローチャートである。発行方法２５０は、例えば、発行者装置１００内のプロセッサ１１４によって実行されるエージェントアプリケーション（以下、単にエージェントという。）１０６を含むソフトウェアモジュールによって実現することができる。発行方法２５０において、発行者装置１００のエージェント１０６は、チャンネル用のプロキシの発行者生成（publisher creation）を受信する（ステップ２５２）。プロキシは、ネットワークとの通信を行う。エージェント１０６は、インタフェースを介してチャンネルにおいて用いられるメッセージフォーマットを判定する（ステップ２５３）。フォーマット情報は、例えば、チャンネルマネージャ又はネットワークにおける他のエンティティから得ることができる。エージェント１０６は、受信経路情報を用いて、チャンネルのプロキシを設定し（ステップ２５４）、この処理は、チャンネルの属性を受信し（ステップ２５６）、チャンネルへの通知を生成する（ステップ２５８）ことを含む。この通知は、チャンネル上でコンテンツを「待機（listening）」している機器にコンテンツを提供する。属性は、通知のパラメータ及び特性を定義する。Publisher and Subscriber Methodologies
FIG. 10 is a flowchart of an exemplary publishing method 250 for setting a channel and publishing content by an issuer device. The issuing method 250 can be realized by, for example, a software module including an agent application (hereinafter simply referred to as an agent) 106 executed by theprocessor 114 in theissuer apparatus 100. In the publishing method 250, the agent 106 of theissuer apparatus 100 receives the publisher creation of the proxy for the channel (step 252). The proxy communicates with the network. Agent 106 determines the message format used in the channel via the interface (step 253). Format information can be obtained, for example, from a channel manager or other entity in the network. The agent 106 sets the proxy of the channel using the reception path information (step 254), and the process receives the attribute of the channel (step 256) and generates a notification to the channel (step 258). Including. This notification provides content to devices that are “listening” for content on the channel. Attributes define notification parameters and characteristics.

エージェント１０６は、チャンネルの識別子（ＩＤ）及びコンテンツ情報を、ネットワークコア内の又は購読予約を処理するためにそれらを用いる他の場所内のインテリジェントルータに送信する（ステップ２６０）。発行者装置１００は、通知属性に適切な値を設定し（ステップ２６１）、そして、発行者装置１００は、チャンネル属性に基づいて、通知に関するコンテンツを発行することができる（ステップ２６２）。この実施例におけるステップ２６０〜２６２により、通知の発行が完了する。この処理は、実際の個々の実施例に応じて、他の又は更なるステップを含んでいてもよい。したがって、この実施例における通知に関連した情報は、順序正しい一連の属性に区切られ、各属性は、名称と、通知内の位置（１から始まる）と、種類と、値とを有する。これに代えて、属性は、個々の実施例に応じて、異なる特性を有していてもよい。例えば、属性は、予め定義された属性、任意の属性又はこれらの両方を含むことができる。  Agent 106 transmits the channel identifier (ID) and content information to intelligent routers in the network core or in other locations that use them to process subscriptions (step 260). Theissuer apparatus 100 sets an appropriate value for the notification attribute (step 261), and theissuer apparatus 100 can issue content related to the notification based on the channel attribute (step 262). In step 260 to 262 in this embodiment, the notification issuance is completed. This process may include other or additional steps depending on the actual individual embodiment. Thus, the information associated with notifications in this embodiment is partitioned into an ordered sequence of attributes, each attribute having a name, position in the notification (starting from 1), type, and value. Alternatively, the attributes may have different characteristics depending on the particular embodiment. For example, the attributes can include predefined attributes, optional attributes, or both.

インテリジェントルータは、パケット内のチャンネルＩＤを用いて、対応するチャンネルの属性を得ることができる。この属性は、チャンネルを介して伝送されるパケットの構造と又はフォーマットを決定している。特に、各パケットは、例えば、チャンネルＩＤに関連したタグと、発行者ＩＤ又は主語のような他のヘッダ情報とを含むことができる。このタグは、例えば図１８の具体例に示すように、主語をメッセージフォーマットの番号にマッピングするために用いることができる。この番号には、小さな整数値、例えば１６ビットの値を用いることができる。これに代えて、他のあらゆる種類の番号又は情報を用いて、主語をマッピングすることができる。主語を番号にマッピングすることにより、特別な利点が得られる。例えば、これにより、メッセージフォーマット内の空間を節約でき、メッセージにおいて主語の指標を指定する一様な又は標準化された手法を提供することができ、この手法により、主語を速やかに検出し、識別できるようになる。インテリジェントルータは、マッピングを局所的に保存することができ、あるいは、これに代えて番号を用い、コマンドによって、リモートから対応する主語を取得することができる。  The intelligent router can obtain the attribute of the corresponding channel using the channel ID in the packet. This attribute determines the structure and format of the packet transmitted over the channel. In particular, each packet may include, for example, a tag associated with the channel ID and other header information such as issuer ID or subject. This tag can be used to map a subject to a message format number, for example, as shown in the example of FIG. This number can be a small integer value, for example a 16 bit value. Alternatively, the subject can be mapped using any other type of number or information. Mapping the subject to a number offers special advantages. For example, this can save space in the message format and provide a uniform or standardized way of specifying subject indicators in the message, which can quickly detect and identify the subject. It becomes like this. The intelligent router can store the mapping locally, or it can use the number instead and obtain the corresponding subject remotely by command.

表１０は、主語を番号にマッピングするための構造を示しており、この具体例では、番号に整数値を用いている。表１０における主語ツリーパラメータは、主語が階層関係内に１つ以上の主語フィールドを含むことができることを示しており、例えば、主語ツリーは、特定のシンボルによって区切られた一連の主語フィールドを含むことができる。主語ツリーの具体例は、表２に示されている。例えば、subject tree quotes.nyse（ニューヨーク証券取引所における主語ツリーの株価）は、主語「quote」とサブフィールド「nyse」を含んでおり、これらの２つの用語は、ＵＲＬ又は他のネットワークアドレスのように、「.（ピリオド）」によって区切られている。ピリオド及びＵＲＬ型の文字列を用いる代わりに、如何なる文字及び区切りのためのシンボルを用いて、如何なる手法で主語ツリーを指定してもよい。  Table 10 shows a structure for mapping a subject to a number. In this specific example, an integer value is used for the number. The subject tree parameter in Table 10 indicates that the subject can include one or more subject fields in a hierarchical relationship, for example, the subject tree includes a series of subject fields separated by a particular symbol. Can do. Specific examples of subject trees are shown in Table 2. For example, subject tree quotes.nyse (the price of the subject tree on the New York Stock Exchange) includes the subject “quote” and the subfield “nyse”, these two terms being like URLs or other network addresses. Are separated by “. (Period)”. Instead of using a period and URL type character string, the subject tree may be specified by any method using any character and symbol for delimiter.

特定のチャンネルのパケットフォーマット又は構造を知ることにより、インテリジェントルータは、コンテンツベースの経路選択のためのパケット内において、主語及び属性、又は他の情報を速やかに検出することができる。例えば、チャンネルは、パケット内のバイトを数えることによって、チャンネルを介して伝送されてきた主語及び属性のバイト位置を容易に特定でき、主語及び属性を簡単に検出することができる。これに代えて、インテリジェントルータは、パケットを解析して、主語及び属性、又は他の情報を検出することができる。  By knowing the packet format or structure of a particular channel, the intelligent router can quickly detect subject and attributes, or other information, in the packet for content-based routing. For example, by counting bytes in a packet, a channel can easily identify the byte position of the subject and attribute transmitted over the channel, and can easily detect the subject and attribute. Alternatively, the intelligent router can analyze the packet to detect subject and attributes, or other information.

表１１は、Ｃ＋＋プログラミング言語で書かれた発行者プログラムの具体例を示している。表１２は、チャンネルを生成するＡＰＩの具体例を示している。表１３は、チャンネルマネージャによって維持されるチャンネル設定ファイルの具体例（図６参照）と、チャンネル関連情報とを示している。これに代えて、システムは、処理負荷を分散させるために、ローカルチャンネルマネージャとして機能する地理的に分散した複数のサーバのＩＰアドレスを提供する広域チャンネルマネージャ（global channel manager）を備えていてもよい。  Table 11 shows a specific example of an issuer program written in the C ++ programming language. Table 12 shows a specific example of an API for generating a channel. Table 13 shows a specific example of the channel setting file maintained by the channel manager (see FIG. 6) and channel related information. Alternatively, the system may include a global channel manager that provides the IP addresses of multiple geographically distributed servers that act as local channel managers to distribute the processing load. .

図１１は、購読予約を受信及び処理するのに用いられる購読方法２６４のフローチャートである。購読方法２６４は、例えば、購読者装置１２２内のプロセッサ１３４によって実行されるエージェントアプリケーション（以下、単にエージェントという。）１２８を含むソフトウェアモジュールによって実現することができる。購読方法２６４において、例えば、グラフィカルユーザインタフェース（graphical user interface；以下、ＧＵＩという。）は、利用可能なチャンネルの指標をユーザに表示する（ステップ２６６）。この処理は、アプリケーション１２６によって行われる。チャンネルを識別する情報は、例えば、チャンネル関連情報を提供するチャンネルマネージャから受信することができる。あらゆる種類のアプリケーション１２６を用いて、如何なる特別な手法又はフォーマットによって、チャンネルを識別する情報を表示してもよい。アプリケーション１２６は、ユーザが選択したチャンネルを受信し（ステップ２６８）、選択されたチャンネルのＡＰＩ又は他のプログラムを呼び出す（ステップ２７０）。ＡＰＩは、選択されたオプションに対応したチャンネルの購読予約オプションをユーザに表示する（ステップ２７２）。ＡＰＩは、ユーザから購読予約に関する値を受け取り（ステップ２７４）、購読予約を、後述する処理のために、エージェント１２８に送る（ステップ２７６）。  FIG. 11 is a flowchart of asubscription method 264 used to receive and process subscription subscriptions. Thesubscription method 264 can be implemented, for example, by a software module that includes an agent application (hereinafter simply referred to as an agent) 128 executed by theprocessor 134 in thesubscriber device 122. In thesubscription method 264, for example, a graphical user interface (GUI) displays an indication of available channels to the user (step 266). This process is performed by theapplication 126. Information identifying the channel can be received, for example, from a channel manager that provides channel related information. Any type ofapplication 126 may be used to display information identifying the channel by any special technique or format.Application 126 receives the channel selected by the user (step 268) and invokes the API or other program of the selected channel (step 270). The API displays to the user a subscription subscription option for the channel corresponding to the selected option (step 272). The API receives a value for the subscription from the user (step 274) and sends the subscription to theagent 128 for processing described below (step 276).

購読予約のパラメータは、例えば表１に示すような述語を含むことができる。各チャンネルは、例えば、対応するチャンネルに関する特定の要求又はパラメータに基づいて、購読予約を処理するために、それ自体のＡＰＩを用いることができる。これらのＡＰＩは、例えば、購読予約を受け取るウェブベースの又はJavaベースのＡＰＩを含むことができ、あらゆる種類のユーザインタフェース及び処理を用いて、購読予約に関する情報を受け取り、この情報をエージェント１２８に渡すことができる。  The subscription parameters may include predicates as shown in Table 1, for example. Each channel can use its own API to process subscriptions based on, for example, specific requirements or parameters for the corresponding channel. These APIs can include, for example, web-based or Java-based APIs that receive subscriptions, receive information about subscriptions using any kind of user interface and processing, and pass this information to theagent 128. be able to.

図１２は、チャンネル及び購読者画面（すなわちＧＵＩ）２７８、２８４を概念的に示す図であり、これらは、購読予約を受信する購読方法２６４に関連して用いられる。購読者画面２７８は、ユーザによって選択される利用可能なチャンネルを識別する複数の領域領域２８２を含んでいる。特定のチャンネルが選択されると、購読者画面２８４に示すように、購読予約のユーザの値を入力する領域２８６が表示される。ユーザが領域２８８を選択すると、購読予約が確定し、又は、ユーザが領域２９０を選択すると、購読予約が中止される。購読者画面２７８、２８４は、例えば、ハイパーテキストマークアップ言語（HyperText Markup Language：以下、ＨＴＭＬという。）のウェブページとしてフォーマットしてもよく、又は如何なる他の形式でフォーマットしてもよい。また、購読者画面２７８、２８４は、領域及びコンテンツのあらゆる構成を含むことができ、例えば、所望の、ユーザフレンドリで視覚的に魅力的なインタフェースを、購読者に提供するために、例えばテキスト、図形、画像、様々な色又はマルチメディア情報を含むことができる。また、購読者画面２７８、２８４は、例えば、従来と同様のブラウザ機能を提供するツールバー２８０を含んでいてもよい。  FIG. 12 conceptually illustrates channel and subscriber screens (ie, GUIs) 278, 284, which are used in connection with asubscription method 264 for receiving a subscription.Subscriber screen 278 includes a plurality ofarea regions 282 that identify the available channels selected by the user. When a specific channel is selected, anarea 286 for inputting a user value of a subscription reservation is displayed as shown in thesubscriber screen 284. When the user selectsarea 288, the subscription is confirmed, or when the user selectsarea 290, the subscription is canceled. Subscriber screens 278, 284 may be formatted, for example, as web pages in HyperText Markup Language (hereinafter referred to as HTML), or in any other format. The subscriber screens 278, 284 can also include any configuration of regions and content, for example, text, to provide the subscriber with a desired, user-friendly and visually attractive interface. It can contain graphics, images, various colors or multimedia information. Further, the subscriber screens 278 and 284 may include, for example, atoolbar 280 that provides a browser function similar to the conventional one.

表１４は、Ｃ＋＋プログラミング言語で書かれた購読者プログラムの具体例を示している。  Table 14 shows a specific example of a subscriber program written in the C ++ programming language.

ペイロード検査によるコンテンツベースの経路選択及びチャンネル
図１３は、コンテンツベースの経路選択のためのペイロード検査方法３００のフローチャートである。ペイロード検査方法３００は、例えば、インテリジェントルータ９２内のプロセッサ９３によって実行され、フィルタリングデーモン２１２として表されるソフトウェアモジュールによって実現することができる。これに代えて、このぺイロード検査方法３００は、ＡＳＩＣによって実現してもよく、あるいはハードウェアとソフトウェアの組合せによって実現してもよい。ペイロード検査方法３００として示すコンテンツベースの経路選択は、インテリジェントルータ内、あるいは、例えばネットワークコア又はエッジルータのようなネットワーク内の任意の場所において実行することができる。Content Based Routing and Channel with Payload Inspection FIG. 13 is a flowchart of a payload inspection method 300 for content based routing. Payload inspection method 300 may be implemented, for example, by a software module that is executed byprocessor 93 inintelligent router 92 and represented as filteringdaemon 212. Alternatively, the payload inspection method 300 may be realized by an ASIC, or may be realized by a combination of hardware and software. Content-based routing, shown as payload inspection method 300, can be performed in an intelligent router or anywhere in the network, such as a network core or edge router.

一般的な意味では、コンテンツベースの経路選択は、パケットをどのように処理するかを決定するために、パケットのペイロード部を検査することが必要である。このコンテンツベースの経路選択方法は、例えば、購読予約のリストを任意の順序で（例えば、フィルタを用いて）処理し、経路選択規則に基づいて、メッセージを主語毎及び属性毎に比較し、メッセージの経路選択を決定し、ネットワークコアにおける処理を実行することを含む。この経路選択規則は、ルータにおける処理を制御する規則又はフィルタに関連したあらゆる規則を含むことができる。したがって、これらの経路決定は、ネットワークコアを介して配信することができる。主語をチャンネルとして表すことにより、メッセージフォーマットが決定され、したがって、インテリジェントルータは、例えば、特定のチャンネルのメッセージ又はパケット内の属性のバイト位置を知ることによって、メッセージ内の属性の位置を速やかに検出できる。  In a general sense, content-based routing requires examining the payload portion of the packet to determine how to process the packet. This content-based route selection method, for example, processes a list of subscription reservations in any order (eg, using a filter), compares messages by subject and attribute based on route selection rules, Determining the path selection and executing processing at the network core. This routing rule can include any rule associated with a rule or filter that controls processing at the router. Therefore, these route decisions can be distributed via the network core. By representing the subject as a channel, the message format is determined, so the intelligent router quickly detects the position of the attribute in the message, for example by knowing the byte position of the attribute in the message or packet of a particular channel it can.

ペイロード検査方法３００において、インテリジェントルータ９２は、メッセージのパケットを受信する（ステップ３０２）。インテリジェントルータ９２は、パケットから、対応するメッセージのチャンネルＩＤを判定し（ステップ３０４）、このチャンネルＩＤを用いて、チャンネルの属性を読み出す（ステップ３０６）。この実施例では、チャンネルの種類（チャンネルＩＤから判定される。）は、パケット内の属性の位置及びデータタイプを決定している。チャンネルの属性は、局所的に保存し、例えばチャンネルマネージャを介して遠隔から読み出すこともできる。インテリジェントルータ９２は、購読予約に対応するフィルタを検索する（ステップ３０８）。フィルタは、購読予約に対する１つ以上の属性テスト（attribute test）、多くの場合、属性テストのグループを含んでいる。インテリジェントルータ９２は、フィルタ記述（filter description）のうちの対応する属性テストを、パケットの属性に適用する（ステップ３１０）。  In the payload inspection method 300, theintelligent router 92 receives a message packet (step 302). Theintelligent router 92 determines the channel ID of the corresponding message from the packet (step 304), and reads the channel attribute using this channel ID (step 306). In this embodiment, the channel type (determined from the channel ID) determines the attribute position and data type in the packet. Channel attributes can be stored locally and retrieved remotely via, for example, a channel manager. Theintelligent router 92 searches for a filter corresponding to the subscription reservation (step 308). A filter includes one or more attribute tests for subscriptions, often a group of attribute tests. Theintelligent router 92 applies the corresponding attribute test in the filter description to the attributes of the packet (step 310).

フィルタ記述の全ての属性テストの結果が肯定的である場合（ステップ３１２）、すなわち、属性が全ての属性テストを満たす場合、インテリジェントルータ９２は、フィルタに関連した規則によって定められた１組の機能を実行する（ステップ３１４）。これらの機能には、例えば、次のリンクにパケットをルーティングすること、及び／又はローカルルータにおいて、パケットのコンテンツに対して、規則で定められた何らかの働き又は演算を実行することが含まれる。この働き又は次のリンクは、例えば、対応する購読予約を指定するデータ構造において識別される。規則がリンクである場合、規則は、通常、パケットを受信する次のネットワークノードを識別し、次のネットワークノードには、インテリジェントルータ、バックボーンルータ、ネットワークに接続された機器又は他のエンティティが含まれる。これに代えて、次のリンクは、他の手法で指定し又は購読予約に関係付けることができる。  If the results of all attribute tests in the filter description are positive (step 312), that is, if the attributes satisfy all attribute tests, theintelligent router 92 sets a set of functions defined by the rules associated with the filter. Is executed (step 314). These functions include, for example, routing the packet to the next link and / or performing some rule-defined action or operation on the packet content at the local router. This action or next link is identified, for example, in a data structure that specifies the corresponding subscription. If the rule is a link, the rule typically identifies the next network node that receives the packet, which includes intelligent routers, backbone routers, equipment connected to the network, or other entities . Alternatively, the next link can be specified in other ways or related to a subscription.

フィルタ記述の全ての属性テストの結果が肯定的でない場合（ステップ３１２）、すなわち、属性が全ての属性テストを満たさない場合、フィルタは、不一致（mismatch）が宣言される（ステップ３１５）。インテリジェントルータ９２は、フィルタ記述の全ての属性テストが終了するまで、又は最初の否定的結果が得られるまで、上述した処理を繰り返す。  If the results of all attribute tests in the filter description are not positive (step 312), that is, if the attribute does not satisfy all attribute tests, the filter is declared mismatch (step 315). Theintelligent router 92 repeats the above process until all attribute tests of the filter description are completed or until the first negative result is obtained.

インテリジェントルータ９２は、このフィルタに対する全ての属性テストを行った後、更なるフィルタが存在するかを判定し（ステップ３１６）、更なるフィルタが存在する場合、インテリジェントルータ９２は、ステップ３０８に戻り、次のフィルタに対する属性テストを読み出して、次のフィルタの属性を処理する。マッチング処理（ステップ３０８、３１０、３１２、３１４、３１５、３１６）は、フィルタの全集合に対する処理が終了するまで、あるいは全ての働き又は全ての規則に対する結果が判定されるまで続けられる。パケットがあるフィルタを満たさない場合、そのフィルタは、ドロップ（破棄）されて、転送されない。  After theintelligent router 92 has performed all the attribute tests on this filter, it determines whether there are more filters (step 316). If there are more filters, theintelligent router 92 returns to step 308, Read the attribute test for the next filter and process the attributes of the next filter. The matching process (steps 308, 310, 312, 314, 315, 316) continues until the process for the entire set of filters is completed or until the results for all actions or all rules are determined. If a packet does not satisfy a filter, the filter is dropped and not forwarded.

インテリジェントルータ９２は、フィルタをある特定の順序に配列することができる。例えば表１５に示すように、インテリジェントルータ９２は、購読予約のフィルタを、ファイル又は経路選択テーブル内に保存することができ、属性にフィルタを適用する（属性テストの）ために、これらのフィルタを直線的に順序付けることができる。これに代えて、経路選択テーブルは、フィルタへのリンク又はポインタを含んでいてもよい。  Theintelligent router 92 can arrange the filters in a certain order. For example, as shown in Table 15, theintelligent router 92 can store subscription reservation filters in a file or routing table and use these filters to apply filters to attributes (for attribute testing). Can be ordered linearly. Alternatively, the route selection table may include a link or pointer to the filter.

コンテンツベースの経路選択では、アプリケーション及び性能向上ヒューリスティックス（performance-enhancing heuristics）、例えばトラヒック条件に基づくアルゴリズムの切換に基づいて、複数の方法を選択的に同時に用いることができる。コンテンツベースの経路選択に関するペイロード部を検査するために、処理用のフィルタは、ネットワーク内のルータにおいて、選択的に暗号化、復号、変換及び併合することができる。例えば、アプリケーションにおける発行（publication）が、小数点以下２桁より小さい通貨属性を含まない場合、購読予約、例えば「価格＞３．５４１２２ドル」は、「価格＞３．５４ドル」に切り捨てられる。また、例えば、海外からの発行が、米国内に位置する最初のルータに到達したときに、外貨を、米国の通貨に換算してもよい。  In content-based routing, multiple methods can be selectively used simultaneously based on application and performance-enhancing heuristics, eg, switching algorithms based on traffic conditions. Processing filters can be selectively encrypted, decrypted, transformed and merged at routers in the network to examine the payload portion for content-based routing. For example, if the publication in the application does not include a currency attribute that is less than two decimal places, a subscription reservation, eg “price> $ 3.54122”, is truncated to “price> $ 3.54”. Also, for example, when an overseas issue reaches the first router located in the United States, the foreign currency may be converted into the US currency.

インテリジェントルータ９２は、線形的な手法に代えて、処理の速度と効率を高めることができる他の順序で、又は様々なアルゴリズムに基づいて、処理するフィルタを選択することができる。表１６は、購読予約と対応するリンクの具体例を示す。これらの具体例において、主語は、特定のチャンネルに関連し、主語の購読予約は、フィルタの経路選択規則によって表すことができる。主語は、例えば、ユニフォームリソースロケータ（Uniform Resource Locator：ＵＲＬ）のようなコンテンツの供給源装置（source）を識別するネットワークアドレスを含むことができる。  Instead of a linear approach, theintelligent router 92 can select filters to process in other orders that can increase the speed and efficiency of processing, or based on various algorithms. Table 16 shows a specific example of the link corresponding to the subscription reservation. In these embodiments, the subject is associated with a particular channel, and subject subscriptions can be represented by filter routing rules. The subject can include a network address that identifies a source of content, such as a Uniform Resource Locator (URL), for example.

図１４は、キャッシング方法３２０のフローチャートである。キャッシング方法３２０は、例えば、インテリジェントルータ９２内のプロセッサ９３によって実行され、キャッシュマネージャ２１８として表されるソフトウェアモジュールによって実現することができる。これに代えて、このキャッシング方法３００は、対応するインテリジェントルータと同じ又は異なる物理機器内のＡＳＩＣによって実現してもよく、あるいはハードウェアとソフトウェアの組合せによって実現してもよい。キャッシング方法３２０において、インテリジェントルータ９２は、データ又はコンテンツと、チャンネルＩＤと、主語とを含むメッセージを受信する（ステップ３２２）。インテリジェントルータ９２は、データにタイムマークを付して（time mark）（ステップ３２４）、データを、例えばメモリ９４又は補助記憶装置９７に局所的に格納する（ステップ３２６）。インテリジェントルータ９２は、キャッシュデータに、チャンネルＩＤ、主語及びタイムスタンプによって、インデックスを付ける（ステップ３２８）。  FIG. 14 is a flowchart of thecaching method 320.Caching method 320 may be implemented, for example, by a software module that is executed byprocessor 93 inintelligent router 92 and represented ascache manager 218. Alternatively, the caching method 300 may be realized by an ASIC in the same or different physical device as the corresponding intelligent router, or may be realized by a combination of hardware and software. In thecaching method 320, theintelligent router 92 receives a message containing data or content, a channel ID, and a subject (step 322). Theintelligent router 92 adds a time mark to the data (step 324) and stores the data locally, for example, in the memory 94 or the auxiliary storage device 97 (step 326). Theintelligent router 92 indexes the cache data by channel ID, subject, and time stamp (step 328).

インテリジェントルータ９２がデータの要求を受信した場合（ステップ３３０）、インテリジェントルータ９２は、その要求に基づき、インデックスを用いて、キャッシュデータを検索する（ステップ３３２）。インテリジェントルータ９２は、最終的に要求者装置（requester）又は他のエンティティに伝送するために、キャッシュデータを、バックボーンルータ９５又は他の経路選択エンティティに転送する。キャッシング方法３２０は、継続的にデータをキャッシュに格納し、キャッシュデータ（cached data）を、要求に応じて検索するために、繰り返し実行することができる。  When theintelligent router 92 receives the request for data (step 330), theintelligent router 92 searches the cache data using the index based on the request (step 332).Intelligent router 92 forwards the cache data tobackbone router 95 or other routing entity for final transmission to the requester or other entity. Thecaching method 320 can be repeatedly executed to continuously store data in the cache and retrieve the cached data on demand.

図１５は、キャッシング方法３２０に用いられるキャッシュインデックス３３６の具体例を示している。キャッシュインデックス３３６は、データ３３８が入力され、これをタイムスタンプ３４０とともに保存する。データを収集する際、全てのデータには期間Δｔ毎にマークが付される。ここで、期間Δｔは、マーク間の時間、例えばｔ２−ｔ１を表す。タイムマークの付与（time marking）のために、他のあらゆる種類のインデックスを用いてもよい。  FIG. 15 shows a specific example of thecache index 336 used in thecaching method 320. Thecache index 336 receivesdata 338 and stores it together with atime stamp 340. When collecting data, all data are marked for each period Δt. Here, the period Δt represents a time between marks, for example, t2−t1. Any other kind of index may be used for time marking.

表１７は、キャッシュデータに用いられるインデックスを概念的に示している。表１８は、キャッシングのための接続履歴を保存するためのデータ構造を概念的に示している。表１９は、インテリジェントルータを有するネットワークノードにおいて、データを局所的にキャッシュに格納するために用いられるデータ構造の具体例を示している。  Table 17 conceptually shows indexes used for cache data. Table 18 conceptually shows a data structure for storing a connection history for caching. Table 19 shows a specific example of a data structure used for storing data locally in a cache in a network node having an intelligent router.

タイムマークの付与は、固定された如何なる間隔で行ってもよく、可変の時間間隔で行ってもよい。例えば、データを５分毎にキャッシュに格納して、インデックスを付けてもよい。キャッシュマネージャ２１８は、ステップ３３２において、時刻及び主語を指定した、キャッシュデータを読み出すコマンド（例えば、#.getCache）を受信すると、キャッシュインデックスを用いて、要求に対応するキャッシュデータを読み出すことができるか否かを判定する。  The time mark may be given at any fixed interval or at a variable time interval. For example, data may be stored in a cache every 5 minutes and indexed. If thecache manager 218 receives a cache data read command (eg, # .getCache) specifying the time and subject instep 332, can thecache manager 218 read the cache data corresponding to the request using the cache index? Determine whether or not.

各主語又はチャンネルは、例えば、マルチキャストツリー及び１組のインテリジェントルータにおけるそれ自体のＩＰアドレスを含むことができる。したがって、表１８は、ユーザ装置に局所的に保存できる、このようなルータ間の接続履歴を示している。エッジルータが故障した場合、ユーザ装置は、エッジルータがオンラインに戻ったときに、チャンネルの上流（upstream）のルータにどのように再接続すべきかを決定するために、この接続履歴にアクセスすることができる。また、ユーザ装置は、例えば、それが切断されていた期間における購読予約に関する保留中のコンテンツを取得するために、ゲットキャッシュコマンド（get cache command）を実行することができる。  Each subject or channel can include, for example, its own IP address in a multicast tree and a set of intelligent routers. Therefore, Table 18 shows such a connection history between routers that can be stored locally in the user equipment. If an edge router fails, the user equipment can access this connection history to determine how to reconnect to the upstream router of the channel when the edge router comes back online. Can do. Also, the user device can execute a get cache command, for example, to obtain pending content for subscription subscriptions during the period when it was disconnected.

これらの例示的なデータ構造は、以下の情報を含んでいる。主語ノード（subject node）は、主語識別子（subject identifier）と、主語レベル（subject level）と、親チャンネル（parent channel）又は主語ノードへのポインタと、それ自体のディレクトリのためのファイル記述子（file descriptor）と、その次のレベルの主語ノードを含むハッシュテーブル（hash table）へのポインタと、データノード（data node）へのポインタとを含んでいる。データノードは、主語親ノード（subject parent node）へのポインタと、データディレクトリ（data directory）のためのファイル記述子と、各記憶装置に保存されたデータのデータ構造を含む循環バッファ（circular buffer）と、バッファの最初及び最後と、検索及び保存中にデータノードをロックするロックとを含んでいる。保存された時間単位ノード（time grain node）は、実際のデータファイルを表すノードであり、最後の時間単位ノードは、メモリには維持されているが、記憶装置にはまだ保存されていない最後のバッファを表す。この実施例におけるキャッシング及びデータ記憶スレッドは、最後の時間単位ノードに対する同時アクセスを防止する、最後の時間単位ノードのミューテックス（mutex）を用いる。  These exemplary data structures include the following information: The subject node includes a subject identifier, a subject level, a pointer to a parent channel or subject node, and a file descriptor for its own directory (file descriptor), a pointer to a hash table including a subject node of the next level, and a pointer to a data node. The data node is a circular buffer that contains a pointer to the subject parent node, a file descriptor for the data directory, and the data structure of the data stored in each storage device. And the beginning and end of the buffer and the lock that locks the data node during retrieval and storage. The saved time grain node is the node that represents the actual data file, and the last time unit node is the last one that is maintained in memory but not yet saved in storage. Represents a buffer. The caching and data storage thread in this embodiment uses a last time unit node mutex that prevents simultaneous access to the last time unit node.

エージェントの処理
図１６は、送信購読予約メッセージのためのエージェント方法３５０のフローチャートである。エージェント方法３５０は、例えば、購読者装置（以下、ユーザ装置ともいう。）１２２内のプロセッサ１３４によって実行され、エージェント１２８として表されるソフトウェアモジュールによって実現することができる。エージェント方法３５０において、エージェント１２８は、例えば、図１１及び図１２を用いて説明した購読方法２６４によって生成された購読予約を受信する（ステップ３５２）。エージェント１２８は、購読予約用の論理式を指定する文字列を生成し（ステップ３５４）、文字列を解析して、購読予約内のエラーを検出する（ステップ３５６）。エラーが存在する場合、エージェント１２８は、ユーザがエラーを修正し、購読予約を再入力するように促すエラーメッセージをユーザに表示する（ステップ３６０）。購読予約がエラーを全く含んでいない場合（ステップ３５８）、エージェント１２８は、例えば後続するステップのように、論理式をデータ構造内に保存する（ステップ３６２）。エージェント１２８は、データ構造内の構成要素である不等号式（constituent not-equal expression）を肯定的形式に変換し（ステップ３６４）、更にデータ構造を対応する論理和標準形式（disjunctive normal form：以下、ＤＮＦという。）に変換する（ステップ３６６）。また、エージェント１２８は、範囲フィルタ（range filter）及びメンバシップテスト（membership test）のみが含まれるように、ＤＮＦ構造のＡＮＤ式（AND expression）を単純化する（ステップ３６８）。Agent Processing FIG. 16 is a flowchart of anagent method 350 for outgoing subscription message. Theagent method 350 may be implemented by a software module that is executed by theprocessor 134 in the subscriber device (hereinafter, also referred to as a user device) 122 and represented as theagent 128, for example. In theagent method 350, theagent 128 receives the subscription reservation generated by thesubscription method 264 described with reference to FIGS. 11 and 12, for example (step 352). Theagent 128 generates a character string specifying a logical expression for the subscription reservation (step 354), analyzes the character string, and detects an error in the subscription reservation (step 356). If there is an error,agent 128 displays an error message to the user prompting the user to correct the error and re-enter the subscription (step 360). If the subscription does not contain any errors (step 358), theagent 128 stores the logical expression in the data structure (step 362), for example, as in a subsequent step. Theagent 128 converts a constituent not-equal expression, which is a component in the data structure, to an affirmative form (step 364), and further converts the data structure to a corresponding disjunctive normal form: (Referred to as DNF) (step 366). In addition, theagent 128 simplifies the AND expression of the DNF structure so that only the range filter and the membership test are included (step 368).

ＤＮＦは、周知の標準形式（canonical form）であり、その標準形式においては、論理式は、１つ以上の部分式（sub-expressions）のＯＲ（選言肢（disjunct）と呼ばれる）として表され、各部分式は、１つ以上の属性テストのＡＮＤで表される。例えば、論理式「price >= 10 AND (symbol ="LU" OR symbol ="T")」に等価なＤＮＦの論理式は、論理式「(price >= 10 AND symbol ="LU") OR (price >= 10 AND SYMBOL ="T")」である。  DNF is a well-known canonical form in which a logical expression is expressed as an OR (called a disjunct) of one or more sub-expressions. Each sub-expression is represented by an AND of one or more attribute tests. For example, the logical expression of DNF equivalent to the logical expression “price> = 10 AND (symbol =" LU "OR symbol =" T ")" is the logical expression "(price> = 10 AND symbol =" LU ") OR ( price> = 10 AND SYMBOL = "T") ".

ステップ３６４における変換では、「不等号（not-equal）」演算子（例示的な構文では、!=で表す。）を有する論理式を、１つの許可されていない値ではなく、全ての許可される値を指定する等価な「肯定的（positive）」形式に変換することが必要である。この実施例のルータは、肯定的形式の式を要求するので、この変換は、ＤＮＦを生成する前に行われる。例えば、論理式「price != 80」は、等価な肯定的論理式「price<= 79 OR price >=81」に変換することができる。  In the transformation instep 364, a logical expression having a “not-equal” operator (represented by! = In the exemplary syntax) is allowed for all allowed values, not one forbidden value. It is necessary to convert to an equivalent "positive" form that specifies the value. Since the router in this example requires an expression in positive form, this conversion is done before generating the DNF. For example, the logical expression “price! = 80” can be converted to the equivalent positive logical expression “price <= 79 OR price> = 81”.

ステップ３６８における変換は、ＤＮＦが生成された後に実行されるので、得られるＡＮＤ式を更に単純化しなければならず、また、この変換は、この実施例におけるルータの作業を単純化するために実行される。特に、同じ属性に対する複数の属性テストのＡＮＤは、１つの下限、１つの上限、下限及び上限の両方、又は等号テスト（equality test）の場合における単一の値のいずれかを標準的な（canonical）「範囲フィルタ」に単純化することができる。そして、特定の種類の範囲フィルタは、例えば表２２に基づいて符号化される。  Since the transformation instep 368 is performed after the DNF is generated, the resulting AND expression must be further simplified, and this transformation is performed to simplify the work of the router in this embodiment. Is done. In particular, AND of multiple attribute tests for the same attribute can be either a single lower limit, one upper limit, both lower and upper limits, or a single value in the case of an equality test. canonical) can be simplified to "range filter". Then, a specific type of range filter is encoded based on Table 22, for example.

例えば、論理式「price >= 10 AND price <= 80 AND price >=20 AND price <= 100」は、論理式「price >= 20 AND price <= 80」に単純化することができ、これは、下限と上限の両方を有する範囲フィルタの具体例である。単純化後の他の種類の具体例としては、「price >= 20（下限のみ）」、「price <= 80（上限のみ）」、「price = 50（単一の値）」等がある。これらの範囲フィルタを生成する際、何らかの部分式を真又は偽に単純化することができ、その場合、部分式は、論理代数の法則に従って削除することができ、これにより、メッセージ内の論理式の符号化が更に最適化される。例えば、論理式「price >= 50 AND price <= 20」は、論理式を満足させる「price」の値がないので、偽に単純化することができる。フィルタの論理式（filter expression）全体が偽に単純化される特別な場合、エージェント１２８は、メッセージを生成する必要がなく、これにより、ルータを不要な作業から解放することができる。  For example, the logical expression "price> = 10 AND price <= 80 AND price> = 20 AND price <= 100" can be simplified to the logical expression "price> = 20 AND price <= 80" This is a specific example of a range filter having both a lower limit and an upper limit. Specific examples of other types after simplification include “price> = 20 (only the lower limit)”, “price <= 80 (only the upper limit)”, “price = 50 (single value)”, and the like. In generating these range filters, any sub-expression can be simplified to true or false, in which case the sub-expression can be deleted according to the laws of logical algebra, thereby allowing the logical expression in the message Is further optimized. For example, the logical expression “price> = 50 AND price <= 20” can be simplified to false because there is no “price” value that satisfies the logical expression. In the special case where the entire filter expression is simplified to false, theagent 128 need not generate a message, thereby freeing the router from unnecessary work.

主語フィルタがワイルドカードを含んでいる場合、エージェント１２８は、後述するように、それらを選択的に変換することができる（ステップ３７０）。これに代えて、如何なるワイルドカードもユーザ装置１２２又は他の機器ではなく、ネットワーク内において変換してもよい。この例示的な実施例では、主語フィルタの構文は、ワイルドカードを用いる唯一の構文であり、属性フィルタの構文は、論理式を用いる唯一の構文である。これに代えて、実施例において、主語フィルタ及び属性フィルタの異なる又は様々な種類の構文を用いてもよい。  If the subject filter includes wildcards,agent 128 can selectively convert them (step 370), as described below. Alternatively, any wildcard may be converted within the network rather than theuser device 122 or other device. In this illustrative example, the subject filter syntax is the only syntax using wildcards, and the attribute filter syntax is the only syntax using logical expressions. Alternatively, different or various types of syntax for subject filters and attribute filters may be used in embodiments.

エージェント１２８は、生成されたＤＮＦの論理式をメッセージに符号化し（ステップ３７２）、メッセージをインテリジェントルータに転送する（ステップ３７４）。この符号化は、購読予約を、一連のデータから構成されることを意味する平坦な（flat）メッセージフォーマットに変換することを含む。また、この転送は、購読予約に対する主語フィルタ及び属性フィルタから生成される経路選択規則を、ネットワーク内の１つ以上のインテリジェントルータ又は他の経路選択エンティティに伝搬することを含む。この伝搬のために、例えば、購読予約の論理式を従来のパケット構造にマッピングすることができる。  Theagent 128 encodes the generated DNF logical expression into a message (step 372), and forwards the message to the intelligent router (step 374). This encoding involves converting the subscription reservation into a flat message format which means that it consists of a series of data. The forwarding also includes propagating routing rules generated from subject filters and attribute filters for subscription reservations to one or more intelligent routers or other routing entities in the network. For this propagation, for example, the subscription formula can be mapped to a conventional packet structure.

ステップ３７２における符号化は、チャンネルの購読予約を、チャンネル全体に亘って伝搬するために、メッセージングＡＰＩのメッセージフォーマットに配列（marshalling）することを含む。例えば、購読予約は、主語#.SUBSCRIPTIONを含む通知として内部的に送られる（messaged）。主語フィルタフィールドの変数（variable number）と属性テストの変数の両方があるので、この実施例では、主語フィルタフィールドの変数を保存するために、１対のバイトが用いられ、属性テストの変数を保存するために、もう１対のバイトが用いられる。主語フィルタの個々のフィールドは、連続して、例えば元の購読予約で指定された順番で配列され、各フィールドは、メッセージの２バイト部分に配列される。ワイルドカードフィールドの配列については後述する。  The encoding instep 372 includes marshalling the channel subscription to the messaging API message format to propagate across the channel. For example, the subscription is sent internally as a notification containing the subject # .SUBSCRIPTION. In this example, a pair of bytes is used to store the variable for the subject filter field and the variable for the attribute test is saved because there are both a variable for the subject filter field and a variable for the attribute test. To do this, another pair of bytes is used. The individual fields of the subject filter are arranged sequentially, for example in the order specified in the original subscription, and each field is arranged in the 2-byte part of the message. The arrangement of the wild card field will be described later.

属性テストの配列においては、属性テストのオペランドは、通知の属性値の配列と同様な方法で、メッセージの最後に配列される。属性テスト及びオペランドは、配列される前に、所定の属性に対する位置順（position order）のテストと、これに続く任意の属性に対する名称順（name order）のテストとによって、ＤＮＦの各選言肢内で属性順（attribute order）にソートされる。更に、各選言肢内のスカラ値の（scalar valued）属性に対する１組の関係テスト（relational tests）は、１つの限界値（limit）（左が開いた範囲（left-open range）又は右が開いた範囲（right-open range）又は等号（equality）のテスト）、又は２つの限界値（異なる限界値間の閉じられた範囲のテスト）を有する範囲フィルタとして、標準形式に単純化される。属性テストに関する残りの情報は、オペランドと同じ順番で、例えば２バイト対（two-byte pairs）に符号化され、この２バイト対のシーケンスは、メッセージ内において、主語フィルタフィールドの２バイト符号化のシーケンスの直後に配置される。２バイト対は、属性テストの連続したビット列の符号化の１つの形式を構成することができ、これは、２バイト対とは別に、他の種類の符号化を表すためにも用いることができる。属性テストの具体例については、後述する。  In the attribute test array, the attribute test operands are arranged at the end of the message in a manner similar to the notification attribute value array. Attribute tests and operands are each ordered by DNF by a position order test for a given attribute, followed by a name order test for any attribute before being arranged. Sorted in attribute order. In addition, a set of relational tests for the scalar valued attribute within each choice has one limit (left-open range or right-open range). Simplified to standard form as a range filter with open range (right-open range or equality test) or two limit values (closed range test between different limit values) . The remaining information about the attribute test is encoded in the same order as the operands, for example, two-byte pairs, and this two-byte pair sequence is included in the message in the two-byte encoding of the subject filter field. Placed immediately after the sequence. Two-byte pairs can constitute one form of encoding of consecutive bit strings of attribute tests, which can be used to represent other types of encodings apart from two-byte pairs. . A specific example of the attribute test will be described later.

表２０は、属性テストの符号化規則を示している。表２１は、２バイト対の符号化を示し、表２２は、２バイト対の演算子ＩＤの符号化を示している。  Table 20 shows the encoding rule for the attribute test. Table 21 shows the encoding of 2-byte pairs, and Table 22 shows the encoding of 2-byte pairs of operator IDs.

テストの２バイト対が、既に、テストのオペランドの種類と、テストが所定又は任意の属性に適用された否かの両方を表しているので、任意の属性又はそれらの種類に対して実行されたテストの回数を別に配列する必要はない。この方式では、通知内の所定の属性の数が１２７個以下であると仮定している。これに代えて、この設計では、属性テストを符号化するために、より多くのビットを用いることができる。  Since the two byte pairs of the test already represent both the operand type of the test and whether or not the test was applied to a given or arbitrary attribute, it was performed on any attribute or those types There is no need to arrange the number of tests separately. In this method, it is assumed that the number of predetermined attributes in the notification is 127 or less. Alternatively, in this design, more bits can be used to encode the attribute test.

この配列規則は、属性フィルタのＤＮＦに基づいて、属性テストを順序付け及びグループ化する（group）が、インフラストラクチャの構成要素（例えば、ルータ）は、属性フィルタの全体評価をより効率的に行うために、属性テストを別の順序で（例えば、異なる属性テストの成功又は失敗の確率に関して動的に導出されたローカルデータに基づいて）評価するように選択することができる。メッセージの購読予約ＩＤフィールドは、購読予約を変更又は取り消す（unsubscribe）後続の要求において、エージェントのエッジルータに対して購読予約を一義的に識別するための、エージェントによって生成された値である。特に、購読予約の属性フィルタに対する動的な変更は、主語が#.RESUBSCRIPTIONであり、且つ購読予約ＩＤが既に登録されたものであって、変更する購読予約ＩＤである場合を除いて、図１８の実施例に示すメッセージフォーマットを用いて伝搬される。購読停止（unsubscription）は、例えば、主語を#.UNSUBSCRIPTIONとし、購読予約ＩＤを、既に登録されたものであって、登録を取り消す（unsubscribed）購読予約ＩＤを有する図１８に示すメッセージフォーマットを用い、購読予約ＩＤフィールドによって伝搬される。  This ordering rule orders and groups attribute tests based on the attribute filter's DNF, but infrastructure components (eg, routers) make the overall evaluation of the attribute filter more efficient. In addition, the attribute tests may be selected to be evaluated in another order (eg, based on dynamically derived local data regarding the probability of success or failure of different attribute tests). The subscription ID field of the message is a value generated by the agent to uniquely identify the subscription to the agent's edge router in subsequent requests to change or unsubscribe the subscription. In particular, the dynamic change to the subscription reservation attribute filter is shown in FIG. 18 except when the subject is # .RESUBSCRIPTION and the subscription reservation ID is already registered and the subscription reservation ID is changed. It is propagated using the message format shown in the embodiment. Unsubscription uses, for example, the message format shown in FIG. 18 where the subject is # .UNSUBSCRIPTION and the subscription ID is already registered and has an unsubscribed subscription ID. Propagated by the subscription ID field.

以下、上述したエージェントによる変換及び符号化の具体例を説明する。具体的な属性フィルタの論理式「price >= 10 AND (symbol == "LU" OR (volume >= 1000 AND volume <= 10000))」について考察する。図１９は、ステップ３６２において、論理式を保存するためにエージェントによって用いられるオブジェクト（object）を表した統一モデリング言語（Unified Modeling Language：以下、ＵＭＬという。）３９０を示している。この図１９は、変数値、定数値又はその両方を含むことができる購読予約を指定するための階層関係を示している。図１９のオブジェクトは、特定の実施例に基づく、フィルタクラスの例である。各単純フィルタ（simple filter）のオブジェクトは、フィルタの論理式の対応する属性テストに関する情報を保存するために用いられる属性の値を表している。図１９に示す表現では、ＯＲフィルタ３９６は、２つのＡＮＤフィルタ３９２、４００に接続している。ＡＮＤフィルタ３９２は、購読予約の属性を有する単純フィルタ３９４を含んでいる。同様に、ＯＲフィルタ３９６は、単純フィルタ３９８を含み、ＡＮＤフィルタ４００は、単純フィルタ４０２、４０４を含んでいる。  Hereinafter, a specific example of the conversion and encoding by the agent described above will be described. Consider a logical expression “price> = 10 AND (symbol ==“ LU ”OR (volume> = 1000 AND volume <= 10000))” of a specific attribute filter. FIG. 19 shows a Unified Modeling Language (hereinafter referred to as UML) 390 that represents an object used by the agent to store a logical expression instep 362. FIG. 19 shows a hierarchical relationship for specifying subscriptions that can include variable values, constant values, or both. The object of FIG. 19 is an example of a filter class based on a specific embodiment. Each simple filter object represents an attribute value that is used to store information about the corresponding attribute test of the filter's logical expression. In the expression shown in FIG. 19, theOR filter 396 is connected to two ANDfilters 392 and 400. The ANDfilter 392 includes asimple filter 394 having a subscription reservation attribute. Similarly, theOR filter 396 includes asimple filter 398, and the ANDfilter 400 includessimple filters 402 and 404.

この実施例においては、属性price、symbol、volumeは、関連したチャンネルの所定の属性であり、それぞれ位置０、１、２が定義されているものとする。更に、各属性の種類は、それぞれ符号なし整数（タイプコード６）、文字配列（character array）（タイプコード１２）、符号なし整数（タイプコード６）であるものとする。  In this embodiment, attributes price, symbol, and volume are predetermined attributes of related channels, andpositions 0, 1, and 2 are defined, respectively. Furthermore, each attribute type is an unsigned integer (type code 6), a character array (type code 12), and an unsigned integer (type code 6).

次に、その属性フィルタとして、上述した具体的な属性フィルタの論理式を含む購読予約について考察する。図１８は、購読予約をメッセージに配列した具体例を示している。図１８の左側の配列３８６は、実際のメッセージ内容を示しており、図１８の右側の配列３８８は、メッセージの各部分の説明を示している。各配列の横幅は、４バイトに対応している。配列する前に、属性フィルタは、その等価なＤＮＦの論理式「(price >= 10 AND symbol == "LU") OR (price >= 10 AND volume >= 1000 AND volume <= 10000)」に変換されている。  Next, a subscription reservation including the above-described logical expression of the specific attribute filter is considered as the attribute filter. FIG. 18 shows a specific example in which subscription reservations are arranged in a message. Anarray 386 on the left side of FIG. 18 shows actual message contents, and anarray 388 on the right side of FIG. 18 shows descriptions of each part of the message. The width of each array corresponds to 4 bytes. Before ordering, the attribute filter converts it to its equivalent DNF logical expression "(price> = 10 AND symbol ==" LU ") OR (price> = 10 AND volume> = 1000 AND volume <= 10000)" Has been.

１６ビットの属性テストの符号化は、異なる部分を分離するギャップ（gap）を有するビットシーケンスとして示される。なお、この実施例においては、priceに対する２つのテストは、それぞれ別の選言肢内に存在するので、結合することができず、したがって、これらは、右の限界値（bound）がない範囲（右が開いた範囲）として別々に配列される。一方、volumeに対する２つのテストは、同じ選言肢内に存在するので、結合することができ、したがって、これらは、単一の「閉じた範囲」のテストとして配列される。  The encoding of the 16-bit attribute test is shown as a bit sequence with a gap separating different parts. Note that in this example, the two tests for price are in separate choices and therefore cannot be combined, so they are in the range without the right bound (bound) Are arranged separately as the open range on the right. On the other hand, the two tests for volume can be combined because they are in the same choice, so they are arranged as a single “closed range” test.

また、特定のフィールドは、「仮定（assumed）」として特徴付けられ、これは、この具体例においては、これらのフィールドの値が、任意に選択され、通常、配列された購読予約から独立していることを意味する。更に、購読予約の主語フィルタは、「>」として任意に選択され、これは、関連したチャンネルによって定義された如何なる主語にも一致する。上述し、図１８及び図１９に示した具体例は、例示的なものであり、配列は、他のあらゆる種類の購読予約とともに用いてもよい。また、エージェント方法３５０は、購読予約を配列する一具体例に過ぎず、購読予約は、他の如何なる方法によって配列することができる。  Also, certain fields are characterized as “assumed”, in which, in this embodiment, the values of these fields are arbitrarily chosen and are usually independent of the arranged subscriptions. Means that In addition, the subject filter for the subscription is arbitrarily selected as “>”, which matches any subject defined by the associated channel. The examples described above and shown in FIGS. 18 and 19 are exemplary, and the arrangement may be used with any other type of subscription. Also, theagent method 350 is just one specific example of arranging subscription reservations, and the subscription reservations can be arranged by any other method.

図１７は、受信メッセージのためのエージェント方法３７６のフローチャートである。エージェント方法３７６は、例えば、ユーザ装置１２２のエージェント１２８及びアプリケーション１２６によって実現することができる。エージェント方法３７６において、エージェント１２８は、インテリジェントルータから購読予約に対応するメッセージを受信する（ステップ３７８）。エージェント１２８は、購読予約に対応するチャンネルを、例えばメッセージのチャンネルＩＤによって判定し（ステップ３８０）、チャンネルのＡＰＩを呼び出す（ステップ３８２）。ＡＰＩは、ユーザ装置１２２において、購読予約のデータをＧＵＩ又は他のフォーマットで表示する（ステップ３８４）。受信メッセージの処理としては、上述した符号化処理の逆のデータ復号処理を用いることができ、この復号（逆符号化）は、ルータ又は他のネットワークエンティティにおいて実行することができる。  FIG. 17 is a flowchart of an agent method 376 for received messages. The agent method 376 can be realized by theagent 128 and theapplication 126 of theuser device 122, for example. In agent method 376,agent 128 receives a message corresponding to the subscription from the intelligent router (step 378). Theagent 128 determines the channel corresponding to the subscription reservation, for example, by the channel ID of the message (step 380), and calls the API of the channel (step 382). The API displays the subscription data in the GUI or other format at the user device 122 (step 384). As the processing of the received message, a data decoding process opposite to the above-described encoding process can be used, and this decoding (decoding) can be performed in the router or other network entity.

ワイルドカード処理
図２０は、ワイルドカード方法４１０のフローチャートである。ワイルドカード方法４１０は、フィルタの１組の経路選択規則を用いて、ワイルドカードを購読予約の論理式に変換する具体例を示している。ワイルドカード方法４１０は、例えば、ユーザ装置１２２内のプロセッサ１３４によって実行され、エージェント１２８として表されるソフトウェアモジュールによって実現することができる。これに代えて、ワイルドカードは、ネットワークにおいて、インテリジェントルータ９２内のソフトウェア制御のプロセッサ９３によって、又はＡＳＩＣ９１内の対応する機能によって処理することができる。ワイルドカードは、空のフィールド（open fields）又は可変長のフィールドを含んでおり、表２１は、このようなフィールドの具体例を示している。Wildcard Processing FIG. 20 is a flowchart of the wildcard method 410. The wildcard method 410 shows a specific example in which a wildcard is converted into a subscription reservation logical expression using a set of filter route selection rules. The wildcard method 410 can be implemented, for example, by a software module that is executed by theprocessor 134 in theuser device 122 and represented as theagent 128. Alternatively, wildcards can be processed in the network by a software controlledprocessor 93 in theintelligent router 92 or by a corresponding function in theASIC 91. Wildcards include empty fields (open fields) or variable length fields, and Table 21 shows specific examples of such fields.

ワイルドカード方法４１０において、エージェント１２８又は他のエンティティは、ワイルドカードを含む購読予約を受信する（ステップ４１２）。購読予約の主語長は、発行者がコンテンツを発行する際に指定でき、主語は、発行者装置１００において前処理することができ、例えば主語のフィールドを数え、したがって、フィールド数（長）を得ることができる。エージェント１２８は、フィルタオペランド内のフィールドの数を数え（ステップ４１４）、フィールド長＝Ｎの新たな規則（フィルタ）を初期化する（ステップ４１６）。エージェント１２８は、購読予約のサブフィールドを読み出し（ステップ４１８）、フィルタオペランドのサブフィールドＯ［ｉ］がワイルドカードであるか否かを判定する（ステップ４２０）。フィルタオペランドのサブフィールドＯ［ｉ］がワイルドカードでない場合、エージェント１２８は、接続詞（conjunctive clause）を規則に追加し、フィールド［ｉ］＝Ｏ［ｉ］とする（ステップ４２２）。フィルタオペランドが更なるサブフィールドを有している場合（ステップ４２４）、エージェント１２８は、ステップ４１８に戻り、この更なるサブフィールドを処理する。パラメータ［ｉ］は、フィールドを表し、ｉは、この実施例においては、フィールド番号を表す整数である。  In the wildcard method 410, theagent 128 or other entity receives a subscription that includes the wildcard (step 412). The subject length of the subscription can be specified when the publisher publishes the content, and the subject can be pre-processed in thepublisher device 100, for example, counting subject fields and thus obtaining the number of fields (long). be able to. Theagent 128 counts the number of fields in the filter operand (step 414) and initializes a new rule (filter) with field length = N (step 416). Theagent 128 reads the subfield of the subscription reservation (step 418) and determines whether the subfield O [i] of the filter operand is a wild card (step 420). If the subfield O [i] of the filter operand is not a wild card, theagent 128 adds a conjunctive clause to the rule, and sets the field [i] = O [i] (step 422). If the filter operand has additional subfields (step 424),agent 128 returns to step 418 to process this additional subfield. The parameter [i] represents a field, and i is an integer representing a field number in this embodiment.

エージェント１２８は、サブフィールドを処理した後に、フィルタオペランドの最後のサブフィールドが「>」であるか否かを判定し（ステップ４２６）、フィルタオペランドの最後のサブフィールドが「>」である場合、長さの制約（constraint）をフィールド長＞Ｎ−１に変更する（ステップ４２８）。ワイルドカード処理は、あらゆる種類のシンボルを用いることができ、「>」は、その一例に過ぎない。この具体例においては、「a.>」は、a.b、a.c、a.d等を表し、全てのレベルにおけるこれらの全てのサブ主語（例えば、a.b.x、a.c.x、a.b.x.y等）を表すことができる。また、他のシンボルをワイルドカードとして用いてもよい。  After processing the subfield,agent 128 determines whether the last subfield of the filter operand is “>” (step 426), and if the last subfield of the filter operand is “>”, The length constraint is changed to field length> N-1 (step 428). Wildcard processing can use any kind of symbol, and “>” is just one example. In this example, “a.>” Represents a.b, a.c, a.d, etc., and can represent all these sub-subjects (eg, a.b.x, a.c.x, a.b.x.y, etc.) at all levels. Other symbols may be used as wild cards.

必要に応じて、エージェント１２８は、変更された規則（transformed rule）をインテリジェントルータ９２又はネットワークにおける他のエンティティに伝搬する（ステップ４３０）。したがって、ワイルドカード方法４１０は、ワイルドカード規則を、ワイルドカードを含まないことを意味する非ワイルドカード規則に変換するために、全てのサブフィールドに対して繰り返される。ワイルドカードの変換は、ネットワーク内の任意の場所、例えば、購読者装置１２２又はインテリジェントルータにおいて行うことができる。したがって、この変換は、他のエンティティに伝搬された、変更された規則を有する１つのエンティティで行い、又は動的に行うことができる。  If necessary,agent 128 propagates the transformed rule tointelligent router 92 or other entity in the network (step 430). Thus, the wildcard method 410 is repeated for all subfields to convert the wildcard rule to a non-wildcard rule that means no wildcards are included. Wildcard conversion can be done anywhere in the network, for example, at thesubscriber device 122 or intelligent router. Thus, this transformation can be done at one entity with modified rules propagated to other entities, or it can be done dynamically.

表２３は、ワイルドカードを処理するこれらの例示的な経路選択規則の概要をその具体例とともに示している。これらの経路選択規則は、例えば、インテリジェントルータで生成してもよく、又は他のネットワークエンティティで生成し、インテリジェントルータに伝搬してもよい。更に、表２３の経路選択規則は、説明のために例示的に示しているに過ぎず、他の経路選択規則を用いてワイルドカードを変換してもよい。  Table 23 outlines these exemplary route selection rules for processing wildcards along with specific examples. These routing rules may be generated, for example, by intelligent routers, or may be generated by other network entities and propagated to intelligent routers. Furthermore, the route selection rules in Table 23 are merely shown for illustrative purposes, and wildcards may be converted using other route selection rules.

警告サービス
上述したインテリジェントなコンテンツベースの経路選択は、様々な用途に用いることができ、その１つとして、デジタルビデオ監視システム（digital video surveillance system：以下、ＤＶＳＳという。）がある。例えば、警察又は警備会社等のユーザは、特定の位置のカメラからのビデオクリップを購読予約することができる。カメラは、デジタルビデオクリップを捕捉し、例えばインターネット等、コンテンツベースの経路選択を有するネットワークを介してこれらのクリップを伝送し、ネットワークコアは、購読予約に基づいて、ビデオクリップを処理する。これにより、ユーザは、興味があるビデオクリップを受信し、これらのフィルタリングは、ネットワークを介して配信することができる。ビデオクリップに加えて、例えば、機密保護違反、発火、不正検出等に対する如何なる種類の警告を提供するために、他の如何なる種類のコンテンツを配信してもよい。Warning Service The intelligent content-based route selection described above can be used in a variety of applications, one of which is a digital video surveillance system (hereinafter referred to as DVSS). For example, a user such as a police or security company can subscribe to a video clip from a camera at a specific location. The camera captures digital video clips and transmits these clips over a network with content-based routing, such as the Internet, for example, and the network core processes the video clips based on the subscription. This allows the user to receive video clips of interest and these filtering can be distributed over the network. In addition to the video clip, any other type of content may be distributed, for example, to provide any type of warning for security breaches, firing, fraud detection, and the like.

他の実施例としてカメラは、関連する動きセンサを備えていてもよい。この動きセンサは、動きを検出すると、カメラを起動し、捕捉と同時にビデオクリップをネットワークに伝送し、ネットワークは、コンテンツベースの経路選択を用いて、購読者にビデオクリップをルーティングする。  As another example, the camera may have an associated motion sensor. When the motion sensor detects motion, it activates the camera and transmits the video clip to the network upon capture, which uses content-based routing to route the video clip to the subscriber.

したがって、上述したコンテンツベースの経路選択により、ビデオクリップの処理及びルーティングに関するネットワークの負担を大幅に削減することができる。例えば、各電荷結合素子（charge coupled device：ＣＣＤ）カメラによって生成されたビデオ信号を、デジタルビデオレコーダ（ＤＶＲ）によって、ＤＶＲによって管理された局部記憶装置、ネットワークに取り付けられた広域記憶装置（global storage）、ＤＶＳＳシステム及びＩＤＳＳ管理サーバといった４つの異なる宛先に書き込む必要があるとする。このような膨大なデータ量を搬送するためのネットワーク帯域幅を考慮すると、ＩＤＳＳによって管理されるＣＣＤカメラ又はＤＶＲの容量が顧客の能力要求を満たさない場合がある。したがって、例えば、媒体又は大口顧客のための技術を用いて、帯域幅を制限する必要がある。図２１は、各ＤＶＲが、４台又は１６台のＣＣＤカメラを管理できる監視システムの全体的なアーキテクチャを示している。  Thus, the content-based route selection described above can greatly reduce the network burden associated with video clip processing and routing. For example, a video signal generated by each charge coupled device (CCD) camera is converted into a local storage device managed by the DVR or a global storage device attached to the network by a digital video recorder (DVR). ), It is necessary to write to four different destinations, the DVSS system and the IDSS management server. Considering the network bandwidth for carrying such an enormous amount of data, the capacity of the CCD camera or DVR managed by the IDSS may not meet customer capability requirements. Thus, for example, there is a need to limit bandwidth using media or technology for large customers. FIG. 21 shows the overall architecture of a surveillance system where each DVR can manage 4 or 16 CCD cameras.

アーキテクチャ概要：
図２２は、主に上述した技術に基づいて、図２１に示す監視システムの能力を向上させる２つの拡張例を示している。図２２に示すように、第１の拡張は、ＤＶＲバックボーントラヒックを低減することを目的とし、第２の拡張は、上述したようなデータ配信効率を向上させるための機能と同様なコンテンツベースの経路選択機能を提供するｚボックス（z-box）と呼ばれる機器を用いる。Architecture overview:
FIG. 22 shows two examples of expansion that improve the capability of the monitoring system shown in FIG. 21 mainly based on the above-described technique. As shown in FIG. 22, the first extension aims to reduce DVR backbone traffic, and the second extension is a content-based route similar to the function for improving the data distribution efficiency as described above. A device called a z-box that provides a selection function is used.

ＤＶＲバックボーンのローカルトラヒックの低減：
データ配信スキームが非効率であると、重大な拡張性の問題が生じることがある。すなわち、ＴＣＰベースのプロトコルを用いて、ＤＶＲによって生成される画像ファイルを他のボックスに供給する場合、使用される帯域幅は、ローカルエリアネットワーク（ＬＡＮ）に接続されている機器の数に比例して大きくなる。例えば、ＩＤＳＳについて言えば、同じストリーミングビデオデータは、ネットワークに接続された記憶装置（ＳＡＮ又はＮＡＳ）、ＩＤＳＳモニタ、及び遠隔監視ソフトウェアである各ＤＶＳＳに送信する必要がある。Reducing local traffic on the DVR backbone:
Inefficient data distribution schemes can cause significant scalability problems. That is, when an image file generated by DVR is supplied to another box using a TCP-based protocol, the bandwidth used is proportional to the number of devices connected to the local area network (LAN). Become bigger. For example, for IDSS, the same streaming video data needs to be sent to each storage device (SAN or NAS) connected to the network, IDSS monitor, and each DVSS which is remote monitoring software.

この問題を解決する１つの手法として、各ＤＶＲが１つのみのデータストリームをＬＡＮに発行し、ネットワークに接続された他の機器が購読予約の結果として、このデータストリームを受信するようにしてもよい。この場合、ＤＶＲの出力レートが１０メガビット／秒（Ｍｂｐｓ）であれば、例えば、ネットワーク上に３個の購読機器に情報を提供するために必要な出力レートは、３０Ｍｂｐｓではなく、１０Ｍｂｐｓで足りる。  One approach to solving this problem is that each DVR issues only one data stream to the LAN and other devices connected to the network receive this data stream as a result of a subscription. Good. In this case, if the output rate of the DVR is 10 megabits / second (Mbps), for example, the output rate required to provide information to three subscribed devices on the network is 10 Mbps instead of 30 Mbps.

このような発行−購読構造を実現するために、ＤＶＲボックス又はＤＶＲデータを利用する他の何らかの機器（例えば、ＩＤＳＳ、広域記憶装置）において、上述した事象通知ＡＰＩを用いることができる。この事象通知ＡＰＩは、単純であるが、有効であり、ここでは、ＩＰマルチキャスティング及び復旧プロトコル（recovery protocol）を用いることができる。また、この事象通知ＡＰＩは、上述の発行−購読モデルに基づいて実現でき、このため、他の実施は、コードを変える必要はなく、単に、事象通知ＡＰＩを提供するライブラリの完全版に再リンクさせればよい。  In order to realize such an issue-subscribe structure, the event notification API described above can be used in a DVR box or some other device (for example, IDSS, wide area storage device) that uses DVR data. This event notification API is simple but effective, where IP multicasting and recovery protocol can be used. This event notification API can also be implemented based on the publish-subscribe model described above, so other implementations do not require code changes and simply relink to the full version of the library that provides the event notification API. You can do it.

ＤＶＳＳのプロキシ：
各ＤＶＳＳは、ＤＶＲボックスへの１つの接続（ＴＣＰベース）を確立し、ストリーミングビデオデータを受信することができる。DVSS proxy:
Each DVSS can establish one connection (TCP-based) to the DVR box and receive streaming video data.

図２２に示すように、この手法は、２つの段階によって説明することができる。第１の段階であるステージ１では、ＬＡＮ側において、全てのＤＶＳＳ発信データ（すなわちＤＶＲからＤＶＳＳに供給されるデータ）を処理するためのプロキシサーバ（例えば、ｚボックス１）を準備する。このプロキシサーバは、ＬＡＮ上の全てのＤＶＲデータを購読し、外部のネットワーク（例えば、インターネット）にそのデータを発行する。ＤＶＳＳは、このデータを購読する。したがって、プロキシサーバであるｚボックス１は、購読者エージェント（例えば、エージェント１２８）と、ＤＶＲからデータを集める上述した発行−購読ネットワーク等の発行−購読ネットワークを介してこのデータを発行する発行者エージェント（例えば、エージェント３６）とを提供する。  As shown in FIG. 22, this approach can be described in two stages. Instage 1, which is the first stage, a proxy server (for example, z box 1) for processing all DVSS transmission data (that is, data supplied from DVR to DVSS) is prepared on the LAN side. The proxy server subscribes to all DVR data on the LAN and publishes the data to an external network (for example, the Internet). DVSS subscribes to this data. Therefore, the z-box 1 that is the proxy server includes a subscriber agent (eg, agent 128) and an issuer agent that issues this data via the publish-subscribe network such as the publish-subscribe network described above that collects data from the DVR (For example, the agent 36).

ステージ１により、ＬＡＮ側において、トラヒックを大幅に削減することができるが、特に幾つかの国において、典型的な非対称デジタル加入者線（ＡＤＳＬ）が６４のキロビット／秒（ｋｂｐｓ）のアップリンク速度しか有していないような場合、送信リンクにおけるトラヒックの問題が残る。  Stage 1 can significantly reduce traffic on the LAN side, but in some countries, a typical asymmetric digital subscriber line (ADSL) has an uplink rate of 64 kilobits per second (kbps). If this is the case, the problem of traffic on the transmission link remains.

更に図２２を用いて説明すると、ステージ２では、好ましくは、サービスプロバイダの機械室（machine room）を借り受け又は他の手法で確保し、ここに第２のｚボックス機器、例えばｚボックス２を配設する。例えば、ｚボックス機器は、ハイネットバックボーン（Hi-Net backbone）上に配設してもよい。顧客の敷地内において、ｚボックス２から又はへの単一の接続（トンネル）を設定することができる。  With further reference to FIG. 22, instage 2, the service provider's machine room is preferably borrowed or otherwise secured, and a second z-box device, such as z-box 2, is placed there. Set up. For example, the z-box device may be disposed on a Hi-Net backbone. Within the customer premises, a single connection (tunnel) from or to the z-box 2 can be set up.

この場合、顧客の敷地内のｚボックス２は、購読者エージェント（例えば、エージェント１２８）として機能する。また、ｚボックス２は、経路選択デーモン（例えば、経路選択デーモン２１６）としても機能することができる。ｚボックス２は、購読者エージェントとして（例えば、ハイネット機械室（Hi-Net machine room）内において）、好ましくは、ＤＶＲがｚボックス１を介して発行する情報を購読する。ｚボックス１とｚボックス２間は、上述のような発行−購読ネットワークである。したがって、ｚボックス１は、ＤＶＲからのビデオ情報を発行し、ｚボックス２は、ＤＶＳＳによる要求に応じて、このビデオ情報を購読する。このように、ここに開示する事象通知システムを用いることによって、警告サービスのデータ配信効率が向上する。ｚボックス機器（例えば、ｚボックス１及びボックス２）は、好ましくは、上述のように、この発行−購読ネットワークを介して発行及び購読を行うためのモジュールを備えている。  In this case, the z-box 2 in the customer premises functions as a subscriber agent (eg, agent 128). Thez box 2 can also function as a route selection daemon (for example, the route selection daemon 216). The z-box 2 subscribes to information issued by the DVR via the z-box 1 as a subscriber agent (eg, in a Hi-Net machine room). Between thez box 1 and thez box 2 is the publish-subscribe network as described above. Therefore, thez box 1 issues video information from the DVR, and thez box 2 subscribes to this video information in response to a request by the DVSS. Thus, by using the event notification system disclosed herein, the data distribution efficiency of the warning service is improved. The z-box equipment (e.g., z-box 1 and box 2) preferably comprises a module for issuing and subscribing via this publish-subscribe network as described above.

デジタルコンテンツ配信
上述したインテリジェントなコンテンツベースの経路選択は、購読予約を介したビデオ及び音楽の配信、ソフトウェアの更新等、様々な用途に用いることができる。例えば、ユーザは、例えば、ウィルス除去ソフト等のソフトウェアの更新を購読予約することにより、アップデートされたソフトウェアを自動的に受け取ることができる。他の実施例として、ユーザは、特定のビデオ及び音楽コンテンツを購読予約し、その購読されたコンテンツを自動的に受け取るようにしてもよい。ビデオ及び音楽コンテンツは、例えば、ストリーミングデジタルコンテンツとして受信することができる。更に、ネットワークコアにおける分散処理により、ソフトウェア、ビデオ及び音楽コンテンツを提供するためのサーバの処理負担を実質的に軽減することができる。したがって、他の様々な利点とともに、コンテンツを提供するための同じネットワークインフラストラクチャにおいて、ネットワーク帯域幅を有効に活用することができる。Digital Content Distribution The intelligent content-based route selection described above can be used for a variety of applications, such as video and music distribution via subscriptions, software updates, etc. For example, a user can automatically receive updated software by, for example, subscribing to software updates such as virus removal software. As another example, a user may subscribe to specific video and music content and automatically receive the subscribed content. Video and music content can be received, for example, as streaming digital content. Furthermore, the processing load on the server for providing software, video, and music content can be substantially reduced by the distributed processing in the network core. Thus, network bandwidth can be effectively utilized in the same network infrastructure for providing content, along with various other advantages.

この経路選択を実現するためのアーキテクチャの一具体例を図２３に示す。なお、このアーキテクチャは、好ましくは、ネットワークサービスプロバイダの同じ設備内に配設されている２つのレベルのキャッシュサーバＣｌ、Ｃ２を想定する。但し、キャッシュサーバＣｌのみを用いても、本発明の利益を享受することができる。キャッシュサーバＣｌ、Ｃ２とは、上述した（図１４、図１５及び対応する説明参照）分散ネットワークキャッシングを提供するサーバである。このアーキテクチャは、例えば、２つの段階によって実現される。キャッシュサーバＣ２が存在しないと仮定する第１の段階では、セントラルディストリビュータ４５０とキャッシュサーバＣｌの間において、高速ファイル転送メカニズムを用いて、大きなメディアファイルを転送するために必要なサーバ負荷と時間を減少させる。この高速ファイル転送メカニズムは、好ましくは、セントラルディストリビュータ４５０とキャッシュサーバＣｌの間にルーティングボックス（図２３における４７０）設けることによって実現される。第２の段階では、キャッシュサーバＣ２において、ルーティングボックスを設け、ユーザ（例えば、ユーザマシン４６０）とキャッシュサーバＣ２の間で上述した購読予約メカニズムを実現する。  A specific example of the architecture for realizing this route selection is shown in FIG. Note that this architecture preferably assumes two levels of cache servers Cl, C2 that are located in the same facility of the network service provider. However, even if only the cache server Cl is used, the benefits of the present invention can be enjoyed. The cache servers Cl and C2 are servers that provide the distributed network caching described above (see FIGS. 14 and 15 and the corresponding description). This architecture is realized, for example, in two stages. In the first stage, assuming that no cache server C2 exists, a high-speed file transfer mechanism is used between thecentral distributor 450 and the cache server Cl to reduce the server load and time required to transfer large media files. Let This high-speed file transfer mechanism is preferably realized by providing a routing box (470 in FIG. 23) between thecentral distributor 450 and the cache server Cl. In the second stage, a routing box is provided in the cache server C2, and the above-described subscription reservation mechanism is realized between the user (for example, the user machine 460) and the cache server C2.

ルーティングボックスを用いる利点：
ルーティングボックス４７０は、好ましくは、上述したようなコンテンツベースの経路選択を実現するためのモジュール（例えば、上述したインテリジェントルータ９２）を備える。上述したコンテンツベースの経路選択を実現するルーティングボックス４７０を用いる主な利点は２つある。これらのルーティングボックス４７０を用いた高速ルーティング及びファイル転送ソリューションにより、ＦＴＰやＲＣＰ等の従来のファイル転送プロトコルに比べて５倍程度ファイル転送を加速できる。また、広域ネットワーク（ＷＡＮ）を介した効率的なマルチキャストを実現できる。中央から受信機のグループにデータを送信する場合、このルーティングソリューションでは、ネットワークマルチキャストトポロジーを利用し、ＷＡＮの上でマルチキャスティングトンネルを構築することによってコンテンツ配信速度が加速され、サーバ負荷とネットワーク帯域幅要求を軽減することができる。Advantages of using a routing box:
Therouting box 470 preferably comprises a module (eg, theintelligent router 92 described above) for implementing content-based routing as described above. There are two main advantages of using therouting box 470 that implements the content-based routing described above. With these high-speed routing and file transfer solutions using therouting box 470, file transfer can be accelerated about 5 times compared to conventional file transfer protocols such as FTP and RCP. In addition, efficient multicast via a wide area network (WAN) can be realized. When sending data from a central location to a group of receivers, this routing solution uses a network multicast topology to accelerate the content delivery speed by building a multicasting tunnel over the WAN, and server load and network bandwidth. The demand can be reduced.

アーキテクチャ：
メディアコンテンツは、セントラルディストリビュータからキャッシュサーバＣ１に配信される。キャッシュサーバＣｌは、全てのコンテンツファイルを保存する。各キャッシュサーバＣｌは、全てのコンテンツを保存するために、例えば、数テトラバイトのディスク容量を必要とする。ユーザは（例えば、購読者装置１２２等のユーザマシン４６０を用いて）、コンテンツの一部のみを保存するキャッシュサーバＣ２に対してコンテンツを要求する。キャッシュサーバＣ２は、例えば、数百ギガバイトものディスク容量を必要とする。architecture:
Media content is distributed from the central distributor to the cache server C1. The cache server Cl stores all content files. Each cache server Cl requires, for example, a disk capacity of several tetrabytes in order to store all contents. The user requests the content from the cache server C2 that stores only a part of the content (for example, using theuser machine 460 such as the subscriber device 122). The cache server C2 requires a disk capacity of several hundred gigabytes, for example.

ユーザとＣ２キャッシュの間のファイル転送：
ユーザ４６０が購読予約を発行することによってメディアファイルを要求すると、キャッシュサーバＣ２の１つによって処理される要求されたメディアファイルがＣ２サーバに既にキャッシングされている場合、ファイルは、直ちに提供される。これ以外の場合、購読予約は、キャッシュサーバＣ１に送信され、要求されたファイルは、キャッシュサーバＣ１からキャッシュサーバＣ２に転送される。File transfer between user and C2 cache:
When auser 460 requests a media file by issuing a subscription, the file is immediately served if the requested media file to be processed by one of the cache servers C2 has already been cached on the C2 server. Otherwise, the subscription is sent to the cache server C1, and the requested file is transferred from the cache server C1 to the cache server C2.

ＣｌキャッシュからＣ２キャッシュまでのメディアデータの予備的キャッシング（Pre-caching）：
メディアファイルは、ユーザ購読予約又は購読予約のパターンに基づいて、キャッシュサーバＣ１からキャッシュサーバＣ２に予めキャッシングしてもよい。例えば、キャッシュサーバＣ２に接続するユーザ４６０が主にポップスに関心がある場合、キャッシュサーバＣ１は、ユーザ４６０がキャッシュサーバＣ２に曲を要求する以前に、ポップスの新たな曲をキャッシュサーバＣ２に自動的に供給してもよい。Pre-caching of media data from Cl cache to C2 cache:
The media file may be cached in advance from the cache server C1 to the cache server C2 based on a user subscription reservation or a subscription reservation pattern. For example, if theuser 460 connected to the cache server C2 is mainly interested in pop music, the cache server C1 automatically sends a new pop music to the cache server C2 before theuser 460 requests the music from the cache server C2. May be supplied.

導入段階：
第１の段階は、例えば、ディストリビュータ４５０と、全てのキャッシュサーバＣ１との間のコンテンツルーティングを行う高速ファイル転送メカニズムをインストールする処理を含む。ここでは、キャッシュサーバＣ２は、不要である。この場合全てのユーザ４６０は、キャッシュＣｌに直接接続する。キャッシュサーバＣ１は、ディストリビュータ４５０から定期的に新たなメディアファイルを受け取る。図２４は、第１の段階のアーキテクチャを示している。Introduction phase:
The first stage includes, for example, a process of installing a high-speed file transfer mechanism that performs content routing between thedistributor 450 and all the cache servers C1. Here, the cache server C2 is unnecessary. In this case, allusers 460 connect directly to the cache Cl. The cache server C1 periodically receives new media files from thedistributor 450. FIG. 24 shows the first stage architecture.

なお、図２４において、ディストリビュータ４５０は、上述したインテリジェントなコンテンツベースの経路選択技術に基づき、ルーティングボックス４７０に新たなメディアファイルを一回だけ送信する。したがって、ディストリビュータ４５０の負担が軽減される。ルーティングボックス４７０は、高速ファイル転送メカニズムを用いて、各キャッシュサーバＣ１にファイルを出力する。この場合、受信機４６０の側では、更なるルーティングボックスは不要である。これに代えてキャッシュサーバＣ１のために他の種類のサーバを用いてもよい。  In FIG. 24, thedistributor 450 transmits a new media file to therouting box 470 only once based on the intelligent content-based route selection technique described above. Therefore, the burden on thedistributor 450 is reduced. Therouting box 470 outputs a file to each cache server C1 using a high-speed file transfer mechanism. In this case, no further routing box is required on thereceiver 460 side. Alternatively, another type of server may be used for the cache server C1.

図２５は、第２段階の実施例のアーキテクチャを示している。この実施例に示す第２の段階では、好ましくは、カーネルを実装するルーティングボックス４７０を用いて、データをルーティング及び送信している。カーネルレイヤソリューションは、バッファコピーを低減し、コンテキスト切換時間を短縮するため、ファイルを送る際のオーバヘッドを更に減少させる。更に、第２の段階のソリューションでは、図２５に示すように、キャッシュサーバＣ２をアーキテクチャに追加する。また、図２５に示すように、好ましくは、Ｃ２側において、サービスプロバイダネットワーク内の同じ位置に、ルーティングボックス４７０が追加されている。これにより、帯域幅要件が大幅に軽減され、帯域幅を数百分の一にできる可能性もある。  FIG. 25 shows the architecture of the second stage embodiment. In the second stage shown in this example, data is routed and transmitted preferably using arouting box 470 that implements the kernel. The kernel layer solution further reduces overhead when sending files to reduce buffer copy and reduce context switch time. Further, in the second stage solution, as shown in FIG. 25, a cache server C2 is added to the architecture. Also, as shown in FIG. 25, arouting box 470 is preferably added at the same position in the service provider network on the C2 side. This can significantly reduce bandwidth requirements and potentially reduce bandwidth to hundreds of times.

図２５に示すように、キャッシュサーバＣ１とキャッシュサーバＣ２の間で転送されるファイルは、キャッシュサーバＣ１に関連付けられるルーティングボックス４７０と、キャッシュサーバＣ２に関連付けられるルーティングボックス４７０とを介して転送される。このように、これらのルーティングボックス４７０を用いて、キャッシュサーバＣ１、Ｃ２の間において、高速ルーティング及びファイル転送ソリューションが実現される。  As shown in FIG. 25, a file transferred between the cache server C1 and the cache server C2 is transferred via arouting box 470 associated with the cache server C1 and arouting box 470 associated with the cache server C2. . Thus, using theserouting boxes 470, a high-speed routing and file transfer solution is realized between the cache servers C1 and C2.

サービス品質の管理
上述したインテリジェントなコンテンツベースの経路選択は、例えば、特定の配信を保証するコンテンツのルーティングのために用いることができる。例えば、サービス品質保証制度（service level agreement：以下、ＳＬＡという。）に基づいて、ＩＳＰ又はコンテンツプロバイダは、サービス品質（quality of service：以下、ＱｏＳという。）を保証するために帯域幅を確保することができる。これは、上述したコンテンツベースのインテリジェントルーティングによって効率的に実現される。Quality of Service Management The intelligent content-based routing described above can be used, for example, for routing content that guarantees specific delivery. For example, based on a service level agreement (hereinafter referred to as SLA), an ISP or a content provider reserves bandwidth to guarantee quality of service (hereinafter referred to as QoS). be able to. This is efficiently achieved by the content-based intelligent routing described above.

アーキテクチャ：
コンテンツ配信におけるＱｏＳを保証するために、少なくとも２つの可能な構成がある。第１の構成では、複数のリンクを１つ以上の電話会社（telephone company：以下、ＴＥＬＣＯという。）のネットワークに接続する。第２の構成では、ＴＥＬＣＯネットワークへの１つのネットワークリンクだけを用いる。図２６に示す実施例では、２つのレイヤのルーティングボックス（以下、Ｒボックスともいう。）を設けている。Ｒボックス１は、データパケットのコンテンツに基づいて、Ｒボックス２とＲボックス３にパケットをルーティングする。Ｒボックス２とＲボックス３は、異なるネットワークリンク（例えば、Ｌ１−Ｌ４）にデータパケットをルーティングする。各リンクは、ＴＥＬＣＯネットワークに接続されている。プレミアムユーザ（premium customers）のための帯域幅を確保するために、最も高いＳＬＡに対応する顧客用に生成されたデータパケットは、最も高い帯域幅（最も高い優先順位）でリンクにルーティングされ、これにより、これらの顧客のための特定のＱｏＳが保証される。architecture:
There are at least two possible configurations to guarantee QoS in content distribution. In the first configuration, a plurality of links are connected to a network of one or more telephone companies (hereinafter referred to as TELCO). In the second configuration, only one network link to the TELCO network is used. In the embodiment shown in FIG. 26, two layers of routing boxes (hereinafter also referred to as R boxes) are provided. TheR box 1 routes the packet to theR box 2 and theR box 3 based on the contents of the data packet.R box 2 andR box 3 route data packets to different network links (eg, L1-L4). Each link is connected to a TELCO network. To ensure bandwidth for premium customers, data packets generated for customers with the highest SLA are routed to the link with the highest bandwidth (highest priority). Guarantees a specific QoS for these customers.

図２７に示す実施例では、Ｒボックス１は、Ｒボックス２及びＲボックス３にデータパケットをルーティングする。Ｒボックス２とＲボックス３は、更に異なる通信リンクにデータパケットをルーティングし、これらの通信リンクは、全てＲボックス４に接続されている。Ｒボックス４は、４つのリンクからそれぞれのリンクのＱｏＳレベルに基づいて、データパケットを受信する。そして、Ｒボックス４は、ネットワークリンク（例えば、Ｌ５）を介して、インターネットＩＳＰにデータパケットを送信する。このシステムは、各リンクからデータを受け取るための様々なアルゴリズムを実装することによって、各リンクについて、帯域幅を動的に割り当てることができ、マルチリンク構成より優れたＱｏＳ管理を行うことができる。  In the embodiment shown in FIG. 27,R box 1 routes data packets toR box 2 andR box 3. TheR box 2 and theR box 3 route data packets to further different communication links, and these communication links are all connected to theR box 4. TheR box 4 receives data packets from the four links based on the QoS level of each link. TheR box 4 transmits a data packet to the Internet ISP via a network link (for example, L5). By implementing various algorithms for receiving data from each link, the system can dynamically allocate bandwidth for each link and can perform better QoS management than a multi-link configuration.

技術：
ＱｏＳ保証には、インテリジェントで分散型の上述したコンテンツベースの経路選択技術を利用することができる。ルーティングされる各パケットは、コンテンツベースの経路選択のためにタグが付される。このソリューションによって、他の様々な利点とともに、ＡＳＰ／コンテンツプロバイダのためのＱｏＳの展開が経済的に可能になる。Technology:
For QoS guarantees, the intelligent and distributed content-based routing technology described above can be used. Each routed packet is tagged for content-based routing. This solution economically enables QoS deployment for ASP / content providers, along with various other advantages.

利点：
このソリューションにより、インターネット接続サービス業者（例えば、ＩＤＣ）又はコンテンツプロバイダ（例えば、メディアオンデマンドの（ＭＯＤ）サービスプロバイダ）は、顧客毎に、それらのＳＬＡＳに基づいて個別に帯域幅を確保できる。advantage:
This solution allows Internet service providers (eg, IDCs) or content providers (eg, media on demand (MOD) service providers) to reserve bandwidth for each customer based on their SLAS.

リアルタイムの警告：
警告に異なる優先順位を付すことができる。例えば、セキュリティ及び火災警報に最も高い優先順位を与え、ニュースの告知には、低い優先順位を与えることができる。ＱｏＳルーティングを行わなければ、優先度が低い警告及び通信によってＡＳＰのネットワーク帯域幅を占領され、最優先の警告がリアルタイムで購読者に届かないこともある。このソリューションは、このような事態の発生を防ぐ。また、警告は、それぞれのＳＬＡＳに基づいて、各顧客に送信することもできる。プレミアムユーザがより多くの料金を支払うことにより、これらのユーザに対してより広い帯域幅を割り当てるようにしてもよい。Real-time alert:
Warnings can have different priorities. For example, security and fire alarms can be given the highest priority and news announcements can be given a lower priority. Without QoS routing, low priority alerts and communications can occupy the ASP network bandwidth, and top priority alerts may not reach subscribers in real time. This solution prevents this from happening. Alerts can also be sent to each customer based on their respective SLAS. Premium users may pay more to allocate more bandwidth to these users.

実時間データ配信：
例えば、ビデオオンデマンド（ＶＯＤ）、ＭＯＤ、及びＩＰを介した音声送信（ＶｏＩＰ）等の幾つかの用途では、帯域幅の利用可能性は、サービスの品質に影響する。このソリューションでは、上述のように、パケットのコンテンツを検査することによって、メッセージの種類に基づいてデータパケットをルーティングできる。帯域幅に大きく影響される用途では、それらのデータパケットをより高い優先順位のリンクにルーティングするとよい。メッセージの種類に加えて、購読者のＳＬＡレベルに基づいて、様々な購読者にデータパケットをルーティングしてもよい。このソリューションを用いることにより、ＳＬＡがより高い顧客に対しては、パケットをより高いレベルのリンクにルーティングできる。Real-time data distribution:
For some applications, such as, for example, video on demand (VOD), MOD, and voice transmission over IP (VoIP), bandwidth availability affects quality of service. In this solution, as described above, data packets can be routed based on the type of message by examining the contents of the packet. In applications that are greatly affected by bandwidth, these data packets may be routed to higher priority links. In addition to the message type, data packets may be routed to various subscribers based on the subscriber's SLA level. Using this solution, packets can be routed to higher level links for customers with higher SLA.

また、このソリューションは、ソフトウェア又はウィルス対策のための更新にも利用できる。例えば、音声用ドライバファイルは、優先順位が低いリンクにルーティングし、アンチウィルスファイルは、優先順位が高いリンクにルーティングすることにより、ウィルス対策のための更新をリアルタイムで行うことができる。  This solution can also be used for software or anti-virus updates. For example, an audio driver file is routed to a link having a low priority, and an anti-virus file is routed to a link having a high priority, whereby updating for anti-virus can be performed in real time.

コンテンツベースのフィルタリング：
図２８に示すように、コロケーションサービスを用いることにより及びＲボックスをＴＥＬＣＯネットワーク内部に配設することにより、システムは、ＩＳＰの外部でフィルタリング及び動的なキャッシングを実行することができる。ＴＥＬＣＯネットワーク内部のＲボックスを用いて、上述したコンテンツのフィルタリング技術に基づいて、データをフィルタリングすることにより、ＩＤＣ／ＩＳＰネットワークにおけるトラヒックを減少させることができる。これにより、例えば、サービス妨害攻撃や不正なデータアクセス等のハッカーアタックを防止することができる。また、Ｒ−ボックスは、要求のコンテンツを検査する能力により、静的及び動的なウェブデータのためのキャッシングボックスとしても機能する。このソリューションは、例えば、機密保護を可能にし、ＴＥＬＣＯとＩＳＰの間のネットワーク帯域幅を節約し、ＩＳＰサーバの負荷を軽減できる等の利点がある。Content-based filtering:
As shown in FIG. 28, the system can perform filtering and dynamic caching outside the ISP by using a collocation service and by placing the R-box inside the TELCO network. By using the R box inside the TELCO network and filtering the data based on the content filtering technique described above, traffic in the IDC / ISP network can be reduced. As a result, for example, it is possible to prevent a hacker attack such as a denial of service attack or unauthorized data access. The R-box also functions as a caching box for static and dynamic web data due to its ability to inspect the requested content. This solution has advantages such as enabling security, saving network bandwidth between TELCO and ISP, and reducing the load on the ISP server.

選択的なマルチキャスティングによるキャッシング
メッセージの持続性とは、メッセージを保存し、後にこの保存されたメッセージを読み出すことができる性質を指す。例えば電子メールを始めとする多くの特定の用途では、通常、ネットワークを介して通信されるメッセージについて、長いメッセージ持続性が必要とされる。ネットワーク障害が発生しない理想的な条件では、常時接続された購読者は、これらの特定の用途において必要とされる以上の如何なる持続も求めない。しかしながら、現実には、メッセージは、ネットワークを介して伝送されている間に様々な理由のために「失われる」ことがある。この理由としては、例えば、（１）ネットワーク又はユーザ側における故障又はバッファオーバフローや（２）ユーザが自らネットワーク接続を切断した後、所定の期間経過後に再び接続する場合等がある。Caching by selective multicasting Message persistence refers to the property that a message can be stored and the stored message can be retrieved later. Many specific applications, such as e-mail, typically require long message persistence for messages communicated over a network. In ideal conditions where no network failure occurs, always-connected subscribers do not require any persistence beyond what is required in these particular applications. In reality, however, messages may be “lost” for various reasons while being transmitted over the network. The reason for this is, for example, (1) a failure or buffer overflow on the network or user side, or (2) a case where the user disconnects the network and then reconnects after a predetermined period.

この実施例における事象通知プラットフォームの持続モデルは、短期持続と長期持続の２つのレベルに分割される。短期持続は、ネットワーク輻輳又は短期的なリンク障害のために失われたパケットを復元する。長期持続は、例えば、ユーザ接続の障害、ユーザ装置の障害、アプリケーションの障害及び／又はより長い期間ネットワーク内の障害等を含む他の障害に起因して失われたパケットを復元する。以下では、これらの２つのスキームの具体例について説明する。  The event notification platform persistence model in this embodiment is divided into two levels: short-term persistence and long-term persistence. Short duration restores packets lost due to network congestion or short term link failures. Long-lasting recovers lost packets due to other failures, including, for example, user connection failures, user device failures, application failures and / or failures in the network for longer periods of time. Hereinafter, specific examples of these two schemes will be described.

短期持続：データ再送及びフロー制御
データネットワークにおいては、データ損失の原因は、単に、リンク障害とバッファオーバフローの２つに分類できる。事象通知システムについて信頼できるチャンネルを提供するためには、これらの問題を解決する必要がある。リンク障害については、順方向誤り訂正（ＦＥＣ）スキームを実行して、リンク障害によって引き起こされる幾つかのエラーを修正することができる。ここで、エラーが深刻であり、如何なるＦＥＣスキームでもエラーを修正できないような場合、パケットを復元するための更なるスキームを提供する必要がある。また、バッファオーバフローの発生を防止する必要もある。データネットワークにおいて、このような問題を避けるためには、通常、フロー制御スキームが用いられる。Short-term persistence: data retransmission and flow control In data networks, the cause of data loss can simply be divided into two categories: link failure and buffer overflow. In order to provide a reliable channel for event notification systems, these problems need to be solved. For link failures, a forward error correction (FEC) scheme can be performed to correct some errors caused by link failures. Here, if the error is severe and cannot be corrected by any FEC scheme, there is a need to provide a further scheme to recover the packet. It is also necessary to prevent the occurrence of buffer overflow. In order to avoid such problems in data networks, a flow control scheme is usually used.

短期持続スキームにおいては、好ましくは、伝送制御プロトコル（Transmission Control Protocol：以下、ＴＣＰという。）トンネルを用いて、ホップバイホップ方式でイベントルータ（例えば、インテリジェントルータ１２）を接続する。信頼できる転送プロトコル（例えば、ＲＭＴＰ）を用いる代わりに、信頼できるレイヤ−２トンネルを用いる理由は複数ある。短期持続スキームでは、好ましくは、事象通知システムにおいて、メッセージがフィルタ規則を満たさない場合、メッセージは、ルータにおいて、無視される。この結果、受信ルータは、多くの場合、ソースシーケンスナンバー（Source Sequence Number：ＳＳＮ）等のスキームを用いても、パケットの損失を検出できない。また、全ての受信ルータが、受信した各パケットについて肯定応答を行うことも望ましくない。このような処理を行うと、肯定応答のオーバロード（すなわち、ＡＣＫエクスプロージョン（ACK-explosion））が生じる。更にバッファオーバフローを避けるために短期持続モデルは、フロー制御スキームを実現し、これにより、ルータのバッファ容量が一杯になる前に、ルータは、自らにメッセージを送る隣接するルータに、メッセージの供給の速度を遅くするよう要求することができる。これらのスキームは、ＴＣＰによってカバーされている。  In the short-term persistence scheme, the event router (for example, the intelligent router 12) is preferably connected in a hop-by-hop manner using a transmission control protocol (hereinafter referred to as TCP) tunnel. There are several reasons for using a reliable layer-2 tunnel instead of using a reliable transport protocol (eg, RMTP). In the short duration scheme, preferably in the event notification system, if the message does not satisfy the filter rules, the message is ignored at the router. As a result, in many cases, the receiving router cannot detect a packet loss even if a scheme such as a source sequence number (SSN) is used. It is also undesirable for all receiving routers to acknowledge each received packet. When such processing is performed, an overload of an acknowledgment (that is, ACK explosion) occurs. Furthermore, to avoid buffer overflow, the short-lived model implements a flow control scheme that allows a router to provide message delivery to neighboring routers that send messages to itself before the router's buffer capacity is full. You can request to slow down. These schemes are covered by TCP.

ＴＣＰ伝送ポリシ：
短期持続スキームにおいて用いられるＴＣＰにおいては、好ましくは、データの送信側で、局所的に送信ウィンドウを用いて、再送処理されたデータを監視する。送信ウィンドウを用いる目的は、２つある。第１に、送信ウィンドウにより、送信側は、データが受信機によって正しく受信されたことを明示的に確認でき、第２に、送信ウィンドウにより、チャンネル容量をより有効に活用できる。ＴＣＰにおいては、送信側が送信した各バイトは、暗示的又は明示的に肯定応答を受ける必要がある。送信ウィンドウは、送信側が、送信され、肯定応答されたデータを監視するのに役立つ。送信側は、動作を止めて、先のパケットに関する肯定応答を待機する必要なく、送信ウィンドウ内でデータを送信できるので、また、送信ウィンドウにより、チャンネルの利用効率を向上させることができる。一旦、前のデータが肯定応答されると、ウィンドウは、自動的に進められる。TCP transmission policy:
In TCP used in the short-term persistence scheme, it is preferable to monitor the retransmitted data locally using a transmission window on the data transmission side. There are two purposes for using the send window. First, the transmission window allows the transmission side to explicitly confirm that the data has been correctly received by the receiver, and second, the transmission window can more effectively utilize the channel capacity. In TCP, each byte sent by the sender needs to be implicitly or explicitly acknowledged. The transmission window helps the sender to monitor the transmitted and acknowledged data. Since the transmission side can transmit data within the transmission window without having to stop the operation and wait for an acknowledgment regarding the previous packet, the transmission window can improve the utilization efficiency of the channel. Once the previous data is acknowledged, the window is automatically advanced.

また、ＴＣＰでは、受信ウィンドウも維持される。受信ウィンドウは、好ましくは、データ受信端末において、使用可能なバッファ容量を示すために用いられる。使用可能なバッファ容量が送信側に送られ、これにより送信側は、受信側におけるバッファオーバフローをどのように回避できるかを知ることができる。  In TCP, the reception window is also maintained. The receive window is preferably used to indicate the available buffer capacity at the data receiving terminal. The available buffer capacity is sent to the sender, which allows the sender to know how to avoid buffer overflow at the receiver.

ＴＣＰ輻輳制御：
ＴＣＰは、エンドツーエンドトランスポートプロトコルとして設計されているので、短期持続スキームで利用されたＴＣＰは、発行−購読ネットワーク内におけるバッファオーバフローの問題も解決する。この問題を解決するために、短期間の持続モデルのために用いられるＴＣＰは、好ましくは、第３のウィンドウである輻輳ウィンドウ（congestion window）を用いる。送信側は、輻輳ウィンドウを用いて、パスに沿ったルータにおける最大のバッファ容量を推定することができる。簡潔に言えば、送信側がパケットの損失を検出すると輻輳ウィンドウのサイズが縮小され、逆にパケットの損失が検出されないと、輻輳ウィンドウのサイズが拡大される。TCP congestion control:
Since TCP is designed as an end-to-end transport protocol, TCP utilized in the short-lasting scheme also solves the problem of buffer overflow in publish-subscribe networks. To solve this problem, the TCP used for the short-term persistence model preferably uses a third window, the congestion window. The sender can use the congestion window to estimate the maximum buffer capacity at the router along the path. In short, the size of the congestion window is reduced when the transmission side detects a packet loss, and conversely, the size of the congestion window is increased when no packet loss is detected.

長期持続：持続的なチャンネルのキャッシング
チャンネルは、（例えば、上述のように）持続的であっても又はリアルタイムであってもよい。リアルタイムチャンネルは、実時間においてのみ有用であり、アプリケーション固有の如何なる持続要求も有さないデータを送信する。持続チャンネルは、持続タイムフレームＴの間、ネットワークを介して送受されるデータを保存する。換言すれば持続チャンネルの持続性は、タイムフレームＴの間、保証される。このデータの持続性は、例えば、チャンネルの持続期間の間、それぞれのエッジノードでデータをキャッシングすること、障害が生じた条件下で、ユーザにトランスペアレントなキャッシュからのデータを検索すること、ユーザがキャッシュから明示的にデータを読み出すことができるようにすること、ルータ障害に対する保護及びルータの間で信頼できるトンネルを確立することにより、ネットワークを介したデータのフローを持続的にすること、及び複製によって、障害に対してチャンネル成分を保護すること等によって実現される。Long-lasting: persistent channel caching Channels may be persistent (eg, as described above) or real-time. Real-time channels are useful only in real time and transmit data without any application specific persistence requirements. The persistent channel stores data transmitted and received over the network for a sustained time frame T. In other words, the persistence of the persistent channel is guaranteed during the time frame T. This data persistence can be achieved, for example, by caching data at each edge node for the duration of the channel, retrieving data from a cache that is transparent to the user under fault conditions, Allows data to be explicitly read from the cache, protects against router failures and establishes a reliable tunnel between routers to make the flow of data through the network persistent and replicate This is realized by protecting the channel component against failure.

したがって、後述するように、長期持続スキームにより、購読者の端末に障害が生じ、持続的なチャンネルのためのタイムフレームＴ内に再び復帰すると、持続的なチャンネルに登録された購読者は、直前のタイムフレーム「Ｘ」（Ｘ＜Ｔ）の間、ネットワークにおいてキャッシングされた古いデータを検索することができる。  Therefore, as described below, when a subscriber's terminal fails due to a long-lasting scheme and returns again within the time frame T for the persistent channel, the subscriber registered in the persistent channel During the time frame “X” (X <T), old data cached in the network can be retrieved.

長期持続スキームにおいては、購読者アプリケーション（例えば、アプリケーション１２６）は、関連する購読者エージェント（例えば、エージェント１２８）から好ましくは、明示的に、データ（例えば、メッセージ）をプルすることができる。上述のように、エージェントは、プロキシを利用でき又はプロキシによって実現することができる。エージェント又はプロキシがネットワーク内の障害から復帰した後、このエージェントは、キャッシュから、自らがエッジルータから切断されていた期間に対応するデータを好ましくはトランスペアレントに検索する。また購読者は、長期持続スキームにおいて、好ましくは、直前のＴタイムフレームに含まれるデータのみにアクセスすることができる。このため、好ましくは、エージェント（又はプロキシ）が接続されているエッジルータに関して、時間が判定される。検索されたキャッシングされたデータは、好ましくは帯域外で配信され、実時間配信は保証されない。長期持続スキームの実施例は、クラッシュから復帰した、又はエッジルータ（例えば、エッジルータ１６）から切断された既存の購読者を対象とするものである。新たな購読者は、キャッシングされた情報を得ることはできない。  In a long-lasting scheme, a subscriber application (eg, application 126) can preferably explicitly pull data (eg, a message) from an associated subscriber agent (eg, agent 128). As described above, the agent can use or be implemented by a proxy. After an agent or proxy recovers from a failure in the network, the agent retrieves data, preferably transparently, from the cache that corresponds to the period during which it was disconnected from the edge router. Also, the subscriber can access only the data contained in the immediately preceding T time frame in the long-lasting scheme. For this reason, the time is preferably determined for the edge router to which the agent (or proxy) is connected. The retrieved cached data is preferably delivered out-of-band and real-time delivery is not guaranteed. Examples of long-lasting schemes are for existing subscribers who have recovered from a crash or disconnected from an edge router (eg, edge router 16). New subscribers will not get the cached information.

持続性の定義：
購読者に対する（タイムフレームＴによる）期限付きの持続性は、発行−購読ネットワークから直前のタイムフレームＴに含まれるデータを読み出すことができる能力として定義される。購読者がネットワークから切断されると、購読者の不在の間に受け取られた持続的なチャンネル上の如何なるデータも、（データの受信から）タイムフレームＴの間、ネットワーク内に保存される。購読者がタイムフレームＴ内に復帰した場合、購読者は、如何なるデータも失わない。但し、購読者がＴから２Ｔの期間内に復帰した場合、購読者は、データを失う可能性がある。また、購読者が２Ｔを過ぎて復帰した場合、購読者に対しては、好ましくは、それまでの如何なるデータも保証されない。Definition of persistence:
Timed persistence (by time frame T) for a subscriber is defined as the ability to retrieve the data contained in the previous time frame T from the publish-subscribe network. When a subscriber is disconnected from the network, any data on the persistent channel received during the absence of the subscriber is stored in the network during the time frame T (from receipt of the data). If the subscriber returns within the time frame T, the subscriber will not lose any data. However, if the subscriber returns within a period of 2T from T, the subscriber may lose data. Also, if the subscriber returns after 2T, the subscriber is preferably not guaranteed any previous data.

上述の定義により、購読者をリーフとする発行−購読ネットワークツリーは、購読者が切断された後、タイムフレームＴの間保持され、その後に購読者を切り離す必要がある。これにより、購読者が切断された後、タイムフレームＴの間に受信された新たなデータは、タイムフレームＴが経過するまで保持される。  According to the above definition, the publish-subscribe network tree with the subscriber as a leaf is maintained for a time frame T after the subscriber is disconnected, after which the subscriber needs to be disconnected. Thus, after the subscriber is disconnected, new data received during the time frame T is held until the time frame T elapses.

アーキテクチャ：
図２９は、キャッシングによって持続性を実現する発行−購読ネットワークの一部を示すブロック図である。図２９に示すように、ネットワークは、コアルーティングノード５４８とエッジルーティングノード５４５とを備える。各ルーティングノードは、図４を用いて上述したように、好ましくは、インテリジェントルータ９２（エッジルーティングノードと共に示す）と、従来のバックボーンルータ（図示せず）とを備える。持続的なチャンネルのためのキャッシングを行う必要がある各インテリジェントルータ９２は、図２９に示すように、好ましくは同じ場所にキャッシュマネージャ２１８を備える。キャッシュマネージャ２１８については、図８を用いて上述した通りである。インテリジェントルータ９２は、好ましくは、失われたデータを読み出し又はルータ故障から復元するための短期的な持続性を実現する。キャッシュマネージャ２１８は、チャンネルにおける長期的な持続を実現するために、データをキャッシングする。キャッシュマネージャ２１８は、好ましくは、キャッシュ５４０内にこのデータをキャッシングする。キャッシュ５４０は、好ましくは、メモリとディスク（図示せず）を含んでいる。architecture:
FIG. 29 is a block diagram illustrating a portion of a publish-subscribe network that provides persistence through caching. As shown in FIG. 29, the network includes acore routing node 548 and anedge routing node 545. Each routing node preferably comprises an intelligent router 92 (shown with an edge routing node) and a conventional backbone router (not shown), as described above with reference to FIG. Eachintelligent router 92 that needs to perform caching for persistent channels comprises acache manager 218, preferably in the same location, as shown in FIG. Thecache manager 218 is as described above with reference to FIG.Intelligent router 92 preferably provides short-term persistence for retrieving lost data or recovering from a router failure. Thecache manager 218 caches data to achieve long-term persistence in the channel.Cache manager 218 preferably caches this data in cache 540. Cache 540 preferably includes memory and disk (not shown).

長期持続のためにデータをキャッシングするために、インテリジェントルータ９２に対して、キャッシュマネージャ２１８を設けることには、例えば次のような利点がある。キャッシングされたデータにインデックスを付すための負荷が大きい演算は、独立したプロセッサによって実行でき、したがって、ルーティング及びフィルタリングプロセッサの性能には影響がなく、及びキャッシングされたデータを定期的にディスクに移動するためのディスクＩ／Ｏ動作も他のプロセッサによって実行でき、これにより、ルーティングとフィルタリングからサイクルが奪われることを防ぎ、エッジルータが定期的な入出力動作を行う必要を無くすことができる。  Providing thecache manager 218 for theintelligent router 92 to cache data for long-lasting has the following advantages, for example. An expensive operation to index the cached data can be performed by an independent processor, and therefore does not affect the performance of the routing and filtering processor, and periodically moves the cached data to disk. Disk I / O operations can be performed by other processors, thereby preventing the cycle from being lost from routing and filtering, and eliminating the need for the edge router to perform periodic input / output operations.

また、図２９に示すエージェント１２８は、図５を用いて上述したように、好ましくは、購読者装置１２２（図２５Ａでは示していない）内に設けられる。エージェント１２８は、キャッシュマネージャ２１８と通信し、キャッシュ５４０からデータを検索し、検索したデータを受け取り、検索したデータを組織化する。上述のように、エージェント１２８は、プロキシを利用でき又はプロキシによって実現することができる。  Also, theagent 128 shown in FIG. 29 is preferably provided in the subscriber device 122 (not shown in FIG. 25A), as described above with reference to FIG.Agent 128 communicates withcache manager 218 to retrieve data from cache 540, receive the retrieved data, and organize the retrieved data. As described above,agent 128 can utilize or be implemented by a proxy.

障害が発生しない条件下では、エッジルータノード５４５のみが関連するキャッシュマネージャ２１８を有していればよい。しかしながら、図２９には示していないが、長期持続スキームでは、障害を予期しているので、好ましくは、エッジルーティングノード５４５より上流側にある第１のレベルのコアルーティングノード５４８のそれぞれがデータを保存するためのキャッシュマネージャ２１８を備えている。上流とは、エージェント１２８から遠ざかる（すなわち、購読者装置１２２から遠ざかる）方向である。第１のレベルの上流コアルーティングノードとは、エッジルーティングノード５４５より上流側に隣接するルーティングノードを意味する。発行−購読ネットワークは、多くの場合、複数の第１のレベルのコアルーティングノードを含んでいるが、図２９では、１つの第１のレベルのコアルーティングノード、すなわちコアルーティングノード５４８のみを示している。上述のように、キャッシュマネージャ２１８は、自らが存在するネットワークノードにおいて、データのローカルなキャッシングを実現する。したがって、例えば、コアルーティングノード５４８を含む様々なコアルーティングノードに存在するキャッシュマネージャ２１８の動作は、ネットワークコア内のデータの分散型のキャッシングを実現する。この分配型のキャッシングは、エッジルーティングノードのキャッシングにバックアップを提供する。  Under conditions where no failure occurs, only theedge router node 545 need have an associatedcache manager 218. However, although not shown in FIG. 29, the long-lasting scheme expects a failure, and preferably each of the first levelcore routing nodes 548 upstream of theedge routing node 545 receives data. Acache manager 218 is provided for saving. Upstream is the direction away from the agent 128 (ie away from the subscriber device 122). The first level upstream core routing node means a routing node adjacent to the upstream side of theedge routing node 545. Although the publish-subscribe network often includes multiple first level core routing nodes, FIG. 29 shows only one first level core routing node, ie,core routing node 548. Yes. As described above, thecache manager 218 realizes local caching of data in the network node where thecache manager 218 exists. Thus, for example, the operation of thecache manager 218 present at various core routing nodes, including thecore routing node 548, provides distributed caching of data within the network core. This distributed caching provides a backup for edge routing node caching.

図３０は、上流ルータ（例えば、コアルーティングノード５４８）におけるバックアップキャッシングを説明する図である。各長期持続スキームにおいては、各キャッシュは、次の上流ルータのキャッシュによってバックアップされる。上流のキャッシュは、全ての受信データを保存し、下流の次のレベルの全てのエッジルータのキャッシュのバックアップとして機能する。上流のキャッシュのデータは、好ましくは、エッジルータキャッシングと同じメカニズムを用いて保存される。  FIG. 30 is a diagram for explaining backup caching in an upstream router (for example, the core routing node 548). In each long-lasting scheme, each cache is backed up by the next upstream router cache. The upstream cache stores all received data and serves as a backup for the cache of all downstream edge routers. Upstream cache data is preferably stored using the same mechanism as edge router caching.

図３１は、持続的なチャンネルのキャッシングのためのアーキテクチャを示しており、このアーキテクチャでは、好ましくは、以下のような４つの異なるモジュールに亘る機能を提供する。キャッシュマネージャ２１８は、好ましくは、インテリジェントルータ９２を通過するデータを保存するサーバ処理を行う。ルータキャッシュＡＰＩ５５２は、好ましくは、インテリジェントルータ９２からキャッシュマネージャ２１８への制御、例えば、キャッシュを作成及び消去する処理に関連する全てのアクセスのためのライブラリである。エージェント（又は、プロキシ）キャッシュＡＰＩ５５４は、好ましくは、エージェント１２８（又はエージェント１２８プロキシ）からキャッシュマネージャ２１８への制御、例えば、データの検索に関連する全てのアクセスのためのライブラリである。エージェント１２８（又はプロキシ）は、好ましくは、キャッシュ５４６から検索されたデータを収集し、このデータを組織化する。  FIG. 31 illustrates an architecture for persistent channel caching, which preferably provides functionality across four different modules as follows. Thecache manager 218 preferably performs server processing for storing data passing through theintelligent router 92. Therouter cache API 552 is preferably a library for all access related to control from theintelligent router 92 to thecache manager 218, eg, the process of creating and clearing the cache. The agent (or proxy)cache API 554 is preferably a library for all access related to control from the agent 128 (oragent 128 proxy) to thecache manager 218, eg, retrieval of data. Agent 128 (or proxy) preferably collects the retrieved data fromcache 546 and organizes this data.

図３１を用いて、これらの４つのモジュールのインタラクションを説明する。エージェント１２８とインテリジェントルータ９２は、好ましくは、キャッシュＡＰＩライブラリ５５２、５５４を介してキャッシュにアクセスする。キャッシュＡＰＩライブラリ５５２、５５４は、キャッシュ５４６を初期化し、主語のためにキャッシュを作成及び消去し、キャッシュアドレスを検索し、及び最も重要な機能としてキャッシュ５４６からデータを検索するためのＡＰＩを提供する。経路選択デーモン２１６は、好ましくは、キャッシュＡＰＩ５５２を介さず、データパスを介して、キャッシュマネージャ２１８にデータを送信する。キャッシュＡＰＩ５５２、５５４は、データ検索を含む全ての制御メッセージについて、好ましくは制御パスを用いる。  The interaction of these four modules will be described with reference to FIG.Agent 128 andintelligent router 92 preferably access the cache viacache API libraries 552, 554.Cache API libraries 552, 554 provide APIs to initializecache 546, create and delete caches for the subject, retrieve cache addresses, and retrieve data fromcache 546 as the most important function. . Therouting daemon 216 preferably sends data to thecache manager 218 via the data path, not via thecache API 552. Thecache APIs 552, 554 preferably use the control path for all control messages including data retrieval.

キャッシュマネージャ−キャッシュ管理：
図３２に示すように、キャッシュマネージャ２１８が新たなチャンネルに遭遇するとキャッシュマネージャ２１８は、好ましくは情報サーバ（例えば、上述したサーバ１５２、１５４及び／又は１５６）を呼び出し、そのチャンネルのためにチャンネルマネージャ１５０を獲得する。キャッシュマネージャ２１８がチャンネルマネージャ１５０のアドレスを得ると、キャッシュマネージャ２１８は、好ましくは、チャンネルマネージャ１５０からチャンネル特性を検索する。チャンネル特性には、例えば、チャンネル主語ツリー及び属性、チャンネルの持続特性、チャンネルの持続タイムフレーム（Ｔ）、及びキャッシングの精度等が含まれる。キャッシュマネージャ２１８が、所定の主語について、チャンネルを介して伝送されるデータのキャッシングを開始する前に、キャッシュマネージャ２１８において、その主語のキャッシュを作成する必要がある。キャッシュマネージャ２１８は、キャッシュ作成メッセージを待機し、そのメッセージに応じて、主語キャッシュを作成する。この主語キャッシュは、要求に応じて、消去され、中断され又は再開される。図３２は、購読予約に対するキャッシュの作成を示している。Cache Manager-Cache management:
As shown in FIG. 32, when thecache manager 218 encounters a new channel, thecache manager 218 preferably calls an information server (eg, theservers 152, 154 and / or 156 described above) and uses the channel manager for that channel. Get 150. Whencache manager 218 obtains the address ofchannel manager 150,cache manager 218 preferably retrieves channel characteristics fromchannel manager 150. Channel characteristics include, for example, channel subject tree and attributes, channel persistence characteristics, channel persistence time frame (T), and caching accuracy. Before thecache manager 218 starts caching data transmitted over a channel for a given subject, thecache manager 218 needs to create a cache for that subject. Thecache manager 218 waits for a cache creation message and creates a subject cache in response to the message. This subject cache is cleared, suspended or resumed on demand. FIG. 32 shows the creation of a cache for a subscription reservation.

キャッシュマネージャ−キャッシュデータ入力：
キャッシュマネージャ２１８は、好ましくは、以下に示すような様々な手法によって、インテリジェントルータ９２に入るデータにアクセスすることができる。すなわち、インテリジェントルータ９２の入力リンク上の全てデータをキャッシュマネージャ２１８にも送るＩＰと同様のソリューションを用いてもよい。また、スニフィングメカニズムを用いてもよい（この場合、キャッシュマネージャ２１８は、インテリジェントルータ９２のネットワークを介して伝送される全てのパケットを待機する）。また、フィルタリングの後に、インテリジェントルータ９２が、１つ以上のリンクに伝搬させる必要がある各メッセージをキャッシュ５４６に供給してもよい。また、キャッシュマネージャ２１８は、全てのインテリジェントルータ９２に供給されるデータに関する購読者として機能してもよい。Cache Manager-Cache data input:
Thecache manager 218 is preferably able to access data entering theintelligent router 92 by various techniques as described below. That is, a solution similar to IP that sends all data on the input link of theintelligent router 92 to thecache manager 218 may be used. A sniffing mechanism may also be used (in this case, thecache manager 218 waits for all packets transmitted over theintelligent router 92 network). Also, after filtering, theintelligent router 92 may supply each message to thecache 546 that needs to be propagated to one or more links. Further, thecache manager 218 may function as a subscriber related to data supplied to allintelligent routers 92.

キャッシュマネージャ−キャッシュデータストレージ：
図３３に示すように、好ましくは、キャッシュマネージャ２１８は、例えば、チャンネルＩＤ、主語、発行者ＩＤ、タイムスタンプ、タイムグレイン（Ｇ）、プライマリキャッシング属性、リンク（キャッシングが障害のために行われる特別な場合）及び他の様々な手法によって、キャッシュ５４６内のデータにインデックスを付す。データにインデックスを付し、ファイルシステム又はメモリ内の階層的ディレクトリ構造に保存してもよい。データは、好ましくは、メモリ内にキャッシングされ、定期的にディスクに移動される。メモリ内のキャッシングは、タイムグレイ「Ｇ」の期間のみ行われる。タイムグレインＧが経過すると、ツリー内の特定のブランチに関連する全てのデータは、好ましくは、そのブランチの下のファイルに移動され、そのブランチの最も古いファイルに上書きされる（なお、各メッセージをディスクに個別に書き込むことは高価であり、Ｇ期間を一回の動作でディスクに書き込んだ方が効率的であるためタイムグレインＧは、好ましくは、スライディングウィンドウとしてではなく、絶対ウィンドウとして実現する）。図３３は、インデックスツリーの具体例を示している。持続性のためにデータをキャッシングする場合、好ましくは、図３３に示す第１のインデックスツリーを用いる。Cache Manager-Cache data storage:
As shown in FIG. 33, preferably, thecache manager 218 may include, for example, a channel ID, subject, issuer ID, time stamp, time grain (G), primary caching attribute, link (a special case where caching is performed due to failure) The data in thecache 546 is indexed by various other techniques. Data may be indexed and stored in a file system or hierarchical directory structure in memory. Data is preferably cached in memory and periodically moved to disk. Caching in the memory is performed only during the time gray “G” period. When time grain G elapses, all data associated with a particular branch in the tree is preferably moved to a file under that branch, overwriting the oldest file in that branch (note that each message Time grain G is preferably implemented as an absolute window, not as a sliding window, because writing to the disk individually is expensive and it is more efficient to write the G period to the disk in a single operation) . FIG. 33 shows a specific example of an index tree. When caching data for persistence, the first index tree shown in FIG. 33 is preferably used.

図３３に示すように、主語は、好ましくは、階層構造内に保存され、ここで、「ａ」は、例えば「ａ．ｂ」、「ａ．ｃ」、「ａ．ｄ」等の主語の親である。キャッシュマネージャ２１８は、キャッシュ５４６のために、全ての主語を対応するファイル位置にマッピングするハッシュテーブルを保管する。幾つかの具体例では、キャッシュ５４６は、上流ルータ（例えば、コアルーティングノード５４８）がそのリンク上の下流のルータ（例えば、エッジルーティングノード５４５）における障害を検出した場合、障害が発生した条件下で、データを保存する必要がある。復旧のための１つの手法は、下流のルータを再起動することである（この処理は、数分もかかることがある）。下流のルータが再起動されている間、上流ルータは、そのリンクの下流方向に供給するデータをキャッシングする必要がある。このキャッシュ（例えば、図３３ではＦＭキャッシュと示す。）は、好ましくは、出力側のリンク上でインデックスが付される。  As shown in FIG. 33, the subject is preferably stored in a hierarchical structure, where “a” is the subject of the subject such as “ab”, “ac”, “ad”, etc. Parent.Cache manager 218 stores a hash table forcache 546 that maps all subjects to corresponding file locations. In some implementations, thecache 546 may detect if a failure occurs if an upstream router (eg, core routing node 548) detects a failure in a downstream router (eg, edge routing node 545) on that link. And you need to save the data. One approach to recovery is to restart the downstream router (this process can take several minutes). While the downstream router is being restarted, the upstream router needs to cache the data supplied in the downstream direction of the link. This cache (eg, shown as FM cache in FIG. 33) is preferably indexed on the output side link.

キャッシュマネージャ：ガーベージコレクション：
チャンネルが持続的でない場合、キャッシュ５４６は、データを保存せず、直ちにデータを消去する。チャンネルが持続的である場合、キャッシュ５４６は、データを保存する。特定のチャンネルの持続タイムフレーム「Ｔ」は、それぞれサイズがＧであるＮ個のタイムグレインに分割される。メモリへのキャッシングは、Ｇに対応する期間のみ行われる。キャッシュマネージャが、期間Ｇが経過したと判定すると、データは、ディスクに移動される。キャッシュマネージャ２１８は、持続タイムフレーム期間Ｔの間、データをディスクに保存する。Cache Manager: Garbage Collection:
If the channel is not persistent, thecache 546 does not save the data and immediately erases the data. If the channel is persistent, thecache 546 stores the data. The duration time frame “T” of a particular channel is divided into N time grains each of size G. Caching to the memory is performed only for a period corresponding to G. If the cache manager determines that period G has elapsed, the data is moved to disk. Thecache manager 218 stores the data on the disk for a sustained time frame period T.

期間Ｇに対応するデータは、時間が、そのチャンネル＋期間の上限の持続タイムフレーム期間（Ｔ）を過ぎた場合、ディスクから削除される。具体的には、例えば、チャンネルの持続タイムフレーム期間Ｔが２時間であるとする。ここでは、例示的に、キャッシュマネージャ２１８は、１５分のタイムグレインＧを用いるとする。この場合、データをディスクから削除するための規則は、次の通りである。すなわち、期間Ｇ（１５分）の間に最後にキャッシングされたデータが期間Ｔ（２時間）の間保存された場合、その１５分の期間の間にキャッシングされた全てのデータが破棄される。したがって、その１５分の期間の最初にキャッシングされたデータは、破棄されるまでに、２時間より長く保存されることとなる。この実施例では、各１５分の期間にキャッシングされるデータは、データのブロックである。持続タイムフレームＴがＮ個の期間に分割される場合、如何なる時刻においても、各主語のためのキャッシュ５４６において、Ｎ＋１個（ディスクにＮ個とメモリに１個）のデータのブロックが保存される。  Data corresponding to period G is deleted from the disk when the time has passed the channel + period upper duration time frame period (T). Specifically, for example, it is assumed that the continuous time frame period T of the channel is 2 hours. Here, as an example, it is assumed that thecache manager 218 uses a time grain G of 15 minutes. In this case, the rules for deleting data from the disk are as follows. That is, when the data cached last during the period G (15 minutes) is stored for the period T (2 hours), all the data cached during the period of 15 minutes is discarded. Therefore, the data cached at the beginning of the 15-minute period will be stored for more than 2 hours before being discarded. In this embodiment, the data cached in each 15 minute period is a block of data. If the duration time frame T is divided into N periods, at any time, N + 1 blocks (N on disk and 1 in memory) of data are stored in thecache 546 for each subject. .

キャッシュマネージャ−キャッシュデータ検索：
図３４に示すように、エージェント１２８（又はプロキシ）は、好ましくは、キャッシュ読出処理（GetCache operation）を呼び出し、現在の時間から期間Ｔ分遡ったデータを入手する。図３４においては、キャッシュ読出処理を呼び出すためにエージェント１２８が接続するキャッシュマネージャ２１８には、ポータルキャッシュのラベルを付している。ルータ又はエージェント１２８の失敗／切断のため、ポータルキャッシュは、エージェント１２８によって要求されたデータの全てを有していない場合がある。この場合、ポータルキャッシュは、他の全てのキャッシュ（例えば、上流のキャッシュ）からデータを検索し、データを照合し、このデータをエージェント１２８に返す。図３４は、異なるタイムスタンプ（ＴＳ１、ＴＳ２、ＴＳ３）に対する、複数のキャッシュ（Ａ、Ｂ、Ｃ）からの検索を示している。Cache Manager-Cache data search:
As shown in FIG. 34, the agent 128 (or proxy) preferably calls a cache read process (GetCache operation), and obtains data that is back for a period T from the current time. In FIG. 34, thecache manager 218 to which theagent 128 is connected in order to call the cache read process is labeled with a portal cache. Due to a router /agent 128 failure / disconnection, the portal cache may not have all of the data requested by theagent 128. In this case, the portal cache retrieves data from all other caches (eg, upstream cache), collates the data, and returns this data to theagent 128. FIG. 34 shows a search from multiple caches (A, B, C) for different time stamps (TS1, TS2, TS3).

キャッシュマネージャ２１８は、好ましくは、タイムグレインＧのデータのブロックのみを検索する。したがって、エージェント１２８には、予期又は要求したデータより多くのデータが提供されることもある。更に複数のキャッシュから検索を行うと、キャッシュ間において、幾つかの期間が重複し、エージェント１２８は、データが重複して供給されることもあり、このため、エージェント１２８は、キャッシュによって提供されるデータストリームにおける重複を削除する必要がある。  Thecache manager 218 preferably retrieves only blocks of time grain G data. Thus, theagent 128 may be provided with more data than expected or requested. Further, when searching from a plurality of caches, several periods are overlapped between the caches, and theagent 128 may be supplied with redundant data, so that theagent 128 is provided by the cache. Duplicates in the data stream need to be removed.

キャッシュマネージャの他のモジュールとのインタラクション：
キャッシュマネージャ２１８は、好ましくは、図３５に示すように、事象通知システムインフラストラクチャにおいて、幾つかのモジュールとインタラクトする。キャッシュマネージャ２１８が（キャッシュ作成時に）新たなチャンネルに遭遇すると、キャッシュマネージャ２１８は、好ましくは、そのチャンネルのチャンネルマネージャ１５０を得るために情報サーバ５５０を呼び出す。一旦、キャッシュマネージャ２１８がチャンネルマネージャ１５０のアドレスを得ると、キャッシュマネージャ２１８は、好ましくは、チャンネルマネージャ１５０からチャンネル特性に関する情報を得る。アドミニストレータモジュール５５２は、好ましくは、キャッシングの分割の度合い等の幾つかの特性を設定／変更することができる。また、アドミニストレータモジュール５５２は、好ましくは、マニュアルでチャンネルキャッシュを作成／削除することもできる。Interaction with other modules of the cache manager:
Thecache manager 218 preferably interacts with several modules in the event notification system infrastructure, as shown in FIG. Whencache manager 218 encounters a new channel (at cache creation time),cache manager 218 preferably callsinformation server 550 to obtainchannel manager 150 for that channel. Oncecache manager 218 obtains the address ofchannel manager 150,cache manager 218 preferably obtains information about channel characteristics fromchannel manager 150. Theadministrator module 552 is preferably capable of setting / changing several characteristics such as the degree of caching division. Theadministrator module 552 can also preferably create / delete channel caches manually.

エージェントキャッシュＡＰＩ−アプリケーションエージェントインタラクション：
アプリケーション（例えば、アプリケーション１２６）は、好ましくは、エージェントキャッシュＡＰＩ５５４を呼び出し、所定の主語とフィルタとともにキャッシュ５４６を得る。好ましくは、アプリケーションは、既にそのデータを購読予約している場合、キャッシュ５４６からそのデータのみを検索することができる。エージェントキャッシュＡＰＩ５５４は、実際には、好ましくは２つのＡＰＩを提供する。Agent Cache API-Application Agent Interaction:
An application (eg, application 126) preferably calls theagent cache API 554 to obtain acache 546 with a predetermined subject and filter. Preferably, the application can retrieve only the data from thecache 546 if the application has already subscribed to the data. Theagent cache API 554 actually provides two APIs preferably.

第１のＡＰＩにより、購読予約していないアプリケーションは、キャッシュ５４６の購読予約と検索を同時に行うことができる。「ＦＩＦＯ」フラグが設定されている場合、購読予約が作成され、エッジルータノード５４５に送信される。エージェント１２８がキャッシングされた全てのデータを受け取った後に、エージェント１２８は、まず、キャッシングされた全てのデータを配信し、そのデータにおいて、全ての発行者が確認できなかった最後のシーケンスを監視し、この各発行者が確認できなかった最後のシーケンスから、中断されたデータを配信する。  The first API allows an application that has not subscribed to subscribe to and search thecache 546 at the same time. If the “FIFO” flag is set, a subscription is created and sent to theedge router node 545. Afteragent 128 has received all the cached data,agent 128 first delivers all the cached data and monitors that data for the last sequence that all issuers could not confirm, The interrupted data is distributed from the last sequence that cannot be confirmed by each issuer.

第２のＡＰＩでは、アプリケーションが既にあるデータを購読予約し、キャッシングされたデータを要求していると仮定する。この場合、アプリケーションには、キャッシュデータに関して、連続的ではない幾つかのデータが既に配信されている。この具体例では、「ＦＩＦＯ」フラグは、単に、キャッシュ５４６から読み出されたデータが自ら順序を決定するが通常のデータストリームと同様の順序である必要はないことを示す。  In the second API, it is assumed that the application subscribes to existing data and requests cached data. In this case, some non-continuous data regarding the cache data is already distributed to the application. In this specific example, the “FIFO” flag simply indicates that the data read from thecache 546 determines its own order but need not be in the same order as a normal data stream.

エージェント１２８は、好ましくは、１つの大きなデータのブロック内の全てのイベントを読み出す。エージェント１２８は、キャッシュＡＰＩ５５４からデータを読み出した後、好ましくは、コールバック動作を呼び出す前に（上述参照）、データに対して以下のような動作を行う。この動作とは、通知のリストからの通知の生成、各発行者について、最後のシーケンス番号の監視、及びフィルタリングである。エージェント１２８によって全てのイベントをコールバックに渡す処理が完了すると、エージェント１２８は、キャッシュ完了イベント（DoneCache event）をコールバックに渡し、キャッシングされた全てのデータが配信されたことを示す。このとき、購読予約がＦＩＦＯであり、通常のデータが中断されている場合、エージェント１２８は、好ましくは、中断された全ての通知を配信する。このとき、エージェント１２８は、シーケンス番号がキャッシングされたデータにおける最後のシーケンス番号より大きい通知のみを配信する。  Agent 128 preferably reads all events in one large block of data. After reading the data from thecache API 554, theagent 128 preferably performs the following operation on the data before invoking a callback operation (see above). This operation is the generation of a notification from the list of notifications, monitoring the last sequence number for each issuer, and filtering. When the process of passing all events to the callback by theagent 128 is completed, theagent 128 passes a cache completion event (DoneCache event) to the callback, indicating that all cached data has been delivered. At this time, if the subscription is a FIFO and normal data is suspended, theagent 128 preferably delivers all suspended notifications. At this time, theagent 128 delivers only a notification whose sequence number is greater than the last sequence number in the cached data.

エージェントキャッシュＡＰＩとキャッシュのインタラクション：
購読者がキャッシングされたデータを供給した場合、エージェント１２８側のキャッシュＡＰＩ５５４は、好ましくは、まず、エージェント１２８が接続されているエッジルータに関する履歴を調べ、キャッシュ読出要求（GetCache request）によって定義されている期間を用いて、リストをフィルタリングする。ＡＰＩ５５４は、キャッシュ読出（GetCache）（チャンネル、主語、フィルタ、local_pubs、time_period、ＦＩＦＯ、ルータのアレー）メッセージをＡＰＩ５５４が接続されていた最後のエッジキャッシュに送信する。キャッシュマネージャ２１８は、好ましくは、チャンネルＩＤ、主語及びタイムスタンプに基づいてデータをプルし、このデータをエージェント１２８に戻す。キャッシュマネージャ２１８によるデータの供給が完了すると、キャッシュマネージャ２１８は、キャッシュ完了イベント（DoneCache event）をキャッシュＡＰＩに渡し、データの転送がキャッシングされた全てのデータが配信されたことを示す。Agent cache API and cache interaction:
When a subscriber provides cached data, thecache API 554 on theagent 128 side preferably first looks at the history of the edge router to which theagent 128 is connected and is defined by a cache read request (GetCache request). The list is filtered using a certain period. TheAPI 554 sends a cache read (GetCache) (channel, subject, filter, local_pubs, time_period, FIFO, router array) message to the last edge cache to which theAPI 554 was connected. Thecache manager 218 preferably pulls data based on the channel ID, subject, and timestamp and returns this data to theagent 128. When the supply of data by thecache manager 218 is completed, thecache manager 218 passes a cache completion event (DoneCache event) to the cache API, indicating that all data for which data transfer has been cached has been distributed.

キャッシュマネージャ２１８がデータをローカルで検出できない場合、キャッシュマネージャ２１８は、エージェント１２８によって提供される「ルータのリスト」を用いて、必要なデータを検索する。キャッシュマネージャ２１８が必要な全てのデータを集めると、キャッシュマネージャ２１８は、必要なデータを照合し、重複削除を行った後に、このデータをエージェント１２８に供給する。  If thecache manager 218 cannot find the data locally, thecache manager 218 uses the “list of routers” provided by theagent 128 to retrieve the required data. When thecache manager 218 collects all the necessary data, thecache manager 218 collates the necessary data and performs deduplication and then supplies this data to theagent 128.

キャッシュ接続履歴：
キャッシュ５４６からのデータの検索を可能にするために、好ましくは、エージェント１２８において、上流のキャッシュと同様に両方の側のキャッシュに関するキャッシュ接続履歴が維持される。この情報は、エージェント１２８がシャットダウン及びクラッシュした場合に必要であるので、この情報は、ファイルに持続的に保存する必要がある。キャッシュ接続履歴は、好ましくは、以下のようなファイル及びフォーマットによってディスクに保存される。Cache connection history:
To enable retrieval of data fromcache 546, preferablyagent 128 maintains cache connection history for both caches as well as upstream caches. Since this information is needed if theagent 128 shuts down and crashes, this information needs to be stored persistently in a file. The cache connection history is preferably stored on the disk in the following file and format.

エッジキャッシュ位置：
エッジキャッシュの位置（例えば、エッジルーティングノード５４６のキャッシュ５４６）は、好ましくは、チャンネルマネージャ／チャンネルライブラリから得られる。これは、起動時及びこれに続く、例えば、接続の切断／再接続、接続の変更等によってエッジキャッシュが変化した、如何なる時点でも発生する。ディスパッチャは、エッジキャッシュ接続の全ての変化をエージェント１２８に通知し、これらの変化は、エージェント１２８のキャッシュライブラリに伝えられる。変化が起こるたび、その情報は持続される。Edge cache location:
The location of the edge cache (eg,cache 546 of edge routing node 546) is preferably obtained from the channel manager / channel library. This occurs at startup and at any time following it, for example when the edge cache changes due to disconnection / reconnection, connection change, etc. The dispatcher notifies theagent 128 of all changes in the edge cache connection and these changes are communicated to theagent 128 cache library. Whenever a change occurs, that information is persisted.

持続的なストレージ：CACHE_ROOT／channel_id／Channel−キャッシングされたデータのためのパスの具体例
データは、好ましくは次のようなフォーマットで保存される。
エッジキャッシュの数；
エッジキャッシュ１：インターバルの数、StartTimel：EndTimel、StartTime2：EndTime2、．．．；
エッジキャッシュ２：インターバルの数、StartTimel：EndTimel、StartTime2：EndTime2、．．．；・・・
ここで、最後のタイムスタンプがリストの最初に設けられる。なお、２つの異なるエッジキャッシュが重複する期間を有することはない（エージェント１２８は、一度に１つのエッジキャッシュのみに接続されるため）。新たなエントリが追加される毎に、古いエントリは、それらがまだ有効であるか確認され、それらが無効である場合、このエントリは、削除される。期間は、時刻EndTime＋チャンネルの持続期間＜現在の時刻となった場合、無効となる。Persistent storage: CACHE_ROOT / channel_id / Channel-path example for cached data Data is preferably stored in the following format.
Number of edge caches;
Edge cache 1: number of intervals, StartTimel: EndTimel, StartTime2: EndTime2,. . . ;
Edge cache 2: number of intervals, StartTimel: EndTimel, StartTime2: EndTime2,. . . ; ...
Here, the last time stamp is provided at the beginning of the list. Note that two different edge caches do not have overlapping periods (becauseagent 128 is connected to only one edge cache at a time). Each time a new entry is added, the old entries are checked to see if they are still valid, and if they are invalid, this entry is deleted. The period becomes invalid when time EndTime + channel duration <current time.

エッジキャッシュエントリは、エントリ内の全ての期間が無効になった場合、無効になる。なお、「EndTime」が０であるということは、その期間が現在有効であることを意味する。  An edge cache entry becomes invalid if all periods in the entry are invalidated. Note that “EndTime” being 0 means that the period is currently valid.

上流のキャッシュ位置：
上流のキャッシュ（例えば、コアルーティングノード５４８のキャッシュ５４６）の位置は、主語に依存している。各主語は、それ自身のマルチキャストツリーを有し、したがって、第１のレベルの上流のキャッシュの組は、主語の関数である。ユーザが主語を購読予約すると、インテリジェントルータ９２は、必ず主語に関連している上流のキャッシュのリストを返す。同様に、障害又はマルチキャストツリーの再構成に起因する上流のキャッシュ位置のあらゆる変化は、制御パスを介してエージェント１２８に伝えられる。これらの変化は、持続的なメモリ（ファイル）に局所的に記録される。Upstream cache position:
The location of the upstream cache (eg,cache 546 of core routing node 548) depends on the subject. Each subject has its own multicast tree, so the first level upstream cache set is a function of the subject. When a user subscribes to a subject,intelligent router 92 always returns a list of upstream caches associated with the subject. Similarly, any change in upstream cache location due to failure or multicast tree reconfiguration is communicated toagent 128 via the control path. These changes are recorded locally in persistent memory (files).

持続的なストレージ：CACHE_ROOT／channel_identifier／subject（階層ではなく、完全な主語）−キャッシングされたデータのためのパスの具体例
データは、好ましくは、以下のフォーマットで保存される。
上流キャッシュの数；
上流キャッシュ１：インターバルの数、StartTimel：EndTimel、StartTime2：EndTime2，．．．；
上流キャッシュ２：インターバルの数、StartTimel：EndTimel、StartTime2：EndTime2、．．．；・・・
ここでも、最後のタイムスタンプがリストの最初に設けられる。エッジキャッシュ期間とは異なり、エージェント１２８は、所定の主語について、複数の上流のキャッシュを有することができるので、２つの上流キャッシュが重複する期間を有することがある。また、上流のキャッシュファイルのコンテンツは、エッジキャッシュの場合と同様なアルゴリズムを用いて集められたガーベージである。Persistent storage: CACHE_ROOT / channel_identifier / subject (full subject, not hierarchy)-path example for cached data The data is preferably stored in the following format:
Number of upstream caches;
Upstream cache 1: number of intervals, StartTimel: EndTimel, StartTime2: EndTime2,. . . ;
Upstream cache 2: number of intervals, StartTimel: EndTimel, StartTime2: EndTime2,. . . ; ...
Again, the last time stamp is placed at the beginning of the list. Unlike the edge cache period, theagent 128 can have multiple upstream caches for a given subject, so two upstream caches may have overlapping periods. Further, the contents of the upstream cache file are garbage collected using the same algorithm as in the edge cache.

データ検索の間のキャッシュ妥当性：
エージェント１２８が有効な間、エージェント１２８は、接続を介して、異なるエッジルータ及び上流ルータ間を移動する。エージェントキャッシュＡＰＩ５５４は、好ましくは、この接続履歴をローカルメモリに保存する。エージェント１２８が、キャッシュ５４６からデータの最後のＴ期間を読み出す必要がある場合、エージェントキャッシュＡＰＩ５５４は、好ましくは、接続履歴を調べ、そのデータにアクセスするためのキャッシュを判定する。これのために用いられるアルゴリズムは、好ましくは以下の通りである。（１）キャッシュライブラリは、全てのエッジキャッシュ期間を探検し、Ｔタイムフレーム内に含まれる期間を確認する。（２）リストＬｅは、期間開始時刻に基づいて、リストＬｅをソートする。（３）ＬＥ内のエッジキャッシュによってカバーされていない各期間について、上流キャッシュを探索し、この期間をカバーできる全ての上流キャッシュ期間に関する情報を得て、有効な期間をリストＬｕに加え、ＬｅにＬｕを追加し、期間開始時刻を用いてＬｅをソートし、Ｌを作成する。Cache validity during data retrieval:
While theagent 128 is active, theagent 128 moves between different edge routers and upstream routers over the connection. Theagent cache API 554 preferably stores this connection history in local memory. When theagent 128 needs to read the last T period of data from thecache 546, theagent cache API 554 preferably examines the connection history to determine the cache for accessing the data. The algorithm used for this is preferably as follows. (1) The cache library explores all edge cache periods and checks the periods included in the T time frame. (2) The list Le sorts the list Le based on the period start time. (3) For each period not covered by the edge cache in LE, search upstream cache, get information about all upstream cache periods that can cover this period, add valid period to list Lu, and add to Le Lu is added, Le is sorted using the period start time, and L is created.

このアルゴリズムによりキャッシュのリストＬが生成され、各キャッシュについて、データを読み出すための期間が得られる。次に、このキャッシュのリストＬは、（４）キャッシュ読出メッセージに組み込まれ、キャッシュマネージャ２１８に送信される。キャッシュマネージャ２１８側では、キャッシュマネージャ２１８は、好ましくは、（５）ゲットキャッシュメッセージからキャッシュ期間を取り出し、開始時刻順にソートされたリストＬを再構築する。リストＬの各期間の間、キャッシュマネージャ２１８は、好ましくは、（６）前の期間と現在の期間の間に、隙間があるか否かを確認し、隙間があれば、そのデータのローカルキャッシュを要求する。このような隙間がなければ、キャッシュマネージャ２１８は、好ましくは（７）関連するキャッシュにデータを読み出すよう指示する。キャッシュマネージャ２１８は、好ましくは（８）全てのキャッシュからのデータを照合し、このデータをエージェント１２８に送信する。  A cache list L is generated by this algorithm, and a period for reading data is obtained for each cache. This cache list L is then incorporated into the (4) cache read message and sent to thecache manager 218. On thecache manager 218 side, thecache manager 218 preferably takes (5) the cache period from the get cache message and reconstructs the list L sorted in the order of the start time. During each period of the list L, thecache manager 218 preferably (6) checks whether there is a gap between the previous period and the current period, and if there is a gap, the local cache of the data Request. If there is no such gap, thecache manager 218 preferably (7) instructs the associated cache to read the data. Thecache manager 218 preferably (8) collates data from all caches and sends this data to theagent 128.

ルータキャッシュＡＰＩ：
インテリジェントルータ９２側のルータキャッシュＡＰＩ５５２は、特定の主語のためのキャッシングを作成し、消去し、停止し、再開するためにキャッシュマネージャ２１８を呼び出す。また、ルータキャッシュＡＰＩ５５２は、初期の構成を処理する。すなわち、ルータキャッシュＡＰＩ５５２は、インテリジェントルータ９２からチャンネルマネージャ１５０にキャッシュアドレスをアップロードし、これにより、エージェント１２８側（エージェントキャッシュＡＰＩ５５４）は、必要なときにこの情報を得ることができる。更に、ルータキャッシュＡＰＩ５５２は、他のルータのキャッシュ５４６の位置を読み出す（この位置は例えば、購読予約に対する応答において及び主語ツリーの変更の後にインテリジェントルータ９２が所定の主語のための上流キャッシュをエージェント１２８に通知する際に用いられる）。Router cache API:
Therouter cache API 552 on theintelligent router 92 side calls thecache manager 218 to create, erase, stop, and resume caching for a particular subject. Therouter cache API 552 also handles the initial configuration. That is, therouter cache API 552 uploads the cache address from theintelligent router 92 to thechannel manager 150, so that theagent 128 side (agent cache API 554) can obtain this information when necessary. In addition, therouter cache API 552 reads the location of the other router's cache 546 (this location can be used, for example, in response to a subscription, and after the subject tree change, theintelligent router 92 sets the upstream cache for a given subject toagent 128. To be used for notifications).

プルのためのキャッシュの使用：
上述の説明では、持続的なチャンネルを実現し、購読者がネットワークからデータをプルすることによって情報を返すためのキャッシュの使用に焦点をあてた。変形例では、如何なる購読者（新たな購読者又は復帰した購読者）もキャッシュ５４６から（例えば、購読者が購読予約していないが、他の誰かの購読予約のためにキャッシュ５４６に保存されているデータを含む）あらゆる種類のデータをプルすることができる。この実施例と先の実施例との違いは、復帰した購読者については、データの存在が保証され、データの位置は、既知であるが、新たな購読者については、保存されているデータの位置が未知であるという点である。この変形例を実現する単純な手法は、チャンネルにおいて「キャッシュ検出（FindCache）」要求を発行することである。キャッシュ検出要求は、チャンネルＩＤ、主語、フィルタ、期間及び要求されたキャッシングされたデータを有するキャッシュ５４６を探すエージェント１２８の位置を含んでいる。全てのキャッシュ５４６がキャッシュ検出要求を待機している。各キャッシュ５４６が要求を受け取ると、キャッシュ５４６は、対応するデータが自らのデータストアにあるか否かを確認し、自らがそのデータを保存している場合、自らの位置をユニキャストメッセージとして返す。エージェント１２８は、キャッシュ５４６の１つを選択し、そのキャッシュ５４６をキャッシュ読出処理によって呼び出し、そのデータを得る。Use of cache for pull:
The above discussion has focused on the use of a cache to implement persistent channels and return information by subscribers pulling data from the network. In a variant, any subscriber (new subscriber or reinstated subscriber) is saved from cache 546 (eg, the subscriber has not subscribed, but is saved incache 546 for someone else's subscription reservation). You can pull any kind of data (including the data you have). The difference between this example and the previous example is that for restored subscribers the existence of data is guaranteed and the location of the data is known, but for new subscribers the stored data The position is unknown. A simple way to implement this variant is to issue a “FindCache” request on the channel. The cache detection request includes the location of theagent 128 looking for thecache 546 with the channel ID, subject, filter, duration, and requested cached data. Allcaches 546 are waiting for a cache detection request. When eachcache 546 receives the request, thecache 546 checks whether the corresponding data is in its own data store, and if it stores the data, returns its location as a unicast message. . Theagent 128 selects one of thecaches 546 and invokes thecache 546 by a cache read process to obtain the data.

最新データプル：
他の実施例では、購読者アプリケーション（例えば、アプリケーション１２６）が所定の主語について、最新のメッセージを得ることができる最新データプルを実現する。これは、例えば、株価警告等のデータに有効であり、この場合、ユーザは、履歴ではなく、最新の株価に関する情報のみを希望する。Latest data pull:
In another embodiment, a subscriber data application (eg, application 126) implements the latest data pull that can obtain the latest message for a given subject. This is effective, for example, for data such as stock price warnings. In this case, the user only wants information on the latest stock price, not a history.

キャッシュマネージャの実現：
キャッシュマネージャ２１８の実現においては、好ましくは、３種類のスレッドを用いる。データキャッシングスレッド−データキャッシングスレッドは、好ましくは、インテリジェントルータ９２への接続からデータを取り出し、データにインデックスを付してメモリに保存する。データストレージスレッド−期間の最後に到達すると、データストレージスレッドは、メモリに保存されているデータをディスクに移動させ、及びこの処理において、期限切れのデータに関するガーベージコレクションを実行する。データ検索スレッド−データ検索スレッドは、好ましくは、キャッシングされたデータの要求を受け、キャッシュ５４６からデータを検索する。これらの３つの種類のスレッドは、単一のスレッドとして実現してもよく、スレッドのプールとして実現してもよい。好ましくは、データキャッシングスレッドとデータストレージスレッドは、データがディスクに移動される時刻に同期される。このようにデータストレージスレッドとデータ検索スレッドとを同期させることにより、データの検索中にデータが消去されることが防止される。Realization of cache manager:
In implementing thecache manager 218, preferably three types of threads are used. Data caching thread—The data caching thread preferably retrieves data from the connection to theintelligent router 92, indexes the data and stores it in memory. Data storage thread—When the end of the period is reached, the data storage thread moves data stored in memory to disk and performs garbage collection on the expired data in this process. Data retrieval thread—The data retrieval thread preferably retrieves data from thecache 546 upon receiving a request for cached data. These three types of threads may be implemented as a single thread or as a pool of threads. Preferably, the data caching thread and the data storage thread are synchronized to the time when the data is moved to disk. By synchronizing the data storage thread and the data retrieval thread in this way, data is prevented from being erased during data retrieval.

データ構造：
キャッシングのためのデータ構造の具体例は、表１９及びこれに関連する説明に記した通りである。data structure:
Specific examples of the data structure for caching are as described in Table 19 and the related description.

データストレージ：
図３６は、「アクイラキャッシュ（Aquila Cache）」と呼ばれるキャッシュ５４６にデータファイルを保存するために用いられる好適なディレクトリ構造を示している。なお、各主語レベルのディレクトリは、好ましくは、その主語について発行されるデータを保存するデータディレクトリに加えて、１組の子主語ディレクトリを有する。例えば、エンターテインメントチャンネルにおいて、ＦＯＸムービーから発行されたデータは、AquilaCache／エンターテインメント／ＦＯＸ／ムービー／データ（AquilaCache/Entertainment/FOX/Movies/Data）のディレクトリのファイルに格納され、主語ＦＯＸについて発行されたデータは、AQUILACACHE／エンターテインメント／フォックス／データ（AquilaCache/Entertainment/FOX/Data）のディレクトリのファイルに格納される。データのストレージを高速に行うために、好ましくは、インテリジェントルータ９２がキャッシュ５４６に対し、所定のチャンネルと主語に関するキャッシングを開始するよう要求した時点で、特定の主語のディレクトリ階層を構築する。Data storage:
FIG. 36 illustrates a preferred directory structure used to store data files in acache 546 called “Aquila Cache”. Note that each subject level directory preferably has a set of child subject directories in addition to a data directory that stores data issued for that subject. For example, in an entertainment channel, data issued from a FOX movie is stored in a file in a directory of AquilaCache / Entertainment / FOX / Movie / Data (AquilaCache / Entertainment / FOX / Movies / Data) and is issued for the subject FOX. Is stored in a file in a directory of AQUILACACHE / entertainment / fox / data (AquilaCache / Entertainment / FOX / Data). In order to perform high-speed data storage, a directory hierarchy of a specific subject is preferably constructed when theintelligent router 92 requests thecache 546 to start caching for a predetermined channel and subject.

データ検索：
キャッシュ５４６からのデータ検索は、データのストレージを妨げないように、及びキャッシュ５４６がホールドアップしないように、効率的に行う必要がある。このデータ検索では、ディスクとメモリの両方からデータを読み出す。データ検索においては、好ましくは以下のようなステップを実行する。（１）データノードの位置を検出する。（２）データノードをロックする。（３）呼び出す必要があるデータのタイムスタンプを検出する。（４）データを読み出し、メモリに保存する。（５）データノードをロック解除する。（６）メモリに保存され、読み出されたデータをフィルタリングし、並べ替えた後、エージェント１２８クライアントにプッシュする。data search:
Data retrieval from thecache 546 needs to be done efficiently so as not to interfere with data storage and to prevent thecache 546 from being held up. In this data search, data is read from both the disk and the memory. In data retrieval, the following steps are preferably performed. (1) The position of the data node is detected. (2) Lock the data node. (3) Detect the time stamp of the data that needs to be recalled. (4) Read data and save it in memory. (5) Unlock the data node. (6) The data stored in the memory and read out are filtered, rearranged, and then pushed to theagent 128 client.

以上、例示的な実施例を用いて本発明を説明してきたが、これらの実施例を様々に変形できることは当業者にとって明らかであり、本発明は、これらの如何なる適応化又は変形をも含む。例えば、本発明の範囲から逸脱することなく、様々な種類の発行者装置、ユーザ又は購読者装置、これらのチャンネル及び構成、コンテンツベースの経路選択及び他の機能のハードウェア及びソフトウェアによる実現が可能である。この発明は、特許請求の範囲及びその均等物によってのみ制限される。  Although the present invention has been described using exemplary embodiments, it will be apparent to those skilled in the art that these embodiments can be variously modified and the present invention includes any adaptations or variations thereof. For example, various types of issuer devices, user or subscriber devices, their channels and configurations, content-based routing and other functions can be realized by hardware and software without departing from the scope of the present invention. It is. The invention is limited only by the claims and the equivalents thereof.

Claims (38)

Translated fromJapanese

プロセッサによって実行され、ネットワークにおいて、サービス品質保証に基づいてパケットをルーティングするルーティング方法において、
ヘッダ部と、ペイロード部とを有するパケットを受信する受信ステップと、
ネットワークコアにおいて、上記パケットをルーティングする前に、該パケットのペイロード部を検査する検査ステップと、
上記パケットの確保された帯域幅に関する上記サービス品質保証を判定する判定ステップと、
上記検査及び上記サービス品質保証に基づいて、上記パケットを選択的にルーティングするルーティングステップとを有し、
上記検査ステップは、
上記ペイロード部からデータ属性を抽出するステップと、
上記抽出したデータ属性を２つ以上の属性フィルタと比較するステップと、
上記２つ以上の属性フィルタのそれぞれが満たされる場合、１組の機能を実行するステップとを有し、
上記各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述していることを特徴するルーティング方法。In a routing method executed by a processor and routing packets in a network based on quality of service guarantees,
A receiving step of receiving a packet having a header portion and a payload portion;
In the network core, before routing the packet, an inspection step of inspecting the payload portion of the packet;
A determination step of determining the quality of service guarantee regarding the reserved bandwidth of the packet;
A routing step for selectively routing the packet based on the inspection and the quality of service guarantee;
The above inspection steps include
Extracting data attributes from the payload portion;
Comparing the extracted data attributes with two or more attribute filters;
Performing each of the functions if each of the two or more attribute filters is satisfied,
Each of the attribute filters described above is characterized in that the subscriber describes a set of events of interest received from the issuer. 上記検査ステップを、上記ネットワークコア内のルータで実行するステップを更に有する請求項１記載のルーティング方法。  The routing method according to claim 1, further comprising the step of executing the checking step at a router in the network core. 上記検査を実行するために、上記属性フィルタを、上記ネットワーク内のルータに伝搬するステップを更に有する請求項１記載のルーティング方法。  The routing method according to claim 1, further comprising the step of propagating the attribute filter to a router in the network in order to perform the inspection. 上記受信ステップ、検査ステップ及びルーティングステップを実行するために、上記ネットワーク内のルータをプログラミングするステップを更に有する請求項１記載のルーティング方法。  The routing method of claim 1, further comprising the step of programming a router in the network to perform the receiving step, the examining step and the routing step. 上記１組の機能は、上記パケットをどのようにルーティングするかを決定することを含むことを特徴とする請求項１記載のルーティング方法。
The routing method of claim 1, wherein the set of functions includes determining how to route the packet.
プロセッサによって実行され、ネットワークにおいて、メッセージをルーティングするルーティング方法において、
ヘッダ部と、少なくとも１つの主語と、複数のデータ属性とを有するメッセージを受信する受信ステップと、
上記メッセージから、上記主語及び上記データ属性を読み出す主語／属性読出ステップと、
上記主語に基づいて、複数の属性フィルタを指定する購読予約を読み出す購読予約読出ステップと、
上記メッセージの確保された帯域幅に関するサービス品質保証を判定するステップと、
上記メッセージをどのようにルーティングするかを決定するために、ネットワークコアにおいて、上記購読予約に上記データ属性を適用する適用ステップと、
上記適用及び上記サービス品質保証に基づいて、上記メッセージを選択的にルーティングするステップとを有し、
上記適用ステップは、
上記パケットから上記データ属性を抽出するステップと、
上記抽出したデータ属性を２つ以上の属性フィルタと比較するステップと、
上記２つ以上の属性フィルタのそれぞれが満たされる場合、１組の機能を実行するステップとを有し、
上記各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述していることを特徴するルーティング方法。In a routing method executed by a processor and routing a message in a network,
Receiving a message having a header portion, at least one subject, and a plurality of data attributes;
A subject / attribute read step for reading the subject and the data attribute from the message;
A subscription reading step for reading a subscription specifying a plurality of attribute filters based on the subject;
Determining a quality of service guarantee for the reserved bandwidth of the message;
Applying the data attribute to the subscription at the network core to determine how to route the message;
Selectively routing the message based on the application and the quality of service guarantee,
The above application steps are:
Extracting the data attribute from the packet;
Comparing the extracted data attributes with two or more attribute filters;
Performing each of the functions if each of the two or more attribute filters is satisfied,
Each of the attribute filters described above is characterized in that the subscriber describes a set of events of interest received from the issuer. 上記１組の機能は、上記メッセージをルーティングすることを含むことを特徴する請求項６記載のルーティング方法。  7. The routing method of claim 6, wherein the set of functions includes routing the message. 上記２つ以上の属性フィルタが満たされない場合、上記メッセージを削除するステップを更に有する請求項６記載のルーティング方法。  The routing method according to claim 6, further comprising a step of deleting the message when the two or more attribute filters are not satisfied. 上記検査ステップを、上記ネットワークコア内のルータにおいて実行するステップを更に有する請求項６記載のルーティング方法。  The routing method according to claim 6, further comprising the step of executing the checking step in a router in the network core. プロセッサ及びメモリを有し、ネットワークにおいて、サービス品質保証に基づいてパケットをルーティングするルーティング装置において、
ヘッダ部と、ペイロード部とを有するパケットを受信する受信手段と、
ネットワークコアにおいて、上記パケットのペイロード部を検査する検査手段と、
上記パケットの確保された帯域幅に関する上記サービス品質保証を判定する判定手段と、
上記検査手段及び判定手段による判定の結果得られた検査結果及び上記サービス品質保証に基づいて、上記パケットを選択的にルーティングするルーティング手段とを備え、
上記検査手段は、
上記ペイロード部からデータ属性を抽出し、
上記抽出したデータ属性を２つ以上の属性フィルタと比較し、
上記２つ以上の属性フィルタのそれぞれが満たされる場合、上記パケットをどのようにルーティングするかを決定し、
上記各属性フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述していることを特徴すルーティング装置。In a routing device having a processor and a memory and routing packets based on quality of service guarantees in a network,
Receiving means for receiving a packet having a header portion and a payload portion;
In the network core, inspection means for inspecting the payload portion of the packet;
Determining means for determining the quality of service guarantee relating to the reserved bandwidth of the packet;
Routing means for selectively routing the packet based on the inspection result obtained as a result of the determination by the inspection means and the determination means and the service quality assurance;
The inspection means is
Extract data attributes from the payload part,
Compare the extracted data attributes with two or more attribute filters,
If each of the two or more attribute filters is satisfied, determine how to route the packet;
Each of the attribute filters described above is characterized in that the subscriber describes a set of events of interest received from the issuer. 上記検査を、上記ネットワークコア内のルータで実行する手段を更に備える請求項１０記載のルーティング装置。  The routing device according to claim 10, further comprising means for executing the inspection by a router in the network core. 上記検査を実行するために、上記属性フィルタを、上記ネットワーク内のルータに伝搬する手段を更に備える請求項１０記載のルーティング装置。  11. The routing device according to claim 10, further comprising means for propagating the attribute filter to a router in the network in order to perform the inspection. 上記受信、検査及びルーティングを実行するために、上記ネットワーク内のルータをプログラミングする手段を更に備える請求項１０記載のルーティング装置。  11. The routing device of claim 10, further comprising means for programming a router in the network to perform the reception, inspection and routing. 当該ルーティング装置は、ルータであることを特徴とする請求項１０記載のルーティング装置。  The routing device according to claim 10, wherein the routing device is a router. プロセッサ及びメモリを有し、ネットワークにおいて、メッセージをルーティングするルーティング装置において、
ヘッダ部と、少なくとも１つの主語と、複数のデータ属性とを有するメッセージを受信する受信手段と、
上記メッセージから、上記主語及び上記データ属性を読み出す主語／属性読出手段と、
上記主語に基づいて、購読予約を読み出す購読予約読出手段と、
上記メッセージを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、上記購読予約を複数のフィルタに照合する照合手段と、
上記パケットの確保された帯域幅に関するサービス品質保証を判定する判定手段とを備え、
上記主語／属性読出手段は、
上記購読予約に対応した複数のフィルタを読み出す手段を備え、
上記各フィルタは、購読者が、発行者から受信した興味があるイベントの組を記述していることを特徴するルーティング装置。In a routing device having a processor and memory and routing messages in a network,
Receiving means for receiving a message having a header part, at least one subject, and a plurality of data attributes;
Subject / attribute reading means for reading the subject and the data attribute from the message;
Subscription reservation reading means for reading out a subscription based on the subject,
Collating means for matching the subscription reservation to a plurality of filters in the network core to determine how to route the message to a subscriber device;
Determining means for determining a quality of service guarantee related to the reserved bandwidth of the packet,
The subject / attribute reading means is:
Means for reading out a plurality of filters corresponding to the subscription;
Each of the filters described above is characterized in that a subscriber describes a set of events of interest received from a publisher. 上記データ属性が上記複数のフィルタのそれぞれを満たす場合、上記サービス品質保証に基づいて、上記メッセージを選択的にルーティングする手段を更に備える請求項１５記載のルーティング装置。  16. The routing device according to claim 15, further comprising means for selectively routing the message based on the quality of service guarantee when the data attribute satisfies each of the plurality of filters. 上記データ属性が上記複数のフィルタの全てを満たさない場合、上記メッセージを削除する手段を更に備える請求項１５記載のルーティング装置。  The routing device according to claim 15, further comprising means for deleting the message when the data attribute does not satisfy all of the plurality of filters. 上記フィルタリングを、上記ネットワークコア内のルータにおいて実行する手段を更に備える請求項１５記載のルーティング装置。  16. The routing device according to claim 15, further comprising means for executing the filtering in a router in the network core. 当該ルーティング装置は、ルータであることを特徴とする請求項１５記載のルーティング装置。  16. The routing device according to claim 15, wherein the routing device is a router. マルチキャストネットワークにおいて、データのパケットをルーティング及びキャッシングするルーティング／キャッシング方法において、
ヘッダ部と、ペイロード部とを有するパケットを受信する受信ステップと、
上記パケットを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、該パケットのペイロード部を検査する検査ステップと、
上記検査に基づいて、上記パケットを選択的にルーティングするルーティングステップと、
上記パケットに対応するチャンネルを判定するステップと、
上記チャンネルのチャンネル特性を読み出すステップと、
上記チャンネル特性から、上記チャンネルが持続的なチャンネルであるか否かを判定するステップと、
上記チャンネルが持続的なチャンネルである場合、上記パケットからデータを、上記ネットワークコアのコアルーティングノードで局所的にキャッシングするステップとを有し、
上記コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置することを特徴するルーティング／キャッシング方法。In a routing / caching method for routing and caching packets of data in a multicast network,
A receiving step of receiving a packet having a header portion and a payload portion;
An inspection step of inspecting the payload portion of the packet at the network core to determine how to route the packet to the subscriber device;
A routing step for selectively routing the packet based on the inspection;
Determining a channel corresponding to the packet;
Reading channel characteristics of the channel;
Determining from the channel characteristics whether the channel is a persistent channel;
Caching the data from the packet locally at a core routing node of the network core if the channel is a persistent channel;
A routing / caching method, wherein the core routing node is located in a direction away from a subscriber device upstream of an edge routing node. 上記検査ステップを、ルータで実行するステップを更に有する請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method according to claim 20, further comprising the step of executing said checking step at a router. 上記検査ステップは、上記ペイロード部内の情報にフィルタを適用するステップを含むことを特徴とする請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method according to claim 20, wherein the checking step includes a step of applying a filter to information in the payload portion. 上記検査を実行するために、上記フィルタを、上記ネットワーク内のルータに伝搬するステップを更に有する請求項２２記載のルーティング／キャッシング方法。  23. The routing / caching method of claim 22, further comprising the step of propagating the filter to a router in the network to perform the inspection. 上記受信ステップ、検査ステップ及びルーティングステップを実行するために、上記ネットワーク内のルータをプログラミングするステップを更に有する請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method of claim 20, further comprising the step of programming a router in the network to perform the receiving, examining and routing steps. 上記検査ステップは、上記パケットをどのようにルーティングするかを決定するために、上記属性を検査するステップを含むことを特徴とする請求項２０記載のルーティング／キャッシング方法。  21. A routing / caching method according to claim 20, wherein said checking step includes the step of checking said attribute to determine how to route said packet. 上記キャッシングされたデータにタイムマークを付すステップを更に有する請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method of claim 20, further comprising the step of time marking the cached data. 上記キャッシングされたデータにインデックスを付すステップを更に有する請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method of claim 20, further comprising the step of indexing the cached data. データ要求を受信するステップと、
上記キャッシングされたデータが上記データ要求を満たすか否かを判定するステップとを更に有する請求項２０記載のルーティング／キャッシング方法。Receiving a data request;
21. The routing / caching method of claim 20, further comprising: determining whether the cached data satisfies the data request. エッジルーティングノードにおいて、上記パケットからデータを局所的にキャッシングするステップを更に有し、
上記コアルーティングノードにキャッシングされたデータは、上記エッジルーティングノードにキャッシングされた全てのデータ及び他の位置にキャッシングされたデータを含むことを特徴する請求項２０記載のルーティング／キャッシング方法。Further comprising locally caching data from the packet at an edge routing node;
21. The routing / caching method according to claim 20, wherein the data cached in the core routing node includes all data cached in the edge routing node and data cached in other locations. タイムフレームＴの経過後に、上記キャッシングされたデータを削除するステップを更に有する請求項２０記載のルーティング／キャッシング方法。  21. The routing / caching method according to claim 20, further comprising the step of deleting the cached data after a time frame T has elapsed. データのパケットをルーティング及びキャッシングするネットワークにおいて、
ヘッダ部と、ペイロード部とを有するパケットを受信して、ルーティングするエッジルーティングノードであって、該受信したパケットをルーティングするインテリジェントルータを含むエッジルーティングノードと、
ネットワークコア内に位置するコアルーティングノードと、
上記コアルーティングノード内に位置し、上記インテリジェントルータに動作可能に接続されたキャッシュマネージャとを備え、
上記インテリジェントルータは、
上記パケットを購読者装置にどのようにルーティングするかを決定するために、上記ネットワークコアにおいて、該パケットのペイロード部を検査する命令と、
上記検査に基づいて、上記パケットを選択的にルーティングする命令とを有し、
上記キャッシュマネージャは、
上記パケットのそれぞれに対応するチャンネルを判定する命令と、
上記チャンネルのチャンネル特性を読み出す命令と、
上記チャンネル特性から、上記各チャンネルが持続的なチャンネルであるか否かを判定する命令と、
上記チャンネルが持続的なチャンネルである場合、上記対応するパケットからデータを、上記コアルーティングノードのローカルキャッシュで局所的にキャッシングする命令とを有し
上記コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置することを特徴するネットワーク。In a network that routes and caches packets of data,
An edge routing node that receives and routes a packet having a header portion and a payload portion, the edge routing node including an intelligent router that routes the received packet;
A core routing node located within the network core;
A cache manager located in the core routing node and operatively connected to the intelligent router;
The above intelligent router
Instructions for examining the payload portion of the packet at the network core to determine how to route the packet to a subscriber device;
Instructions for selectively routing the packet based on the inspection;
The above cache manager
An instruction for determining a channel corresponding to each of the packets;
A command to read the channel characteristics of the above channel;
A command to determine whether each channel is a persistent channel from the channel characteristics;
If the channel is a persistent channel, it has instructions to locally cache data from the corresponding packet in a local cache of the core routing node. The core routing node subscribes upstream from the edge routing node. A network characterized by being located in a direction away from a user device. 上記エッジルーティングノードに動作可能に接続されたエージェントを更に備え、
エージェントは、
上記キャッシングされたデータの位置を判定する命令と、
上記ローカルキャッシュから、上記キャッシングされたデータを読み出す命令と、
上記読み出したキャッシングされたデータを処理する命令とを有することを特徴する請求項３１記載のネットワーク。An agent operatively connected to the edge routing node;
Agent
An instruction to determine the location of the cached data;
An instruction to read the cached data from the local cache;
32. The network of claim 31, further comprising instructions for processing the read cached data. 上記チャンネルのチャンネル特性をそれぞれを提供する複数のチャンネルマネージャを更に備える請求項３１記載のネットワーク。  32. The network of claim 31, further comprising a plurality of channel managers each providing channel characteristics of the channel. 上記キャッシュマネージャは、
上記キャッシングされたデータにタイムマークを付す命令を更に有することを特徴とする請求項３１記載のネットワーク。The above cache manager
32. The network of claim 31, further comprising instructions for attaching a time mark to the cached data. 上記キャッシュマネージャは、
上記キャッシングされたデータにインデックスを付す命令を更に有することを特徴とする請求項３１記載のネットワーク。The above cache manager
32. The network of claim 31, further comprising instructions for indexing the cached data. 上記キャッシュマネージャは、
データ要求を受信する命令と、
上記キャッシングされたデータが上記データ要求を満たすか否かを判定する命令とを更に有することを特徴とする請求項３１記載のネットワーク。The above cache manager
An instruction to receive a data request;
32. The network of claim 31, further comprising instructions for determining whether the cached data satisfies the data request. マルチキャストネットワークにおいて、データのパケットをルーティング及びキャッシングするルーティング／キャッシング装置において、
複数のプロセッサと、
上記複数のプロセッサによって実行される命令とを備え、
上記命令は、
ヘッダ部と、ペイロード部とを有するパケットを受信する命令と、
上記パケットを購読者装置にどのようにルーティングするかを決定するために、ネットワークコアにおいて、該パケットのペイロード部を検査する命令と、
上記検査に基づいて、上記パケットを選択的にルーティングする命令と、
上記パケットに対応するチャンネルを判定する命令と、
上記チャンネルのチャンネル特性を読み出す命令と、
上記チャンネル特性から、上記チャンネルが持続的なチャンネルであるか否かを判定する命令と、
上記チャンネルが持続的なチャンネルである場合、上記パケットからデータを、上記ネットワークコアのコアルーティングノードで局所的にキャッシングする命令とを有し、
上記コアルーティングノードは、エッジルーティングノードの上流の購読者装置から離れる方向に位置することを特徴するルーティング／キャッシング装置。In a routing / caching device for routing and caching data packets in a multicast network,
Multiple processors,
Instructions executed by the plurality of processors,
The above instruction
An instruction to receive a packet having a header portion and a payload portion;
In order to determine how to route the packet to the subscriber device, at the network core, an instruction to examine the payload portion of the packet;
Instructions to selectively route the packet based on the inspection;
An instruction for determining a channel corresponding to the packet;
A command to read the channel characteristics of the above channel;
A command to determine whether the channel is a persistent channel from the channel characteristics;
If the channel is a persistent channel, the data from the packet is locally cached at a core routing node of the network core, and
The routing / caching apparatus, wherein the core routing node is located in a direction away from a subscriber apparatus upstream of the edge routing node. 上記複数のプロセッサは、
上記検査する命令と、選択的にルーティングする命令とを実行する第１のプロセッサと、
上記局所的にキャッシングする命令を実行する第２のプロセッサとを含むことを特徴とする請求項３７記載のルーティング／キャッシング装置。The plurality of processors are
A first processor that executes the instructions to be inspected and instructions to selectively route;
38. The routing / caching apparatus according to claim 37, further comprising: a second processor that executes the locally caching instruction.

Images