CN1998198A - 发布设备、接收设备、树型发布系统和信息处理方法等 - Google Patents

Abstract

提供一种处理设备、树型发布系统、处理程序和记录介质等，其能够减少上行网络中的通信路径中的负载集中，同时执行对系统中的较低节点设备的请求。在布置在包括有广播站设备的树型发布系统中的节点设备中，广播站设备用于将诸如请求接收开始数据的查询信息发送到多个节点设备，该请求接收开始数据用于请求诸如选择节点信息的响应信息的发送，从被连接成较高层级的另一个节点设备接收该查询信息，并且该查询信息被传递到被连接成较低层级的又一个节点设备。从该另一个处理设备接收该响应结果信息，并且产生该节点设备本身的响应信息。根据包含在该响应结果信息中的该响应信息和该生成的响应信息而生成的响应结果信息被返回到被连接成较高层级的该另一个节点设备。

Description

发布设备、接收设备、树型发布系统和信息处理方法等

技术领域

[0001]

本发明涉及对等(P2P)型发布系统，并且更具体地说，涉及树型发布系统及其方法，其中多个层级是通过最高层级的用于发布信息的发布设备和经由多条通信路径以树型结构被连接到发布设备的多个节点设备形成的，并且其中通过发布设备进行发布的发布信息依次从较高层级的节点发布到较低层级的节点。本发明涉及对等(P2P)型网络系统中的处理设备等，用于响应于来自最高级设备的查询，将回复信息发送给最高级设备。

背景技术

[0002]

该系统就是所谓的对等型数据内容发布系统，并且与客户机-服务器型数据内容发布系统的不同之处在于通过流送(streaming)发布的数据内容是在作为客户机的节点设备之间进行发送或接收的。

[0003]

专利文献1中公开了一种流数据发布系统作为该种系统的例子。并且在该系统中，每一个节点设备具有用于识别网络连接关系的拓扑信息，并且通过使用拓扑信息，每一个节点设备能够连接到所识别的上游(高位层级)节点设备，接收从上游节点设备发送的流数据，并且将该流数据传递(中继)到下游(低位层级)节点设备。通过这样做，可以防止将访问集中在诸如服务器的一定计算机上。

[专利文献1]

日本专利申请2003-169089。

发明内容

本发明要解决的问题

[0004]

不过，在使用这种类型的树型发布系统的双向通信服务中，当发布设备收集响应于由发布设备发布到每一个节点设备的查询消息而来自每一个节点设备的响应消息时，将这些响应依次传递到位于最高层级上的发布设备这一方法是可行的。

[0005]

不过，在该方法中，在大量节点设备同时发送响应消息的情况下，存在这些响应消息在较短的时段内积累在较高层级的节点设备上或者发布设备上。特别是在每一个节点设备之间的通信线路的上行和下行通信带宽为异步ADSL(异步数字用户线路)的情况下。上行方向(朝着较高层级的节点设备)的通信带宽比下行方向(朝着较低层级的节点设备)的通信带宽窄。因此在响应消息的发送中发生延迟的可能性较高。因此，当设置了用于从节点设备收集响应消息的时限时，存在着来自使用了具有这种发送延迟的通信线路的节点设备的响应消息不能按时到达发布设备这样一个问题，并且因此无法获得双向通信服务的优点。

[0006]

另外，作为待解决的第二个问题，当将这种类型的计算机网络系统应用于请求程序时，其中广播设备将请求接收信息发送到下游节点设备，并且下游节点设备将所有请求一起发送到广播设备。在广播设备和节点设备形成较宽的IP(因特网协议)网络并且下游节点同时将请求发送到广播设备的情况下，会产生在IP网络的上游(高位层级)通信路径上具有较大通信负载，并且网络负载变大(换句话说，使用的网络的上游IP路由器和通信路径的频率变高)，并且上游节点设备的处理负载变大这一问题。

[0007]

考虑到上述问题，本发明的目的是提供一种在具有能够更有效率地收集响应消息的树型结构发布中的发布设备、接收设备、树型发布系统和信息处理方法。

[0008]

另外，考虑到上述第二个问题，本发明的目的是提供一种处理设备、树型网络系统、处理程序和记录方法，它能够同时执行对高位层级设备的请求，同时减少被集中在网络上游的通信路径中和上游节点设备上的负载。

用于解决问题的装置

[0009]

用于解决这些问题的如权利要求1所述的本发明针对的是用于发布发布信息并且作为树型发布系统的一部分的发布设备，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该发布设备具有：第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；以及收集信息接收装置，用于接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

[0010]

根据权利要求1的本发明，其结构为在包括有查询消息的第一发布信息已经被发布到多条通信路径上的发布设备之后，发布包括有用于收集该查询消息的响应消息的收集消息的第二发布信息，使得其经由多条通信路径中的一条通信路径(路线)依次进行传递，并且经由依次传递了该第二发布信息的该一条通信路径上的该一个接收设备将包括有已被添加了来自该通信路径上的接收设备的响应消息的收集消息的收集信息依次传递(返回)到该发布设备，因此可以更有效率地收集响应消息，并且可以减少在整个树型发布系统的上行方向上的通信量。

[0011]

用于解决这些问题的如权利要求2所述的本发明针对的是权利要求1的发布设备，其中所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的接收设备个数成正比的概率，从被连接到所述发布设备的多个接收设备中选择所述接收设备中的一个。

[0012]

根据权利要求2的本发明，以与位于每一个所述接收设备之下的层级中的接收设备个数成正比的概率，来选择该第二发布信息要被发布到的接收设备，因此可以保持公平。

[0013]

用于解决这些问题的如权利要求3所述的本发明针对的是权利要求1或2的发布设备，其中所述收集信息是从位于所述一条通信路径的最低层级中的所述接收设备发送的。

[0014]

用于解决这些问题的如权利要求4所述的本发明针对的是权利要求1至3中的任何一项的发布设备，其进一步具有消息收集条件判断装置，用于根据所述收集信息来确定是否已经满足指定消息收集条件；其中当所述消息收集条件判断装置已经确定还不满足所述消息收集条件时，所述接收设备选择装置选择被连接到所述发布设备的所述接收设备中的一个；并且所述第二发布信息发布装置将所述第二发布信息发布到所述选择的一个接收设备。

[0015]

根据权利要求4的本发明，第二发布信息被传递到该选择的接收设备，一直到满足了消息收集条件为止，因此可以可靠地收集期望的响应消息。

[0016]

用于解决这些问题的如权利要求5所述的本发明针对的是权利要求4的发布设备，其中所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的所述接收设备个数成正比的概率，从被连接到该发布设备的多个所述接收设备中选择所述接收设备中的一个。

[0017]

根据权利要求5的本发明，以与位于每一个所述接收设备之下的层级中的接收设备个数成正比的概率，选择该第二发布信息要被发布到的接收设备，因此可以保持公平。

[0018]

用于解决这些问题的如权利要求6所述的本发明针对的是权利要求4或5的发布设备，其中所述接收设备选择装置选择不同于之前被选择的接收设备的一个接收设备。

[0019]

根据权利要求6的本发明，选择了不同于之前被选择的接收设备的接收设备，因此可以保持公平。

[0020]

用于解决这些问题的如权利要求7所述的本发明针对的是权利要求1或2的发布设备，其中所述第二发布信息包含表示指定消息收集条件的信息；并且当满足该消息收集条件时，从所述通信路径上的所述接收设备发送所述收集信息。

[0021]

根据权利要求7的本发明，当已经满足了该消息收集条件时，从该接收设备发送该收集信息，因此可以更有效率地收集响应消息。

[0022]

用于解决这些问题的如权利要求8所述的本发明针对的是权利要求4至7中的任何一项的发布设备，其中所述消息收集条件包含用于指定要被收集的所述响应消息的个数的条件、用于指定在所述响应消息中包括的有效回答的个数的条件和用于指定所述第二发布信息要被传递的次数的条件中的至少一个条件。

[0023]

用于解决这些问题的如权利要求9所述的本发明针对的是权利要求1至8中的任何一项的发布设备，其中来自所述一条通信路径上的所述接收设备的所述响应消息和每一个所述接收设备惟一的ID信息是相关联的并且被附着到所述收集消息。

[0024]

用于解决这些问题的如权利要求10所述的本发明针对的是作为树型发布系统的一部分的接收设备，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该接收设备具有：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及收集信息发送装置，用于将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

[0025]

根据权利要求10的本发明，响应于在该第一发布信息中包括的该查询消息，接收了该第一发布信息的接收设备生成响应消息，并且将生成的响应消息添加到在接收的第二发布信息中包括的收集消息，并且当在该接收设备之下的层级中没有连接其他接收设备时，将包括有该收集消息的该收集信息发送给该发布设备，因此可以更有效率地将响应消息发送给该发布设备，并且可以减少在整个树型发布系统中的上行方向上的通信量。

[0026]

用于解决这些问题的如权利要求11所述的本发明针对的是作为树型发布系统的一部分的接收设备，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该接收设备具有：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及收集信息发送装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

[0027]

根据权利要求11的本发明，响应于在该第一发布信息中包括的该查询消息，接收了该第一发布信息的接收设备生成响应消息，并且将该生成的响应消息添加到在接收的第二发布信息中包括的收集消息，并且当满足在第二发布信息中包括的指定消息收集条件时，将包括有该收集消息的该收集信息直接发送给该发布设备，因此可以更有效率地将响应消息发送给该发布设备，并且可以减少整个树型发布系统中的上行方向上的通信量。

[0028]

用于解决这些问题的如权利要求12所述的本发明针对的是权利要求11的接收设备，其进一步具有：较低层级判断装置，用于当所述消息收集条件判断装置确定不满足所述消息收集条件时，确定在之下层级中是否存在另一个连接的所述接收设备；以及收集信息发送装置，用于当所述较低层级判断装置确定没有连接另一个所述接收设备时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

[0029]

用于解决这些问题的如权利要求13所述的本发明针对的是权利要求10或12的接收设备，其进一步具有：接收设备选择装置，用于当所述较低层级判断装置确定在之下层级中存在另一个连接的接收设备时，选择被连接在包括有已添加了所述响应消息的所述收集消息的收集信息被发送到的所述接收设备之下的层级中的一个所述接收设备；以及收集信息传递装置，用于将所述收集信息传递到所述选择的接收设备。

[0030]

用于解决这些问题的如权利要求14所述的本发明针对的是权利要求13的接收设备，其中所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的所述接收设备个数成正比的概率，从被连接在所述接收设备之下的层级中的多个所述接收设备中选择一个所述接收设备。

[0031]

用于解决这些问题的如权利要求15所述的本发明针对的是权利要求13或14的接收设备，所述接收设备选择装置选择另一个所述接收设备，该另一个所述接收设备不是之前选择的接收设备。

[0032]

用于解决这些问题的如权利要求16所述的本发明针对的是权利要求11至15中的任何一项的接收设备，其中所述消息收集条件包含用于指定要被收集的所述响应消息的个数的条件、用于指定在所述响应消息中包括的有效回答的个数的条件和用于指定所述第二发布信息要被传递的次数的条件中的至少一个条件。

[0033]

用于解决这些问题的如权利要求17所述的本发明针对的是权利要求10至16中的任何一项的接收设备，其中所述响应消息添加装置使所述生成的响应消息与该接收设备惟一的ID信息相关联，并且将它们添加到在所述第二发布信息中包括的所述收集消息。

[0034]

用于解决这些问题的如权利要求18所述的本发明针对的是用于发布发布信息并且作为树型发布系统的一部分的发布设备的信息处理方法，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法具有以下步骤：发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

[0035]

用于解决这些问题的如权利要求19所述的本发明针对的是用于作为树型发布系统的一部分的接收设备的信息处理方法，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法具有以下步骤：从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；生成用于所述查询消息的响应消息；从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；确定在之下层级中是否存在另一个连接的所述接收设备；以及将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

[0036]

用于解决这些问题的如权利要求20所述的本发明针对的是用于作为树型发布系统的一部分的接收设备的信息处理方法，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法具有以下步骤：从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；生成用于所述查询消息的响应消息；从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

[0037]

用于解决这些问题的如权利要求21所述的本发明针对的是使用于发布发布信息并且作为树型发布系统的一部分的发布设备中的计算机起如下作用的信息处理程序，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；以及收集信息接收装置，用于接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

[0038]

用于解决这些问题的如权利要求22所述的本发明针对的是使作为树型发布系统的一部分的接收设备中的计算机起下述作用的信息处理程序，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及收集信息发送装置，用于将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

[0039]

用于解决这些问题的如权利要求23所述的本发明针对的是使作为树型发布系统的一部分的接收设备中的计算机起如下作用的信息处理程序，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及收集信息发送装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

[0040]

用于解决这些问题的如权利要求24所述的本发明针对的是记录介质，其上记录了如权利要求21至23的任何一项所述的信息处理程序，以便可以由计算机读取。

[0041]

用于解决这些问题的如权利要求25所述的本发明针对的是树型发布系统，其包括用于发布发布信息的发布设备和用于接收所述发布信息的多个接收设备，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，其中所述发布设备具有：第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集与所述查询消息相对应的响应消息的收集消息；以及第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备；并且所述接收设备具有：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及收集信息发送/传递装置，用于当所述较低层级判断装置已经确定没有连接所述其他接收设备时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备，并且将包括有已经被添加了所述响应消息的所述收集消息的所述收集信息传递到被连接在之下层级中的所述接收设备中的一个。

[0042]

用于解决这些问题的如权利要求26所述的本发明针对的是树型发布系统，其具有用于发布发布信息的发布设备和用于接收所述发布信息的多个接收设备，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，其中所述发布设备具有：第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集与所述查询消息相对应的响应消息的收集消息和用于表示指定消息收集条件的信息；以及第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备；并且所述接收设备具有：第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第一发布信息；响应消息生成装置，用于生成用于所述查询消息的响应消息；第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收所述第二发布信息；响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及收集信息发送/传递装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备，并且当所述消息收集条件判断装置确定不满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的所述收集信息传递到被连接在之下层级中的所述接收设备中的一个。

