WO2009094919A1 - Method, device and system for diagnosing whether nodes are abnormal or not in p2p network - Google Patents

Description

说明书 在对等网络中诊断节点是否异常的方法、 装置及系统

[1] 本申请要求于 2008年 01月 29日提交中国专利局， 申请号为 200810057085.1， 发 明名称为"在对等网络中诊断节点是否异常的方法、 装置及系统"的中国专利申请 的优先权， 其全部内容通过引用结合在本申请中。

[2] 技术领域

[3] 本发明涉及网络通信领域， 尤其涉及一种在对等网络中诊断节点是否异常的方 法、 装置及系统。

[4] 发明背景

[5] 对等网络 （peer-to-peer, P2P) 是一种分布式， 网络的参与者共享他们所拥有 的一部分硬件资源， 如处理能力、 存储能力， 网络连接能力、 打印机等， 这些 共享资源需要由网络提供服务和内容， 能被其它对等节点 Peer直接访问而无需经 过中间实体， Peer在 P2P中既是资源的提供者， 又是资源的获取者。 P2P打破了 传统的客户端 /服务器

(Client/Server, C/S)模式， 网络中的每个节点的地位都是对等的， 每个节点即充 当服务器， 为其它节点提供服务， 同吋也享用其它节点提供的服务。 P2P系统包 括结构化 P2P系统、 非结构化 P2P系统和松散结构化 P2P系统。

[6] 结构化 P2P系统的特点是， 所有的节点都有一个定长的逻辑地址， 使用这个逻 辑地址并根据分布哈希表 DHT (Distributed Hash

Table) 算法规则将所有的节点构成一个逻辑的叠加网， 在结构化 P2P网络中， 根 据分布哈希表 (Distributed Hash Table

， DHT) 算法规则， 每个节点都需要负责存储一段资源索引表， 这段资源索引 表和节点自身的逻辑地址根据 DHT算法规则有唯一的映射关系， 在资源査找吋 ， 也是根据 DHT算法规则将査找消息在 P2P网络中一跳一跳逐渐逼近的方式转发 到对应资源索引的存储节点。 这种一跳一跳逐渐逼近的转发方式如下所示， 假 设 A1是一个异常节点， A2是另一个异常节点， S是发起节点， D是目的节点， M 1、 M2是普通路径中的正常节点。 假设 S有一个请求， 需要经过的正常路径为 S →M1→A1→M2→D, 这里将 Ml、 Al、 M2、 D称为发起节点 S的下游节点， 由于

Al是一个异常节点， 所以在 A1接收到该从 Ml转发过来的请求后， 可以将请求丢 弃、 修改请求或不发送给 M2， 而发送给其它的异常节点， 如另一个异常节点 A2 等， A1将 Ml转发过来的请求丢弃。

[7] 在实现本发明的过程中， 发明人发现现有技术所述的方法存在如下问题：

[8] 由于现有技术中异常节点的存在使得通过该异常节点的消息或请求丢失， 进而 影响 P2P系统中消息或请求的转发成功率， 获知该节点为异常节点能限制通过该 异常节点的消息或请求的数量， 而现有技术中没有一种诊断节点是否异常的方 法， 所以无法获知节点是否为异常节点。

[9] 发明内容

[10] 鉴于上述现有技术所存在的问题， 本发明实施方式提供一种在对等网络中诊断 节点是否异常的方法、 装置及系统， 所述方法、 装置及系统能获知节点是否为 异常节点， 进而限制通过该异常节点的消息或请求的数量。

[11] 本发明的具体实施方式提供一种在对等网络中诊断节点是否异常的方法， 所述 方法包括：

[12] 发送带有待检测消息标识的诊断消息；

[13] 在收到节点发送的对应所述诊断消息的响应消息的情况下， 判断出所述节点为 正常节点， 否则判断出所述节点为异常节点； 所述响应消息包括所述下游节点 的确认消息。

[14] 本发明具体实施方式提供一种在对等网络中诊断节点是否异常的装置， 所述装 置包括：

[15] 发送单元， 用于发送带有待检测消息标识的诊断消息；

[16] 接收单元， 用于接收节点发送的对应所述诊断消息的响应消息， 所述响应消息 包括所述下游节点的确认消息；

[17] 判断单元， 用于判断接收单元是否收到所述确认消息， 如收到所述确认消息的 情况下， 判断出所述节点为正常节点， 否则判断出所述节点为异常节点。

[18] 本发明具体实施方式提供一种中间节点装置， 所述装置包括：

[19] 接收单元， 用于接收带有待检测消息标识的诊断消息、 接收其它节点发送的信息和所述下 游节点发送的确认消息和所述下游节点的信息；

[20] 发送单元， 用于在所述接收单元收到其它节点发送的信息后， 回复确认消息和 所述中间节点的信息、 并向所述中间节点的下游节点转发所述其它节点发送的 信息， 在所述接收单元收到所述诊断消息后， 发送对应所述诊断消息的响应消 息， 所述响应消息包括所述确认消息和所述下游节点的信息。

[21] 本发明具体实施方式提供一种在对等网络中诊断节点是否异常系统， 所述系统 包括，

[22] 源节点、 中间节点和目的节点，

[23] 所述源节点用于发送带有待检测消息标识的诊断消息和接收所述中间节点或目 的节点发送的对应所述诊断消息的响应消息， 并根据所述响应消息判断节点是 否异常；

[24] 所述中间节点用于接收所述诊断消息， 并发送对应所述诊断消息的响应消息， 所述响应消息包括所述节点的下游节点的信息和所述下游节点的确认消息； 所 述中间节点用于接收其它节点发送的信息， 并在收到所述其它节点发送的信息 后回复确认消息和所述中间节点的信息， 并转发所述其它节点发送的信息； 所 述中间节点还用于接收所述诊断消息， 并发送对应所述诊断消息的响应消息， 所述响应消息包括所述节点的下游节点的信息和所述下游节点的确认消息。

[25] 由上述所提供的技术方案可以看出， 本发明实施例的技术方案通过诊断消息来 判断获知节点是否为正常节点， 从而获知节点是否为异常节点， 进而限制通过 该异常节点的消息或请求的数量， 提高 P2P系统中消息或请求的转发成功率。

[26] 附图简要说明

[27] 图 1为本发明具体实施方式所述的诊断节点是否异常的方法流程图。

[28] 图 2为本发明一实施例的在对等网络中诊断节点是否异常的方法的流程图。

[29] 图 3为本发明具体实施方式所述的在对等网络中诊断节点是否异常的装置的结 构图。

[30] 图 4位本发明具体实施方式所述的中间节点装置的结构图。

[31] 图 5为本发明具体实施方式所述的系统的结构图。 [32] 实施本发明的方式

[33] 本发明实施方式提供了一种在对等网络中诊断节点是否异常的方法。

[34] 该方法如图 1所示， 包括如下步骤：

[35] 步骤 11、 发送带有待检测消息标识的诊断消息；

[36] 该步骤中的待检测消息标识可以为， 待检测消息的消息标签， 如待检测消息的 哈希值； 或待检测消息的对等网络识别码和处理识别码 Peer ID + Transaction ID, 本发明具体实施方式不限制消息标识的具体形式， 只需该消息标识能使节 点分辨出该诊断消息对应的待检测消息即可。

[37] 步骤 12、 判断是否收到节点发送的对应所述诊断消息的响应消息， 所述响应消 息包括所述下游节点的确认消息； 在收到所述响应消息的情况下， 判断出所述 节点为正常节点， 否则判断出所述节点为异常节点。

[38] 可选的， 该响应消息还可以包括该节点的下游节点的信息。

[39] 该步骤中该节点的下游节点为该节点传送路径中的下一个节点。

[40] 完成该步骤 12可以由下述方法实现， 节点在接收到上一节点转发的信息后， 回 复确认消息和该节点的信息， 该回复的确认消息带有该节点的签名， 并转发该 接收到的信息， 在转发完该信息后接收下游节点发送的确认消息和下游节点的 信息， 收到下游节点发送的确认消息和下游节点的信息后存储， 在接收到带有 待检测消息标识的诊断消息后， 将对应该诊断消息的确认消息和下游节点的信 息加载在响应消息内， 并将该响应消息发送。 该接收到的信息可以为报文。

[41] 上述方法在完成步骤 11之前， 还可以包括下述步骤：

[42] 判断是否接收到目的节点发送的回复消息； 未收到目的节点发送的回复消息的 情况下， 进行步骤 11 ; 否则结束操作。

[43] 上述未收到目的节点发送的回复消息的情况包括下述情况：

[44] 情况 A、 中间节点在转送报文信息的过程中超吋；

[45] 情况 B、 中间节点收到该中间节点的下游节点发送的确认消息， 但所述确认消 息错误；

[46] 情况 C、 中间节点将转送信息删除或恶意修改。

[47] 上述情况 A〜C仅说明了普通的未收到目的节点发送的回复消息的情况， 本发 明具体实施方式并不限制未收到目的节点发送的回复消息的具体情况， 只要未 收到目的节点发送的回复消息， 均可以直接发送诊断消息。

[48] 上述方法可以由源节点完成， 也可以由管理节点完成。

[49] 上述方法在完成步骤 12后， 还可以包括以下步骤： 将所述异常节点的信息发送 给其它的节点。 该步骤可以由源节点或管理节点完成， 该步骤中的其它节点为 除了异常节点以外的其它节点。 通过将异常节点的信息发送给其它的节点， 使 得其它节点控制对异常节点发送的消息或请求的数量， 从而减少消息或请求的 丢失率。

[50] 为更好的描述本发明实施方式所述的方法， 现结合附图 2对本发明的具体实施 方式进行说明：

[51] 本发明的具体实施方式提供一实施例， 本实施例提供的一种诊断节点是否异常 的方法， 本实施例的技术场景为， 本实施例由源节点完成， 带有待检测消息标 识的诊断消息为， 带有 Peer ID +Transaction

ID的诊断消息， 该方法如图 2所示， 包括如下步骤：

[52] 步骤 21、 源节点判断是否收到目的节点发送的回复消息； 未收到回复消息， 进 行步骤 22， 否则结束操作；

[53] 该步骤中的未收到回复消息的情况已在上述说明， 这里就不在赞述。 而实现该 步骤的方法可以由下述方法实现， 可以在源节点设定一个吋间， 如超出这个吋 间还未收到目的节点发送的回复消息， 则判断出未收到回复消息， 还可以在中 间节点进行设置， 当中间节点转发信息失败的情况下， 向源节点发送转发失败 的消息， 源节点收到该消息后判断出未收到回复消息。

[54] 步骤 22、 源节点发送带有 Peer ID + Transaction ID的诊断消息；

[55] 实现该步骤的具体方法可以为， 源节点逐一向节点发送诊断消息， 或源节点统 一向节点发送诊断消息。

[56] 步骤 23、 源节点判断是否收到节点发送的对应所述诊断消息的响应消息， 所述 响应消息包括该节点的下游节点的信息和所述下游节点的确认消息； 在收到所 述响应消息的情况下， 判断出所述节点为正常节点， 否则判断出所述节点为异 常节点。 在源节点判断出所述节点为异常节点吋， 还可以进行步骤 24; [57] 该步骤中的判断是否收到节点发送的对应所述诊断消息的响应消息的方法可以 釆用步骤 21中判断是否收到目的节点发送的回复消息相类似的方法。

[58] 步骤 24、 源节点将异常节点的信息发送给其它节点。

[59] 本发明实施方式提供的方法通过诊断消息来判断节点是否为异常节点。

[60] 本发明的实施方式还提供一种在对等网络中诊断节点是否异常的装置， 如图 3 所示， 该装置包括： 发送单元 31， 发送带有待检测消息标识的诊断消息； 接收 单元 32， 用于接收节点发送的对应所述诊断消息的响应消息， 所述响应消息包 括所述下游节点的确认消息； 判断单元 33， 用于判断接收单元 32是否收到所述 响应消息， 如收到所述响应消息的情况下， 判断出所述节点为正常节点， 否则 判断出所述节点为异常节点。 该诊断节点是否异常的装置可以为源节点装置或 管理节点装置。

[61] 可选的， 该响应消息还可以包括该节点的下游节点的信息。

[62] 上述装置还可以包括； 判断模块 311， 用于判断是否收到目的节点发送的回复 消息； 所述发送单元 31还可以用于在判断模块判断出未收到目的节点发送的回 复消息的情况下， 发送所述诊断消息。

[63] 上述装置还可以包括， 信息发送单元 34， 用于将所述异常节点的信息发送给其 它的节点。

[64] 本发明实施方式提供的装置通过诊断消息来判断获知节点是否为异常节点。

