A kind of heterogeneous device centralized monitoring systemTechnical field
The present invention relates to a kind of heterogeneous device centralized monitoring system, belong to computer communication field.
Background technology
Satellite communications vehicle utilizes artificial earth satellite as relay station to forward radio signal, it is achieved two or more defendInformation exchange between star communication truck, earth station is transmitted with information.Do not limited by external elements owing to satellite communications vehicle utilizesSystem artificial earth satellite as relay station, therefore one of its indispensable instrument becoming disaster assistance, in disaster assistance playImmeasurable effect, meets command scheduling demand and the communication support demand in disaster area.Satellite communications vehicle include satellite antenna,The equipment etc. such as antenna servo control system, satellite communication equipment, data communication.The type of these equipment is different, and production firm is alsoBeing typically different, the occupation mode that result in every kind equipment is the most different from monitor mode.This situation requires practical operation personnel notNeed only to grasp the use of these equipment, in addition it is also necessary to the running state information of real time inspection equipment, to practical operation people comprehensivelyMember brings the biggest difficulty.And when disaster assistance, owing to being pressed for time, it usually needs it is logical that certain time could set up satelliteLetter link, the easily actual effect of impact rescue.The present invention is directed to use above background designs a kind of hetero-com-munication monitoring of toolsSystem and method, form comprehensively monitoring to satellite communications vehicle mobile unit.
Comprehensively monitoring comprises two tasks, and one is that the running status to network is monitored, and two is the operation shape to networkState is controlled.Network monitor includes that data collection, data process and data analysis；It is to quilt based on network monitoring that network controlsMonitored object implements control action.Network monitor is the premise that network controls, and network control is the result of network monitor.By prisonSurvey understanding current state the most normal, if there is bottleneck problem and potential crisis；By control, network state is closedReason regulation, improves performance, it is ensured that service.
Legacy network monitoring system is merely with Simple Network Management Protocol (Simple Network ManagementProtocol, SNMP) perform the management of homogeneous network equipment, it is not related to the scheduling between dissimilar equipment and switching, onlyIt is monitored only with same mission mode.System and method towards hetero-com-munication monitoring of tools is different from, but baseGathering data with from these heterogeneous device in real time in dissimilar agreement, monitoring protocol therein includes that simple network management is assistedView (Simple Network Management Protocol, SNMP), ICP/IP protocol, serial communication protocol etc..
Chinese patent application 201210419524.5, denomination of invention: wireless network monitoring system and monitoring method, discloseA kind of wireless network monitoring system and monitoring method.But the method only performs monitoring from monitoring wireless network self performance angleManage rather than perform monitoring for network end nodes, it is impossible to being applied to the monitoring of heterogeneous device.
The public publication the most similar to the present invention and patent is not found by retrieval.
Summary of the invention
The technology of the present invention solves problem: overcome the deficiencies in the prior art, it is provided that a kind of heterogeneous device Centralized Monitoring systemSystem, this system realizes the integrated management of heterogeneous device by layered shaping mechanism, utilizes dynamic polling time window mechanism to carryThe efficiency of high monitoring system.
The technical solution of the present invention is:
A kind of heterogeneous device centralized monitoring system, including: data collection layer, data analysis layer and data presentation layer；DataAcquisition layer include clock module, data collection layer scheduler, based on SNMP network equipment data acquisition module, based on TCP/IP netNetwork device data acquisition module, serial equipment data acquisition module；Data analysis layer includes operation layer scheduler；Data presentation layerIncluding parameter configuration module and fault monitor module；
There is first queue module between data presentation layer and data analysis layer, have between data analysis layer and data collection layerSecond Queue module；
When described monitoring system is in passive work mode, the configuration parameter data that outside is inputted by parameter configuration modulePass sequentially through first queue module, operation layer scheduler and the second Queue module and send in data collection layer scheduler, data acquisitionCollection layer scheduler according to built-in default dispatch list, inquire-receive to configuration parameter data belong to based on SNMP network equipment numberAccording to acquisition module, based on TCP/IP network equipment data acquisition module or serial equipment data acquisition module, and join describedPutting the supplemental characteristic corresponding data acquisition module of feeding to configure this data acquisition module, this data acquisition module is to accordinglyEquipment carries out data acquisition, and data collection layer scheduler controls described data acquisition module and the data collected are sent into the second teamIn row module, sending into operation layer scheduler after the second Queue module caching, operation layer scheduler is according to built-in defaultThe described data collected are differentiated by threshold value, if within threshold range, then data are delayed by first queue moduleAfter depositing, feeding parameter configuration module carries out result to show, if outside threshold range, then by data by first queue mouldSend into after block caching while parameter configuration module carries out result, also send in fault monitor module and show；
When described monitoring system has the initiative mode of operation, it is input in parameter configuration module without exterior arrangement parameter,Clock module provides clock pulse signal to data collection layer scheduler, and data collection layer scheduler calculates the clock arteries and veins receivedRush the quantity of signal, generate collection period pulse signal to based on SNMP network equipment data acquisition according to built-in default timetableCollection module, based on TCP/IP network equipment data acquisition module or serial equipment data acquisition module, control corresponding data and adoptCollection module carries out data acquisition, and data collection layer scheduler controls described data acquisition module and the data collected are sent into secondIn Queue module, sending into operation layer scheduler after the second Queue module caching, operation layer scheduler is preset according to built-inThreshold value the described data collected are differentiated, if within threshold range, then by data by first queue moduleAfter caching, feeding parameter configuration module carries out result to show, if outside threshold range, then data are passed through first queueSend into after module caching while parameter configuration module carries out result, also send in fault monitor module and show, businessThe result that data are also in outside threshold value by layer scheduler feeds back to data collection layer scheduler, and data collection layer scheduler adjustsPulse accumulation quantity in its internal timetable, carries out data acquisition again.
In described timetable built-in based on SNMP network equipment data acquisition module, based on TCP/IP network equipment dataAcquisition module or the corresponding clock pulse signal quantity of serial equipment data acquisition module, when data collection layer scheduler tires outWhen the clock pulses quantity of meter reaches the number of pulses of data acquisition module in timetable, data collection layer scheduler dispatches gathersPeriodic pulse signal is to corresponding data acquisition module.
Data collection layer scheduler adjust the pulse accumulation quantity in its internal timetable particularly as follows:
Data collection layer scheduler is that the polling cycle of the equipment that all data acquisition modules are corresponding arranges initial value Ti(1≤ i≤N), and all polling cycle initial values are equal, wherein Ti=2n, N represents that number of devices, n represent positive integer；At oneThe poll moment, if data collecting module collected to the data of equipment i be in outside described preset threshold range time, then will setThe polling cycle of standby i shortens to Ti/2；
In the next poll moment, if the data of the equipment i collected remain at outside described preset threshold rangeTime, then continuing to shorten polling cycle, polling cycle value shortens to Ti/ 4, till foreshortening to 1s so on up to polling cycle；And if within the data of the equipment i that the described next poll moment collects remain at described preset threshold range, then taken turnsThe inquiry cycle becomes 2 times of current polling cycle, and the rest may be inferred until polling cycle recovers to TiTill.
The present invention compared with prior art has the beneficial effect that
(1) by layered shaping mechanism, set up data collection layer scheduler and operation layer scheduler realizes heterogeneous deviceIntegrated management, utilizes modular thinking to realize the seamless connection of heterogeneous device, expands the application model of monitoring method and systemEnclose；
(2) by dynamically arranging polling cycle, shorten the polling cycle of warping apparatus targetedly, treat that it recovers normalIt is gradually brought to initial value after state, solves the link bandwidth that takies that fixing polling cycle brought and too much and easily missEquipment state transformation period point problem, thus short at polling cycle or long between be made that balance；
Accompanying drawing explanation
Fig. 1 is present system block diagram；
Detailed description of the invention
As it is shown in figure 1, the invention provides a kind of heterogeneous device centralized monitoring system, including: at data collection layer, dataReason layer and data presentation layer；Data collection layer include clock module, data collection layer scheduler, based on SNMP network equipment dataAcquisition module, based on TCP/IP network equipment data acquisition module, serial equipment data acquisition module；Data analysis layer includes numberAccording to processing layer scheduler；Data presentation layer includes parameter configuration module and fault monitor module.
There is first queue module between data presentation layer and data analysis layer, have between data analysis layer and data collection layerSecond Queue module.
Based on SNMP network equipment data acquisition module: this module is as the reality realizing network data acquisition class based on SNMPExample, including an entry queue and a gate region, and the entry queue of reference data acquisition layer scheduler exports as itQueue, completes two aspect tasks: 1) this monitoring module reads clock signal from its entry queue, gathers one the most in a synchronous mannerOrganize the status parameter values corresponding to management information bank (Management Information Base, MIB) node or running parameterValue, these parameter values, as the response results of active inquiry, are back to the entry queue of data collection layer scheduler；2) this monitoringModule is read requests order from its entry queue, resolves this request command, performs read-write operation in a synchronous manner, then will behaviourThe entry queue of data collection layer scheduler it is back to as result.
Based on TCP/IP network equipment data acquisition module: this module is as reality based on TCP/IP network data acquisition classExample, including an entry queue, and the entry queue of reference data acquisition layer is as its gate region, completes two aspect tasks:1) this monitoring module reads clock signal, the most in a synchronous manner acquisition state parameter value or running parameter from its entry queueValue, these parameter values, as the response results of active inquiry, are back to the entry queue of data collection layer scheduler；2) this managementModule is read requests order from its entry queue, resolves this request command, performs read-write operation in a synchronous manner, then will behaviourThe entry queue of data collection layer scheduler it is back to as result.
Serial equipment data acquisition module: this module is as example based on serial acquisition class, including an entry queue,And the entry queue of reference data acquisition layer scheduler is as its gate region, complete two aspect tasks: 1) this monitoring module fromIn its entry queue read clock signal, the most in an asynchronous manner acquisition state parameter value or operating parameter values, Query Result with inDisconnected mode returns, and is back to the entry queue of data collection layer scheduler；2) this management module reads from its entry queue and asksAsk order, resolve this request command, perform read-write operation in a synchronous manner, then operating result is back to data collection layer and adjustsThe entry queue of degree device.
Clock module: utilize Quartz task scheduling framework to generate clock signal with 1 second for the cycle, be forwarded to number after generationEntry queue according to acquisition layer scheduler module.
Data collection layer scheduler: perform the task scheduling of data acquisition with active mode and passive mode, complete threeAspect task: 1) state parameter of active inquiry equipment or operational factor, and the working method of this active inquiry be based on timeClock signal completes；When the message bag read in its entry queue is clock signal, this scheduler is first depending on scheduling instanceTable judges which managed devices current clock signal belongs to, and then clock signal is forwarded to the data acquisition of corresponding deviceThe entry queue of module；2) passive query based on operator's request or modification parameter；Request command is entered by schedulerRow classification, is forwarded to the data acquisition module entry queue of corresponding device according to dispatch list by order；3) by active inquiry and quiltThe response results of dynamic request is forwarded to the entry queue of data collection layer scheduler.
When described monitoring system is in passive work mode, the configuration parameter data that outside is inputted by parameter configuration modulePass sequentially through first queue module, operation layer scheduler and the second Queue module and send in data collection layer scheduler, data acquisitionCollection layer scheduler according to built-in default dispatch list, inquire-receive to configuration parameter data belong to based on SNMP network equipment numberAccording to acquisition module, based on TCP/IP network equipment data acquisition module or serial equipment data acquisition module, and join describedPutting the supplemental characteristic corresponding data acquisition module of feeding to configure this data acquisition module, this data acquisition module is to accordinglyEquipment carries out data acquisition, and data collection layer scheduler controls described data acquisition module and the data collected are sent into the second teamIn row module, sending into operation layer scheduler after the second Queue module caching, operation layer scheduler is according to built-in defaultThe described data collected are differentiated by threshold value, if within threshold range, then data are delayed by first queue moduleAfter depositing, feeding parameter configuration module carries out result to show, if outside threshold range, then by data by first queue mouldSend into after block caching while parameter configuration module carries out result, also send in fault monitor module and show；
When described monitoring system has the initiative mode of operation, it is input in parameter configuration module without exterior arrangement parameter,Clock module provides clock pulse signal to data collection layer scheduler, and data collection layer scheduler calculates the clock arteries and veins receivedRush the quantity of signal, generate collection period pulse signal to based on SNMP network equipment data acquisition according to built-in default timetableCollection module, based on TCP/IP network equipment data acquisition module or serial equipment data acquisition module, control corresponding data and adoptCollection module carries out data acquisition, and data collection layer scheduler controls described data acquisition module and the data collected are sent into secondIn Queue module, sending into operation layer scheduler after the second Queue module caching, operation layer scheduler is preset according to built-inThreshold value the described data collected are differentiated, if within threshold range, then by data by first queue moduleAfter caching, feeding parameter configuration module carries out result to show, if outside threshold range, then data are passed through first queueSend into after module caching while parameter configuration module carries out result, also send in fault monitor module and show, businessThe result that data are also in outside threshold value by layer scheduler feeds back to data collection layer scheduler, and data collection layer scheduler adjustsPulse accumulation quantity in its internal timetable, carries out data acquisition again.
In timetable built-in based on SNMP network equipment data acquisition module, based on TCP/IP network equipment data acquisitionModule or the corresponding clock pulse signal quantity of serial equipment data acquisition module, when data collection layer scheduler is accumulativeWhen clock pulses quantity reaches the number of pulses of data acquisition module in timetable, data collection layer scheduler dispatches collection periodPulse signal is to corresponding data acquisition module.
Data collection layer scheduler adjust the pulse accumulation quantity in its internal timetable particularly as follows:
Data collection layer scheduler is that the polling cycle of the equipment that all data acquisition modules are corresponding arranges initial value Ti(1≤ i≤N), and all polling cycle initial values are equal, wherein Ti=2n, N represents that number of devices, n represent positive integer；At oneThe poll moment, if data collecting module collected to the data of equipment i be in outside described preset threshold range time, then will setThe polling cycle of standby i shortens to Ti/2；
In the next poll moment, if the data of the equipment i collected remain at outside described preset threshold rangeTime, then continuing to shorten polling cycle, polling cycle value shortens to Ti/ 4, till foreshortening to 1s so on up to polling cycle；And if within the data of the equipment i that the described next poll moment collects remain at described preset threshold range, then taken turnsThe inquiry cycle becomes 2 times of current polling cycle, and the rest may be inferred until polling cycle recovers to TiTill.
Data analysis layer scheduler: this module includes an entry queue and three gate region, wherein gate region 1 withThe entry queue of data collection layer scheduler is associated, and gate region 2 is associated with the entry queue of fault monitor module, outletQueue 3 is associated with parameter configuration module.Work of both completing: 1) resolve the request of practical operation user, according in advanceRequest is classified by the Classification Management strategy set, and repacks the entry queue put into data collection layer scheduler；2) read response message bag from entry queue, the numerical value gathered in message bag is stored in local variable.
Fault monitor module: this module only includes an entry queue is relevant to data analysis layer scheduler gate region 2Connection, for receiving information and the equipment alarm information that equipment working state changes, in a tabular form in alarm in real timeMonitoring interface shows；According to equipment supplier, regulation and the operator of alarm grade being used experience, we are equipmentWarning information carries out classification, is divided into slight grade, menace level and critical grade, with different face in alerting real-time monitoring interfaceColor presents these alarms.
Parameter configuration module: this module only includes an entry queue is relevant to data analysis layer scheduler gate region 3Connection, for receiving the parameter response of equipment.
Embodiment:
The network equipment included by Emergency communication vehicle is: modem, demodulator, router, switch, wireless aps, lightTerminal, wherein modem, demodulator, router, switch, wireless aps support SNMP, and optical transmitter and receiver supports TCP/IP；InstituteSerial equipment is: antenna servo control system and upconverter.Satellite communications vehicle centralized monitoring system runs on industrial computer, and workControl machine is realized and the interconnecting of other network by switch, and industrial computer serial ports board is connected with serial equipment, therefore this collectionMiddle monitoring system completes the monitoring of satellite communications vehicle mobile unit in industrial computer this locality.Because the type of management equipment is different, instituteTo arrange these two aspects to improve existing method from architecture and polling cycle.
In terms of architecture, this method is data-centered, divides aspect according to the process of data transmission, definesData collection layer, data analysis layer and data presentation layer.In the inside of each aspect, divide mould according to the difference performing functionBlock.Data collection layer divides module based on equipment, including modem acquisition module, demodulator acquisition module, routerAcquisition module, switch acquisition module, wireless aps acquisition module, optical transmitter and receiver acquisition module, antenna servo control system module, onConverter module and data collection layer scheduler.Acquired original data are converted to number required for management system by data analysis layerAccording to form, according to represent layer request pass data to specifically represent interface, therefore this layer only includes that data analysis layer is adjustedDegree device.Represent that layer includes that Configuration Manager and fault management module, each module include that several represent interface.The present invention fromTransverse and longitudinal both direction carries out partition by fine granularities to management system, and the most each aspect is equivalent to the combination of some management modules.ThisSample reduces the coupled relation between function, improves the efficiency that management system performs, and also reduces the complexity that system realizes.
After dividing level and module, the present invention connects adjacent module based on producers and consumers's Model Establishment,Realize organic linking between disparate modules and between layers.Based on FIFO (First-In-during this connectionFirst-Out, FIFO) queue realizes, and fifo queue ensure that scheduler rings according to the sequencing of task requests timeShould ask, task is forwarded to corresponding device data acquisition module.
Because needing bi-directional message between data collection layer and data analysis layer, so Producer in this caseBeing a kind of relativeness with consumer, message therein represents request task or response.When request task is transferred to from operation layerDuring data collection layer, operation layer as consumer, connects the fifo queue conduct of two aspects as Producer, data collection layerRelief area.When operation layer generation request is thought, then request task is put into relief area；And if the fullest between buffer empty, then hinderRequest task, until after the Free up Memory of relief area, waking up the operation layer thread blocked up, is just put into slow by plug operation layer threadRush district.As consumer, data collection layer monitors whether relief area exists task requests all the time, if there is request task, then takeGo out this request task to be for further processing；Otherwise data collection layer thread will block, until there is request task in relief areaAfter wake up it up till.After data collection layer has performed task requests, need response results is back to operation layer.At this moment,Data collection layer is as Producer, and operation layer is as consumer, and the fifo queue of two aspects of connection is as relief area, and it performsProcess is consistent with the above.
Adjacent two aspects utilize fifo queue come transmission tasks request or response, utilize queue come transmission tasks request orIts response so that queue becomes message queue, transmission represents task requests or the message queue of its response.Operation layer and data acquisitionCollection layer all includes a scheduler, and this scheduler forwards task requests or its response based on type of message.The work of schedulerBetween disparate modules or aspect, carry out data exchange with being to ensure that, thus ensure between module, between aspect or module withCan facilitate between aspect, efficiently, reliably communicate, maintain the feature of extensibility and motility.Built-in one of schedulerRepresent message destination address dispatch list, first determine whether type of message after receiving message, then look up whether scheduling exists turnSending out address, if there is then this message being put into the entry address of respective modules, otherwise abandoning.The false code forwarding message is as followsShown in:
//InQueue represents the entry queue of scheduler, and Map represents that dispatch list, object represent that what scheduler received disappearsBreath, MessageName represents type of message
Inside data collection layer, this results in point centered by scheduler, with concrete data acquisition module for extension pointStructure.The relation between producers and consumers is still conformed between each data acquisition module and scheduler.Scheduler andEach data acquisition module works independently of one another, the most each data acquisition module independent acquisition data, after collection data completeIt is back to scheduler in an asynchronous manner.Owing to Ethernet interface network interface is two-forty port and serial ports is low rate port, use differentStep gathers data mode and avoids that port speed is inconsistent and the problem of bringing wait-for-response Time Inconsistency.
In terms of polling cycle, polling cycle becomes the key point of NMS execution efficiency.If actively pollCycle is the shortest, then occupy more bandwidth resources, affects the communication of regular traffic；If poll is oversize, then cannot monitorThe change of some particular state information.Therefore this method have employed the management strategy in dynamic polling cycle, there may be shorteningThe polling cycle of abnormality equipment, is gradually increased polling cycle after it recovers normal condition, until recovering to polling cycleInitial value.Data collection layer includes that multiple data acquisition module, each data acquisition module are directed to actively poll device parameter.
Scheduling instance table set up by data collection layer scheduler, and each of scheduling instance table is an integer value, represents equipmentThe initial value of polling cycle.After each clock signal arrives scheduler, in dispatch list, the value of each all subtracts 1.If there is valueWhen being the item of 0, represent that this corresponding equipment arrives state parameter and gathers the moment, clock signal is forwarded to corresponding device ginsengNumber acquisition module.Scheduler will revise the polling cycle value of each equipment according to collection result.
Data collection layer scheduler is that the polling cycle of each equipment arranges initial value Ti(1≤i≤N), and these take turnsInquiry cycle initial value is equal, wherein Ti=2n, N represents the quantity of managed devices, and n represents integer.In some poll moment,If the state parameter of equipment i or operational factor are abnormal or time not within normal range, are then contracted by the polling cycle of equipment iShort for Ti/2.In the next poll moment, if the state parameter of equipment i or operational factor be not the most extremely or at normal modelTime within enclosing, continuing to shorten polling cycle, polling cycle value shortens to Ti/ 4, foreshortening to 1s so on up to polling cycle isOnly.And the next one poll moment, if the state parameter of equipment i or operational factor recover normal, then polling cycle becomes current2 times of polling cycle, the rest may be inferred until polling cycle recovers to TiTill.
// judge that whether the parameter value gathered is in normal range
Actively poll equipment status parameter and running parameter to realize process as follows:
(1) scheduling instance table set up by the scheduler of data collection layer, and each of scheduling instance table is an integer value, representsThe initial value in device polling cycle；
(2) clock module generates clock signal with 1 second for the cycle, puts it into data collection layer and adjust after producing clock signalThe entry queue of degree module；
(3) scheduler is according to scheduling instance table forwarded clock signal, and device parameter acquisition module is opened after receiving clock signalBegin to perform parameter acquisition, after collection, be back to data collection layer scheduler with call-back manner, be subsequently forwarded to data analysis layer and adjustDegree device；
(4), after data Layer scheduler receives data, resolve to represent form required for layer, aobvious in Network Weathermap interfaceShow.
Device parameter inquiry based on operator's request with revise to realize process as follows:
(1) operator's clicking operation in systems inquires about a concrete class parameter, inquiry request is sent to dataThe entry queue of reason layer, at this moment represents that the thread of layer will suspend, until the response obtained wakes up it up；
(2) inquiry request is inserted the entry queue of data collection layer scheduler by data analysis layer；
(3) corresponding device data acquisition module is forwarded it to after data collection layer scheduler receives inquiry request immediatelyEntry queue；
(4) device data acquisition module performs associative operation according to request command, and response is back to data acquisitionLayer scheduler；Data collection layer scheduler puts it into the entry queue of data analysis layer scheduler after receiving response；
(5), after data analysis layer receives response, the form represented required for layer is resolved to, and the response after resolvingResult puts into expression layer entry queue.After representing that layer entry queue receives response results, wake up expression layer line journey up so that response knotFruit shows in representing bed boundary.
The present invention is not disclosed technology and belongs to general knowledge as well known to those skilled in the art.