[0043]

用于解决这些问题的如权利要求27所述的本发明针对的是树型网络系统中的处理设备，该树型网络系统包括：查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由通信路径与所述多个处理设备连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成了多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中所述处理设备之一具有：查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的另一个所述处理设备或者从所述查询设备发送的所述查询信息；查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备中的一个或多个；回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中的至少一个或多个发送的所述回复结果信息；回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备。

[0044]

因此，结构使得新回复结果信息是根据从被连接在正下层中的处理设备所发送的回复结果信息来创建的，并且然后发送到高位层级，因此可以减少负载集中在网络的上游通信路径(例如一定IP路由器等)中，从而可以提高系统的运行效率。

[0045]

用于解决这些问题的如权利要求28所述的本发明针对的是权利要求27的处理设备，其进一步具有：选择装置，用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复信息创建装置创建的回复信息中选择指定个数项的所述回复信息，其中所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

[0046]

因此，从查询设备发送查询信息，并且当该查询设备从在回复结果信息中包括的回复信息和从下游处理设备发送的为查询信息创建的各项回复信息中选择指定个数项的回复信息时，结构使得每一个下游设备从在来自被连接在正下层中的处理设备的回复结果信息中包括的回复信息和由该处理设备本身的创建装置创建的回复信息的各项中选择指定个数项的回复信息，并且将它们包括在要发送到处理设备或被连接在正上层中的查询设备的回复结果信息中，因此查询设备只需在从被连接在正下层中的每一个处理设备发送的各回复结果信息中包括的各回复信息中选择指定个数项的回复信息，从而可以更有效率地执行回复信息的选择。

[0047]

用于解决这些问题的如权利要求29所述的本发明针对的是权利要求28的处理设备，其进一步具有：总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；其中所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

[0048]

因此，当处理设备从来自被连接在正下层中的每一个处理设备的回复信息和由该处理设备本身创建的回复信息的各项中选择指定个数项的回复信息，并且将这些项的回复信息发送给被连接在正上层中的处理设备时，结构使得用于表示从多少项回复信息中选择了所述项回复信息的总个数信息得以被发送，因此当从被连接在正下层中的每一个处理设备发送的各项回复信息中选择指定个数项的回复信息时，可以在选择指定个数项的回复信息时考虑每一个的权重，从而可以得到均等地选择由所有处理设备创建的各项回复信息的结构。

[0049]

用于解决这些问题的如权利要求30所述的本发明针对的是权利要求29的处理设备，其中当所述回复结果信息回复装置发送所述回复结果信息时，所述总个数信息发送装置发送所述总个数信息。

[0050]

因此，当处理设备选择指定个数项的回复信息并且将这些项发送给被连接在正上层中的处理设备时，结构使得这些项与用于表示从多少项回复信息中选择了所述选择项的总个数信息一起被发送。因此当选择指定个数项的回复信息时，可以通过考虑每一个的权重来快速选择指定个数项的回复信息。

[0051]

用于解决这些问题的如权利要求31所述的本发明针对的是权利要求27至30中的任何一项的处理设备，其进一步具有：结束信息接收装置，用于从被连接在所述高位层级中的其他所述处理装置或者所述查询装置接收给出用于结束针对所述查询信息的回答信息的输入接收指令的结束信息；以及回答信息输入接收装置，用于从当所述查询信息接收装置接收到所述查询信息时一直到所述结束信息接收装置接收到所述结束信息为止，接收所述回答信息的输入；其中所述回复信息创建装置根据由所述回答信息输入接收装置接收的所述回答信息的输入来创建所述回复信息。

[0052]

因此，结构使得请求接收结束数据与来自查询设备的查询信息被分开接收，因此所有下游设备可以在不收到通信延迟时间等的影响的情况下，在相同的时间段内输入回答信息。

[0053]

用于解决这些问题的如权利要求32所述的本发明针对的是权利要求27至31中的任何一项的处理设备，其进一步具有：等待时间设置装置，用于设置用于从被连接在所述低位层级中的所述其他处理设备接收所述回复结果信息的接收等待时间；其中所述回复结果信息创建装置根据由所述回复结果信息接收装置在所述接收等待时间内接收的所述回复结果信息来创建用于所述一个处理设备本身的回复结果信息。

[0054]

因此，接收可以被任意时间量分开，而不必长时间等待被连接在正下层中的所有处理设备发送回复结果信息，并且甚至当在被连接在低位层级中的处理设备中或者在通信网络中发生某种故障时，也可以防止对整个系统产生负面效应。

[0055]

用于解决这些问题的如权利要求33所述的本发明针对的是权利要求28至32中的任何一项的处理设备，其进一步具有：判断装置，用于确定由所述回复信息创建装置创建的回复信息是否与由所述查询信息接收装置接收的查询信息相对应；其中当确定该回复信息与所述查询信息不对应时，所述选择装置去除作为选择对象的由所述回复信息创建装置创建的回复信息，并且仅从在由所述回复结果信息接收装置接收的回复结果信息中包括的回复信息中选择所述指定个数项的回复信息。

[0056]

因此，在从查询设备发送的查询信息用于测验的情况下，结构使得查询信息与正确回答一起被发送，以便当创建的该回复信息不与测验的正确回答相匹配时，将该项回复信息作为选择对象去除掉。这样，可以进行观看者/收听者参与类型的测验。

[0057]

用于解决这些问题的如权利要求34所述的本发明针对的是树型网络系统，该树型网络系统具有：查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由多条通信路径与所述多个处理设备连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中所述处理设备之一具有：查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的另一个所述处理设备或者从所述查询设备发送的所述查询信息；查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备；回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中发送的所述回复结果信息；回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；其中所述查询设备具有：查询信息发送装置，用于将所述查询信息发送到被连接在所述查询设备之下的低位层级中的所述处理设备中的至少一个或多个；以及回复结果信息装置，用于接收从被连接在低位层级中的所述处理设备中的至少一个或多个发送的所述回复结果信息。

[0058]

用于解决这些问题的如权利要求35所述的本发明针对的是权利要求34的树型网络系统，其中所述处理设备进一步具有：选择装置，用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复信息创建装置创建的回复信息中选择指定个数项的所述回复信息；并且其中所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

[0059]

用于解决这些问题的如权利要求36所述的本发明针对的是权利要求35的树型网络系统，其中所述处理设备进一步具有：总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；并且其中所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

[0060]

用于解决这些问题的如权利要求37所述的本发明针对的是用于树型网络系统中的处理设备中包含的计算机的处理程序，该树型网络系统具有：查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由多条通信路径与所述多个处理设备被连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中所述程序使所述处理设备的所述计算机起到以下作用：查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的另一个所述处理设备或者从所述查询设备发送的所述查询信息；查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备中的一个或多个；回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中的至少一个或多个发送的所述回复结果信息；回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备。

[0061]

用于解决这些问题的如权利要求38所述的本发明针对的是权利要求37的处理程序，其进一步使所述计算机起到选择装置的作用，该选择装置用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复结果信息创建装置创建的回复信息中选择指定个数项的所述回复信息；并且使所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

[0062]

用于解决这些问题的如权利要求39所述的本发明针对的是权利要求38的处理程序，其进一步使所述计算机起到如下作用：总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；并且使所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

[0063]

用于解决这些问题的如权利要求40所述的本发明针对的是一种记录介质，其上记录有如权利要求37至39中的任何一项的所述处理程序，以便其可以被所述计算机读取。

本发明的效果

[0064]

通过本发明，发布包括有用于收集针对询问消息的响应消息的收集消息的第二发布信息，以便经由多条通信路径中的一条通信路径依次将其发送，并且将包括有已由该通信路径上的接收设备添加了响应消息的收集消息的收集信息从第二发布信息依次被传递到的一条通信路径上的一个接收设备发送到发布设备，因此可以更有效率地收集响应消息，并且可以减少整个树型发布系统中上行方向上的通信量。

[0065]

通过该发明，结构使得在处理设备创建和汇总针对从最高层中的设备发送的询问信息的回复结果信息之后，根据从被连接在低位层级中的每一个处理设备发送的各项回复结果信息，将该信息发送到被连接在高位层级中的处理设备，因此可以减少网络的上游通信路径和上游处理设备中负载的集中，由此可以改善系统的运行效率。

附图说明

[0066]

图1示出了本发明的实施例的树型发布系统中的每一个设备的连接状态的例子。

图2示出了广播站设备的结构的例子。

图3示出了节点设备的结构的例子。

图4A为流程图，示出了由广播站设备1的控制单元11执行的用于发布询问消息数据的处理。

图4B为流程图，示出了由节点设备2的控制单元21执行的用于接收询问消息数据的处理。

图5为流程图，示出了由广播站设备1的控制单元11执行的用于发布收集消息数据的处理。

图6为流程图，示出了由广播站设备1的控制单元11执行的用于接收收集消息数据的处理。

图7为流程图，示出了由节点设备2的控制单元21执行的用于接收和传递收集消息数据的处理。

图8示出了当在通信路径K3中满足消息收集条件时发送收集消息数据的状态的例子。

图9示出了当在通信路径K3中不满足消息收集条件时发送收集消息数据的状态的例子。

图10示出了再发布收集消息数据以满足消息收集条件的状态的例子。

图11为框图，示出了第二实施例中的树型网络系统S的结构。

图12解释了广播设备201的结构。

图13解释了节点设备202的结构。

图14示出了广播设备201和节点设备202之间发送和接收请求接收数据和回复结果信息Ans。

图15为流程图，示出了由广播设备201的控制单元211执行的请求接收数据发送处理。

图16为流程图，示出了由节点设备202的控制单元221执行的回复结果信息发送处理。

图17解释了在节点设备202的存储单元222中存储的总个数信息和选择节点信息。

图18为流程图，示出了由节点202的控制单元221执行的回复结果信息生成处理。

图19示出了用于将回复结果信息Ans发送到树型网络系S中的广播设备201的发送处理。

标号和字母说明

[0067]

1   广播站设备

2   节点设备

3   系统管理服务器设备

10  网络

11  控制单元

12  存储单元

13  编码单元

14  通信单元

15  总线

16  解码单元

21  控制单元

22  存储单元

23  缓冲存储器

24  解码单元

25  视频处理单元

26  显示单元

27  音频处理单元

28  扬声器

29  通信单元

29a   输入单元

30    总线

31    编码单元

32    视频处理单元

33    照相机

34    音频处理单元

35    麦克风

K     通信路径

S     树型发布系统

201   广播设备

202(202a、202b、202c、202d、202e、202f、202g、202h、202i、202j、202k、202l、202m、202n、202o、202p)节点设备

203(203a、203b、203c、203d、203e、203f、203g、203h、203i、203j、203k、203l、203m、203n、203o、203p)通信路径

211  控制单元

212  存储单元

213  操作输入单元

214  编码单元

215  通信单元

216  总线

221  控制单元

222  存储单元

223  缓冲存储器

224  解码单元

225  视频处理单元

226  音频处理单元

227  操作输入单元

228  通信单元

229  总线

M    显示单元

U    扬声器

Rb   请求接收开始数据

Re   请求接收结束数据

X    选择节点信息

N    总个数信息

Ans  回复结果信息

Tr   请求可能时段

To   超时时间

M    设备的总个数

Su   被连接在正下层中的节点设备202的个数

具体实施方式

[0068]第一实施例

下面根据附图来讲述本发明的优选实施例。以下实施例为将本发明应用到树型发布系统中的实施例。

[0069]

[1.树型发布系统的结构]

首先参照图1来讲述树型发布系统的结构。

[0070]

图1示出了本发明的树型发布系统中的设备的连接状态的例子。在图1所示的例子中，上方框100示出了树型发布系统S中的设备的电气连接状态(例如，建立了通信的设备之间的连接关系)，并且下方框101示出了包括有树型发布系统S的各设备的设备之间的物理连接状态。

[0071]

如图1所示，该树型发布系统S为对等(P2P)型网络系统，其包括：广播设备1，作为用于发布作为发布信息的内容数据(也被称为流数据)以及作为发布信息的包括有各种类型消息的发布信息的各种消息数据的发布设备的例子；以及多个节点设备(对等设备)2a、2b、2c...2l，作为用于接收上述内容数据和消息数据的多个接收设备的例子。

[0072]

这种类型的树型发布系统的节点设备2a至2l被称为树型发布系统S的加入节点设备。另外，在图1中，可以从树型发布系统S中去除掉加入树型发布系统S中的节点设备2a至2l。

[0073]

如图1的下方框101所示，广播站设备1和多个节点设备2被物理连接到诸如由IX(因特网交换)5、ISP(因特网服务供应商)6、DSL(数字用户线)线路供应商(设备)7、FTTH(光纤入户)线路供应商(设备)和通信线路(例如电话线、光缆等)9构成的因特网等网络，并且广播站设备1和每一个节点设备2被分配惟一设备ID和IP(因特网协议)地址。在图1的下方框101中，与通信线路9相对应的实线的厚度表示通信线路的带宽(例如数据传输比率)。

[0074]

假设这些设备以如下方框101中所示的方式进行物理连接，则如图1的上方框100所示，树型发布系统S形成为多个层级，其中广播站设备1形成最高层级，并且多个节点设备2a至2l形成多个层级，并且根据每一个IP地址，具有树状的覆盖网络是经由多条通信路径K1、K2、K3...创建的。另外，由广播站设备1发布的内容数据和消息数据从诸如2a等较高层级的节点设备被依次传递到诸如2g等较低层级的节点设备。这样，加入树型发布系统S的节点设备2能够接收发布或传递的内容数据，不过，当从树型发布系统S中去除掉节点设备2时，其不再能够接收内容数据。

[0075]

