CN107483297B - 对嵌入式设备上所承载业务质量的主动监测系统及方法 - Google Patents
对嵌入式设备上所承载业务质量的主动监测系统及方法 Download PDFInfo
- Publication number
- CN107483297B CN107483297B CN201710943496.XA CN201710943496A CN107483297B CN 107483297 B CN107483297 B CN 107483297B CN 201710943496 A CN201710943496 A CN 201710943496A CN 107483297 B CN107483297 B CN 107483297B
- Authority
- CN
- China
- Prior art keywords
- probe
- monitoring
- access
- subsystem
- management module
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000012544 monitoring process Methods 0.000 title claims abstract description 287
- 238000000034 method Methods 0.000 title claims description 39
- 239000000523 sample Substances 0.000 claims abstract description 274
- 238000004458 analytical method Methods 0.000 claims abstract description 35
- 238000007619 statistical method Methods 0.000 claims abstract description 16
- 238000007726 management method Methods 0.000 claims description 169
- 230000006854 communication Effects 0.000 claims description 84
- 238000004891 communication Methods 0.000 claims description 81
- 230000001360 synchronised effect Effects 0.000 claims description 30
- 238000012360 testing method Methods 0.000 claims description 20
- 230000008569 process Effects 0.000 claims description 17
- 238000013500 data storage Methods 0.000 claims description 15
- 238000012545 processing Methods 0.000 claims description 14
- 238000012795 verification Methods 0.000 claims description 14
- 230000002776 aggregation Effects 0.000 claims description 9
- 238000004220 aggregation Methods 0.000 claims description 9
- 238000006243 chemical reaction Methods 0.000 claims description 9
- 230000004044 response Effects 0.000 claims description 7
- 238000004364 calculation method Methods 0.000 claims description 6
- 238000013507 mapping Methods 0.000 claims description 6
- 238000009434 installation Methods 0.000 claims description 5
- 230000000737 periodic effect Effects 0.000 claims description 4
- 230000010354 integration Effects 0.000 claims description 3
- 230000002085 persistent effect Effects 0.000 claims description 3
- 238000003860 storage Methods 0.000 claims description 3
- 230000005540 biological transmission Effects 0.000 abstract description 5
- 230000000694 effects Effects 0.000 abstract description 3
- 230000008447 perception Effects 0.000 abstract description 2
- 238000002513 implantation Methods 0.000 abstract 1
- 230000006870 function Effects 0.000 description 12
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 238000009826 distribution Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000005457 optimization Methods 0.000 description 1
- 238000004088 simulation Methods 0.000 description 1
- 239000000344 soap Substances 0.000 description 1
- 238000012546 transfer Methods 0.000 description 1
Images
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
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
- H04L43/0805—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
- H04L43/0817—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking functioning
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/50—Network service management, e.g. ensuring proper service fulfilment according to agreements
- H04L41/5003—Managing SLA; Interaction between SLA and QoS
- H04L41/5009—Determining service level performance parameters or violations of service level contracts, e.g. violations of agreed response time or mean time between failures [MTBF]
-
- 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
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
-
- 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
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
- H04L43/0805—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
- H04L43/0811—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking connectivity
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02P—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN THE PRODUCTION OR PROCESSING OF GOODS
- Y02P90/00—Enabling technologies with a potential contribution to greenhouse gas [GHG] emissions mitigation
- Y02P90/02—Total factory control, e.g. smart factories, flexible manufacturing systems [FMS] or integrated manufacturing systems [IMS]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Environmental & Geological Engineering (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明提出了一种对嵌入式设备上所承载业务质量的主动监测系统，包括：探针子系统、探针接入子系统、数据汇聚子系统、管理与分析平台；本发明还提出了一种对嵌入式设备上所承载业务质量的主动监测系统，包括：植入探针子系统；完成探针注册；进行监测管理；进行数据收集存储；进行统计分析。本发明不仅支持传统的网络节点可达性监测，更支持网络内容质量监测。前者提供的网络可达性性能监测，无论是新建的网络和已成熟的网络而言，这都可以提供精细的网络基础质量分析；后者可提供模拟用户角度得出的内容访问质量监测，对于网络运营者分析其用户使用网络时的质量感知情况、内容提供商的业务访问情况以及其网络自身的传输能力等都有极大作用。
Description
技术领域
本发明涉及监测技术领域，特别涉及一种对嵌入式设备上所承载业务质量的主动监测系统及方法。
背景技术
目前嵌入式设备上的主动监测系统存在以下缺点：1)监测目标单一；仅支持监测网络节点间的可达性。对于已经建设成熟的网络而言，网络节点间的可达性出现质量问题的概率非常低，因此简单的可达性监测通常无法发现质量问题。相反，网络内容质量监测需求更为迫切，即对通过网络访问的数据内容的传输性能监测。2)监测手段少且作用有限；仅支持通过PING和TRACEROUTE等工具进行节点间可达性监测，对于网络内容质量监测尚无高效的方法。虽然有众多支持HTTP、FTP、TCP等协议的开源或商业网络内容质量监测工具，但这些工具对于资源有限的嵌入式设备而言过于重量级，设备无法提供其运行所需的内存、CPU等计算资源。简单的可达性监测结果并不能发现网络内容质量问题，从而无法为网络服务提供者提供其用户对网络使用体验情况，进而也不法提供网络质量优化意见和建议。3)监测系统通信协议开销大且部署方法受限；目前嵌入式设备上的监测系统很多是基于传统的TR069协议族，采用XML+SOAP+HTTP的通信协议组合方式实现。在传输过程中，数据的协议开销巨大。为传输一个字节有效数据量，需要传输的额外的协议规定的数据量可能是有效字数据量的数倍。同时，由于TR069协议通常只在网络提供者的网管网内使用，所有在系统部署时无法灵活地部署到其他业务网络以支持更多的监测手段和支持监测更多的网络节点。
发明内容
本发明的目的旨在至少解决所述技术缺陷之一。
为此，本发明的目的在于提出一种能够同时监测网络节点可达性和内容质量的对嵌入式设备上所承载业务质量的主动监测系统及方法。
为了实现上述目的，本发明提供一种对嵌入式设备上所承载业务质量的主动监测系统，包括：探针子系统、探针接入子系统、数据汇聚子系统、管理与分析平台；
所述探针子系统包括探针管理模块、监测管理模块、探针TR069通信模块；
探针管理模块用于负责探针的安装、升级，并收集探针的运行状态和系统资源使用情况；
监测管理模块用于接收、创建、执行监测任务并上报监测结果；
探针TR069通信模块用于实现与探针接入子系统直接通信，完成探针配置信息、监测任务信息的接收，以及探针状态信息和监测结果信息的上报；
所述探针接入子系统包括接入同步管理模块、负载均衡模块、接入TR069通信模块、接入管理模块；
接入同步管理模块用于实现探针接入子系统向管理与分析平台注册认证、从管理与分析平台获取最新的需要下发给探针的监测任务信息以及向管理与分析平台同步；
负载均衡模块用于对接探针子系统，并将高并发量的探针连接请求的负载分发至多个服务端通信模块；
接入TR069通信模块用于简化的TR069协议，解析消息，校验消息格式的合法性和数据的有效性，并将消息所负载的业务数据提交给接入管理模块；所述接入TR069通信模块与接入管理模块为一对一绑定关系；
接入管理模块用于接收并处理探针发起的注册、状态及监测结果请求消息、根据不同的消息类型，完成对探针的注册鉴权过程、状态数据提交至数据汇聚子系统或监测结果提交至数据汇聚子系统；
数据汇聚子系统包括数据转换模块和数据存储模块；
数据转换模块负责接收并提取探针接入子系统上报的监测结果和探针状态数据，并按照一定的格式进行数据转换，将转换后的数据以消息形式发送至数据存储模块；
数据存储模块用于将逐条的消息缓存，并在缓存大小超过一定阈值或一定时间周期到达时，将缓存中的内容存储至持久化的系统；
管理与分析平台包括平台同步管理模块、监测目标管理模块、监测探针管理模块、监测任务管理模块和统计分析模块；
监测探针管理模块用于管理监测探针信息；
监测目标管理模块用于创建并维护监测目标节点；
监测任务管理模块用于创建并维护监测任务；
平台同步管理模块将配置信息下发至接入子系统，由接入子系统的接入同步管理模块将其存储至本地数据库；
统计分析模块用于从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
进一步的，所述探针子系统的监测管理模块包含调度器、监测任务管理器；
所述监测任务管理器用于创建、删除监测任务、提交监测结果给探针TR069通信模块；
所述调度器用于依据不同的调度策略创建任务执行计划，并依据计划，控制任务的一次性运行或周期性运行。
进一步的，所述探针子系统的监测管理模块创建执行监测任务时，利用监测会话保存并跟踪当前监测任务中的一个监测目标相关的信息；监测会话创建后，即开始运行监测脚本；监测脚本由会话控制其生命周期：加载配置数据、开始执行、监控执行状态、停止执行、上报结果。
进一步的，所述接入TR069通信模块在远程调用InformResponse函数后，检查是否有探针相关的升级任务、参数配置任务或监测任务需要下发到该探针；如无，则发送空请求给探针，以告诉探针接入子系统已经没有事务需要探针完成，并请求探针断开连接以释放服务器资源；如存在，则发送相应消息内容给探针。
本发明还提供一种对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：包括以下步骤：
步骤S1，植入探针子系统；
将探针接入子系统的地址固化在探针子系统的探针中，然后将探针内置在嵌入式设备中，并配置在设备启动时，自动运行探针子系统，使探针子系统整合入原嵌入式设备系统；
步骤S2，完成探针注册；
探针子系统中的探针管理模块通过固化的地址连接探针接入子系统；
由接入TR069通信模块远程调用函数，调用请求符合规定后，由接入管理模块获取探针子系统传入的标识和安全信息，并校验探针合法性安全性，校验合格后，建立探针子系统与探针接入子系统通信，并将探针的注册信息提交给同步管理模块，验证注册信息合格后，由接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块，平台同步管理模块收到上传的注册信息后，将数据存储至数据库中，以允许管理与分析平台对探针信息进行监测管理；
步骤S3，进行监测管理；
监测目标管理模块创建并维护监测目标节点，监测任务管理模块创建并维护监测任务，创建并设置好配置监测任务后，通过平台同步管理模块将配置信息下发至探针接入子系统，由探针接入子系统的接入同步管理模块将其存储至本地数据库中；同时由接入TR069通信模块检查是否有探针相关的升级任务、参数配置任务或监测任务，并将任务下发至探针管理模块，监测管理模块依据监测任务信息创建监测任务执行任务，并在满足调度条件时，执行这些任务，并由探针TR069通信模块将监试结果上传至探针接入子系统；
步骤S4，进行数据收集存储；
探针接入子系统的接入管理模块收到监试结果后，将其直接提交给数据汇聚子系统；数据汇聚子系统的数据转换模块对监测结果进行加工，将监测任务相关三类配置数据与监测结果整合为统一格式的详单记录，整合完成后将详单记录提交给数据存储模块；数据存储模块将收到的详单记录信息将写入固定大小或固定时间跨度的文件中，并通过批量导入的方式将文件导入至数据库系统进行存储；
步骤S5，进行统计分析；
管理与分析平台的统计分析模块从配置数据库获得各类监测结果中上报的业务质量指标信息，由统计分析模块，每隔一段时间，从数据库获取数据，执行流水线处理过程，计算该统计周期内各类监测任务的各个监测结果的指标统计值；并从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
进一步的，在步骤S2中，探针接入子系统的接入管理模块获取传入的标识和安全信息，并校验探针是否合法，安全信息验证是否通；校验完成后，将校验的结果转交给接入TR069通信模块，并且如校验失败，则提供相应的错误码和错误描述给接入TR069通信模块；如校验成功，则完成以下工作：
1)传入正确的响应码给接入TR069通信模块；
2)创建TR069会话，并在会话中保存探针的标识，以跟踪在整个通信过程中的数据流动；
3)获取传入的探针注册信息，并提交给同步管理模块。
进一步的，在步骤S2中，探针接入子系统在注册校验通过时，需要向上和向下完成两个工作：
1)其接入TR069通信模块处理接入管理模块提交的InformResponse调用请求，并依据检验结果，远程调用探针的InformResponse函数，如校验失败，则传入错误码和错误描述，并强制断开与探针之间连接；否则，传入正确的响应码作为参数以响应探针；
2)其接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块。
进一步的，在步骤S3中，监测任务管理模块创建任务时，需指定三类信息：一、监测任务本身参数描述；二、监测的目标节点信息；三、监测任务的执行方法。
进一步的，探针子系统的探针TR069通信模块处在等待循环中，当收到探针接入子系统下发的消息时，判断消息类型并进行相应的处理；如果是升级请求和参数配置消息，则探针TR069通信模块将消息交由探针管理模块处理，如果是监测任务消息，则探针TR069通信模块将消息交由监测管理模块处理。
进一步的，探针子系统的探针TR069通信模块依次处理各个监测结果，并依据JSON-RPC规范将结果上报至探针接入子系统。
本发明具有以下有益效果：
1、本发明不仅支持传统的网络节点可达性监测，更支持网络内容质量监测。前者提供的网络可达性性能监测，无论是新建的网络和已成熟的网络而言，这都可以提供精细的网络基础质量分析；后者可提供模拟用户角度得出的内容访问质量监测，对于网络运营者分析其用户使用网络时的质量感知情况、内容提供商的业务访问情况以及其网络自身的传输能力等都有极大作用。
2、本发明对于目标网络节点可提供多种监测手段，具体包括PING可达性监测、TRACEROUTE可达性监测、网页浏览类业务质量监测、文件下载类业务质量监测、网速测试类业务质量监测、游戏服务器访问类业务质量监测、在线视频播放类业务质量监测。并且，本系统提供具有优秀扩展性的测试方法，通过增加并实现测试脚本库即可增加对新测试手段的支持。
3、本系统基于JSON-RPC和TR069协议规范，简化了通信协议，使有效数据传输的协议开销降低约2/3；同时，本系统中探针所特有的学习能力，支持部署监测平台到网络提供者的网管网或业务网内，从而可以支持监测更多的内容提供商业务。
本发明附加的方面和优点将在下面的描述中部分给出，部分将从下面的描述中变得明显，或通过本发明的实践了解到。
附图说明
本发明的上述和/或附加的方面和优点从结合下面附图对实施例的描述中将变得明显和容易理解，其中：
图1为本发明的结构框图；
图2为本发明的主要流程图。
具体实施方式
下面详细描述本发明的实施例，所述实施例的示例在附图中示出，其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的，旨在用于解释本发明，而不能理解为对本发明的限制。
本发明提供一种对嵌入式设备上所承载业务质量的主动监测系统，参考附图1所示，包括：探针子系统1、探针接入子系统2、数据汇聚子系统3、管理与分析平台4。
探针子系统1包括探针管理模块11、监测管理模块13、探针TR069通信模块12。
探针管理模块11用于负责探针的安装、升级，并收集探针的运行状态和系统资源使用情况。
监测管理模块13用于接收、创建、执行监测任务并上报监测结果。
探针子系统1的监测管理模块13包含调度器、监测任务管理器；监测任务管理器用于创建、删除监测任务、提交监测结果给探针TR069通信模块。
调度器用于依据不同的调度策略创建任务执行计划，并依据计划，控制任务的一次性运行或周期性运行。
监测任务管理器用于存储任务的基本信息，并保存监测会话信息。
监测任务负责存储任务的基本信息，并保存监测会话信息；一个监测任务对应多个监测会话，一个监测会话对应一个监测目标。
监测会话在执行监测任务时创建，负责保存并跟踪当前监测任务中的一个监测目标相关的信息；监测会话是调度器控制监测任务执行的最小调度单元。
每个监测会话的执行，实际由监测脚本完成；监测会话创建后，即开始运行监测脚本；监测脚本由会话控制其生命周期：加载配置数据、开始执行、监控执行状态、停止执行、上报结果。每个监测脚本对应一种监测手段，该系统默认内置支持PING和TRACEROUTE测试，同时支持模拟用户使用的网页浏览器、在线视频播放器、FTP客户端等轻量级网络工具，以支持测试内容质量；通过该五个生命周期控制机制，监测管理模块提供了一个易于扩展的监测脚本框架，对于新增加的内容质量监测需求，只需要提供满足相应规范接口的监测脚本即可
探针TR069通信模块12用于实现与探针接入子系统直接通信，完成探针配置信息、监测任务信息的接收，以及探针状态信息和监测结果信息的上报。
探针接入子系统3包括接入同步管理模块21、负载均衡模块22、接入TR069通信模块23、接入管理模块24。
接入同步管理模块21用于实现探针接入子系统向管理与分析平台注册认证、从管理与分析平台获取最新的需要下发给探针的监测任务信息以及向管理与分析平台同步。
负载均衡模块22用于对接探针子系统，并将高并发量的探针连接请求的负载分发至多个服务端通信模块。
接入TR069通信模块23用于简化的TR069协议，解析消息，校验消息格式的合法性和数据的有效性，并将消息所负载的业务数据提交给接入管理模块；接入TR069通信模块与接入管理模块为一对一绑定关系。
接入TR069通信模块在远程调用InformResponse函数后，检查是否有探针相关的升级任务、参数配置任务或监测任务需要下发到该探针；如无，则发送空请求给探针，以告诉探针接入子系统已经没有事务需要探针完成，并请求探针断开连接以释放服务器资源；如存在，则发送相应消息内容给探针。
接入管理模块24用于接收并处理探针发起的注册、状态及监测结果请求消息、根据不同的消息类型，完成对探针的注册鉴权过程、状态数据提交至数据汇聚子系统或监测结果提交至数据汇聚子系统。
数据汇聚子系统3包括数据转换模块31和数据存储模块32。
数据转换模块31负责接收并提取探针接入子系统上报的监测结果和探针状态数据，并按照一定的格式进行数据转换，将转换后的数据以消息形式发送至数据存储模块；
数据存储模块32用于将逐条的消息缓存，并在缓存大小超过一定阈值或一定时间周期到达时，将缓存中的内容存储至持久化的系统；
管理与分析平台4包括平台同步管理模块41、监测目标管理模块42、监测探针管理模块43、监测任务管理模块44和统计分析模块45；
监测探针管理模块43用于管理监测探针信息；
监测目标管理模块42用于创建并维护监测目标节点；
监测任务管理模块44用于创建并维护监测任务；
平台同步管理模块41将配置信息下发至接入子系统，由接入子系统的接入同步管理模块将其存储至本地数据库。
统计分析模块45用于从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
本发明对于目标网络节点可提供多种监测手段，具体包括PING可达性监测、TRACEROUTE可达性监测、网页浏览类业务质量监测、文件下载类业务质量监测、网速测试类业务质量监测、游戏服务器访问类业务质量监测、在线视频播放类业务质量监测。并且，本系统提供具有优秀扩展性的测试方法，通过增加并实现测试脚本库即可增加对新测试手段的支持。
本发明还提供一种对嵌入式设备上所承载业务质量的主动监测方法，如图2所示，包括以下步骤：
步骤S1，植入探针子系统；
将探针接入子系统的地址固化在探针子系统的探针中，然后将探针内置在嵌入式设备中，并配置在设备启动时，自动运行探针子系统，使探针子系统整合入原嵌入式设备系统；
步骤S2，完成探针注册；
探针子系统中的探针管理模块通过固化的地址连接探针接入子系统；
由接入TR069通信模块远程调用函数，调用请求符合规定后，由接入管理模块获取探针子系统传入的标识和安全信息，并校验探针合法性安全性，校验合格后，建立探针子系统与探针接入子系统通信，并将探针的注册信息提交给同步管理模块，验证注册信息合格后，由接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块，平台同步管理模块收到上传的注册信息后，将数据存储至数据库中，以允许管理与分析平台对探针信息进行监测管理。
完成探针注册的详细的步骤为：
1)嵌入式设备安装部署完成并开机启动后，探针子系统随系统自动运行。
2)探针子系统中的探针管理模块开始工作，尝试通过固化的地址连接探针接入子系统。如连接失败，则重试该步骤直到成功；如连接成功，则进入下一步。
3)探针管理模块激活探针TR069通信模块，由探针TR069通信模块远程调用探针接入子系统中的Inform函数，并在远程调用函数时依据JSON-RPC规范，提供探针的标识、安全、安装日期等信息和嵌入式设备固有的厂商、型号、串号等信息作为函数参数。
4)探针接入子系统的负载均衡模块收到调用请求后，通过预先设置好的负载分发策略，将请求颁发至某个接入TR069通信模块并负责转发后续该探针和探针接入子系统之间的请求与响应消息。
5)探针接入子系统的接入TR069通信模块收到调用请求后，校验消息格式是否符合规范，如不符合，则远程调用探针的InformResponse函数，传入错误码和错误描述，并强制断开与探针之间连接；否则，将调用请求将由接入管理模块处理。
6)探针接入子系统的接入管理模块获取传入的标识和安全信息，并校验探针是否合法，安全信息验证是否通过。校验完成后，将校验的结果转交给接入TR069通信模块，并且如校验失败，则提供相应的错误码和错误描述给接入TR069通信模块；如校验成功，则完成以下工作：一、传入正确的响应码给接入TR069通信模块；二、创建TR069会话，并在会话中保存探针的标识，以跟踪在整个通信过程中的数据流动；三、获取传入的探针注册信息，并提交给接入同步管理模块。
7)探针接入子系统在注册校验通过时，需要向上和向下完成两个工作：一、其接入TR069通信模块处理接入管理模块提交的InformResponse调用请求，并依据检验结果，远程调用探针的InformResponse函数，如校验失败，则传入错误码和错误描述，并强制断开与探针之间连接；否则，传入正确的响应码作为参数以响应探针；二、其接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块。
8)探针侧接入TR069通信模块收到探针接入子系统的InformResponse远程调用请求，校验是否发生错误；如有错误，则断开连接并在一定时间后重新尝试连接探针接入子系统并重复注册过程；如无错误，则进入等待循环，等待探针接入子系统的后续任务配置要求。
9)管理与分析平台的平台同步管理模块收到上传的注册信息后，将数据存储至数据库中，以允许平台对探针信息的增删改查操作。
步骤S3，进行监测管理；
监测目标管理模块创建并维护监测目标节点，监测任务管理模块创建并维护监测任务，创建并设置好配置监测任务后，通过平台同步管理模块将配置信息下发至探针接入子系统，由探针接入子系统的接入同步管理模块将其存储至本地数据库中；同时由接入TR069通信模块检查是否有探针相关的升级任务、参数配置任务或监测任务，并将任务下发至探针管理模块，监测管理模块依据监测任务信息创建监测任务执行任务，并在满足调度条件时，执行这些任务，并由探针TR069通信模块将监试结果上传至探针接入子系统。
进行监测管理的具体步骤为：
1)探针通过探针接入子系统完成注册后，在管理与分析平台通过监测探针管理模块实现对探针信息的增删改查；
2)通过管理与分析平台的监测目标管理模块，创建并维护监测目标节点；
3)通过管理与分析平台的监测任务管理模块，创建并维护监测任务。创建任务时，需指定三类信息：一、监测任务本身参数描述(包括任务调度信息、监测指标信息和质量测试参数信息)；二、监测的目标节点信息(包括目标域名或IP地址和端口)；三、监测任务的执行方法(由哪个探针负责执行任务)；
4)创建并设置好配置监测任务后，通过管理与分析平台的平台同步管理模块将配置信息下发至探针接入子系统，由探针接入子系统的同步管理模块将其存储至本地数据库中；
5)探针接入子系统接入TR069通信模块在远程调用InformResponse函数后，检查是否有探针相关的升级任务、参数配置任务或监测任务需要下发到该探针。如无，则发送空请求给探针，以告诉探针接入子系统已经没有事务需要探针完成，并请求探针断开连接以释放服务器资源；如存在，则发送相应消息内容给探针；
6)探针子系统的接入TR069通信模块处在等待循环中，当收到探针接入子系统下发的消息时，判断消息类型并进行相应的处理。如果是升级请求和参数配置消息，则接入TR069通信模块将消息交由探针管理模块处理，如果是监测任务消息，则接入TR069通信模块将消息交由监测管理模块处理；
7)探针子系统监测管理模块依据监测任务信息创建监测任务执行任务，并在满足调度条件时，执行这些任务；
8)探针子系统监测管理模块在任务执行完成后，将监测任务执行结果提交给接入TR069通信模块；同时，将监测任务清除或变更调度信息以支持周期性执行；
9)探针子系统的接入TR069通信模块依次处理各个监测结果，并依据JSON-RPC规范将结果上报至探针接入子系统。
步骤S4，进行数据收集存储；
探针接入子系统的接入管理模块收到监试结果后，将其直接提交给数据汇聚子系统；数据汇聚子系统的数据转换模块对监测结果进行加工，将监测任务相关三类配置数据与监测结果整合为统一格式的详单记录，整合完成后将详单记录提交给数据存储模块；数据存储模块将收到的详单记录信息将写入固定大小或固定时间跨度的文件中，并通过批量导入的方式将文件导入至数据库系统进行存储；
步骤S5，进行统计分析；
管理与分析平台的统计分析模块从配置数据库获得各类监测结果中上报的业务质量指标信息，由统计分析模块，每隔一段时间(称为一个统计周期，如5分钟)，从数据库获取数据，执行流水线处理过程，计算该统计周期内各类监测任务的各个监测结果的指标统计值；并从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
本发明对于目标网络节点可提供多种监测手段，具体包括PING可达性监测、TRACEROUTE可达性监测、网页浏览类业务质量监测、文件下载类业务质量监测、网速测试类业务质量监测、游戏服务器访问类业务质量监测、在线视频播放类业务质量监测。并且，本系统提供具有优秀扩展性的测试方法，通过增加并实现测试脚本库即可增加对新测试手段的支持。
尽管上面已经示出和描述了本发明的实施例，可以理解的是，上述实施例是示例性的，不能理解为对本发明的限制，本领域的普通技术人员在不脱离本发明的原理和宗旨的情况下在本发明的范围内可以对上述实施例进行变化、修改、替换和变型。本发明的范围由所附权利要求极其等同限定。
Claims (10)
1.一种对嵌入式设备上所承载业务质量的主动监测系统，其特征在于，包括：探针子系统、探针接入子系统、数据汇聚子系统、管理与分析平台；
所述探针子系统包括探针管理模块、监测管理模块、探针TR069通信模块；
探针管理模块用于负责探针的安装、升级，并收集探针的运行状态和系统资源使用情况；
监测管理模块用于接收、创建、执行监测任务并上报监测结果；
探针TR069通信模块用于实现与探针接入子系统直接通信，完成探针配置信息、监测任务信息的接收，以及探针状态信息和监测结果信息的上报；
所述探针接入子系统包括接入同步管理模块、负载均衡模块、接入TR069通信模块、接入管理模块；
接入同步管理模块用于实现探针接入子系统向管理与分析平台注册认证、从管理与分析平台获取最新的需要下发给探针的监测任务信息、与所述管理与分析平台进行同步；
负载均衡模块用于对接探针子系统，并将高并发量的探针连接请求的负载分发至多个服务端通信模块；
接入TR069通信模块用于简化TR069协议，解析消息，校验消息格式的合法性和数据的有效性，并将消息所负载的业务数据提交给接入管理模块；所述接入TR069通信模块与接入管理模块为一对一绑定关系；
接入管理模块用于接收并处理探针发起的注册、状态及监测结果请求消息、根据不同的消息类型，完成对探针的注册鉴权过程、状态数据提交至数据汇聚子系统或监测结果提交至数据汇聚子系统；
数据汇聚子系统包括数据转换模块和数据存储模块；
数据转换模块负责接收并提取探针接入子系统上报的监测结果和探针状态数据，并按照一定的格式进行数据转换，将转换后的数据以消息形式发送至数据存储模块；
数据存储模块用于将逐条的消息缓存，并在缓存大小超过一定阈值或一定时间周期到达时，将缓存中的内容存储至持久化的系统；
管理与分析平台包括平台同步管理模块、监测目标管理模块、监测探针管理模块、监测任务管理模块和统计分析模块；
监测探针管理模块用于管理监测探针信息；
监测目标管理模块用于创建并维护监测目标节点；
监测任务管理模块用于创建并维护监测任务；
平台同步管理模块将配置信息下发至探针接入子系统，由探针接入子系统的接入同步管理模块将其存储至本地数据库；
统计分析模块用于从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
2.如权利要求1所述的对嵌入式设备上所承载业务质量的主动监测系统，其特征在于：所述探针子系统的监测管理模块包含调度器、监测任务管理器；
所述监测任务管理器用于创建、删除监测任务、提交监测结果给探针TR069通信模块；
所述调度器用于依据不同的调度策略创建任务执行计划，并依据计划，控制任务的一次性运行或周期性运行。
3.如权利要求1所述的对嵌入式设备上所承载业务质量的主动监测系统，其特征在于：所述探针子系统的监测管理模块创建执行监测任务时，利用监测会话保存并跟踪当前监测任务中的一个监测目标相关的信息；监测会话创建后，即开始运行监测脚本；监测脚本由会话控制其生命周期：加载配置数据、开始执行、监控执行状态、停止执行、上报结果。
4.如权利要求1所述的对嵌入式设备上所承载业务质量的主动监测系统，其特征在于：所述接入TR069通信模块在远程调用InformResponse函数后，检查是否有探针相关的升级任务、参数配置任务或监测任务需要下发到该探针；如无，则发送空请求给探针，以告诉探针接入子系统已经没有事务需要探针完成，并请求探针断开连接以释放服务器资源；如存在，则发送相应消息内容给探针。
5.一种对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：包括以下步骤：
步骤S1，植入探针子系统；
将探针接入子系统的地址固化在探针子系统的探针中，然后将探针内置在嵌入式设备中，并配置在设备启动时，自动运行探针子系统，使探针子系统整合入原嵌入式设备系统；
步骤S2，完成探针注册；
探针子系统中的探针管理模块通过固化的地址连接探针接入子系统；
由接入TR069通信模块远程调用函数，调用请求符合规定后，由接入管理模块获取探针子系统传入的标识和安全信息，并校验探针合法性安全性，校验合格后，建立探针子系统与探针接入子系统通信，并将探针的注册信息提交给接入同步管理模块，验证注册信息合格后，由接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块，平台同步管理模块收到上传的注册信息后，将数据存储至数据库中，以允许管理与分析平台对探针信息进行监测管理；
步骤S3，进行监测管理；
监测目标管理模块创建并维护监测目标节点，监测任务管理模块创建并维护监测任务，创建并设置好配置监测任务后，通过平台同步管理模块将配置信息下发至探针接入子系统，由探针接入子系统的接入同步管理模块将其存储至本地数据库中；同时由接入TR069通信模块检查是否有探针相关的升级任务、参数配置任务或监测任务，并将任务下发至探针管理模块，监测管理模块依据监测任务信息创建监测任务执行任务，并在满足调度条件时，执行这些任务，并由探针TR069通信模块将监测结果上传至探针接入子系统；
步骤S4，进行数据收集存储；
探针接入子系统的接入管理模块收到监测结果后，将其直接提交给数据汇聚子系统；数据汇聚子系统的数据转换模块对监测结果进行加工，将监测任务相关三类配置数据与监测结果整合为统一格式的详单记录，整合完成后将详单记录提交给数据存储模块；数据存储模块将收到的详单记录信息将写入固定大小或固定时间跨度的文件中，并通过批量导入的方式将文件导入至数据库系统进行存储；
步骤S5，进行统计分析；
管理与分析平台的统计分析模块从配置数据库获得各类监测结果中上报的业务质量指标信息，由统计分析模块，每隔一段时间，从数据库获取数据，执行流水线处理过程，计算统计周期内各类监测任务的各个监测结果的指标统计值；并从配置数据库获取各个统计指标与业务质量之间的模型映射数学关系，通过该数学关系，分析监测结果所量化计算得出的业务质量情况。
6.如权利要求5所述的对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：在步骤S2中，探针接入子系统的接入管理模块获取传入的标识和安全信息，并校验探针是否合法，安全信息验证是否通过；校验完成后，将校验的结果转交给接入TR069通信模块，并且如校验失败，则提供相应的错误码和错误描述给接入TR069通信模块；如校验成功，则完成以下工作：
1)传入正确的响应码给接入TR069通信模块；
2)创建TR069会话，并在会话中保存探针的标识，以跟踪在整个通信过程中的数据流动；
3)获取传入的探针注册信息，并提交给接入同步管理模块。
7.如权利要求5所述的对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：在步骤S2中，探针接入子系统在注册校验通过时，需要向上和向下完成两个工作：
1)其接入TR069通信模块处理接入管理模块提交的InformResponse调用请求，并依据检验结果，远程调用探针的InformResponse函数，如校验失败，则传入错误码和错误描述，并强制断开与探针之间连接；否则，传入正确的响应码作为参数以响应探针；
2)其接入同步管理模块将探针注册信息通过同步通信通道，上传至管理与分析平台的平台同步管理模块。
8.如权利要求5所述的对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：在步骤S3中，监测任务管理模块创建任务时，需指定三类信息：一、监测任务本身参数描述；二、监测的目标节点信息；三、监测任务的执行方法。
9.如权利要求5所述的对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：探针子系统的探针TR069通信模块处在等待循环中，当收到探针接入子系统下发的消息时，判断消息类型并进行相应的处理；如果是升级请求和参数配置消息，则探针TR069通信模块将消息交由探针管理模块处理，如果是监测任务消息，则探针TR069通信模块将消息交由监测管理模块处理。
10.如权利要求5所述的对嵌入式设备上所承载业务质量的主动监测方法，其特征在于：探针子系统的探针TR069通信模块依次处理各个监测结果，并依据JSON-RPC规范将结果上报至探针接入子系统。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710943496.XA CN107483297B (zh) | 2017-10-11 | 2017-10-11 | 对嵌入式设备上所承载业务质量的主动监测系统及方法 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710943496.XA CN107483297B (zh) | 2017-10-11 | 2017-10-11 | 对嵌入式设备上所承载业务质量的主动监测系统及方法 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN107483297A CN107483297A (zh) | 2017-12-15 |
| CN107483297B true CN107483297B (zh) | 2023-06-02 |
Family
ID=60605368
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710943496.XA Active CN107483297B (zh) | 2017-10-11 | 2017-10-11 | 对嵌入式设备上所承载业务质量的主动监测系统及方法 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107483297B (zh) |
Families Citing this family (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109067584A (zh) * | 2018-08-13 | 2018-12-21 | 海南宝通实业公司 | 一种基于终端单元的移动网络性能探测方法及系统 |
| CN110035132B (zh) * | 2019-04-30 | 2022-08-12 | 深圳市网心科技有限公司 | 数据同步方法、计算机装置及存储介质 |
| CN112333020B (zh) * | 2020-11-03 | 2023-07-21 | 广东电网有限责任公司 | 一种基于五元组的网络安全监测及数据报文解析系统 |
| CN113382056A (zh) * | 2021-06-07 | 2021-09-10 | 北京博睿宏远数据科技股份有限公司 | 数据上报方法、装置、设备、存储介质及系统 |
| CN116208432B (zh) * | 2023-05-05 | 2023-06-30 | 北京安普诺信息技术有限公司 | 一种Web应用安全探针管理方法、系统、电子设备及存储介质 |
| CN118317129B (zh) * | 2024-02-02 | 2024-11-05 | 上海艾策通讯科技股份有限公司 | 一种基于探针拨测的视频监管系统 |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102143022A (zh) * | 2011-03-16 | 2011-08-03 | 北京邮电大学 | 用于ip网络的云测量装置和测量方法 |
| CN104009890A (zh) * | 2014-06-10 | 2014-08-27 | 江苏省邮电规划设计院有限责任公司 | 一种互联网中的网络质量测试系统及方法 |
| CN106850298A (zh) * | 2017-02-08 | 2017-06-13 | 中国联合网络通信集团有限公司 | Iptv业务质量监测方法、终端及系统 |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9426046B2 (en) * | 2011-12-27 | 2016-08-23 | Tektronix Texas, Llc | Web page download time analysis |
| CN102801587B (zh) * | 2012-08-29 | 2014-09-17 | 北京邮电大学 | 面向大规模网络的虚拟化监测系统与动态监测方法 |
-
2017
- 2017-10-11 CN CN201710943496.XA patent/CN107483297B/zh active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102143022A (zh) * | 2011-03-16 | 2011-08-03 | 北京邮电大学 | 用于ip网络的云测量装置和测量方法 |
| CN104009890A (zh) * | 2014-06-10 | 2014-08-27 | 江苏省邮电规划设计院有限责任公司 | 一种互联网中的网络质量测试系统及方法 |
| CN106850298A (zh) * | 2017-02-08 | 2017-06-13 | 中国联合网络通信集团有限公司 | Iptv业务质量监测方法、终端及系统 |
Also Published As
| Publication number | Publication date |
|---|---|
| CN107483297A (zh) | 2017-12-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107483297B (zh) | 对嵌入式设备上所承载业务质量的主动监测系统及方法 | |
| CN111861140B (zh) | 一种业务处理方法、装置、存储介质和电子装置 | |
| EP4066441B1 (en) | Management of iot devices in wireless communication networks | |
| CN107357571B (zh) | 设备组件程序的维护方法及系统 | |
| CN111324363A (zh) | 设备升级方法及升级终端、设备和存储介质 | |
| US20070158404A1 (en) | Method and system for management of terminal devices | |
| CN105052076B (zh) | 一种基于云计算的网元管理系统及网元管理方法 | |
| CN106993043B (zh) | 基于代理的数据通信系统和方法 | |
| CN110138876B (zh) | 任务部署方法、装置、设备及平台 | |
| CN113794652B (zh) | 数据处理方法、装置、电子设备及存储介质 | |
| CN108833565A (zh) | 一种监控服务器的方法、装置、服务器和存储介质 | |
| CN112584398B (zh) | 数据处理方法、装置及存储介质 | |
| CN110636127B (zh) | 一种各信息数据间的通信处理方法及系统 | |
| CN107634871B (zh) | 一种连通性测试方法、装置及系统 | |
| CN103677983A (zh) | 应用的调度方法及装置 | |
| CN111224828A (zh) | 一种智能cpe设备的网络管理方法 | |
| CN112733062B (zh) | 一种物联应用管理系统及方法 | |
| CN114422386B (zh) | 一种微服务网关的监测方法及装置 | |
| CN111756599B (zh) | 一种业务监控方法及业务监控系统 | |
| CN113824801A (zh) | 一种智能融合终端统一接入管理组件系统 | |
| CN111294252B (zh) | 一种集群测试系统 | |
| CN111082964A (zh) | 一种配置信息的分发方法和装置 | |
| CN113721938B (zh) | 适应电力物联网的边边协同任务处理方法、装置及系统 | |
| CN115277362A (zh) | 故障诊断方法、装置、电子设备和计算机可读介质 | |
| CN114679472A (zh) | 通信系统、方法、装置、存储介质及电子设备 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |