本发明涉及网络设备流量管理领域， 尤其涉及一种流量釆集系统及其 方法、 装置。 背景技术

随着因特网的高速发展， 网际协议（IP, Internet Protocol ) 网络已经成 为人们日常工作和生活中必不可少的工具， 并且在 IP网络中进行点到点的 数据传输更加普遍， 存在很少的用户占用大量的设备带宽， 从而导致了电 信运营商的网络设备投入远远满足不了用户对 带宽的需求。 因此， 电信运 营商希望增加网络的可视性， 了解网络的实际占用情况， 进而可以对网络 进行有效的控制， 保障用户使用的均衡性， 并且可以推出差异化产品满足 不同用户的需求。

为了增加网络的可视性， 了解网络的实际占用情况， 并满足不同用户 的需求， 需要釆集网络设备的流量数据并进行分析控制 ， 一般通过单个流 量釆集器对网络中的所有网络设备（如交换机 和路由器等） 的流量数据进 行釆集， 在城域网或大型企业的网络环境中， 用户 IP网络设备的流量数据 信息非常大， 使得流量釆集器的釆集和查询压力巨大， 导致单个流量釆集 器无法完成对所有网络设备（如多个路由器或 者交换机） 的大流量数据信 息的釆集和查询， 甚至提高单个流量釆集器的硬件性能都无法满 足大流量 数据信息的釆集和查询， 可见， 亟待提供一种可以完成对网络设备的大流 量数据信息的釆集和查询的解决方案。 发明内容

本发明实施例提供一种流量釆集系统及其方法 、 装置， 用以解决现有 技术中存在的单个流量釆集器无法完成对网络 设备大流量数据信息的釆集 和查询的问题。

本发明所提供的流量釆集系统， 该系统包括管理服务器和至少一个流 量釆集器； 其中，

所述管理服务器， 用于向已注册的至少一个流量釆集器广播流量 查询 消息， 并对各流量釆集器上报的网络设备的流量数据 进行汇总， 得到汇总 结果；

所述流量釆集器， 用于根据管理服务器广播的所述流量查询消息 ， 釆 集所管辖网络设备的流量数据并上报给所述管 理服务器。

相应地， 本发明还提供了一种流量釆集方法， 该方法包括：

管理服务器向已注册的至少一个流量釆集器广 播流量查询消息； 管理服务器获得所述各流量釆集器根据所述流 量查询消息釆集到的所 管辖网络设备的流量数据；

管理服务器对获得的流量数据进行汇总， 并存储汇总结果。

基于流量釆集方法， 本发明还提供了一种流量釆集装置， 该装置包括 消息主题模块、 消息队列模块和汇总模块； 其中，

所述消息主题模块， 用于向已注册的至少一个流量釆集器广播流量 查 询消息；

所述消息队列模块， 用于获得所述各流量釆集器根据所述流量查询 消 息釆集到的网络设备的流量数据；

所述汇总模块， 用于对获得的流量数据进行汇总， 并存储汇总结果。 本发明实施例提供的基于上述流量釆集系统及 其方法、 装置， 对于单 个流量釆集器无法完成的大流量数据信息的釆 集和查询工作， 通过至少一 个流量釆集器分担网络设备大流量数据信息的 釆集和查询工作， 集中管理 所有的流量釆集器， 保证了消息的可靠性， 解决了由单个流量釆集器无法 完成的大流量数据信息的釆集和查询的问题， 保证了电信运营商对网络的 有效控制和用户使用网络的均衡性， 随着汇聚层和核心层网络设备的增加， 通过增加流量釆集器即可， 无需升级现有的流量釆集器， 增加了系统的可 扩展性。

本发明的其它特征和优点将在随后的说明书中 阐述， 并且， 部分地从 说明书中变得显而易见， 或者通过实施本发明而了解。 本发明的目的和其 他优点可通过在所写的说明书、 权利要求书、 以及附图中所特别指出的结 构来实现和获得。 附图说明

图 1为本发明实施例一中流量釆集系统的组成框� �；

图 2为本发明实施例一中以 3个流量釆集器为例的流量釆集系统的组 成框图；

图 3为本发明实施例二中流量釆集方法流程图；

图 4为本发明实施例二中流量釆集器的注册流程� �；

图 5为本发明实施例二中管理服务器广播消息的� �程图；