这里，通过从广播站设备1到位于最低层级中的节点设备的通信线路等形成了一条通信路径。例如，在上方框100中所示的通信路径K1是由通信线路4a、节点设备2a、通信线路4c、节点设备2c、通信线路4g和节点设备2g形成的。另外，在上方框100中所示的通信路径K2是由通信线路4a、节点设备2a、通信线路4c、节点设备2c、通信线路4h和节点设备2h形成的。另外，例如，通信线路4a是由在图1的下方框101中所示的各种带宽的多条通信线路9形成的。

[0076]

在以下讲述中，当表示节点设备2a、2b...中的一个节点设备时，出于方便可以将该节点设备简称为节点设备2。另外，当表示通信路径K1、K2、K3...中的一条通信路径时，出于方便可以将该通信路径简称为通信路径K。

[0077]

而且，在本实施例中，通过系统管理服务器设备3来执行图1的上方框100所示的树型发布系统S中的各设备之间的连接状态(连接拓扑)的设置、控制和管理。例如，系统管理服务器设备3根据来自每一个节点设备2的加入请求来设置如图1的上方框100所示的树型发布系统S的各设备之间的连接状态，之后根据该连接状态，创建用于每一个节点设备2的连接状态表，并且将该表发送到请求加入的每一个节点设备2。并且树型发布系统S是通过根据连接状态表将连接请求发送到广播站设备1或者较高层级节点设备2并且进行连接的每一个节点设备创建的。被发送到每一个节点设备2的连接状态表至少包括作为节点设备2要连接到的广播站设备1的惟一ID信息的广播站设备ID(或者广播站设备1的IP地址)或者作为较高层级节点设备2的惟一ID信息的节点设备ID(或者节点设备的IP地址)。另外，系统管理服务器设备3将连接状态表发送到广播站设备1，该连接状态表包括有由广播站设备1将内容数据或各种类型的消息数据发布到的节点设备2的节点设备ID(或者节点设备2的IP地址)。

[0078]

另外，由于从树型发布系统S中去除掉位于较高层级中的节点设备2而不再能够接收内容数据等的节点设备2可以将加入请求发送到系统管理服务器设备3，以获取新的连接状态表，并且通过根据该连接状态表来执行连接到广播站设备1或较高层级节点设备2的请求，树型发布系统S得到重建。

[0079]

广播站设备1还可以取代系统管理服务器设备3来设置、控制和管理各设备之间的连接状态。

[0080]

[2.广播站设备的结构]

接下来参照图2来讲述广播站设备1的结构和功能。

[0081]

图2示出了广播站设备1的结构。

[0082]

如图2所示，广播站设备1包括：控制单元11，由具有计算功能的CPU(中央处理单元)、用于工作区域的RAM(随机访问存储器)和用于存储各种数据和程序的ROM(只读存储器)构成；存储单元12，由用于存储各种数据和程序以及内容数据和消息数据的HDD(硬盘驱动器)构成；编码单元13，用于对在内容数据中包括的视频数据(视频信息)和音频数据(音频信息)进行编码(数据压缩或加密)；解码单元16，用于对视频数据(视频信息)和音频数据(音频信息)进行解码(扩展或解码)；以及通信单元14，用于控制经由网络10与节点设备2的通信，其中所有这些组件经由总线15连接在一起。

[0083]

另外，通过控制单元11的CPU执行被存储在存储单元12中的程序，控制单元11读取被存储在存储器12中的内容数据，并且通过编码单元13对在内容数据中包括的视频数据和音频数据进行编码，并且经由通信单元14将结果发布到节点设备2(图1的上方框100中所示的例子中的节点设备2a和2b)。

[0084]

此外，通过控制单元11中的CPU执行被存储在存储单元12中的信息处理程序，控制单元11起到第一发布信息发布装置、接收设备选择装置、第二发布信息发布装置、收集信息接收装置和消息收集条件判断装置的作用。例如，信息处理程序可以从网络10上的特定服务器中下载，或者可以被记录在诸如CD-ROM等记录介质上并且通过记录介质驱动器来进行读取。

[0085]

下面来详细讲述通过控制单元11执行的第一发布信息发布装置、接收设备选择装置、第二发布信息发布装置、收集信息接收装置和消息收集条件判断装置。

[0086]

控制单元11与通信单元14一起起到第一发布信息发布装置的作用，并且在本实施例中，沿着多条通信路径根据他们各自的IP地址将包括有作为第一发布信息的查询消息的查询消息数据发布到所有节点设备2。例如，通过使用被形成为树状的覆盖网络，查询消息数据首先从广播站设备1被发布到在图1的上方框100中所示的节点设备2a和2b，之后，依次将其从节点设备2a和2b传递到较低层级设备2。另外，除了查询消息之外，该查询消息数据还包括作为该查询消息的惟一ID信息的消息ID和广播站设备1的广播站设备ID(或者广播站设备1的IP地址)。

[0087]

这里，查询消息为可以包括问卷调查、测验问题、来自诸如DJ(电台的音乐节目主持人)等个人的查询等的消息，广播站使用该消息来要求节点设备2的一些用户进行回复。

[0088]

当节点设备2接收到该查询消息数据时，响应于该查询消息，节点设备2生成和保存响应消息。该响应消息包含对查询消息的响应，例如，当查询消息包含调查问卷或测验问题时(例如，从5个选项中选择一项的查询)，响应消息包含对调查问题或测验问题的回答(例如5个选项中的第3个选项)。另外，在查询消息包含来自DJ等的查询时(例如，关于想与DJ进行通话的查询)，响应消息包含与该查询有关的请求(例如，通话请求)。

[0089]

还可以构造控制单元11，以便它根据节点设备2的IP地址将查询消息数据发布到所有节点设备。

[0090]

另外，作为接收设备选择装置，控制单元11选择被连接到广播站设备1的、收集消息数据要被发布到的节点设备2中的一个节点设备，其中收集消息数据作为包含有用于收集由至少一个节点设备2生成的上述响应消息的收集消息的第二发布信息。这种选择没有特别限制，可以通过产生随机数来随机执行，或者可以通过考虑赋予通信路径K的权重来执行。

[0091]

例如，当考虑赋予通信路径K的权重来执行选择时，根据与位于每一个节点设备2之下的较低层级中的所有节点设备2的个数成正比的概率，控制单元11从被连接到广播站设备1的多个节点设备2中选择一个节点设备2。例如，位于如图1的上方框100所示的节点设备2a之下的较低层级中的节点设备2的个数为6，或者换句话说为节点设备2c、2d、2g、2h、2i和2j。不过，位于如图1的上方框100所示的节点设备2b之下的较低层级中的节点设备2的个数为4，或者换句话说为节点设备2e、2f、2k和2l。另外，以与节点设备的个数成正比的概率来选择一个节点设备2意味着例如假设从被连接到广播站设备1的两个节点设备2a和2b中选择一个节点设备10次，节点设备2a被选择的概率为6/10，而节点设备2b被选择的概率为4/10。因此，即使位于较低层级中的节点设备2的个数对于节点设备2a侧和节点设备2b侧不同，也可以保持之后选择位于这些较低层级中的节点设备2的公平性。位于每一个节点设备2之下的较低层级中的所有节点设备2的个数是通过参考用于管理整个系统S的连接拓扑的系统管理服务器设备3而获取的。

[0092]

除了收集消息之外，上述收集消息数据还包含作为收集对象的查询消息的消息ID以及广播站设备ID(或者广播站设备1的IP地址)。

[0093]

另外，控制单元11与通信单元14一起起到第二发布信息发布装置的作用，并且发布上述收集消息数据，以便经由多条通信路径K中的一条通信路径K(例如如图1的帧100所示的通信路径K1)将其依次传递到选择的节点设备2(例如如图1的帧100所示的节点设备2a)。

[0094]

依次传递该收集消息数据，以便收集消息数据包含下述收集消息，其中响应消息通过位于一条通信路径上的节点设备2(在如图1的帧100所示的通信路径K1的情况下为节点设备2a、2c和2g)被附着到该收集消息。

[0095]

从位于一条通信路径K上的一个节点设备2将收集消息数据作为包含有收集消息的收集信息发送到广播站设备1，其中响应消息通过该条通信路径K的所有节点设备2被附着到该收集消息。下面来讲述从节点设备2收集收集消息数据。

[0096]

控制单元11与通信单元14一起起到收集信息接收装置的作用，并且接收从节点设备2发送的上述收集消息数据。在此过程中，广播站设备1从位于一条通信路径K上的所有节点设备2收集响应消息例如对调查问卷的响应。

[0097]

此时，作为消息收集判断装置，控制单元11还可以根据收集消息数据来确定是否满足指定消息收集连接。消息收集条件可以是用于指定收集的响应消息的个数的条件、用于指定在响应消息中包括的有效回答的个数的条件、用于指定收集消息数据要被传递的次数的条件等条件。

[0098]

另外，当控制单元11确定还没有满足消息收集条件时，例如当收集的响应消息的个数小于由用于指定收集的响应消息的个数的条件指定的收集的响应的个数时，再次选择被连接到广播站设备1并且假定发布收集消息数据的节点设备2。换句话说，由于没有满足消息收集条件，因此收集消息数据被再次发布到节点设备2(基本上为再次传递)。另外在这种情况下，与上述的方式相同，可以通过生成随机数来随机执行选择，或者可以通过考虑通信路径的权重来执行选择。

[0099]

此外，控制单元11可以选择另一个节点设备2，而不是以前选择的节点设备2(这意味着在发布和再发布收集消息数据直到满足消息收集条件为止的一系列处理期间选择节点设备)。例如，当之前从图1的上方框100所示的节点设备2a和2b中选择节点设备2a时，此时选择节点设备2b。通过这样做，可以保持更加公平地进行选择。

[0100]

通过例如控制单元11将内容数据和各种消息数据形成包，并且将发布目的地的IP地址添加到每一个各自的包，并且从通信单元14将其发送。

[0101]

当广播站设备1接收包括有与查询消息相对应的请求的响应消息时，广播站设备1的用户(例如DJ)可以使用下述程序，该程序使用随机数来自动指定从发送了请求的节点设备2中选择的节点设备2的IP地址，并且直接连接到该节点设备2。在这种情况下，控制单元11可以通过解码单元16对从选择的节点设备2发送的经过编码的视频数据(视频信息)和音频数据(音频信息)(例如选择的节点设备2的用户和DJ之间的通话)进行解码，并且经由通信路径14将其发送到节点设备(如图1的上方框100所示的例子中的节点设备2a和2b)。

[0102]

[3.节点设备的结构]

接下来参照图3来讲述节点设备2的结构和功能。

[0103]

图3示出了节点设备2的结构的例子。

[0104]

如图3所示，每一个节点设备2都包括：控制单元21，作为由具有计算功能的CPU、用于工作区的RAM和用于存储各种数据和程序的ROM等构成的计算机；缓冲存储器23，用于暂时存储接收的内容数据；解码单元24，用于对在内容数据中包括的经过编码的视频数据和音频数据进行解码；视频处理单元25，用于对经过解码的视频数据执行指定图像处理并且输出视频信号；显示器26，诸如CRT或液晶显示器等，用于根据从视频处理单元25输出的视频信号来显示视频；音频处理单元27，用于将经过解码的音频数据从数字转换成模拟音频信号(D/A转换)并且之后将其放大并且输出结果；扬声器28，用于将从音频处理单元27输出的音频信号作为声波输出；照相机33，当广播站设备1的用户(例如广播程序的DJ)允许发送视频数据(视频信息)和音频数据(音频信息)时，由节点设备2的用户进行使用；视频处理单元32，用于当需要由照相机33拍摄的视频或者由节点设备2的用户准备的记录视频时，执行A/D转换(模数转换)；麦克风35，由节点设备2的用户使用；音频处理单元34，用于当需要使用麦克风35记录的音频(声音)或者由节点设备2的用户准备的记录音频(声音)时，执行A/D转换(模数转换)；编码单元31，用于对由节点设备2的用户发送的视频数据(视频信息)和音频数据(音频信息)进行编码；通信单元29，用于控制经由网络10与广播站设备1或其他节点设备2的通信；以及输入单元29a，用于从用户接收指令并且将与该指令相对应的指令信号发给控制单元21；其中控制单元21、存储单元22、缓冲存储器23、解码单元24、编码单元31和通信单元29经由总线30相互连接在一起。

[0105]

另外，通过控制单元21的CPU执行在存储单元22中存储的程序，控制单元21接收从广播站设备1发布的内容数据，或者经由通信单元29从被连接在之上层级中的节点设备2(例如在图1的上方框100所示的例子中，被连接在节点设备2c之上的层级中的节点设备为节点设备2a)传递来的内容数据，并且将该内容数据存储在缓冲存储器23中，然后从缓冲存储器23中读取该内容数据，并且通过解码单元24对在该数据中包括的视频数据和音频数据进行解码，并且将视频数据输出到视频处理单元25，将音频数据输出到音频处理单元27。

[0106]

而且，控制单元21(除了最低层级中的节点设备2g至2l之外)通过通信单元29将接收的内容数据传递到被连接在之下层级中的节点设备2(例如，在图1的上方框100所示的例子中，被连接在节点设备2b之下的层级中的节点设备为节点设备2e和2f)。通过这样做，内容数据依次一直传递到最低层级的节点设备2g至2l。

[0107]

此外，通过控制单元21的CPU执行在存储单元22中存储的信息处理程序，控制单元21起到第一发布信息接收装置、响应消息生成装置、第二发布信息接收装置、响应消息添加装置以及较低层级判断装置、接收设备选择装置、收集信息传递装置、收集信息发送装置和消息收集条件判断装置的作用。信息处理程序可以从网络10上的特定服务器中下载，或者可以被记录在诸如CD-ROM等记录介质上并且通过记录介质驱动器来进行读取。

[0108]

下面来更为详细地讲述第一发布信息接收装置、响应消息生成装置、第二发布信息接收装置、响应消息添加装置以及较低层级判断装置、接收设备选择装置、收集信息传递装置、收集信息发送装置和消息收集条件判断装置。

[0109]