[65] 本发明具体实施方式还提供一种中间节点装置， 所述装置如图 4所示， 在现有 技术的中间节点上设置了下述单元， 包括： 接收单元 41，

用于接收带有待检测消息标识的诊断消息、 接收其它节点发送的信息和所述下 游节点发送的确认消息和所述下游节点的信息； 发送单元 42， 用于在所述接收 单元收到其它节点发送的信息后， 回复确认消息和所述中间节点的信息、 并向 所述中间节点的下游节点转发所述其它节点发送的信息， 在所述接收单元收到 所述诊断消息后， 发送对应所述诊断消息的响应消息， 所述响应消息包括所述 确认消息和所述下游节点的信息。

[66] 上述装置还可以包括： 存储单元 43， 用于存储所述接收单元接收的所述下游节 点发送的确认消息和所述下游节点的信息。 [67] 上述装置还可以包括： 提取模块 461， 用于提取存储单元存储的所述下游节点 发送的确认消息和所述下游节点的信息； 加载模块 462， 用于将所述下游节点发 送的确认消息和所述下游节点的信息加载在响应消息内， 并将所述响应消息发 送给发送单元； 所述发送单元 42接收到所述响应消息内后， 发送所述响应消息

[68] 本发明实施方式提供的中间节点装置在收到诊断消息后， 发送对应该诊断消息 的响应消息， 以此来支持本发明具体实施方式的方法来判断获知节点是否为异 常节点。

[69] 本发明具体实施方式还提供一种在对等网络中诊断节点是否异常系统， 所述系 统如图 5所示： 包括， 源节点 51、 中间节点 52和目的节点 53，

[70] 所述源节点 51， 用于发送带有待检测消息标识的诊断消息和接收所述中间节点 或目的节点发送的对应所述诊断消息的响应消息， 并根据所述响应消息判断节 点是否异常；

[71] 所述中间节点 52， 用于接收所述诊断消息， 并发送对应所述诊断消息的响应消 息， 所述响应消息包括所述节点的下游节点的信息和所述下游节点的确认消息 ； 所述中间节点用于接收其它节点发送的信息， 并在收到所述其它节点发送的 信息后回复确认消息和所述中间节点的信息， 并转发所述其它节点发送的信息 ； 所述中间节点还用于接收所述诊断消息， 并发送对应所述诊断消息的响应消 息， 所述响应消息包括所述节点的下游节点的信息和所述下游节点的确认消息

[72] 上述系统中的根据所述响应消息判断节点是否异常可以包括： 如收到所述响应 消息的情况下， 判断出所述节点为正常节点， 否则判断出所述节点为异常节点

[73] 本发明实施方式提供的系统通过诊断消息来判断节点是否为异常节点。

[74] 本领域技术人员可以理解附图只是一个优选实施例的示意图， 附图中的模块或 流程并不一定是实施本发明所必须的。

[75] 本领域普通技术人员可以理解实现上述实施例方法中的全部或部分步骤可以通 过程序来指令相关的硬件完成， 所述的程序可以存储于一种计算机可读存储介 质中， 该程序在执行吋， 包括方法实施例的步骤之一或其组合。

[76] 另外， 在本发明各个实施例中的各功能单元可以集成在一个处理模块中， 也可 以是各个单元单独物理存在， 也可以两个或两个以上单元集成在一个模块中。 上述集成的模块既可以釆用硬件的形式实现， 也可以釆用软件功能模块的形式 实现。 所述集成的模块如果以软件功能模块的形式实现并作为独立的产品销售 或使用吋， 也可以存储在一个计算机可读取存储介质中。

[77] 上述提到的存储介质可以是只读存储器， 磁盘或光盘等。

[78] 综上所述， 本发明具体实施方式提供的技术方案， 具有判断节点是否为异常节 点的优点。

[79] 以上所述， 仅为本发明较佳的具体实施方式， 但本发明的保护范围并不局限于 此， 任何熟悉本技术领域的技术人员在本发明实施例揭露的技术范围内， 可轻 易想到的变化或替换， 都应涵盖在本发明的保护范围之内。 因此， 本发明的保 护范围应该以权利要求的保护范围为准。

Claims

权利要求书

[1] 一种在对等网络中诊断节点是否异常的方法， 其特征在于， 所述方法包括 发送带有待检测消息标识的诊断消息；