图 6为本发明实施例二中流量釆集装置。 具体实施方式

本发明实施例为了解决现有技术中用户占用网 络资源不均衡， 而单个 流量釆集器无法满足网络中大流量数据信息的 釆集和查询工作， 导致电信 运营商不能有效控制网络资源的问题， 提供了一种流量釆集系统及其方法、 装置， 通过至少一个流量釆集器分担网络设备的流量 釆集和查询工作， 并 集中管理所有的流量釆集器， 解决了单个流量釆集器无法完成的大流量数 据信息的釆集和查询的问题。

以下结合说明书附图对本发明的优选实施例进 行说明， 应当理解， 此 处所描述的优选实施例仅用于说明和解释本发 明， 并不用于限定本发明，

合。

实施例一

本实施例首先提供了流量釆集系统， 如图 1所示， 包括管理服务器 100 和至少一个流量釆集器 ₂₀₀ , 其中： 所述管理服务器 100,用于向已注册的至少一个流量釆集器广播� �量查 询消息， 并对各流量釆集器上报的网络设备的流量数据 进行汇总， 得到汇 总结果。

所述流量釆集器 200, 用于根据管理服务器广播的流量查询消息， 釆集 所管辖网络设备的流量数据并上报给所述管理 服务器。

进一步地， 所述流量釆集器 200还用于在正常工作状态下， 周期性向 所述管理服务器上报心跳消息。

所述管理服务器 100,还用于在接收到流量釆集器上报的心跳消� �时更 新存储的该流量釆集器的心跳消息的接收时间 ， 根据存储的每一个流量釆 集器的心跳消息的接收时间判断所述流量釆集 器是否处于正常工作状态， 并查询正常工作状态的流量釆集器的状态信息 。

所述管理服务器 100,具体用于分别向各正常工作状态的流量釆� �器发 送状态查询消息， 其中携带该正常工作状态的流量釆集器的釆集 器 ID。

所述流量釆集器 200, 用于接收管理服务器发送的状态查询消息， 确认 所述状态查询消息中携带的釆集器 ID与本地存储的釆集器 ID相一致时， 根据所述状态查询消息查询本流量釆集器的状 态信息并上报给所述管理服 务器。 较佳地， 所述管理服务器 100, 还用于将非正常工作状态的流量釆集器 所管辖的网络设备移交给状态信息满足设定条 件的正常工作状态的流量釆 集器。

为了便于介绍，假设有三个结构相同的流量釆 集器，分别为 200A、 200B 和 200C, 如图 2所示， 包括管理服务器 100、 流量釆集器（200A、 200B和 200C ); 其中：

所述管理服务器 100 , 用于向已注册的流量釆集器 （200A、 200B 和 200C )广播流量查询消息； 并对各流量釆集器上报的网络设备的流量数据 进行汇总， 得到汇总结果。

所述流量釆集器（ 200A、 200B和 200C ), 用于接收管理服务器 100广 播的流量查询消息， 确认所述流量查询消息的消息对象包括本流量 釆集器 的釆集器 ID时， 根据所述流量查询消息釆集所管辖网络设备的 流量数据并 上报给所述管理服务器 100。

假设流量釆集器 200A和流量釆集器 200B的心跳消息的接收时间都满 足设定时间的要求，流量釆集器 200C的心跳消息的接收时间不满足设定时 间的要求， 则管理服务器 100确认流量釆集器（200A和 200B )处于正常工 作状态， 流量釆集器 200C处于非正常工作状态。

所述的状态消息包括服务器 CPU使用率消息、 内存使用率消息和磁盘 使用百分比消息等。

较佳地， 所述管理服务器 100, 还用于将非正常工作状态的流量釆集器

200C所管辖的网络设备移交给状态信息满足� �定条件的正常工作状态的流 量釆集器 200A或流量釆集器 200B。

显而易见， 假设状态消息中流量釆集器 200B的 CPU内存使用率比流 量釆集器 200A低， 则说明流量釆集器 200B的釆集压力小， 即把工作状态 非正常的流量釆集器 200C所管辖的网络设备移交给流量釆集器 200B, 从 而实现了流量釆集器的动态釆集。

较佳地， 所述管理服务器 100还用于在广播流量查询消息之前， 通过 向所述至少一个流量釆集器发送釆集打开消息 来将流量釆集器的釆集开关 打开。

