WO2011153838A1 - 流量采集系统及其方法、装置 - Google Patents
流量采集系统及其方法、装置 Download PDFInfo
- Publication number
- WO2011153838A1 WO2011153838A1 PCT/CN2011/070633 CN2011070633W WO2011153838A1 WO 2011153838 A1 WO2011153838 A1 WO 2011153838A1 CN 2011070633 W CN2011070633 W CN 2011070633W WO 2011153838 A1 WO2011153838 A1 WO 2011153838A1
- Authority
- WO
- WIPO (PCT)
- Prior art keywords
- traffic
- collector
- management server
- message
- traffic collector
- Prior art date
Links
- 238000000034 method Methods 0.000 title claims abstract description 38
- 230000002159 abnormal effect Effects 0.000 claims description 9
- 238000012790 confirmation Methods 0.000 claims description 6
- 230000002776 aggregation Effects 0.000 description 3
- 238000004220 aggregation Methods 0.000 description 3
- 239000012792 core layer Substances 0.000 description 2
- 238000010586 diagram Methods 0.000 description 2
- 239000000284 extract Substances 0.000 description 2
- 239000010410 layer Substances 0.000 description 2
- 230000005540 biological transmission Effects 0.000 description 1
- 239000000203 mixture Substances 0.000 description 1
- 230000003442 weekly effect Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
Definitions
- the present invention relates to the field of network device traffic management, and in particular, to a traffic collection system, a method and a device thereof. Background technique
- IP Internet Protocol
- the embodiments of the present invention provide a traffic collection system, a method, and a device thereof, which are used to solve the problem that a single traffic collector in the prior art cannot complete the collection and query of large traffic data information of the network device.
- the traffic collection system provided by the present invention, the system includes a management server and at least one traffic collector;
- the management server is configured to broadcast a traffic query message to the registered at least one traffic collector, and summarize traffic data of the network device reported by each traffic collector to obtain a summary result;
- the traffic collector is configured to collect traffic data of the network device under the jurisdiction according to the traffic query message broadcasted by the management server, and report the traffic data to the management server.
- the present invention also provides a traffic collection method, the method comprising:
- the management server broadcasts the traffic query message to the registered at least one traffic collector; the management server obtains the traffic data of the governed network device that the traffic collector collects according to the traffic query message;
- the management server summarizes the obtained traffic data and stores the summary results.
- the present invention also provides a traffic collection device, which includes a message subject module, a message queue module, and a summary module;
- the message subject module is configured to broadcast a traffic query message to the registered at least one traffic collector
- the message queue module is configured to obtain traffic data of the network device that is collected by the traffic collector according to the traffic query message;
- the summary module is configured to summarize the obtained traffic data and store the summary result.
- the above-mentioned traffic collection system, method, and apparatus provided by the embodiments of the present invention, for collecting and querying large-flow data information that cannot be completed by a single traffic collector, by at least one
- the traffic collector collects the collection and query of the large-flow data information of the network device, centrally manages all the traffic collectors, ensures the reliability of the message, and solves the large-flow data information that cannot be completed by a single traffic collector.
- the problem of collection and query ensures the effective control of the network by the telecom operator and the balance of the network used by the user. With the increase of the network equipment at the aggregation layer and the core layer, the traffic collector can be added without upgrading. Some traffic collectors increase the scalability of the system.
- FIG. 1 is a block diagram showing the composition of a traffic collection system according to Embodiment 1 of the present invention.
- FIG. 2 is a structural block diagram of a traffic collection system with three traffic collectors as an example in the first embodiment of the present invention
- FIG. 3 is a flowchart of a method for collecting traffic in a second embodiment of the present invention.
- Embodiment 4 is a flow chart of registration of a traffic collector in Embodiment 2 of the present invention.
- FIG. 5 is a flowchart of a management server broadcast message according to Embodiment 2 of the present invention.
- FIG. 6 is a flow collection device according to Embodiment 2 of the present invention. detailed description
- the invention provides a traffic collection system, a method, and a device thereof, which share traffic collection and query work of a network device by using at least one traffic collector, and centrally manage all traffic collectors, thereby solving a single traffic collector cannot Number of completed large flows According to the collection of information and query questions.
- This embodiment first provides a traffic collection system, as shown in FIG. 1, including a management server 100 and at least one traffic collector 200 , wherein: the management server 100 is configured to register at least one traffic collector The broadcast traffic query message is summarized, and the traffic data of the network device reported by each traffic collector is summarized to obtain a summary result.
- the traffic collector 200 is configured to collect traffic data of the network device under the jurisdiction according to the traffic query message broadcasted by the management server, and report the traffic data to the management server.
- the traffic collector 200 is further configured to periodically report a heartbeat message to the management server in a normal working state.
- the management server 100 is further configured to: when receiving the heartbeat message reported by the traffic collector, update the received time of the stored heartbeat message of the traffic collector, according to the received heartbeat message of each traffic collector. The time is judged whether the traffic collector is in a normal working state, and the status information of the traffic collector in the normal working state is queried.
- the management server 100 is configured to send a status query message to the traffic collector of each normal working state, where the collector ID of the traffic collector of the normal working state is carried.
- the traffic collector 200 is configured to receive a status query message sent by the management server, and confirm that the collector ID carried in the status query message is consistent with the locally stored collector ID, and query the message according to the status.
- the status information of the traffic collector is queried and reported to the management server.
- the management server 100 is further configured to hand over the network device under the jurisdiction of the traffic collector in the abnormal working state to the traffic collector in which the state information meets the normal working state of the set condition.
- the management server 100 is configured to broadcast a traffic query message to the registered traffic collectors (200A, 200B, and 200C), and summarize the traffic data of the network devices reported by each traffic collector to obtain a summary result.
- the traffic collectors (200A, 200B, and 200C) are configured to receive a traffic query message broadcast by the management server 100, and confirm that the message object of the traffic query message includes the collector ID of the traffic collector, according to the The traffic query message collects the traffic data of the network device under the jurisdiction and reports it to the management server 100.
- the management server 100 confirms.
- the traffic collectors (200A and 200B) are in a normal working state, and the traffic collector 200C is in an abnormal working state.
- the status message includes a server CPU usage message, a memory usage message, and a disk usage percentage message.
- the management server 100 is further configured to use a traffic collector of an abnormal working state.
- the network device under the jurisdiction of 200C is handed over to the traffic collector 200A or the traffic collector 200B whose status information satisfies the normal operating state of the set condition.
- the CPU memory usage of the traffic collector 200B in the status message is lower than that of the traffic collector 200A, it indicates that the collection pressure of the traffic collector 200B is small, that is, the traffic collector 200C of the abnormal working state is The governed network device is handed over to the traffic collector 200B, from The dynamic collection of the traffic collector is implemented.
- the management server 100 is further configured to open the collector switch of the traffic collector by sending a collection open message to the at least one traffic collector before broadcasting the traffic query message.
- the traffic collector is further configured to send a registration message to the management server according to the configured IP address of the management server each time it is started;
- the management server is further configured to extract, from the received registration message, an IP address of the traffic collector that initiates registration, and find whether the collector ID corresponding to the IP address of the traffic collector is recorded locally, if not, Configuring a collector ID for the traffic collector and recording a correspondence between the IP address of the traffic collector and the configured collector ID, and if so, extracting the collector ID of the traffic collector; And returning a registration confirmation message carrying the collector ID to the traffic collector that initiated the registration.
- £ is provided with three traffic collectors, that is, the traffic collectors (200A, 200B, and 200C) are also used to send a registration message to the management server 100 according to the configured IP address of the management server 100 each time it is started. .
- the method for obtaining the collector ID by the traffic collectors (200A, 200B, and 200C) is:
- the management server 100 is further configured to extract, from the received registration message, the traffic collectors (200A, 200B, and 200C) that initiate registration.
- IP address find whether the local collector ID of the IP address of the traffic collector (200A, 200B, and 200C) is recorded locally. If the collector ID of the traffic collector 200A is not found, it is the traffic collector 200A. Configure the collector ID and record the correspondence between the IP address of the traffic collector and the configured collector ID. If the collector ID of the traffic collectors (200B and 200C) is found, the traffic collector is set.
- the collector IDs of (200B and 200C) are fetched; and the registration confirmation message carrying the collector ID is fed back to the traffic collectors (200A, 200B, and 200C) that initiated the registration.
- Embodiment 2 Based on the same technical concept, this embodiment provides a traffic collection method, as shown in FIG. 3, including the following steps:
- Step S301 The management server broadcasts a traffic query message to the registered at least one traffic collector.
- Step S302 The management server obtains traffic data of the governed network device that is collected by the traffic collector according to the traffic query message.
- Step S303 The management server summarizes the obtained traffic data, and stores the summary result. Further, before the broadcast server queries the traffic query message, the management server further includes: opening the aggregation switch of the traffic collector by broadcasting the set open message to the at least one traffic collector.
- the process of registering the traffic collector with the management server includes: the management server extracting an IP address of the traffic collector from the registration message sent by the traffic collector.
- the management server searches whether the local collector ID corresponding to the IP address of the traffic collector is recorded locally, and if not, configures the collector ID for the traffic collector and records the IP address and configuration of the traffic collector. Corresponding relationship between the collector IDs, if any, fetching the collector ID of the traffic collector;
- the management server feeds back to the originating traffic collector a registration confirmation message carrying the collector ID.
- Step S401 The traffic collector sends a registration message to the management server according to the configured IP address of the management server each time it starts.
- Step S402 The management server extracts the IP address of the traffic collector that initiates the registration from the received registration message, and searches whether the collector ID corresponding to the IP address of the traffic collector is recorded in the management server. If not, the process proceeds to the step. S403; if yes, go to step S404. Step S403: The management server configures the collector ID for the traffic collector and records the correspondence between the IP address of the traffic collector and the configured collector ID.
- Step S404 The management server extracts the collector ID of the traffic collector.
- Step S405 After obtaining the corresponding traffic collector identifier, the management server feeds back the registration confirmation message carrying the collector ID to the originating traffic collector.
- the management server updates the stored reception time of the heartbeat message of the traffic collector when receiving the heartbeat message periodically reported by the traffic collector;
- the traffic collector According to the received time of the heartbeat message of each of the stored traffic collectors, it is determined whether the traffic collector is in a normal working state, and the status information of the traffic collector in the normal working state is queried.
- the heartbeat message is used to determine an indicator of whether the traffic collector is working normally, and the receiving time can be set to 10 seconds or other time.
- the management server queries the status information of the traffic collector in a normal working state, and specifically includes:
- the management server sends a status query message to each of the normal working state traffic collectors, where the query message carries the collector identifier of the traffic collector in the normal working state.
- the management server obtains the status information reported by the traffic collector when it confirms that the collector identifier carried in the received query message is consistent with the locally stored collector identifier.
- the management server further includes:
- the network device under the jurisdiction of the traffic collector of the abnormal working state is handed over to the traffic collector whose state information satisfies the normal working state of the set condition.
- the management server confirms that the traffic collector is in an abnormal working state, and according to the status reported by the other traffic collector The message determines the traffic set with the lowest collection pressure in other traffic collectors. And handing over the network device under the jurisdiction of the traffic collector of the abnormal working state to the traffic collector with the lowest collection pressure.
- the process of the management server broadcasting the message to the at least one traffic collector is as shown in FIG. 5, and specifically includes the following steps:
- Step S501 The management server encapsulates the broadcasted message object.
- Step S502 The management server determines whether it is sent to the specified traffic collector, if the message is sent to the specified traffic collector, the process proceeds to step S503; if the message is sent to all the traffic collectors, the process proceeds to step S504. .
- Step S503 The management server encapsulates the collector ID of the specified traffic collector into the query message object, and then proceeds to step S504.
- Step S504 The management server sets the attribute of the collector ID of each traffic collector to NULL, and then proceeds to step S505.
- Step S505 The management server sends the message to each traffic collector.
- Step S506 After receiving the message, the traffic collector obtains the collector ID from the message object, and determines whether it is NULL; if not NULL, the process proceeds to step S507; if it is NULL, the process proceeds to step S508.
- Step S507 Determine whether the acquired ID of the collector is the same as the ID obtained after the registration of the collector, and if yes, go to step S508; otherwise, go to step S509.
- Step S508 The traffic collector receives the message and processes the process, and the process ends.
- Step S509 The traffic collector abandons the received message, and the process ends.
- step S508 refers to an operation performed by the traffic collector in accordance with the content of the instruction carried in the management server broadcast message.
- the present invention further provides a traffic collection device, as shown in FIG. 6, including a message subject module 601, a message queue module 602, and a summary module 603;
- the message subject module 601 is configured to broadcast traffic to the registered at least one traffic collector. Query the message.
- the message queue module 602 is configured to obtain traffic data of the network device that is collected by the traffic collector according to the traffic query message.
- the summary module 603 is configured to summarize the obtained traffic data and store the summary result.
- the summary module 603 is further configured to generate a flow data information report in a plurality of formats, such as a real-time report, a daily report, a weekly report, and a monthly report, and may also be a histogram, a two-dimensional, a three-dimensional coordinate curve, and a pie chart.
- the form generates real-time network device traffic data information reports, and the summary results of large-scale network device traffic data information situation analysis.
- the traffic collection device further includes a storage module, configured to store a summary result obtained by the summary module;
- the traffic collection device further includes a display module, configured to display a summary result of the storage module.
- the method and the device thereof the collection and query work of the large-flow data information that cannot be completed by a single traffic collector, and the large traffic of the network device is shared by multiple traffic collectors.
- Collecting and querying data information centrally managing all traffic collectors, ensuring the reliability of messages, and solving the problem of collecting and querying large-volume data information that cannot be completed by a single traffic collector.
- the traffic collector With the increase of the network equipment at the aggregation layer and the core layer, the traffic collector can be added, and the existing traffic collector can be upgraded without adding an existing system. Scalability.
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Description
流量采集系统及其方法、 装置 技术领域
本发明涉及网络设备流量管理领域， 尤其涉及一种流量釆集系统及其 方法、 装置。 背景技术
随着因特网的高速发展， 网际协议（IP, Internet Protocol ) 网络已经成 为人们日常工作和生活中必不可少的工具， 并且在 IP网络中进行点到点的 数据传输更加普遍， 存在很少的用户占用大量的设备带宽， 从而导致了电 信运营商的网络设备投入远远满足不了用户对带宽的需求。 因此， 电信运 营商希望增加网络的可视性， 了解网络的实际占用情况， 进而可以对网络 进行有效的控制， 保障用户使用的均衡性， 并且可以推出差异化产品满足 不同用户的需求。
为了增加网络的可视性， 了解网络的实际占用情况， 并满足不同用户 的需求， 需要釆集网络设备的流量数据并进行分析控制， 一般通过单个流 量釆集器对网络中的所有网络设备（如交换机和路由器等） 的流量数据进 行釆集， 在城域网或大型企业的网络环境中， 用户 IP网络设备的流量数据 信息非常大， 使得流量釆集器的釆集和查询压力巨大， 导致单个流量釆集 器无法完成对所有网络设备（如多个路由器或者交换机） 的大流量数据信 息的釆集和查询， 甚至提高单个流量釆集器的硬件性能都无法满足大流量 数据信息的釆集和查询， 可见， 亟待提供一种可以完成对网络设备的大流 量数据信息的釆集和查询的解决方案。
发明内容
本发明实施例提供一种流量釆集系统及其方法、 装置， 用以解决现有 技术中存在的单个流量釆集器无法完成对网络设备大流量数据信息的釆集 和查询的问题。
本发明所提供的流量釆集系统， 该系统包括管理服务器和至少一个流 量釆集器； 其中，
所述管理服务器， 用于向已注册的至少一个流量釆集器广播流量查询 消息， 并对各流量釆集器上报的网络设备的流量数据进行汇总， 得到汇总 结果；
所述流量釆集器， 用于根据管理服务器广播的所述流量查询消息， 釆 集所管辖网络设备的流量数据并上报给所述管理服务器。
相应地， 本发明还提供了一种流量釆集方法， 该方法包括：
管理服务器向已注册的至少一个流量釆集器广播流量查询消息； 管理服务器获得所述各流量釆集器根据所述流量查询消息釆集到的所 管辖网络设备的流量数据；
管理服务器对获得的流量数据进行汇总， 并存储汇总结果。
基于流量釆集方法， 本发明还提供了一种流量釆集装置， 该装置包括 消息主题模块、 消息队列模块和汇总模块； 其中，
所述消息主题模块， 用于向已注册的至少一个流量釆集器广播流量查 询消息；
所述消息队列模块， 用于获得所述各流量釆集器根据所述流量查询消 息釆集到的网络设备的流量数据；
所述汇总模块， 用于对获得的流量数据进行汇总， 并存储汇总结果。 本发明实施例提供的基于上述流量釆集系统及其方法、 装置， 对于单 个流量釆集器无法完成的大流量数据信息的釆集和查询工作， 通过至少一
个流量釆集器分担网络设备大流量数据信息的釆集和查询工作， 集中管理 所有的流量釆集器， 保证了消息的可靠性， 解决了由单个流量釆集器无法 完成的大流量数据信息的釆集和查询的问题， 保证了电信运营商对网络的 有效控制和用户使用网络的均衡性， 随着汇聚层和核心层网络设备的增加， 通过增加流量釆集器即可， 无需升级现有的流量釆集器， 增加了系统的可 扩展性。
本发明的其它特征和优点将在随后的说明书中阐述， 并且， 部分地从 说明书中变得显而易见， 或者通过实施本发明而了解。 本发明的目的和其 他优点可通过在所写的说明书、 权利要求书、 以及附图中所特别指出的结 构来实现和获得。 附图说明
图 1为本发明实施例一中流量釆集系统的组成框图；
图 2为本发明实施例一中以 3个流量釆集器为例的流量釆集系统的组 成框图；
图 3为本发明实施例二中流量釆集方法流程图；
图 4为本发明实施例二中流量釆集器的注册流程图；
图 5为本发明实施例二中管理服务器广播消息的流程图；
图 6为本发明实施例二中流量釆集装置。 具体实施方式
本发明实施例为了解决现有技术中用户占用网络资源不均衡， 而单个 流量釆集器无法满足网络中大流量数据信息的釆集和查询工作， 导致电信 运营商不能有效控制网络资源的问题， 提供了一种流量釆集系统及其方法、 装置， 通过至少一个流量釆集器分担网络设备的流量釆集和查询工作， 并 集中管理所有的流量釆集器， 解决了单个流量釆集器无法完成的大流量数
据信息的釆集和查询的问题。
以下结合说明书附图对本发明的优选实施例进行说明， 应当理解， 此 处所描述的优选实施例仅用于说明和解释本发明， 并不用于限定本发明，
合。
实施例一
本实施例首先提供了流量釆集系统， 如图 1所示， 包括管理服务器 100 和至少一个流量釆集器 200, 其中： 所述管理服务器 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还用于生成实时报表、 日报表、 周报表、 月报表等多种格式的流量数据信息报表， 还可以以直方图， 二维、 三维坐 标曲线， 扇形图等形式生成实时网络设备流量数据信息报表， 以及大规模 网络设备流量数据信息态势分析的汇总结果。
较佳地， 所述的流量釆集装置还包括存储模块， 用于存储汇总模块得 到的汇总结果；
较佳地， 所述的流量釆集装置还包括显示模块， 用于显示存储模块的 汇总结果。
本发明实施例提供的基于上述流量釆集系统及其方法、 装置， 对于单 个流量釆集器无法完成的大流量数据信息的釆集和查询工作， 通过多个流 量釆集器分担网络设备大流量数据信息的釆集和查询工作， 集中管理所有 的流量釆集器， 保证了消息的可靠性， 解决了由单个流量釆集器无法完成 的大流量数据信息的釆集和查询的问题， 保证了电信运营商对网络的有效 控制和用户使用网络的均衡性， 随着汇聚层和核心层网络设备的增加， 通 过增加流量釆集器即可， 无需升级现有的流量釆集器， 增加了系统的可扩 展性。
Claims
1、 一种流量釆集系统， 其特征在于， 该系统包括管理服务器和至少一 个流量釆集器； 其中，
所述管理服务器， 用于向已注册的至少一个流量釆集器广播流量查询 消息， 并对各流量釆集器上报的网络设备的流量数据进行汇总， 得到汇总 结果；
所述流量釆集器， 用于根据管理服务器广播的所述流量查询消息， 釆 集所管辖网络设备的流量数据并上报给所述管理服务器。
2、 根据权利要求 1所述的流量釆集系统， 其特征在于，
所述流量釆集器， 还用于在每次启动时根据配置的管理服务器的 IP地 址， 向管理服务器发送注册消息；
所述管理服务器， 还用于从接收到的所述注册消息中提取发起注册的 流量釆集器的 IP地址，查找本地是否记录有所述流量釆集器的 IP地址对应 的釆集器 ID , 如果没有， 为所述流量釆集器配置釆集器 ID , 并记录所述流 量釆集器的 IP地址与配置的釆集器 ID之间的对应关系； 如果有， 将所述 流量釆集器的釆集器 ID取出；向发起注册的流量釆集器反馈携带釆集器 ID 的注册确认消息。
3、 根据权利要求 1所述的流量釆集系统， 其特征在于，
所述流量釆集器， 还用于在正常工作状态下， 周期性向所述管理服务 器上报心跳消息；
所述管理服务器， 还用于在接收到流量釆集器上报的所述心跳消息时 更新存储的所述流量釆集器的心跳消息的接收时间， 根据存储的每一个流 量釆集器的心跳消息的接收时间判断所述流量釆集器是否处于正常工作状 态， 并查询正常工作状态的流量釆集器的状态信息。
4、 根据权利要求 3所述的流量釆集系统， 其特征在于， 所述管理服务器， 还用于分别向各正常工作状态的流量釆集器发送状 态查询消息， 其中携带所述正常工作状态的流量釆集器的釆集器 ID;
所述流量釆集器， 还用于接收管理服务器发送的所述状态查询消息， 确认所述状态查询消息中携带的釆集器 ID与本地存储的釆集器 ID相一致 时， 根据所述状态查询消息查询本流量釆集器的状态信息并上报给所述管 理服务器。
5、 根据权利要求 3或 4所述的流量釆集系统， 其特征在于，
所述管理服务器， 还用于将非正常工作状态的流量釆集器所管辖的网 络设备移交给状态信息满足设定条件的正常工作状态的流量釆集器。
6、 根据权利要求 1所述的流量釆集系统， 其特征在于， 所述管理服务 器， 还用于在广播所述流量查询消息之前， 通过向所述至少一个流量釆集 器发送釆集打开消息， 将流量釆集器的釆集开关打开。
7、 一种流量釆集方法， 其特征在于， 该方法包括：
管理服务器向已注册的至少一个流量釆集器广播流量查询消息； 管理服务器获得各流量釆集器根据所述流量查询消息釆集到的所管辖 网络设备的流量数据；
管理服务器对获得的流量数据进行汇总， 并存储汇总结果。
8、 根据权利要求 7所述的方法， 其特征在于， 该方法还包括： 流量釆 集器向管理服务器进行注册； 流量釆集器向管理服务器进行所述注册包括： 管理服务器从流量釆集器发送的注册消息中提取流量釆集器的 IP 地 址；
管理服务器查找本地是否记录有所述流量釆集器的 IP地址对应的釆集 器 ID, 如果没有， 为所述流量釆集器配置釆集器 ID , 并记录所述流量釆集 器的 IP地址与配置的釆集器 ID之间的对应关系； 如果有， 将所述流量釆 集器的釆集器 ID取出； 管理服务器向发起注册的流量釆集器反馈携带釆集 器 ID的注册确认消息。
9、 根据权利要求 7所述的方法， 其特征在于， 该方法还包括： 管理服务器在接收到流量釆集器周期性上报的心跳消息时， 更新存储 的所述流量釆集器的心跳消息的接收时间；
根据存储的每一个流量釆集器的心跳消息的接收时间， 判断所述流量 釆集器是否处于正常工作状态， 并查询正常工作状态的流量釆集器的状态 信息。
10、 根据权利要求 9所述的方法， 其特征在于， 所述管理服务器查询 所述正常工作状态的流量釆集器的状态信息包括：
所述管理服务器分别向各正常工作状态的流量釆集器发送状态查询消 息， 所述查询消息携带正常工作状态的流量釆集器的釆集器标识；
所述管理服务器获得所述流量釆集器在确认接收到的查询消息中， 携 带的釆集器标识与本地存储的釆集器标识一致时上>¾的状态信息。
11、 根据权利要求 9或 10所述的法， 其特征在于， 所述管理服务器在 查询正常工作状态的流量釆集器的状态信息之后， 该方法还包括：
将非正常工作状态的流量釆集器所管辖的网络设备移交给状态信息满 足设定条件的正常工作状态的流量釆集器。
12、 根据权利要求 7所述的方法， 其特征在于， 所述管理服务器在广 播流量查询消息之前， 该方法还包括：
通过向所述至少一个流量釆集器广播釆集打开消息， 将流量釆集器的 釆集开关打开。
13、 一种流量釆集装置， 其特征在于， 该装置包括消息主题模块、 消 息队列模块和汇总模块； 其中，
所述消息主题模块， 用于向已注册的至少一个流量釆集器广播流量查 询消息； 所述消息队列模块， 用于获得所述各流量釆集器根据所述流量查询消 息釆集到的网络设备的流量数据；
所述汇总模块， 用于对获得的流量数据进行汇总， 并存储汇总结果。
Applications Claiming Priority (2)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201010194818.3A CN101854305B (zh) | 2010-06-07 | 2010-06-07 | 流量采集系统及其方法、装置 |
| CN201010194818.3 | 2010-06-07 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| WO2011153838A1 true WO2011153838A1 (zh) | 2011-12-15 |
Family
ID=42805581
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| PCT/CN2011/070633 WO2011153838A1 (zh) | 2010-06-07 | 2011-01-26 | 流量采集系统及其方法、装置 |
Country Status (2)
| Country | Link |
|---|---|
| CN (1) | CN101854305B (zh) |
| WO (1) | WO2011153838A1 (zh) |
Families Citing this family (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101854305B (zh) * | 2010-06-07 | 2015-12-16 | 中兴通讯股份有限公司 | 流量采集系统及其方法、装置 |
| CN105099742B (zh) * | 2014-05-20 | 2020-01-14 | 中兴通讯股份有限公司 | 一种采集数据的方法、装置、系统及终端 |
| CN106559237A (zh) * | 2015-09-28 | 2017-04-05 | 中兴通讯股份有限公司 | 一种获取流量数据的方法及装置 |
| CN106209495A (zh) * | 2016-06-24 | 2016-12-07 | 浪潮(北京)电子信息产业有限公司 | 一种云监控系统的报表生成方法及装置 |
| CN107888456B (zh) * | 2017-12-04 | 2019-05-10 | 北京百度网讯科技有限公司 | 用于监测端口数据量的方法及装置 |
| CN111292518A (zh) * | 2020-02-17 | 2020-06-16 | 上海威派格智慧水务股份有限公司 | 一种dtu数据采集器的管理系统 |
| CN111487920A (zh) * | 2020-05-26 | 2020-08-04 | 上海威派格智慧水务股份有限公司 | 一种数据采集处理系统 |
| CN115604137A (zh) * | 2021-06-28 | 2023-01-13 | 深信服科技股份有限公司（Cn） | 一种流量处理方法、装置及电子设备和存储介质 |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1414740A (zh) * | 2002-03-28 | 2003-04-30 | 华为技术有限公司 | 一种局域网交换设备的集中管理方法 |
| US20050249125A1 (en) * | 2002-12-13 | 2005-11-10 | Yoon Seung H | Traffic measurement system and traffic analysis method thereof |
| US20080114873A1 (en) * | 2006-11-10 | 2008-05-15 | Novell, Inc. | Event source management using a metadata-driven framework |
| CN101369916A (zh) * | 2007-08-15 | 2009-02-18 | 中兴通讯股份有限公司 | 性能指标的采集方法 |
| CN101854305A (zh) * | 2010-06-07 | 2010-10-06 | 中兴通讯股份有限公司 | 流量采集系统及其方法、装置 |
-
2010
- 2010-06-07 CN CN201010194818.3A patent/CN101854305B/zh not_active Expired - Fee Related
-
2011
- 2011-01-26 WO PCT/CN2011/070633 patent/WO2011153838A1/zh active Application Filing
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1414740A (zh) * | 2002-03-28 | 2003-04-30 | 华为技术有限公司 | 一种局域网交换设备的集中管理方法 |
| US20050249125A1 (en) * | 2002-12-13 | 2005-11-10 | Yoon Seung H | Traffic measurement system and traffic analysis method thereof |
| US20080114873A1 (en) * | 2006-11-10 | 2008-05-15 | Novell, Inc. | Event source management using a metadata-driven framework |
| CN101369916A (zh) * | 2007-08-15 | 2009-02-18 | 中兴通讯股份有限公司 | 性能指标的采集方法 |
| CN101854305A (zh) * | 2010-06-07 | 2010-10-06 | 中兴通讯股份有限公司 | 流量采集系统及其方法、装置 |
Also Published As
| Publication number | Publication date |
|---|---|
| CN101854305A (zh) | 2010-10-06 |
| CN101854305B (zh) | 2015-12-16 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| WO2011153838A1 (zh) | 流量采集系统及其方法、装置 | |
| US12149426B1 (en) | Generating alarms in a wireless network | |
| CN113796108B (zh) | 将用户平面功能映射到用户设备 | |
| US9571358B2 (en) | Service level view of audiovisual conference systems | |
| US9306798B2 (en) | Aggregate monitoring of internet protocol television (IPTV) channel activity across user-based groups of private computer networks | |
| JP5631330B2 (ja) | 大規模通信ネットワークシステムにおいて障害情報を配信する方法及び装置 | |
| CN102064975B (zh) | 网络设备监管方法及系统 | |
| JP2003533925A (ja) | ネットワーク用のセキュリティ・カメラ | |
| WO2007082465A1 (fr) | Terminal, système et procédé de statistiques des débits sur la base des services utilisateurs | |
| WO2014056344A1 (zh) | 监控方法及装置 | |
| WO2009089742A1 (en) | Distributed network management collection system, realization method and corresponding device | |
| EP2590363B1 (en) | Method and system for collecting performance statistics data | |
| CN102710965B (zh) | 视频监控数据获取方法和系统，以及承载专用网络 | |
| WO2009071025A1 (fr) | Procédé d'interrogation, système, station de gestion de réseau et dispositif géré | |
| WO2015085748A1 (zh) | 交换装置及丢包方法 | |
| WO2014008694A1 (zh) | 一种实现ps域分布式架构的信令监测装置 | |
| WO2014056345A1 (zh) | 监控任务的管理方法及装置 | |
| WO2012171168A1 (zh) | 监控室内覆盖网络的方法、设备及系统 | |
| JP2000134203A (ja) | ネットワーク管理システム及びその管理方法 | |
| CN106936900B (zh) | 集群节点统计方法及装置 | |
| TWI646803B (zh) | 異質軟體定義網路控制器及其管理裝置和方法 | |
| JP6035566B2 (ja) | 遠隔監視システム及び遠隔監視方法 | |
| WO2010121471A1 (zh) | 一种自动设备配置方法及业务运营支撑系统 | |
| WO2011017947A1 (zh) | 性能管理实现方法和网管系统 | |
| JP2007251346A (ja) | イベント通知の同報配信をなすコールセンタシステム |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| 121 | Ep: the epo has been informed by wipo that ep was designated in this application |
Ref document number: 11791830 Country of ref document: EP Kind code of ref document: A1 |
|
| NENP | Non-entry into the national phase |
Ref country code: DE |
|
| 122 | Ep: pct application non-entry in european phase |
Ref document number: 11791830 Country of ref document: EP Kind code of ref document: A1 |