在收到节点发送的对应所述诊断消息的响应消息的情况下， 判断出所述节 点为正常节点， 否则判断出所述节点为异常节点； 所述响应消息包括所述 下游节点的确认消息。

[2] 根据权利要求 1所述的方法， 其特征在于， 所述发送带有待检测消息标识的 诊断信息包括，

在未收到目的节点发送的回复消息的情况下， 发送带有待检测消息标识的 诊断消息。

[3] 根据权利要求 1所述的方法， 其特征在于， 所述方法在判断出所述节点为异 常节点后， 还包括，

将所述异常节点的信息发送给其它的节点。

[4] 根据权利要求 1所述的方法， 其特征在于， 所述待检测消息标识包括， 待检测消息的消息标签；

或待检测消息的对等网络识别码和处理识别码。

[5] 根据权利要求 1所述的方法， 其特征在于， 所述响应消息还包括所述节点的 下游节点的信息。

[6] 一种在对等网络中诊断节点是否异常装置， 其特征在于， 所述装置包括： 发送单元， 用于发送带有待检测消息标识的诊断消息；

接收单元， 用于接收节点发送的对应所述诊断消息的响应消息， 所述响应 消息包括所述下游节点的确认消息；

判断单元， 用于判断接收单元是否收到所述确认消息， 如收到所述确认消 息的情况下， 判断出所述节点为正常节点， 否则判断出所述节点为异常节 点。

[7] 根据权利要求 6所述的装置， 其特征在于， 所述装置还包括；

判断模块， 用于判断是否收到目的节点发送的回复消息， 并将判断结果发 送给发送单元；

所述发送单元在判断模块判断出未收到目的节点发送的回复消息的情况下

， 发送所述诊断消息。

[8] 根据权利要求 7所述的装置， 其特征在于， 所述装置还包括：

信息发送单元， 用于将所述异常节点的信息发送给其它的节点。

[9] 一种中间节点装置， 其特征在于， 所述装置包括：

接收单元，

用于接收带有待检测消息标识的诊断消息、 接收其它节点发送的信息和所 述下游节点发送的确认消息和所述下游节点的信息；

发送单元， 用于在所述接收单元收到其它节点发送的信息后， 回复确认消 息和所述中间节点的信息、 并向所述中间节点的下游节点转发所述其它节 点发送的信息， 在所述接收单元收到所述诊断消息后， 发送对应所述诊断 消息的响应消息， 所述响应消息包括所述确认消息和所述下游节点的信息

[10] 根据权利要求 9所述的装置， 其特征在于， 所述装置还包括，

存储单元， 用于存储所述接收单元接收的所述下游节点发送的确认消息和 所述下游节点的信息。

[11] 根据权利要求 10所述的装置， 其特征在于， 所述装置还包括：

提取模块， 用于提取存储单元存储的所述下游节点发送的确认消息和所述 下游节点的信息；

加载模块， 用于将所述下游节点发送的确认消息和所述下游节点的信息加 载在响应消息内， 并将所述响应消息发送给发送单元；

所述发送单元在接收到所述响应消息后， 发送所述响应消息。

[12] 一种在对等网络中诊断节点是否异常的系统， 其特征在于， 所述系统包括

， 源节点、 中间节点和目的节点，

所述源节点用于发送带有待检测消息标识的诊断消息和接收所述中间节点 或目的节点发送的对应所述诊断消息的响应消息， 并根据所述响应消息判 断节点是否异常； 所述中间节点用于接收所述诊断消息， 并发送对应所述诊断消息的响应消 息， 所述响应消息包括所述节点的下游节点的信息和所述下游节点的确认 消息； 所述中间节点用于接收其它节点发送的信息， 并在收到所述其它节 点发送的信息后回复确认消息和所述中间节点的信息， 并转发所述其它节 点发送的信息； 所述中间节点还用于接收所述诊断消息， 并发送对应所述 诊断消息的响应消息， 所述响应消息包括所述节点的下游节点的信息和所 述下游节点的确认消息。

根据权利要求 12所述的系统， 其特征在于， 所述根据所述响应消息判断节 点是否异常包括：

如收到所述响应消息的情况下， 判断出所述节点为正常节点， 否则判断出 所述节点为异常节点。