进一步地， 所述流量釆集器还用于在每次启动时根据配置 的管理服务 器的 IP地址， 向管理服务器发送注册消息；

所述管理服务器， 还用于从接收到的注册消息中提取发起注册的 流量 釆集器的 IP地址，查找本地是否记录有该流量釆集器的 IP地址对应的釆集 器 ID, 如果没有， 为该流量釆集器配置釆集器 ID并记录该流量釆集器的 IP地址与配置的釆集器 ID之间的对应关系， 如果有， 将该流量釆集器的釆 集器 ID取出； 以及向发起注册的流量釆集器反馈携带釆集器 ID的注册确 认消息。

进一步地， £设有 3个流量釆集器，即流量釆集器（ 200A、200B和 200C ) 还用于在每次启动时根据配置的管理服务器 100的 IP地址， 向管理服务器 100发送注册消息。

所述的流量釆集器（200A、 200B和 200C )获取釆集器 ID方法是： 管理服务器 100还用于从接收到的注册消息中提取发起注册 的流量釆 集器（ 200A、 200B和 200C ) 的 IP地址， 查找本地是否记录有流量釆集器 ( 200A、 200B和 200C )的 IP地址对应的釆集器 ID , 如果没有找到流量釆 集器 200A的釆集器 ID, 为流量釆集器 200A配置釆集器 ID并记录该流量 釆集器的 IP地址与配置的釆集器 ID之间的对应关系， 如果找到流量釆集 器（200B和 200C ) 的釆集器 ID , 将流量釆集器 （ 200B和 200C ) 的釆集 器 ID取出； 以及向发起注册的流量釆集器（ 200A、 200B和 200C )反馈携 带釆集器 ID的注册确认消息。

实施例二 基于同样的技术构思， 本实施例提供了一种基于流量釆集方法， 如图 3 所示， 包括如下步骤：

步骤 S301、 管理服务器向已注册的至少一个流量釆集器广 播流量查询 消息。

步骤 S302、 管理服务器获得所述各流量釆集器根据流量查 询消息釆集 到的所管辖网络设备的流量数据。

步骤 S303、管理服务器对获得的流量数据进行汇总� � 并存储汇总结果。 进一步地， 所述管理服务器在广播流量查询消息之前， 还包括： 通过向所述至少一个流量釆集器广播釆集打开 消息将流量釆集器的釆 集开关打开。

进一步地， 流量釆集器向管理服务器进行注册的过程， 包括： 管理服务器从流量釆集器发送的注册消息中提 取流量釆集器的 IP 地 址。

管理服务器查找本地是否记录有该流量釆集器 的 IP地址对应的釆集器 ID, 如果没有， 为所述流量釆集器配置釆集器 ID并记录该流量釆集器的 IP 地址与配置的釆集器 ID之间的对应关系， 如果有， 将该流量釆集器的釆集 器 ID取出； 以及

管理服务器向发起注册的流量釆集器反馈携带 釆集器 ID的注册确认消 息。

流量釆集器的具体注册流程如图 4所示， 包括以下步骤：

步骤 S401、流量釆集器在每次启动时根据配置的管� �服务器的 IP地址， 向管理服务器发送注册消息。

步骤 S402、 管理服务器从接收到注册消息中提取发起注册 的流量釆集 器的 IP地址，查找管理服务器中是否记录有该流量� ��集器的 IP地址对应的 釆集器 ID, 如果没有， 进入步骤 S403 ; 如果有， 进入步骤 S404。 步骤 S403、管理服务器为所述流量釆集器配置釆集� � ID并记录该流量 釆集器的 IP地址与配置的釆集器 ID之间的对应关系。

步骤 S404、 管理服务器将该流量釆集器的釆集器 ID取出。

步骤 S405、管理服务器获取相应的流量釆集器釆集� � ID后，向发起注 册的流量釆集器反馈携带釆集器 ID的注册确认消息。

进一步地， 管理服务器在接收到流量釆集器周期性上报的 心跳消息时， 更新存储的该流量釆集器的心跳消息的接收时 间； 以及

根据存储的每一个流量釆集器的心跳消息的接 收时间， 判断所述流量 釆集器是否处于正常工作状态， 并查询正常工作状态的流量釆集器的状态 信息。

所述的心跳消息用于确定流量釆集器是否正常 工作的一个指标， 所述 的接收时间可以设置为 10秒或者其他时间。