控制单元21与通信单元29一起起到第一发布信息接收装置的作用，并且从广播站设备或者被连接在较高层级中的节点设备2接收查询消息数据，然后作为响应消息生成装置，根据来自输入单元29a的输入来生成响应于查询消息的响应消息，并且使该响应消息与在查询消息数据中包括的消息ID和广播站ID相关联，并且将该响应消息存储在存储单元22中。例如，根据控制单元21的控制，通过视频处理单元25将在接收的查询消息数据中包括的查询消息显示在显示单元26中，并且响应于显示的查询消息，用户操作输入单元29a并且输入响应(回答)指令(例如用户从调查问卷的5个选项中选择一个选项)，并且生成与该输入相对应的响应消息。

[0110]

另外，控制单元21将上述查询消息数据传递到被连接到该节点设备2的较低层级节点设备。

[0111]

而且，控制单元21与通信单元29一起起到第二发布信息接收装置的作用，用于从广播站设备1或被连接到之上层级中的节点设备2接收上述收集消息数据；并且起到响应消息添加装置的作用，用于将在存储单元22中保存的生成的响应消息及其自己的节点设备ID添加到在收集消息数据中包括的收集消息中。

[0112]

另外，作为较低层级判断装置，控制单元21确定另一个节点设备2是否被连接在之下的层级中，并且当确定连接了节点设备2时，控制单元21作为接收设备选择装置，选择被连接在之下层级中的一个节点设备2来作为收集消息数据要被传递到的节点设备2。在这种情况下，与上述广播站设备1的情况一样，可以通过生成随机数来随机执行该选择，或者可以通过考虑通信路径K的权重来执行选择。例如，当考虑通信路径K的权重来执行选择时，控制单元21以与位于被连接到该节点设备2的每一个节点设备2之下的层级中的节点设备2的总个数成正比的概率，来选择一个节点设备2。位于每一个节点设备2之下的层级中的节点设备2的总个数是通过参考用于管理整个系统S的连接拓扑的系统管理服务器设备3而获取的。

[0113]

此外，控制单元21可以选择另一个节点设备2，而不是以前选择的节点设备2。

[0114]

另外，控制单元21与通信单元29一起起到收集信息传递装置的作用，并且根据IP地址将上述收集消息数据传递到选择的节点设备2。这样，如上所述，依次传递包括有被添加了来自位于一条通信路径K上的节点设备的响应消息的收集消息的收集消息数据。

[0115]

另一方面，当控制单元21确定没有其他节点设备被连接在之下的层级中，或者换句话说，当该节点设备2位于最低层级上时，控制单元21与通信单元29一起起到收集信息发送装置的作用，并且从在收集消息数据中包括的广播站设备ID获取IP地址(例如将广播站设备ID发送到系统管理服务器设备3并且获取与它相对应的IP地址)，并且根据该IP地址将收集消息数据发送到广播站设备1。通过这样做，如上所述，来自位于一条通信路径K上的所有节点设备2的响应消息都聚集在广播站设备1中。

[0116]

而且，作为消息收集条件判断装置，控制单元21还可以确定是否满足指定消息收集条件。消息收集条件可以与用于广播站设备1的条件相同，例如，它可以是用于指定收集的响应消息的个数的条件、用于指定在响应消息中包括的有效回答的个数的条件、用于指定收集消息数据要被传递的次数的条件等条件。这种消息收集条件可以与收集消息一起被包括在收集消息数据中并且被发布。

[0117]

另外，当控制单元21确定已经满足消息收集条件时，例如当收集消息数据已经被传递的次数到达由用于指定收集消息数据要被传递的次数的条件指定的指定次数时，即使该节点设备2不在最低层级上，也将收集消息数据发送到广播站设备1。不过，当控制单元21确定还没有满足消息收集条件时，其选择被连接在之下层级中的一个节点设备2来作为收集消息数据要被传递到的节点设备2。

[0118]

控制单元将内容数据和各种消息数据打成包，并且将发布目的地的IP地址添加到每一个包的头部中，并且由通信单元29发送各包。

[0119]

另外，节点设备2不需要包括诸如解码单元24、视频处理单元25、显示单元26、音频处理单元27和扬声器28等组件中的所有或一些组件，并且例如，其中在经由同轴电缆或LAN(局域网)电缆被连接到节点设备的另一个设备(电视接收机、个人计算机等)中包括这些组件的结构也是可以的。

[0120]

[4.树型发布的操作]

接下来参照图4至7来讲述树型发布系统S的操作。

[0121]

图4A为流程图，示出了由广播站设备1的控制单元11执行的查询消息数据发布处理；图4B为流程图，示出了由节点设备2的控制单元21执行的查询消息数据接收处理。另外，图5为流程图，示出了由广播站设备1的控制单元11执行的收集消息数据发布处理；图6为流程图，示出了由广播站设备1的控制单元11执行的收集消息接收处理。而且，图7为流程图，示出了由节点设备2的控制单元21执行的收集消息数据接收和传递处理。

[0122]

图4至图7示出了通过广播站设备1的控制单元11或者节点设备2的控制单元21执行的处理的例子。

[0123]

[发布和接收查询消息数据]

首先，参照图4来讲述当查询消息数据从广播站设备1发布并且通过节点设备进行接收时的操作。

[0124]

首先，当通过广播站设备1来开始图4A所示的处理时，获取包含有预定调查问卷、测验问题、来自诸如DJ的个人查询等的查询消息、该消息的消息ID和广播站ID(例如从存储单元12中获取并且将其存储在ROM的指定区域中)(步骤S1)。接下来，生成包括有获取的查询消息、消息ID和广播站设备ID的查询消息数据(步骤S2)。

[0125]

接下来，根据位于广播站设备1之下的层级中的所有连接的节点设备2(例如，在图1的上方框100所示的例子中为节点设备2a和2b)的IP地址，经由网络10发布(发送)生成的查询消息(步骤S3)，之后结束处理。

[0126]

接下来，在节点设备2中，开始如图4B所示的处理，并且接收从广播站设备1发布的或者从节点设备2传递的查询消息数据(步骤S11)。

[0127]

接下来，根据用户经由输入单元29a输入的指令输入来生成与在该查询消息数据中包括的查询消息相对应的响应消息(步骤S12)。如上所述，响应消息包括针对查询消息的回答，不过，这并不总是限于有效回答，也可以包括无效回答。例如，当在回答调查问卷或测验的问题中从5个选项选择一个选项时，该响应消息可以包括有效回答，即从5个选项中选择的第3个选项，来作为对调查问卷或测验中的问题的回答，同时也可以包括没有选择任何选项的无效回答。在这种无效回答的情况下，不需要生成响应消息本身。

[0128]

接下来，生成的响应消息与在查询消息中包括的消息ID和广播站设备ID相关联，并且将其存储在存储单元22中(步骤S13)。

[0129]

接下来，根据位于该节点设备(在图1的上方框100所示的例子中的节点设备2a)之下的层级中的所有连接的节点设备2(例如，在图1的上方框100所示的例子中为节点设备2c和2d)的IP地址，经由网络10传递查询消息数据(步骤S14)，然后结束处理。

[0130]

类似地，接收了这样传递的查询消息数据的节点设备2执行如图4B所示的处理，并且将该查询消息数据依次向最低层级中的节点设备2传递，直到其最后到达加入树型通信系统S的所有节点设备2为止。

[0131]

[发布和接收收集消息数据]

接下来，参照图5和图6来讲述当从广播站设备1发布并且由每一个节点设备2接收收集消息数据时的操作。

[0132]

首先，当开始如图5所示的处理时，在广播站设备1中，获取预定收集消息、作为收集对象的查询消息的消息ID、广播站设备1的ID以及如果需要还有消息收集条件(步骤S21)。然后，生成包括有获取的收集消息、消息ID和广播站设备ID的收集消息数据(步骤S22)。

[0133]

接下来，确定是否存在管理服务器参考标记(步骤S23)，并且当不存在标记时(步骤S23：否)，处理进展到步骤S24。不过，当存在标记时(步骤S23：是)，处理进展到步骤S25。例如，通过广播站设备1的操作者来执行管理服务器参考标记的设置。

[0134]

在步骤S24中，生成随机数，并且从位于广播站设备1之下的层级中的所有连接的节点设备(在图1的上方框100所示的例子中为节点设备2a和2b)中随机选择一个节点设备2。

[0135]

另一方面，在步骤S25中，广播站设备连接到系统管理服务器设备3并且参考用于整个系统S的连接拓扑，并且例如获取位于被连接到广播站设备1的每一个节点设备2之下的层级中的所有节点设备2的个数。

[0136]

接下来，考虑每一条通信路径的权重，从位于广播站设备1之下的层级中的所有连接的节点设备2中选择一个节点设备2。例如，如上所述，以与位于每一个得到的节点设备2之下的层级中的节点设备的总个数成正比的概率来选择一个节点设备2(步骤S26)。

[0137]

另外，根据IP地址经由网络10将生成的收集消息数据发布(发送)到选择的节点设备2(步骤S27)。

[0138]

接下来，在节点设备2中，开始如图6所示的处理，并且接收从广播站设备1或者位于之上层级中的节点设备2发布或传递的收集消息数据(步骤S31)。

[0139]

接下来，从存储单元22中获取(读取)与在该收集消息数据中包括的消息ID相对应的响应消息(在步骤S13中在存储器中存储的响应消息)，并且将该响应消息添加到在收集消息数据中包括的收集消息中(步骤S32)。

[0140]

接下来，该节点设备2的节点设备ID被附着到该收集消息(步骤S33)。

[0141]

接下来，确定在该收集消息数据中是否包括有消息收集条件(步骤S34)，当包括有消息收集条件时(步骤S34：是)，处理进展到步骤S35。另一方面，当不包括消息收集条件时(步骤S34：否)，处理进展到步骤S36。

[0142]

在步骤S35中，根据该收集消息数据，确定是否已经满足消息收集条件，并且当还不满足该条件时(步骤S35：否)，处理进展到步骤S36，并且当已经满足了该条件时，处理进展到步骤S37。例如，在消息收集条件为用于指定收集消息数据所被传递的次数的条件的情况下，添加的信息表示当前被传递的次数(直到节点设备2，收集消息数据已经被传递的次数)，并且当当前传递的次数已经达到由该条件指定的次数时，处理进展到步骤S37。另外，例如，在消息收集条件为用于指定收集的响应消息的个数的条件的情况下，将表示当前收集的响应消息的个数(直到该节点设备2，收集的响应消息的个数)的信息附着到该条件上，并且当当前收集的响应个数已经达到由该条件指定的收集的响应个数时，处理进展到步骤S37。还可以确定是否已经满足用于指定在响应消息中包括的有效回答的个数的条件。

[0143]

在步骤S36中，确定是否存在其他节点设备2被连接在之下的层级中，并且当没有节点设备2被连接时(步骤S36：否)，处理进展到步骤S37，并且当存在节点设备2被连接时(步骤S36：是)，处理进展到步骤S38。

[0144]

在步骤S37中，从在收集消息数据中包括的广播站设备ID中获取IP地址，并且根据该IP地址，经由网络10将包括有附着了响应消息等的收集消息的收集消息数据发送到广播站设备1。

[0145]

在步骤S38中，确定是否存在管理服务器参考标记，并且当不存在标记时(步骤S38：否)，处理进展到步骤S39。不过，当存在标记时(步骤S38：是)，处理进展到步骤S40。管理服务器参考标记可以被包括在在广播站设备1侧上设置的收集消息数据中并且被发布，或者可以由节点设备2的用户进行设置。

[0146]

在步骤S39中，生成随机数，并且从位于节点设备2(在图1的上方框100所示的例子中为节点设备2a)之下的层级中的所有连接的节点设备(在图1的上方框100所示的例子中为节点设备2c和2d)中随机选择一个节点设备2。

[0147]

另一方面，在步骤S40中，该节点设备2连接到系统管理服务器设备3并且参考整个系统S的连接拓扑，并且例如获取位于被连接到该节点设备2的每一个节点设备2之下的层级中的节点设备2的总个数。

[0148]

接下来，考虑每一条通信路径的权重，从位于节点设备2之下的层级中的所有连接的节点设备2中选择一个节点设备2，并且例如，如上所述，以与位于每一个得到的节点设备2之下的层级中的节点设备2的总个数成正比的概率，来选择一个节点设备2。

[0149]

另外，根据IP地址经由网络10将收集消息数据传递到该选择的节点设备2(步骤S42)，并且结束处理。

[0150]

类似地，接收了如上述传递的收集消息数据的节点设备2执行如图6所示的处理，并且将该收集消息数据依次向位于一条通信路径K的最低层级上的节点设备2传递，直到在步骤S35中满足消息收集条件为止，或者直到在步骤S36中确定没有其他节点设备被连接在较低层级中为止。

[0151]

图8示出了当满足消息收集条件时沿着通信路径K3发送收集消息数据的例子，并且图9示出了当不满足消息收集条件时沿着通信路径K3发送收集消息数据的例子。在图8所示的例子中，将收集消息数据依次传递到位于通信路径K3上的节点设备2a、2d和2i，并且在节点设备2m上，满足消息收集条件例如用于指定收集消息数据要被传递的次数(在例子中为4次)的条件，从而从节点设备2m将收集消息数据发送到广播站设备1。另一方面，在如图9所示的例子中，将收集消息数据依次传递到位于通信路径K3上的节点设备2a、2d、2i、2m和2n，并且由于在沿着该路径的任一个节点设备都不满足消息收集条件，因此位于最低层级上的节点设备将收集消息数据发送到广播站设备1。

[0152]

在该收集消息数据中包括了用于指定收集消息数据要被传递的次数的条件的情况下，每次传递收集消息数据时，被附着到该条件上的已经被传递的当前次数以“1”递增。另外，在该收集消息数据中包括了用于指定要被收集的响应消息的个数的条件的情况下，每次收集响应消息时(被添加到收集消息中)，被附着到该条件上的响应消息的当前个数以“1”递增。

[0153]

[接收和再发布收集消息数据]

接下来参照图7来讲述当从节点设备2发送并且由广播站设备1接收收集消息数据并且然后从广播站设备1再发布收集消息数据时的操作。

[0154]

首先，在广播站设备1中，开始如图7所示的处理，并且接收从节点设备2发送的收集消息数据(步骤S51)。

[0155]

接下来，根据该收集消息数据，确定是否已经满足消息收集条件，并且当不满足条件时(步骤S52：否)，处理进展到步骤S53，并且当满足条件时(步骤S52：是)，处理进展到步骤S58。

[0156]

例如，在消息收集条件为用于指定在响应消息中包括的有效回答的个数的条件的情况下，对作为有效回答的收集的响应消息(添加到收集消息的响应消息)中包括的回答个数进行计数，并且当计数的有效回答个数等于或大于由条件指定的有效回答的个数时，处理进展到步骤S58。另外，例如，在其中消息收集条件为用于指定要被收集的响应消息的个数的条件的情况下，当收集的响应消息的个数等于或大于由该条件指定的要被收集的响应消息的个数时，处理进展到步骤S58。而且，在消息收集条件为用于指定收集消息数据要被传递的次数的条件的情况下，当收集消息数据被传递的实际次数到达由该条件指定的次数时，处理进展到步骤S58。

[0157]

在步骤S53中，确定是否存在管理服务器参考标记，并且当不存在标记时(步骤S53：否)，处理进展到步骤S54。另一方面，当存在标记时(步骤S53：是)，处理进展到步骤S55。管理服务器参考标记的设置可以通过位于广播站设备1侧上的操作者来执行。

[0158]

在步骤S54中，生成随机数，并且从除了之前已经被选择的节点设备2之外的位于广播站设备1之下的层级中的所有连接的节点设备中随机选择一个节点设备2(不过，在没有进展到步骤S58的情况下已经选择了所有节点设备2的情况下，还包括了该选择的节点设备2，并且以下也是相同的)。还可以增加过去未被选择的节点设备2将来被选择的概率。

[0159]

另一方面，在步骤S55中，广播站设备1连接到系统管理服务器设备3并且参考用于整个系统S的连接拓扑，例如，获取位于被连接到广播站设备的每一个节点设备2之下的层级中的节点设备2的总个数。

[0160]

接下来，考虑每一条通信路径K的权重，从除了之前已经被选择的节点设备2之外的位于广播站设备1之下的层级中的所有连接的节点设备2中选择一个节点设备2，例如，如上所述，除了之前被选择的节点设备之外，以与位于每一个得到的节点设备2之下的层级中的节点设备2的总个数成正比的概率，来选择一个节点设备2(步骤S56)。

[0161]

根据IP地址经由网络10将收集消息数据再发布到选择的节点设备2(例如，发布在步骤S51中接收的收集消息数据)(步骤S57)，并且结束处理。

[0162]

这样，类似地由该节点设备2执行如图6所示的处理。在对收集消息数据进行再发布的情况下，在如图6所示的步骤中，生成随机数，并且从除了之前选择的节点设备之外的位于节点设备2之下的层级中的所有连接的节点设备中随机选择一个节点设备2。不过，在步骤S41中，考虑每一条通信路径K的权重，从位于该节点设备2之下的层级中的所有连接的节点设备2中选择一个节点设备2。还可以增加过去从未被选择过的节点设备2将来被选择的概率。

[0163]

图10示出了再发布收集消息数据以满足消息收集条件的例子。在图10所示的例子中，将收集消息数据依次传递到位于通信路径K3上的节点设备2a、2d、2i、2m和2n，不过，由于在沿着该路径的节点设备2上不满足消息收集条件，因此该收集消息数据从位于最低层级中的节点设备2发送到广播站设备1，之后将该收集消息数据依次再发布(再传递)到位于不同通信路径K4上的节点设备2b、2e和2l，并且当在节点设备2p上满足消息收集条件时，该收集消息数据从该节点设备2发送到广播站设备1。

[0164]

另外，在步骤S58中，根据收集的响应消息来执行诸如计数等指定处理。例如，在响应消息中包括了调查问卷的回答的情况下，对该调查问卷的回答进行计数，并且从响应消息中随机或任意选择一定响应消息，然后将与该消息相对应的节点设备ID确定为获奖者的节点设备ID。另外，例如，当在响应消息中包括有测验的回答时，对作为测验的正确回答的回答进行计数，并且从包含正确回答的响应消息中随机或任意选择一定响应消息，然后将与该消息相对应的节点设备ID确定为测验的正确回答的个人的节点设备。而且，例如在当在响应消息中包括了DJ时回答要求通话的情况下，从响应消息中随机或任意选择一定响应消息，然后将与该消息相对应的节点设备ID确定为选择的与DJ进行通话的用户的节点设备ID。另外，广播站设备1连接到与确定的节点设备ID相对应的节点设备2，并且发送表示该用户是获奖者或者正确回答的个人的信息，或者开始DJ和用户之间的通话。

[0165]

如上所述，通过本实施例，经由多条通信路径K中的一条通信路径K依次从广播站设备1发布收集消息数据，其包括用于收集与查询消息相对应的响应消息的收集消息，并且从位于依次传递了该收集消息数据的通信路径K上的一个节点设备2发送(返回)下述收集消息数据到广播站设备1，其中所述收集消息数据包括通过位于该通信路径K上的所有节点设备2添加有响应消息的收集消息，因此可以更有效率地收集响应消息，并且可以减少树型发布系统中的上行方向上的整个通信量。

[0166]

另外，通过考虑该通信路径K的权重来确定传递该收集消息数据的通信路径K(例如，以与位于要被选择的节点设备2之下的层级中的节点设备2的总个数成正比的概率)，因此可以在选择通信路径K时保持公平性。

[0167]

此外，从广播站设备1再发布(再传递)收集消息数据，直到满足了指定的消息收集条件为止，因此可以可靠地收集期望的响应消息。

[0168]第二实施例

下面根据附图来讲述本发明的第二实施例。以下说明的实施例为将本发明应用到计算机网络系统中的实施例。

[0169]

[1.树型网络系统的结构]

首先，图11用于讲述优选实施例的树型网络系统的结构。

[0170]

图11示出了第二实施例的树型网络系统中的每一个设备的连接状态的例子。图11所示的例子示出了树型网络系统S中的每一个设备之间的电气连接状态(例如，诸如在其中建立了通信的设备之间的连接关系)。

[0171]

如图11所示，该树型网络系统S为对等(P2P)型网络系统，其包括：广播设备201，作为用于发送作为查询信息的请求接收开始数据Rb的查询设备的例子；以及多个节点设备(对等设备)202a、202b、202c、...、202p，作为用于接收上述请求接收开始数据Rb的多个处理设备的例子。

[0172]

如图11所示，在树型网络系统S中存在多层，其具有作为最高层的广播设备201以及多个节点设备202a至202p，它们根据各自的IP地址经由多条通信路径203a、203b、203c、...、203p以树形结构进行连接。

[0173]

另外，由广播设备201发布的各种数据从诸如202a和202b等高位层级节点设备依次被传递到诸如202g至202p等低位层级节点设备。在以下讲述中，为方便起见，当表示节点设备202a至202p中的任一个时，都可以将该节点设备简称为节点设备202。

[0174]

广播设备201和多个节点设备202a至202p被物理连接到诸如包括有位于诸如IX(因特网交换)、ISP(因特网服务供应商)、DSL(数字用户线)等供应商的设备；位于FTTH(光纤入户)线路供应商的设备；以及诸如电话线和光缆等通信线路的因特网等网络，并且广播设备201和每一个节点设备202a至202p被分配有其自己的惟一设备ID和IP(因特网协议)地址。

[0175]

[广播设备的结构和功能]

接下来，图12用于讲述广播设备201的结构和功能。

[0176]

图12示出了广播设备201的结构。

[0177]

如图12所示，广播设备201包括：计算机的控制单元211，其包括具有计算功能的CPU(中央处理单元)、用于工作的RAM(随机访问存储器)和用于存储各种数据和程序的ROM(只读存储器)；存储单元212，包括有用于存储各种数据、表格和程序的HDD(硬盘驱动器)；操作输入单元213，用于给出用于发送请求接收数据的指令；编码单元214，用于对在请求接收数据中包括的视频数据(视频信息)和音频数据(音频信息)进行编码(数据压缩、编码等)；以及通信单元215，用于控制经由网络10与节点设备202的通信；其中这些组件的每一个经由总线216相互连接。另外，通过执行被存储在ROM等中的程序，控制单元211起到本发明的查询信息发送装置和回复结果信息接收装置的作用。

[0178]

请求接收数据为请求接收开始数据Rb或请求接收结束数据Re，并且例如通过诸如电台的音乐节目主持人等操作者来进行创建，所述操作者通过操作输入单元213来操作广播设备201。更具体地说，操作者创建诸如“有请求的观看者(或收听者)，请按下请求按钮”等请求接收开始数据Rb，来作为视频数据或者还包括有音频数据的多媒体数据，并且在附着表示开始接收请求输入的ID代码之后，将数据保存在存储单元212中。另外，操作者创建诸如“接收请求已经结束，谢谢！”等请求接收结束数据Re，来作为视频数据或者音频数据，并且在附着表示结束接收请求输入的ID代码之后，将数据保存在存储单元212中。

[0179]

只要ID代码可以由节点设备进行识别，则用于附着上述ID代码的方法可以是任何方法；例如，在执行使用MPEG(动态图像专家组)格式的编码的情况下，ID代码可以进入序列层(sequence layer)的用户数据部分中。

[0180]

另外，当操作者对操作输入单元213进行操作并且给出用于发送请求接收开始数据Rb或者请求接收结束数据Re的指令时，控制单元211中的CPU执行在存储单元212中存储的程序，并且在此过程中，控制单元211读取在存储单元212中存储的请求接收开始数据Rb或请求接收结束数据Re，然后编码单元214对在该数据中包括的视频数据和/或音频数据进行编码，并且经由通信单元215将该数据发送到节点设备202(在图11所示的例子中的节点设备202a和202b)。节点设备202根据被附着到该数据的ID数据来确定该数据是请求接收开始数据Rb还是请求接收结束数据Re。

[0181]

另外，通信单元215具有诸如包处理、UDP处理、数据链接处理、物理层处理等各种通信功能，并且在请求接收数据已经被打成包并且作为发送目的地的节点设备202的IP地址已经被附着到每一个包头之后，从通信单元215将其发送。

[0182]

作为发送目的地的节点设备202的IP地址(在图11所示的树型网络系统S的例子中，这些为被连接在正下层中的节点设备202a和202b的IP地址)可以通过参考在存储单元212中存储的连接状态表并且根据控制单元211的控制来获取。

[0183]

下面来更为详细地讲述用于发送(传递)请求接收数据的处理。

[0184]

而且，控制单元211与通信单元215一起起到回复结果信息接收装置的作用，用于从被连接在正下层中的节点设备(在图11所示的例子中为节点设备202a和202b)接收回复结果信息Ans。

[0185]

回复结果信息Ans包括选择节点信息X和总个数信息N，其表示从该选择节点信息X中选择的选择节点信息X，来作为本发明的回复信息的例子。这里，选择节点信息X为用于表示从被连接在正下层中的节点设备202下游的节点设备和节点设备202本身中选择的节点设备之一的信息，并且它包括给予每一个节点设备202的ID号信息，用于识别这些设备。

[0186]

当通信单元215从被连接在正下层中的各个节点设备202的每一个接收回复结果信息Ans时，它根据控制单元211的控制来从在接收的回复结果信息Ans中包括的选择节点信息X的每一项中选择一项选择节点信息X。当这样做时，它根据在接收的回复结果信息Ans中包括的各个总个数信息N来选择一项选择节点信息X。

[0187]

换句话说，在图11所示的例子中，广播设备201从被连接在正下层中的节点设备202a和202b中的每一个接收回复结果信息Ans，并且从节点设备202a中发送的回复结果信息Ans在其中包括用于表示从节点设备202a本身和节点设备202a下游的节点设备202c、202d、202g、202h、202i和202j中选择的节点设备的选择节点信息X和总个数信息N(N＝6)。

[0188]

另外，从节点设备202b中发送的回复结果信息Ans在其中包括用于表示从节点设备202b本身和节点设备202b下游的节点设备202e、202f、202k、202l、202m、202n、202o和202p中选择的节点设备的选择节点信息X和总个数信息N(N＝9)。

[0189]

因此，广播设备201根据来自二者的回复结果信息Ans中包括的总个数信息N，从在从节点设备202a发送的回复结果信息Ans中包括的选择节点信息X和在从节点设备202b发送的回复结果信息Ans中包括的选择节点信息X中选择一项选择节点信息X。

[0190]

通过这种结构，当从在来自作为被连接在正下层中的节点设备的节点设备202a和节点设备202b的回复结果信息Ans中包括的选择节点信息X中选择一项选择节点信息X时，在进行选择时可以考虑被连接在节点设备202a和202b的下游的节点设备202的总个数信息N，因此可以均等地选择由所有节点设备202生成的选择节点信息X。用于选择选择节点信息X的处理的详细方法与通过节点设备202进行回复信息选择处理的方法相同，因此当讲述节点设备202的回复信息选择处理时对其进行讲述。

[0191]

[节点设备的结构和功能]

接下来，图13用于讲述节点设备202的结构和功能。

[0192]

图13解释了节点设备202的结构的例子。

[0193]

如图13所示，每一个节点设备202都包括：控制单元221，作为用于控制节点设备202的每一个组件的计算机；存储单元222，包括用于存储各种数据、表格和程序的磁盘等；缓冲存储器223，用于暂时存储接收的请求接收数据；解码单元224，用于对在请求接收数据中包括的经过编码的视频数据和音频数据进行解码；视频处理单元225，用于对经过解码的视频数据执行指定图像处理并且将该数据作为视频信号输出；显示单元M，诸如CRT或液晶显示器等，用于根据从视频处理单元225输出的视频信号来显示视频图像；音频处理单元226，用于将经过解码的数字音频数据转换成模拟音频信号(D/A转换)，之后通过放大器将该信号放大并且输出结果；操作输入单元227，由提出请求的用户进行操作；以及通信单元228，用于经由节点设备202和广播设备201或另一个节点设备202之间的网络执行通信控制；其中控制单元221、存储单元222、缓冲存储器223、解码单元224、操作输入单元227和通信单元228经由总线219相互连接。