进一步地， 所述管理服务器查询正常工作状态的流量釆集 器的状态信 息， 具体包括：

所述管理服务器分别向各正常工作状态的流量 釆集器发送状态查询消 息， 所述查询消息携带正常工作状态的流量釆集器 的釆集器标识。

所述管理服务器获得所述流量釆集器在确认接 收到的查询消息中携带 的釆集器标识与本地存储的釆集器标识一致时 ， 上报的状态信息。

进一步地， 所述管理服务器在查询正常工作状态的流量釆 集器的状态 信息之后， 还包括：

将非正常工作状态的流量釆集器所管辖的网络 设备移交给状态信息满 足设定条件的正常工作状态的流量釆集器。

较佳地， 所述的流量釆集器上 其心跳消息的时间不满足设定时间时， 管理服务器确认所述的流量釆集器处于非正常 工作状态， 并根据其他流量 釆集器上报的状态消息确定其他流量釆集器中 釆集压力最小的流量釆集 器， 将所述非正常工作状态的流量釆集器所管辖的 网络设备移交给所述釆 集压力最小的流量釆集器。

所述管理服务器广播消息给所述至少一个流量 釆集器的过程如图 5 所 示， 具体包括以下步骤：

步骤 S501、 管理服务器封装广播的消息对象。

步骤 S502、 管理服务器判断是否发给指定的流量釆集器， 如果该消息 给指定某个流量釆集器发送的， 进入步骤 S503; 如果该消息是发送给所有 的流量釆集器， 进入步骤 S504。

步骤 S503、管理服务器将指定的流量釆集器的釆集� � ID封装到查询消 息对象中， 然后进入步骤 S504。

步骤 S504、 管理服务器将各个流量釆集器的釆集器 ID 的属性置为 NULL, 然后进入步骤 S505。

步骤 S505、 管理服务器将该消息发送给各个流量釆集器。

步骤 S506、 流量釆集器接收到消息后从消息对象中获取釆 集器 ID, 判 断是否为 NULL; 如果不为 NULL进入步骤 S507; 如果为 NULL, 进入步 骤 S508。

步骤 S507、 判断获取到釆集器 ID与本釆集器注册后获取的 ID是否相 同， 如果相同， 进入步骤 S508; 否则进入步骤 S509。

步骤 S508、 流量釆集器接收消息并进行处理， 至此流程结束。

步骤 S509、 流量釆集器放弃接收到的消息， 至此流程结束。

在步骤 S508中所述的处理是指流量釆集器按照管理服� �器广播消息中 携带的指令内容执行流量釆集等操作。

基于流量釆集方法， 本发明还提供了一种流量釆集装置， 如图 6所示， 包括消息主题模块 601、 消息队列模块 602和汇总模块 603; 其中，

所述消息主题模块 601 ,用于向已注册的至少一个流量釆集器广播流� � 查询消息。

所述消息队列模块 602,用于获得所述各流量釆集器根据流量查询� �息 釆集到的网络设备的流量数据。

所述汇总模块 603 ,用于对获得的流量数据进行汇总，并存储汇� �结果。 较佳地， 所述的汇总模块 603还用于生成实时报表、 日报表、 周报表、 月报表等多种格式的流量数据信息报表， 还可以以直方图， 二维、 三维坐 标曲线， 扇形图等形式生成实时网络设备流量数据信息 报表， 以及大规模 网络设备流量数据信息态势分析的汇总结果。

较佳地， 所述的流量釆集装置还包括存储模块， 用于存储汇总模块得 到的汇总结果；

较佳地， 所述的流量釆集装置还包括显示模块， 用于显示存储模块的 汇总结果。

本发明实施例提供的基于上述流量釆集系统及 其方法、 装置， 对于单 个流量釆集器无法完成的大流量数据信息的釆 集和查询工作， 通过多个流 量釆集器分担网络设备大流量数据信息的釆集 和查询工作， 集中管理所有 的流量釆集器， 保证了消息的可靠性， 解决了由单个流量釆集器无法完成 的大流量数据信息的釆集和查询的问题， 保证了电信运营商对网络的有效 控制和用户使用网络的均衡性， 随着汇聚层和核心层网络设备的增加， 通 过增加流量釆集器即可， 无需升级现有的流量釆集器， 增加了系统的可扩 展性。