[0194]

控制单元221包括：CPU(中央处理单元)(图中未示出)；工作RAM(随机访问存储器)；ROM(只读存储器)，用于存储包括有处理程序的各种控制程序和各种数据；以及振荡电路；其根据来自操作单元(图中未示出)的操作信号，生成用于控制执行与在操作信号中包括的操作信息相对应的操作的每一个组件的控制信息，并且经由总线219将控制信息输出到恰当的组件，以执行这些组件的操作的整体控制。另外，通过执行在ROM等中存储的程序，控制单元221起到本发明的查询信息接收装置、查询消息传递装置、回复结果信息接收装置、回复信息创建装置、回复结果信息创建装置、回复结果信息回复装置、选择装置、总个数信息获取装置、总个数信息发送装置、结束信息接收装置、回答信息输入接收装置和等待时问设置装置的作用。

[0195]

更具体地说，当控制单元211的CPU执行在存储单元222等中存储的程序时，控制单元211与通信单元228一起起到查询信息接收装置的作用，并且经由通信单元228接收从广播设备201发送或从被连接在正上层中的节点设备202(例如，在图11中，被连接在节点设备202c正上层中的节点设备202为节点设备202a)传递来的请求接收数据，并且同时将该数据存储在缓冲存储器223中，从缓冲存储器223中读取请求接收数据，然后解码单元224对在该数据中包括的视频数据和音频数据进行解码，并且将视频数据输出到视频处理单元225并且将音频数据输出到音频输出单元227。

[0196]

此外，(除了最底层中的节点设备202g至202p之外的)控制单元211与通信单元228一起起到查询信息传递装置的作用，并且经由通信单元228将从被连接在正上层中的节点设备202发送的请求接收数据传递到被连接在正下层中的节点设备202。

[0197]

换句话说，在图11所示的例子中，被连接在节点设备202a的正下层中的节点设备202为节点设备202c和202d，因此当节点设备202a从广播设备201接收请求接收数据时，其将该请求接收数据传递到节点设备202c和202d。

[0198]

另外，被连接在节点设备202c的正下层中的节点设备202为节点设备202g至202i，因此当节点设备202c从被连接在高位层级中的节点设备202a接收请求接收数据时，其将该请求接收数据传递到节点设备202g至202i。

[0199]

这样，从广播设备201发送的请求接收数据被依次传递到最低级的节点设备202g至202p。

[0200]

这里，与上述广播设备201类似，控制单元211参考在存储单元222中存储的连接状态表，以确定请求接收数据的传递目的地。该连接状态表至少包括该节点设备202和该节点设备被连接到的节点设备202的IP地址。

[0201]

而且，操作输入单元227与控制单元221一起起到回答信息输入接收装置的作用，并且其包括请求按钮、操作条和键盘等，并且从通过扬声器U或显示单元M来重放和输出通过通信单元228接收的请求接收开始数据Rb的时间一直到接收到请求接收结束数据Re为止，操作输入单元227接收从用户输入的请求来作为回答信息。

[0202]

另外，控制单元221起到回复信息创建装置的作用，并且根据输入请求，创建作为本发明中的回复信息的例子的选择节点信息X，并且暂时将该信息存储在存储单元222中。

[0203]

而且，控制单元221与通信单元228一起起到回复结果信息接收装置的作用，并且接收从被连接在正下层中的每一个节点设备202发送的选择节点信息X来作为回复结果信息Ans。另外，控制单元221起到等待时间设置装置的作用，并且在过去了过时时间To(下面将讲述)之后，接收从被连接在正下层中的每一个节点设备202发送的回复结果信息Ans。

[0204]

而且，控制单元221起到回复结果信息创建装置的作用，并且根据作为回复结果信息Ans的被连接在正下层中的每一个节点设备202发送的选择节点信息X以及由本身创建的选择节点信息X，来创建新的回复结果信息Ans。

[0205]

此外，控制单元221与通信单元228一起起到回复结果信息回复装置的作用，并且将创建的回复结果信息Ans传递(发送)到被连接在正上层中的节点设备202。节点设备202a和202b将新创建的回复结果信息Ans传递(发送)到广播设备201。

[0206]

换句话说，当除了最低层的节点设备202g至202p之外的节点设备202通过通信单元228从被连接在正下层中的各个节点设备202接收回复结果信息Ans时，其根据控制单元211的控制来从在接收的回复结果信息Ans中包括的各选择节点信息X以及由该节点设备202本身创建的选择节点信息X的所有项中选择一项选择节点信息X。当这样做时，其根据在接收的回复结果信息Ans中包括的总个数信息N的每一项来选择一项选择节点信息X。

[0207]

另外，控制单元211创建新的回复结果信息Ans，其包括选择的选择节点信息X和用于表示从多少项选择节点信息X选择了该选择节点信息的总个数信息N。

[0208]

最低级节点设备202g至202p不具有来自下游节点设备的回复结果信息Ans，因此它们创建其中选择了由节点设备202本身创建的选择节点信息X的回复结果信息Ans，并且总个数信息N只对该设备本身进行计数。

[0209]

通过这样做，在广播设备201中可以知道在从多少项选择节点信息X中选择了从节点设备202a和节点设备202b发送的回复结果信息Ans中包括的所述项选择节点信息X，并且根据该数量，可以均等地选择各项选择节点信息X中的一项。下面来详细讲述用于生成回复结果信息Ans的方法。

[0210]

节点设备202不需包括作为节点设备202的组件的解码单元224、视频处理单元225、显示单元M、音频处理单元226和扬声器U等组件中的所有或者部分组件，并且结构可以是这样的：经由同轴电缆和LAN(局域网)电缆等连接到节点设备202的另一个设备(例如电视接收机和个人计算机等)包括这些组件。

[0211]

[广播设备的请求接收数据发送处理]

首先，下面来详细讲述通过本发明的广播设备201来发送请求接收数据的处理。

[0212]

下面使用图11至图15来讲述从广播设备201将请求接收数据发送到节点设备202的处理和从节点设备202接收回复结果信息Ans的处理。

[0213]

图14解释了广播设备201和节点设备202之间的请求接收数据和回复结果信息Ans的发送和接收，其中在该图中，在广播设备201与节点设备202a、节点设备202c和节点设备202g之间发送和接收各种数据。

[0214]

图15为流程图，示出了由广播设备201的控制单元211执行的处理，用于发送请求接收数据，其中流程图中所示的处理是基于在控制单元211内部的ROM(图中未示出)中事先存储的程序根据控制单元211的控制来执行的。

[0215]

图15所示的处理是通过下述指令开始的，该指令用于发送由诸如操作操作输入单元213的电台的音乐节目主持人等的广播设备201的操作者给出的请求接收开始数据Rb。另外，此时，操作者进入请求可能时段Tr(例如1分钟或者1小时)，并且将其存储在控制单元的RAM(图中未示出)中。

[0216]

首先，广播设备201将请求接收开始数据Rb发送到被连接在正下层中的节点设备202(步骤S101)。在图11所示的例子中，将请求接收开始数据Rb发送到被连接在正下层中的节点设备202a和202b。

[0217]

另外，广播设备201使用被安装在广播设备201中的内部时钟，以开始测量时间(步骤S102)。接下来，广播设备201确定是否过去了在控制单元211的RAM中存储的请求可能时段Tr(步骤S103)，并且当确定还没有过去请求可能时段Tr时(步骤S103：否)，重复步骤S103的处理。换句话说，广播设备201在进行下一个处理之前，要等待请求可能时段Tr过去。

[0218]

另一方面，当广播设备201确定已经过去了请求可能时段Tr时(步骤S103：是)，其将请求接收结束数据Re发送到被连接在正下层中的节点设备202(在图11所示的例子中为节点设备202a和202b)(步骤S104)。

[0219]

在图14所示的例子中，在已经将请求接收开始数据Rb从广播设备201发送到节点设备202a之后，广播设备201仅在已经过去了请求可能时段Tr之后将请求接收结束数据发送到节点设备202a。

[0220]

当这样做时，根据广播设备201、节点设备202a、节点设备202c和节点设备202g之间的通信负载，在数据通信中分别发生发送延迟时间Td1、Td2和Td3。不过，结构使得广播设备201单独将用于表示可以接收请求输入的请求可能时段Tr的结束的请求接收结束数据Re发送(发布)到每一个节点设备202，因此每一个节点设备202还可以精确保持由广播设备201设置的请求可能时段Tr。

[0221]

接下来，广播设备201再次开始时间测量(步骤S105)。

[0222]

接下来，广播设备201确定是否从被连接在正下层中的所有节点设备202已经接收了回复结果信息Ans(步骤S106)。当作为该判断的结果，确定还没有从被连接在正下层中的所有节点设备202接收到回复结果信息Ans时(步骤S106：否)，广播设备201确定是否已经过去了预定的过时时间To(步骤S107)，并且当还没有过去过时时间To时(步骤S107：否)，处理返回到步骤S106。

[0223]

另一方面，当作为步骤S106中判断的结果，确定已经从被连接在正下层中的所有节点设备202接收到回复结果信息Ans时(步骤S106：是)，或者当作为步骤S107中判断的结果，确定已经过去了过时时间To时(步骤S107：是)，广播设备201执行选择节点信息选择处理(步骤S108)。

[0224]

用于执行选择节点信息选择处理的方法与通过节点设备202进行的选择节点信息选择处理的相同，因此下面将详细进行讲述。

[0225]

[节点设备的回复结果信息发送处理]

接下来，使用图11至图17来详细讲述通过本发明的节点设备202发送回复结果信息的处理。

[0226]

图16为流程图，示出了由节点设备202的控制单元211执行的回复结果信息发送处理。这里来讲述根据从被连接在正下层中的节点设备202发送的回复结果信息Ans和由节点设备本身创建的选择节点信息X来创建新的回复结果信息Ans并且将该新创建的回复结果信息Ans发送到节点设备202或者被连接在高位层级中的广播设备201的方法。因此，除了最低位层级中的节点设备202g至202p之外，本处理中的步骤S118至步骤S120的处理为通过节点设备202a至202f执行的处理。

[0227]

首先，当从广播设备201或者从被连接在正上层中的节点设备202接收请求接收开始数据Rb时(步骤S110)，节点设备202开始接收请求输入(步骤S111)。更具体地说，在解码单元224对接收的请求接收开始数据Rb进行解码并且通过视频处理单元225和/或音频处理单元226已经执行了指定输出处理之后，组合的视频和音频消息诸如“有请求的观看者(或收听者)，请按下请求按钮”从显示单元M和/或扬声器U被输出，并且当用户期望进行请求时，用户操作操作输入单元227，以产生该请求。

[0228]

节点设备202还通过通信单元228将请求接收开始数据Rb传递到被连接在正下层中的节点设备202(步骤S112)。在图11所示的例子中，节点设备202a将请求接收开始数据Rb传递到节点设备202c，并且节点设备202c将其传递到节点设备202g至202i。

[0229]

接下来，节点设备202使用被附着到请求接收数据的ID代码，以确定是否已经接收到请求接收结束数据Re(步骤S113)。当节点设备202确定还没有接收到请求接收结束数据Re时(步骤S113：否)，重复步骤S113的处理。换句话说，在执行下一个处理之前等待，直到已经接收到请求接收结束数据Re为止。

[0230]

另一方面，当节点设备确定已经接收到请求接收结束数据Re时(步骤S113：是)，结束接收请求输入(步骤S114)。更具体地说，在解码单元224对接收的请求接收结束数据Re进行解码并且通过视频处理单元225和/或音频处理单元226已经执行了指定处理之后，组合的视频和音频消息诸如“接收请求已经结束，非常感谢！”从显示单元M和/或扬声器U被输出，并且用户停止使用操作输入单元227进行请求。另外，即使用户可以操作操作输入单元227，在当接收到请求接收结束数据Re以停止接收请求输入时的步骤上也可以执行控制。

[0231]

而且，节点设备202还通过通信单元228将请求接收结束数据Re传递到被连接在正下层中的节点设备(步骤S115)。在图11所示的例子中，节点设备202a将请求接收结束数据Re传递到节点设备202c，并且节点设备202c将请求接收结束数据Re传递到节点设备202g至202i。

[0232]

另外，节点设备202确定从在步骤S111中开始接收请求输入的时间起一直到在步骤8114中结束接收请求输入的时间期间是否存在请求输入(步骤S116)。当作为判断的结果，确定不存在请求输入时(步骤S116：否)，处理进展到步骤S118。不过，当作为判断的结果，确定存在请求输入时(步骤S116：是)，节点设备202创建用于表示存在请求的选择节点信息X(步骤S117)。当执行稍候讲述的回复结果信息创建处理时使用该节点本身创建的选择节点信息X，因此将其存储在存储单元222中。当在步骤S116中不存在请求输入时，不创建该节点设备本身的选择节点信息。

[0233]

另外，节点设备202使用节点设备202的内部时钟，以开始测量时间(步骤S118)。

[0234]

接下来，节点设备202确定是否从被连接在正下层中的所有节点设备202已经接收了回复结果信息Ans(步骤S119)。当作为该判断的结果，节点设备202确定还没有从被连接在正下层中的所有节点设备202接收到回复结果信息Ans时(步骤S119：否)，确定是否已经过去了作为接收等待时间事先设置的过时时间To(步骤S120)，并且当确定还没有过去过时时间To时(步骤S120：否)，处理返回到步骤S119。

[0235]

另一方面，当作为步骤S119中的判断结果，节点设备202确定已经从被连接在正下层中的所有节点设备202接收到回复结果信息Ans时(步骤S119：是)，或者当作为步骤S120中的判断结果，确定已经过去了过时时间To时(步骤S120：是)，根据此时接收的回复结果信息Ans来执行回复结果信息创建处理(步骤S121)。在不存在被连接在正下层中的节点设备202的情况下，节点设备202不执行步骤S118至S120。

[0236]

另外，总个数信息N和由被连接在正下层中的节点设备202选择的选择节点信息X被包括在从被连接在正下层中的节点设备202发送的回复结果信息Ans中，并且如图17所示，多项回复结果信息Ans被保存在存储单元222中。换句话说，在存在k个被连接在正下层中的节点设备202的情况下，k项总个数信息N和各项选择节点信息X相关联，并且被保存在存储单元222中。

[0237]

另外，节点设备202将在要被讲述的回复结果信息创建处理中创建的回复结果信息Ans发送到被连接在正上层中的节点设备202(节点设备202a和202b将回复结果信息Ans发送到广播设备201)(步骤S122)，并且然后结束处理。

[0238]

[回复结果信息创建处理]

接下来讲述以上提到的步骤S121的回复结果信息处理。

[0239]

图18为流程图，示出了由节点设备202的控制单元221所执行的回复结果信息创建处理。在以下讲述中，假设最低位层级中的节点设备202g至202p提出了请求，并且在该情况下，最低位层级中的节点设备202g至202p创建回复结果信息Ans来作为由节点设备本身创建的选择节点信息X，并且创建作为1的总个数信息N，并且将该信息发送给被连接在正上层中各个节点设备202c至202f。

[0240]

首先，根据从被连接在正下层中的每一个节点设备202发送的回复结果信息Ans，节点设备202计算该节点设备202之下的低位层级中的设备的总个数M。

[0241]

换句话说，如图17所示，节点设备202对在存储单元222中存储的所有总个数信息N1、N2、N3、N4，...N(k)进行汇总，以获取设备的总个数M。

[0242]

这里，图19用于更为详细地讲述总个数信息N。

[0243]

首先，节点设备202c将从被连接在正下层中的每一个节点设备202(在图19的例子中为节点设备202g、202h和202i)发送的回复结果信息Ans中包括的选择节点信息X中选择的一项选择节点信息X、节点设备202c本身创建的选择节点信息X以及总个数信息N作为回复结果信息Ans发送到节点设备202a。这里，总个数信息N为被连接在节点设备202c本身之下的节点设备202的总个数(在图19所示的例子中为3)加上本身的个数“1”(在图19所示的例子中总数为4)。

[0244]

另外，类似地，节点设备202d将从被连接在正下层中的节点设备202(在图19所示的例子中为节点设备202j)发送的回复结果信息Ans中包括的选择节点信息X中选择的一项选择节点信息X、节点设备202d本身创建的选择节点信息X以及总个数信息N作为回复结果信息Ans发送到节点设备202a。这里，总个数信息N为被连接在节点设备202d本身之下的节点设备202的总个数(在图19所示的例子中为1)加上本身的个数“1”(在图19所示的例子中总数为2)。

[0245]

通过这样做，从节点设备202c和节点设备202d接收了回复结果信息Ans的各个项的节点设备202a可以从各个总个数信息N中知道从多少项选择节点信息X选择了在从节点设备202c和节点设备202d发送的各项回复结果信息Ans中包括的所述项选择节点信息X，并且据此可以公正地选择一项选择节点信息X。稍后来详细讲述选择选择节点信息X的万法。

[0246]

例如，在选择从节点设备202g发送的回复结果信息Ans中包括的选择节点信息Xg的同时，节点设备202c获取作为4的总个数信息，并且将这些作为回复结果信息Ans发送给节点设备202a。

[0247]

另一方面，在节点设备202d选择了本身创建的选择节点信息Xd的情况下，和该选择节点信息Xd一起，还获取作为2的总个数信息N(节点设备202d和节点设备202j)，并且将这些作为回复结果信息Ans发送给节点设备202a。

[0248]

通过这样做，根据从被连接在正下层中的节点设备202c和节点设备202d发送的各项回复结果信息Ans，节点设备202a根据各项总个数信息N(在图19所示的例子中，各项总个数信息N为4和2)，核对从多少项选择节点信息X选择了通过节点设备202c和节点设备202d选择的所述项选择节点信息X(在图19中为选择节点信息Xg和Xd)，并且考虑到其权重，从分别通过节点设备202c和节点设备202d选择的各项选择节点信息Xg和Xd中选择一项选择节点信息X。另外，节点设备202a根据选择的选择节点信息X(在图19中为选择节点信息Xg)和总个数信息N(在图19所示的例子中为7)来创建回复结果信息Ans，并且将其发送到广播设备201。

[0249]

换句话说，在步骤S131中，节点设备202参考存储单元222，并且获取和添加在从被连接在正下层中的每一个节点设备202发送的各项回复结果信息Ans中包括的各项总个数信息N，并且计算设备的总个数M。

[0250]

接下来，节点设备202确定在存储单元222是否存在选择节点信息X(步骤S132)。换句话说，当在上述步骤S116中存在请求输入时，将在步骤S117中创建的选择节点信息X存储在存储单元222中，并且当不存在请求输入时，在存储单元222就不会有选择节点信息X。

[0251]

另外，当作为在步骤S132中的判断结果，确定在存储单元222中存在选择节点信息时(步骤S132：是)，节点设备202将用于本身的一个添加到设备的总个数M中(步骤S133)。不过，当确定在存储单元222中不存在选择节点信息X时(步骤S132：否)，节点设备202移动到步骤S134。

[0252]

节点设备202生成0到9999之间的伪随机数W(步骤S134)。另外，将用于表示被连接在正下层中的节点设备202的值“k”初始化为“1”  (步骤S135)。接下来，获取被连接在正下层中的节点设备202的第k个节点设备202发送的总个数信息N(k)，作为变量T(步骤S136)。

[0253]

另外，节点设备202根据总个数信息来选择选择节点信息(步骤S137至步骤S142)。

[0254]

首先，节点设备202确定在步骤S134中生成的伪随机数W是否小于T×10000/M(步骤S138)。当作为判断结果确定伪随机数W小于T×10000/M时(步骤S138：是)，节点设备202选择选择节点信息X(k)(步骤S139)。

[0255]

例如，下面来讲述通过图19所示的节点设备202a来执行处理的情况。在从节点设备202c发送的回复结果信息Ans中包括的总个数信息N(1)＝4和选择节点信息Xg，以及在从节点设备202d发送的总个数信息N(2)＝2和选择节点信息Xd被存储在存储单元222中。

[0256]

之后，假设在步骤S133的处理中节点设备202a在存储单元222中具有选择节点信息，则接下来讲述被获取为N(1)+N(2)+1＝4+2+1＝7的设备的总个数M。

[0257]

接下来，在步骤S136的处理中，首先获取变量T作为N(1)或者换句话说为4。

[0258]

因此，在步骤S138的判断中，T×10000/M被计算为4×10000/7＝5714.286。

[0259]

换句话说，当在步骤S134中生成的伪随机数W为0到5713时，从节点设备202c发送的选择节点信息Xg被节点设备202a选择为选择节点信息Xg。

[0260]

另一方面，当伪随机数为5714或更大时，节点设备202a进展到步骤S140的处理。

[0261]

接下来，节点设备202将1添加到用于表示节点设备202的值“k”中(步骤S140)，并且获得新的变量T(步骤S141)。换句话说，在图19所示的例子中，节点设备202a获得变量T＝N(1)+N(2)＝4+2＝6。另外，节点设备202返回到步骤S137的处理(步骤S142)，并且重复步骤S137至S142，直到值“k”超过被连接在正下层中的节点设备Su的个数为止，并且当“k”超过个数Su时结束循环。

[0262]

当在步骤S137至步骤S142中不能选择一项选择节点信息X时，节点设备202选择本身创建的选择节点信息X(步骤S143)。

[0263]

另外，在获得在步骤S139或步骤S143中选择的选择节点信息X的同时，节点设备202获取设备的总个数M来作为总个数信息N，然后用它们创建回复结果信息Ans(步骤S144)，并且结束处理。

[0264]

换句话说，在图19所示的例子中，在用于选择上述选择节点信息的第一循环的处理中，当步骤S134中生成的伪随机数W为0到5713时，节点设备202a选择从节点设备202c发送的选择节点信息Xg来作为选择节点信息。当不是这种情况时，则在用于选择选择节点信息的第二循环的处理中，T×10000/M被计算为(4+2)×10000/7＝8571.429，因此当在步骤S134中生成的伪随机数W为5714至8570时，节点设备202a选择从节点设备202d发送的选择节点信息Xd来作为选择节点信息。

[0265]

当不是这种情况时(换句话说，当伪随机数W为8571或更大)，则节点设备202a选择在步骤S143中本身创建的选择节点信息Xa。换句话说，节点设备202a选择由总个数信息N较大的节点设备202c选择的节点设备202g的概率要大于选择由总个数信息N较小的节点设备202d选择的节点设备202d的概率。也就是说，选择从节点设备202c发送的选择节点信息Xg的概率为5713/1000＝4/7，并且选择从节点设备202d发送的选择节点信息Xd的概率为(8570-5713)/10000＝2/7，并且选择由节点设备202a创建的选择节点信息Xa的概率为(9999-8570)/10000＝1/7。结果，均等地选择由加入树型网络系统的所有节点设备202生成的各项选择节点信息Xg的结构是可能的。

[0266]

通过上述本发明的实施例，结构使得从被连接在正下层中的节点设备202接收选择节点信息X来作为回复结果信息Ans，并且新的回复结果信息Ans是根据该回复结果信息Ans来创建的并且然后将其发送到被连接在正上层中的节点设备202(或广播设备201)，因此可以减少负载(访问)集中在网络的上游通信路径(例如一定路由器IP)中和上游节点设备202中，并且因此可以提高系统的操作效率。

[0267]

另外，当提出诸如请求等查询的广播设备201要求请求，并且广播设备201在从下游节点设备202中发送的各项选择节点信息X中选择一项选择节点信息X时，结构使得当节点设备202从被连接在正下层中的每一个节点设备接收作为回复结果信息Ans的各项选择节点信息X并且根据该回复结果信息Ans来创建新的回复结果信息Ans时，每一个节点设备202选择选择节点信息X，然后创建包括有选择的选择节点信息X的回复结果信息Ans并且将其发送到被连接在正上层中的节点设备202，因此广播设备201只需要在从被连接在正下层中的节点设备202(在图19所示的例子中为节点设备202a和202b)发送的各项选择节点信息X中选择一项选择节点信息X，因此可以更有效率地执行选择节点信息的选择。

[0268]

此外，当从来自被连接在正下层中的节点设备202的选择节点信息X以及由节点设备202c本身创建的选择节点信息X的各项中选择一项选择节点信息X，并且然后将其发送给被连接在正上层中的节点设备202时，用于表示从多少项选择节点信息X选择了该选择的选择节点信息X的总个数信息N也被包括在回复结果信息Ans中，因此结构使得当在从被连接在正下层中的节点设备202发送的各项回复结果信息Ans中包括的各项选择节点信息X中选择一项选择节点信息X时，可以在选择一项选择节点信息X时考虑其权重，以便均等地选择由所有节点设备202创建的各项选择节点信息X。

[0269]

在步骤S108中由广播设备201执行的选择节点信息选择处理与上述由节点设备202所执行的选择节点信息选择处理相同，因此当广播设备2最后选择一项选择节点信息X时，结构使得可以均等地从加入树型网络系统S的所有节点设备创建的各项选择节点信息中进行选择。

[0270]

在上述实施例中，步骤S107中的过时时间To与步骤S120中的过时时间To是相同的，不过，本发明并不限于此，并且可以根据节点设备(ISP和DSL等)的连接状态和设备的性能等来适当地改变设置。

[0271]

另外，在上述实施例中，请求接收数据作为多媒体信息被发送到节点设备202，不过本发明并不限于此，并且还可以只将其作为标记信号进行发送。换句话说，请求接收开始数据Rb作为开始标记被发送，以表示开始请求输入的接收，并且请求接收结束数据Re作为结束标记被发送，用于表示结束请求输入的接收。在这种情况下，接收这些信号的节点设备202可以重放和输出用于表示开始(或者结束)请求输入的接收的图像和音频。

[0272]

而且，在上述实施例中，最低位层级中的节点设备202g至202p被讲述成正确地执行请求，不过，当用户没有按下例如请求按钮时，不生成用于该节点设备本身的选择节点信息X(或者生成用于表示“还没有进行选择”的信息)，并且发送用于表示在回复结果信息Ans中不存在选择节点信息并且总个数信息N为“0”的信息。

[0273]

此外，从广播设备201发送的请求接收开始数据Rb的内容包括○×测验，并且其结构使得用于表示正确回答的正确回答信息与请求接收开始数据Rb一起被发送的同时，节点设备202的控制单元221起到判断装置的作用，并且确定来自每一个节点设备的输入是否与测验的正确回答相匹配，并且当根据该输入创建的选择节点信息X与测验的正确回答不匹配时，创建的选择节点信息X作为在上述选择节点信息选择处理中的选择对象被去除掉。通过这样做，可以将本发明应用到观看者参与型测验。在输入不与该测验的正确回答相匹配的情况下，结构可以不创建任何选择节点信息X。

[0274]

另外，在上述实施例中，在0到9999之间生成伪随机数，不过，当加入树型网络系统S中的所有节点设备202的个数为较大的数时(例如，10,000或更大)，则为了减少在使概率计算的结果变成整数时的舍入误差，可以使用较大范围的随机数。

[0275]

另外，在上述实施例中，在从被连接在正下层中的每一个节点设备202发送的回复结果信息Ans中包括的各项选择节点信息X中选择一项选择节点信息X，并且将其发送给节点设备202或者被连接在正上层中的广播设备201。不过，本发明并不限于此，并且结构可以发送指定个数项的选择节点信息X。在这种情况下，在上述步骤S134的处理中，只生成了指定个数的随机数，并且对每一个伪随机数W执行选择节点信息选择循环(步骤S137至步骤S143)，以选择指定个数项的选择节点信息X并且然后发送在回复结果信息Ans中包括的该指定个数的选择节点信息X。

Claims (40)

1.一种发布设备，用于发布发布信息并且作为树型发布系统的一部分，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该发布设备包括：

第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；

接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；

第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；以及

收集信息接收装置，用于接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

2.如权利要求1所述的发布设备，其中

所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的接收设备个数成正比的概率，从被连接到所述发布设备的多个接收设备中选择所述接收设备中的一个。

3.如权利要求1或2所述的发布设备，其中

所述收集信息是从位于所述一条通信路径的最低层级中的所述接收设备发送的。

4.如权利要求1至3中的任何一项所述的发布设备，进一步包括消息收集条件判断装置，用于根据所述收集信息来确定是否已经满足指定消息收集条件，其中

当所述消息收集条件判断装置已经确定还不满足所述消息收集条件时，所述接收设备选择装置选择被连接到所述发布设备的所述接收设备中的一个；并且

所述第二发布信息发布装置将所述第二发布信息发布到所述选择的一个接收设备。

5.如权利要求4所述的发布设备，其中

所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的所述接收设备个数成正比的概率，从被连接到发布设备的多个所述接收设备中选择所述接收设备中的一个。

6.如权利要求4或5所述的发布设备，其中

所述接收设备选择装置选择不同于之前被选择的接收设备的一个接收设备。

7.如权利要求1或2所述的发布设备，其中

所述第二发布信息包含表示指定消息收集条件的信息；并且

当满足该消息收集条件时，从所述通信路径上的所述接收设备发送所述收集信息。

8.如权利要求4至7中的任何一项所述的发布设备，其中

所述消息收集条件包含用于指定要被收集的所述响应消息的个数的条件、用于指定在所述响应消息中包括的有效回答的个数的条件和用于指定所述第二发布信息要被传递的次数的条件中的至少一个条件。

9.如权利要求1至8中的任何一项所述的发布设备，其中

来自所述一条通信路径上的所述接收设备的所述响应消息和每一个所述接收设备惟一的ID信息是相关联的并且被附着到所述收集消息。

10.一种接收设备，其作为树型发布系统的一部分，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该接收设备包括：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及

收集信息发送装置，用于将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

11.一种接收设备，其作为树型发布系统的一部分，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该接收设备包括：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及

收集信息发送装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

12.如权利要求11所述的接收设备，进一步包括：

较低层级判断装置，用于当所述消息收集条件判断装置确定不满足所述消息收集条件时，确定在之下层级中是否存在另一个连接的所述接收设备；以及

收集信息发送装置，用于当所述较低层级判断装置确定没有连接另一个所述接收设备时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

13.如权利要求10或12所述的接收设备，进一步包括：

接收设备选择装置，用于当所述较低层级判断装置确定在之下层级中存在另一个连接的接收设备时，选择被连接在包括有已添加了所述响应消息的所述收集消息的收集信息要被发送到的所述接收设备之下的层级中的一个所述接收设备；以及

收集信息传递装置，用于将所述收集信息传递到所述选择的接收设备。

14.如权利要求13所述的接收设备，其中

所述接收设备选择装置以与位于每一个所述接收设备之下的层级中的所述接收设备个数成正比的概率，从被连接在所述接收设备之下的层级中的多个所述接收设备中选择一个所述接收设备。

15.如权利要求13或14所述的接收设备，其中

所述接收设备选择装置选择另一个所述接收设备，该另一个所述接收设备不是之前选择的接收设备。

16.如权利要求11至15的任何一项所述的接收设备，其中

所述消息收集条件包含用于指定要被收集的所述响应消息的个数的条件、用于指定在所述响应消息中包括的有效回答的个数的条件和用于指定所述第二发布信息要被传递的次数的条件中的至少一个条件。

17.如权利要求10至16中的任何一项所述的发布设备，其中

所述响应消息添加装置使所述生成的响应消息与该接收设备惟一的ID信息相关联，并且将它们添加到在所述第二发布信息中包括的所述收集消息。

18.一种信息处理方法，用于发布发布信息的并且作为树型发布系统的一部分的发布设备，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法包括以下步骤：

发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；

选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；

将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；

接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

19.一种信息处理方法，用于作为树型发布系统的一部分的接收设备，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法包括以下步骤：

从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

生成用于所述查询消息的响应消息；

从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；

将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

确定在之下层级中是否存在另一个连接的所述接收设备；以及

将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

20.一种信息处理方法，用于作为树型发布系统的一部分的接收设备，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，该信息处理方法包括以下步骤：

从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

生成用于所述查询消息的响应消息；

从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；

将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及

当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

21.一种信息处理程序，用于使用于发布发布信息并且作为树型发布系统的一部分的发布设备中的计算机起下述作用，其中该树型发布系统是由所述发布设备和用于接收所述发布信息的多个接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：

第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；

接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集由每一个所述接收设备生成的与所述查询消息相对应的响应消息的收集消息；

第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备，以便经由所述多条通信路径中的一条通信路径依次传递所述第二发布信息；以及

收集信息接收装置，用于接收下述收集信息，所述收集信息是从沿着所述第二发布信息依次传递的所述通信路径之一上的所述接收设备中的一个发送的并且包括有所述收集消息，其中由该一条通信路径上的所述接收设备附着的所述响应消息被添加到所述收集消息。

22.一种信息处理程序，用于使作为树型发布系统的一部分的接收设备中的计算机起下述作用，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息的第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及

收集信息发送装置，用于将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备。

23.一种信息处理程序，用于使作为树型发布系统的一部分的接收设备中的计算机起下述作用，其中该树型发布系统是由用于发布发布信息的所述发布设备和用于接收所述发布信息的多个所述接收设备组成的，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，所述作用是：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有查询消息的第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收包括有用于收集所述响应消息的收集消息和用于表示指定消息收集条件的信息的第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及

收集信息发送装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息直接发送给所述发布设备。

24.一种记录介质，其上记录了如权利要求21至23的任何一项所述的信息处理程序，以便能够由计算机读取。

25.一种树型发布系统，其包括用于发布发布信息的发布设备和用于接收所述发布信息的多个接收设备，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，其中

所述发布设备包括：

第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；

接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集与所述查询消息相对应的响应消息的收集消息；以及

第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备；并且

所述接收设备包括：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

较低层级判断装置，用于确定在之下层级中是否存在另一个连接的所述接收设备；以及

收集信息发送/传递装置，用于当所述较低层级判断装置已经确定没有连接所述其他接收设备时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备，并且将包括有已经被添加了所述响应消息的所述收集消息的所述收集信息传递到被连接在之下层级中的所述接收设备中的一个。

26.一种树型发布系统，其包括用于发布发布信息的发布设备和用于接收所述发布信息的多个接收设备，其中所述设备经由多条通信路径以树形连接，并且所述发布设备形成了最高层级，并且所述多个接收设备形成了多个层级，以便从所述发布设备发布的所述发布信息依次从较高层级中的所述接收设备传递到较低层级中的所述接收设备，其中

所述发布设备包括：

第一发布信息发布装置，用于发布第一发布信息，以便包括有查询消息的所述第一发布信息被发布到多条通信路径上的所述接收设备；

接收设备选择装置，用于选择被连接到所述发布设备并且下述第二发布信息要发布到的一个所述接收设备，所述第二发布信息包括有用于收集与所述查询消息相对应的响应消息的收集消息和用于表示指定消息收集条件的信息；以及

第二发布信息发布装置，用于将所述第二发布信息发布到所述选择的一个接收设备；并且

所述接收设备包括：

第一发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收第一发布信息；

响应消息生成装置，用于生成用于所述查询消息的响应消息；

第二发布信息接收装置，用于从所述发布设备或位于之上层级中的所述接收设备接收所述第二发布信息；

响应消息添加装置，用于将所述生成的响应消息添加到在所述第二发布信息中包括的收集消息；

消息收集条件判断装置，用于确定是否满足在所述第二发布信息中包括的所述指定消息收集条件；以及

收集信息发送/传递装置，用于当所述消息收集条件判断装置确定满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的收集信息发送给所述发布设备，并且当所述消息收集条件判断装置确定不满足所述消息收集条件时，将包括有已经被添加了所述响应消息的所述收集消息的所述收集信息传递到被连接在之下层级中的所述接收设备中的一个。

27.一种树型网络系统中的处理设备，该树型网络系统包括查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由通信路径与所述多个处理设备连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成了多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中所述处理设备之一包括：

查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的其他所述处理设备或者从所述查询设备发送的所述查询信息；

查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备中的一个或多个；

回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中的至少一个或多个发送的所述回复结果信息；

回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；

回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及

回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备。

28.如权利要求27所述的处理设备，进一步包括：

选择装置，用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复信息创建装置创建的回复信息中选择指定个数项的所述回复信息，其中

所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

29.如权利要求28所述的处理设备，进一步包括：

总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及

总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；其中

所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

30.如权利要求29所述的处理设备，其中

当所述回复结果信息回复装置发送所述回复结果信息时，所述总个数信息发送装置发送所述总个数信息。

31.如权利要求27至30中的任何一项所述的处理设备，进一步包括：

结束信息接收装置，用于从被连接在所述高位层级中的其他所述处理装置或者所述查询装置接收给出用于结束针对所述查询信息的回答信息的输入接收指令的结束信息；以及

回答信息输入接收装置，用于从当所述查询信息接收装置接收到所述查询信息时一直到所述结束信息接收装置接收到所述结束信息为止，接收所述回答信息的输入；其中

所述回复信息创建装置根据由所述回答信息输入接收装置接收的所述回答信息的输入来创建所述回复信息。

32.如权利要求27至31中的任何一项所述的处理设备，进一步包括：

等待时间设置装置，用于设置用于从被连接在所述低位层级中的所述其他处理设备接收所述回复结果信息的接收等待时间；其中

所述回复结果信息创建装置根据由所述回复结果信息接收装置在所述接收等待时间内接收的所述回复结果信息来创建用于所述一个处理设备本身的回复结果信息。

33.如权利要求28至32中的任何一项所述的处理设备，进一步包括：

判断装置，用于确定由所述回复信息创建装置创建的回复信息是否与由所述查询信息接收装置接收的查询信息相对应；其中

当确定该回复信息与所述查询信息不对应时，所述选择装置去除作为选择对象的由所述回复信息创建装置创建的回复信息，并且仅从在由所述回复结果信息接收装置接收的回复结果信息中包括的回复信息中选择所述指定个数项的回复信息。

34.一种树型网络系统，其包括：查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由多条通信路径与所述多个处理设备连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中

所述处理设备之一包括：

查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的其他所述处理设备或者从所述查询设备发送的所述查询信息；

查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备；

回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中发送的所述回复结果信息；

回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；

回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及

回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；其中

所述查询设备包括：

查询信息发送装置，用于将所述查询信息发送到被连接在所述查询设备之下的低位层级中的所述处理设备中的至少一个或多个；以及

回复结果信息装置，用于接收从被连接在低位层级中的所述处理设备中的至少一个或多个发送的所述回复结果信息。

35.如权利要求34所述的树型网络系统，其中所述处理设备进一步包括：

选择装置，用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复信息创建装置创建的回复信息中选择指定个数项的所述回复信息；并且其中

所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

36.如权利要求35所述的树型网络系统，其中

所述处理设备进一步包括：

总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及

总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；并且其中

所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

37.一种用于树型网络系统中的处理设备中包含的计算机的处理程序，该树型网络系统包括：查询设备，用于发送用于请求发送回复结果信息的查询信息；以及多个处理设备，用于接收所述查询信息，其中所述查询设备经由多条通信路径与所述多个处理设备被连接成树形，以便所述查询设备是最高的，并且所述多个处理设备形成多个层级，并且从所述查询设备发送的所述查询信息连续从高位层级中的所述处理设备传递到低位层级中的所述处理设备，其中所述程序使所述处理设备的所述计算机起到以下作用：

查询信息接收装置，用于接收从被连接在所述一个处理设备的高位层级中的其他所述处理设备或者从所述查询设备发送的所述查询信息；

查询信息传递装置，用于将所述接收的查询信息传递到被连接在所述一个处理设备的低位层级中的所述其他处理设备中的一个或多个；

回复结果信息接收装置，用于接收包括有用于所述查询信息的回复信息并且从被连接在所述低位层级中的所述其他处理设备中的至少一个或多个发送的所述回复结果信息；

回复信息创建装置，用于使所述一个处理设备创建其自己的用于所述查询信息的所述回复结果信息；

回复结果信息创建装置，用于使所述一个处理设备根据由所述回复结果信息接收装置接收的回复结果信息和由所述回复信息创建装置创建的回复信息来创建其自己的回复结果信息；以及

回复结果信息回复装置，用于将所述创建的回复结果信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备。

38.如权利要求37所述的处理程序，进一步使所述计算机起到如下作用：

选择装置，用于从在由所述回复结果信息接收装置接收的所述回复结果信息中包括的回复信息以及由所述回复结果信息创建装置创建的回复信息中选择指定个数项的所述回复信息；并且使

所述回复结果信息创建装置创建包括有所述选择的指定个数项的所述回复信息的所述回复结果信息。

39.如权利要求38所述的处理程序，其进一步使所述计算机起到如下作用：

总个数信息获取装置，用于获取被连接在所述低位层级中的所述其他处理设备的总个数加“1”的和来作为总个数信息；以及

总个数信息发送装置，用于将所述总个数信息发送给作为由所述查询信息接收装置接收的查询信息的发送源并且被连接在所述高位层级中的其他所述处理设备或者所述查询设备；并且使

所述选择装置根据从被连接在所述低位层级中的所述其他处理设备发送的所述总个数信息来选择所述指定个数项的回复信息。

40.一种记录介质，其上记录有如权利要求37至39中的任何一项所述的处理程序，以便其能够由所述计算机读取。

Images