[go: up one dir, main page]

CN106100914B - A method and system for pushing alarm information of cloud AC - Google Patents

A method and system for pushing alarm information of cloud AC Download PDF

Info

Publication number
CN106100914B
CN106100914B CN201610727818.2A CN201610727818A CN106100914B CN 106100914 B CN106100914 B CN 106100914B CN 201610727818 A CN201610727818 A CN 201610727818A CN 106100914 B CN106100914 B CN 106100914B
Authority
CN
China
Prior art keywords
information
alarm information
alarm
cloud
user
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
Application number
CN201610727818.2A
Other languages
Chinese (zh)
Other versions
CN106100914A (en
Inventor
陈昊
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Chuangweilai Fuzhou Technology Co ltd
Original Assignee
Phicomm Shanghai Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Phicomm Shanghai Co Ltd filed Critical Phicomm Shanghai Co Ltd
Priority to CN201610727818.2A priority Critical patent/CN106100914B/en
Publication of CN106100914A publication Critical patent/CN106100914A/en
Application granted granted Critical
Publication of CN106100914B publication Critical patent/CN106100914B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/06Management of faults, events, alarms or notifications
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/06Management of faults, events, alarms or notifications
    • H04L41/0631Management of faults, events, alarms or notifications using root cause analysis; using analysis of correlation between notifications, alarms or events based on decision criteria, e.g. hierarchy, tree or time analysis
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/02Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Telephonic Communication Services (AREA)
  • Computer And Data Communications (AREA)
  • Information Transfer Between Computers (AREA)

Abstract

本发明公开了一种云AC告警信息的推送方法及系统,该方法包括:接收AP设备上报的告警事件,云AC根据业务规则生成告警信息;云AC将生成的告警信息推送至消息中间件;前端通过WebSocket协议与后台服务器连接,并于后台服务器注册,生成用户管理信息;后台服务器从所述消息中间件获取告警信息,根据所述告警信息于已生成的用户管理信息中查找所述告警信息对应的设备信息;于查找到所述告警信息对应的设备信息所对应的用户信息时,所述后台服务器通过WebSocket协议将所述告警信息发送到对应用户的前端,本发明实现了后端系统与前端页面的双向消息通讯,提高了消息推送系统的稳定性和及时性,减轻了后端系统的压力。

Figure 201610727818

The invention discloses a method and system for pushing alarm information of a cloud AC. The method includes: receiving alarm events reported by AP equipment, generating alarm information according to business rules; and pushing the generated alarm information to message middleware; The front end connects with the backend server through the WebSocket protocol, and registers with the backend server to generate user management information; the backend server obtains alarm information from the message middleware, and searches for the alarm information in the generated user management information according to the alarm information The corresponding device information; when the user information corresponding to the device information corresponding to the alarm information is found, the background server sends the alarm information to the front end of the corresponding user through the WebSocket protocol. The two-way message communication on the front-end page improves the stability and timeliness of the message push system and reduces the pressure on the back-end system.

Figure 201610727818

Description

一种云AC告警信息的推送方法及系统A method and system for pushing alarm information of cloud AC

技术领域technical field

本发明涉及通信技术领域,特别是涉及一种云AC告警信息的推送方法及系统。The invention relates to the field of communication technologies, and in particular, to a method and system for pushing alarm information of a cloud AC.

背景技术Background technique

目前,基于虚拟化技术的软件定义网络和网络功能虚拟化趋势越来越清晰,众多研究机构、通信设备商以及通信服务商开始研究将传统模块下的网络业务功能重构部署在云端,例如,在云端部署AC(Access Controller,接入控制器),简称云Ac,云端部署AC与传统模式部署的差异,主要是AP设备(Access Pointer,接入节点)需要跨越Internet与AC相连。At present, the trend of software-defined network and network function virtualization based on virtualization technology is becoming more and more clear, and many research institutions, communication equipment manufacturers and communication service providers have begun to study the reconstruction and deployment of network service functions under traditional modules in the cloud. For example, The AC (Access Controller, access controller) is deployed in the cloud, referred to as the cloud AC. The difference between the cloud deployment and the traditional mode deployment is that the AP (Access Pointer, access node) needs to be connected to the AC across the Internet.

在云AC与AP设备通信的过程中,当云AC接收到某一AP设备上报的告警事件时,需要根据业务规则生成告警详细信息,并需要把告警信息及时推送到用户的告警监测页面,以便运维人员及时处理相关告警。然而,目前,由于AP设备与云AC的连接是基于HTTP协议的,如果前端页面需要与后台服务器通讯,需要使用长连接的方式,即页面主动发起HTTP连接,等后台返回消息后,HTTP连接断开,前端页面需要再次发起HTTP请求,建立连接,这种方式增加了后台服务器连接处理的压力,消息的发送实时性不高,前后端的通信异常处理非常复杂。During the communication between the cloud AC and the AP device, when the cloud AC receives an alarm event reported by an AP device, it needs to generate alarm details according to business rules, and it needs to push the alarm information to the user's alarm monitoring page in time, so that Operation and maintenance personnel deal with relevant alarms in a timely manner. However, at present, since the connection between the AP device and the cloud AC is based on the HTTP protocol, if the front-end page needs to communicate with the back-end server, it needs to use a long connection, that is, the page actively initiates an HTTP connection, and after the back-end returns a message, the HTTP connection is disconnected Open, the front-end page needs to initiate an HTTP request again to establish a connection. This method increases the pressure on the connection processing of the back-end server. The real-time sending of messages is not high, and the communication exception handling between the front-end and the back-end is very complicated.

发明内容SUMMARY OF THE INVENTION

为克服上述现有技术存在的不足,本发明之目的在于提供一种云AC告警信息的推送方法及系统,其通过利用WebSocket技术,实现了后端系统与前端页面的双向消息通讯,提高了消息推送系统的稳定性和及时性,减轻了后端系统的压力。In order to overcome the above-mentioned deficiencies of the prior art, the purpose of the present invention is to provide a method and system for pushing alarm information of cloud AC, which realizes the two-way message communication between the back-end system and the front-end page by using the WebSocket technology, and improves the message communication efficiency. The stability and timeliness of the push system reduces the pressure on the back-end system.

为达上述目的,本发明提出一种云AC告警信息的推送方法,包括如下步骤:In order to achieve the above purpose, the present invention provides a method for pushing alarm information of a cloud AC, including the following steps:

步骤一,接收AP设备上报的告警事件,云AC根据业务规则生成告警信息;Step 1: Receive alarm events reported by AP devices, and cloud AC generates alarm information according to business rules;

步骤二,云AC将生成的告警信息推送至一消息中间件;Step 2, the cloud AC pushes the generated alarm information to a message middleware;

步骤三,前端通过WebSocket协议与后台服务器连接,并于后台服务器注册,生成用户管理信息;Step 3, the front end is connected with the backend server through the WebSocket protocol, and is registered with the backend server to generate user management information;

步骤四,后台服务器从所述消息中间件获取告警信息,根据所述告警信息于已生成的用户管理信息中查找所述告警信息对应的设备信息;Step 4, the background server obtains the alarm information from the message middleware, and searches for the device information corresponding to the alarm information in the generated user management information according to the alarm information;

步骤五,于查找到所述告警信息对应的设备信息所对应的用户信息时,所述后台服务器通过WebSocket协议将所述告警信息发送到对应用户的前端。In step 5, when the user information corresponding to the device information corresponding to the alarm information is found, the background server sends the alarm information to the front end of the corresponding user through the WebSocket protocol.

进一步地,所述告警信息至少包括所述告警信息至少包括产生告警事件的设备信息、告警时间以及告警事件的相关内容。Further, the alarm information includes at least the alarm information including the information of the device generating the alarm event, the alarm time and the related content of the alarm event.

进一步地,于步骤四中,所述后台服务器每隔若干时间从所述消息中间件获取最新的告警信息,从所述告警信息中提取出设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。Further, in step 4, the background server obtains the latest alarm information from the message middleware every several times, extracts the device information from the alarm information, and sends the registered users according to the device number of the device information. Check whether there is the device number and its corresponding user information in the management information.

进一步地,所述消息中间件为STOMP消息中间件。Further, the message middleware is STOMP message middleware.

进一步地,该方法还包括:Further, the method also includes:

所述前端实时或定期监测与所述后台服务器的WebSocket连接状态,在连接中断后,主动尝试利用WebSocket协议重连所述后台服务器。The front end monitors the WebSocket connection state with the backend server in real time or periodically, and after the connection is interrupted, actively tries to reconnect to the backend server by using the WebSocket protocol.

进一步地,该方法还包括:Further, the method also includes:

所述后台服务器定期向前端发送心跳以监测前端用户的连接状态,在确认所述前端用户连接断开后,注销用户管理信息,关闭连接通道。The back-end server periodically sends a heartbeat to the front-end to monitor the connection state of the front-end user, and after confirming that the front-end user is disconnected, logs out the user management information and closes the connection channel.

为达到上述目的,本发明还提供一种云AC告警信息的推送系统,包括:In order to achieve the above object, the present invention also provides a system for pushing alarm information of the cloud AC, including:

告警信息生成单元,利用所述云AC接收AP设备上报的告警事件,根据业务规则生成告警信息;an alarm information generating unit, which uses the cloud AC to receive alarm events reported by AP devices, and generates alarm information according to business rules;

第一推送单元,将生成的告警信息推送至一消息中间件;a first push unit, which pushes the generated alarm information to a message middleware;

用户管理信息建立单元,以于前端通过WebSocket协议与后台服务器连接时,将前端用户于后台服务器注册,生成用户管理信息;The user management information establishment unit is used to register the front-end user with the back-end server when the front-end is connected to the back-end server through the WebSocket protocol to generate user management information;

检索单元,利用所述后台服务器从所述消息中间件获取告警信息,根据所述告警信息于已注册的用户管里信息中查找该告警信息对应的设备信息;a retrieval unit, using the background server to obtain alarm information from the message middleware, and searching for device information corresponding to the alarm information in the registered user management information according to the alarm information;

第二推送单元,于所述检索单元的检索结果为查找到所述告警信息对应的设备信息时,利用所述后台服务器通过WebSocket协议将该告警信息发送到对应用户的前端。The second push unit, when the retrieval result of the retrieval unit is that the device information corresponding to the alarm information is found, uses the background server to send the alarm information to the front end of the corresponding user through the WebSocket protocol.

进一步地,所述检索单元利用所述后台服务器每隔若干时间从所述消息中间件获取最新的告警信息,从所述告警信息中提取出设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。Further, the retrieval unit utilizes the background server to obtain the latest alarm information from the message middleware every several times, extracts the device information from the alarm information, and records the registered users according to the device number of the device information. Check whether there is the device number and its corresponding user information in the management information.

进一步地,所述系统还包括第一连接状态监测单元,所述该第一连接状态监测单元于前端实时或定期监测前端与后台服务器的WebSocket连接状态,在连接中断后,使前端主动尝试利用WebSocket协议重连后台服务器。Further, the system also includes a first connection state monitoring unit, the first connection state monitoring unit monitors the WebSocket connection state between the front end and the backend server in real time or periodically at the front end, and after the connection is interrupted, the front end actively tries to use the WebSocket. The protocol reconnects to the background server.

进一步地,所述系统还包括第二连接状态监测单元,所述第二连接状态监测单元于所述后台服务器定期向所述前端发送心跳以监测前端用户的连接状态,在确认所述前端用户连接断开后,注销用户管理信息,关闭所述后台服务器与该前端的连接通道。Further, the system also includes a second connection state monitoring unit, the second connection state monitoring unit periodically sends a heartbeat to the front end from the backend server to monitor the connection state of the front end user, and confirms the connection state of the front end user. After disconnection, log out the user management information, and close the connection channel between the backend server and the frontend.

与现有技术相比,本发明一种云AC告警信息的推送方法及系统,其通过将云AC告警模块生成的告警信息推送到消息中间件,由消息中间件将消息推送至后台服务器,并通过利用WebSocket技术,实现了后台服务器与前端页面的双向消息通讯,提高了消息推送系统的稳定性和及时性,减轻了后台服务器的压力。Compared with the prior art, the present invention provides a method and system for pushing alarm information of a cloud AC. By pushing the alarm information generated by the alarm module of the cloud AC to a message middleware, the message middleware pushes the message to a background server, and sends the message to a background server. By using WebSocket technology, the two-way message communication between the background server and the front-end page is realized, the stability and timeliness of the message push system are improved, and the pressure on the background server is reduced.

附图说明Description of drawings

图1为本发明一种云AC告警信息的推送方法的步骤流程图;1 is a flow chart of steps of a method for pushing alarm information of a cloud AC according to the present invention;

图2为本发明一种云AC告警信息的推送方法之较佳实施例的消息传送示意图;2 is a schematic diagram of message transmission according to a preferred embodiment of a method for pushing cloud AC alarm information according to the present invention;

图3为本发明一种云AC告警信息的推送系统的系统架构图。FIG. 3 is a system architecture diagram of a system for pushing alarm information of a cloud AC according to the present invention.

具体实施方式Detailed ways

以下通过特定的具体实例并结合附图说明本发明的实施方式,本领域技术人员可由本说明书所揭示的内容轻易地了解本发明的其它优点与功效。本发明亦可通过其它不同的具体实例加以施行或应用,本说明书中的各项细节亦可基于不同观点与应用,在不背离本发明的精神下进行各种修饰与变更。The embodiments of the present invention will be described below through specific examples and in conjunction with the accompanying drawings, and those skilled in the art can easily understand other advantages and effects of the present invention from the contents disclosed in this specification. The present invention can also be implemented or applied through other different specific examples, and various details in this specification can also be modified and changed based on different viewpoints and applications without departing from the spirit of the present invention.

图1为本发明一种云AC告警信息的推送方法的步骤流程图。如图1所示,本发明一种云AC告警信息的推送方法,包括如下步骤:FIG. 1 is a flowchart of steps of a method for pushing alarm information of a cloud AC according to the present invention. As shown in FIG. 1 , a method for pushing alarm information of a cloud AC according to the present invention includes the following steps:

步骤101,接收AP设备上报的告警事件,云AC根据业务规则生成告警信息。具体地说,当某一AP设备发生告警事件时,会向云AC上报该告警事件,云AC的告警模块接收到该告警事件后,根据业务规则生成告警信息,该告警信息中至少包括有产生告警事件的设备信息(例如设备编号)、告警时间以及告警事件的内容等。In step 101, an alarm event reported by an AP device is received, and the cloud AC generates alarm information according to a service rule. Specifically, when an alarm event occurs on an AP device, it will report the alarm event to the cloud AC. After receiving the alarm event, the alarm module of the cloud AC generates alarm information according to business rules. Device information (for example, device number) of the alarm event, alarm time, and content of the alarm event, etc.

步骤102,云AC将生成的告警信息推送到一消息中间件。在本发明较佳实施例中,云AC将告警信息推送至STOMP消息中间件。Step 102, the cloud AC pushes the generated alarm information to a message middleware. In a preferred embodiment of the present invention, the cloud AC pushes the alarm information to the STOMP message middleware.

步骤103,前端通过WebSocket协议与后台服务器连接,并通过WebSocket协议在后台服务器注册,生成用户管理信息,该用户管理信息至少包括用户信息以及用户信息对应的设备信息,例如注册用户A,其对应的设备信息包括设备A、设备B、设备C等。Step 103, the front end connects with the backend server through the WebSocket protocol, and registers with the backend server through the WebSocket protocol to generate user management information, the user management information at least includes user information and device information corresponding to the user information, such as registered user A, whose corresponding The device information includes device A, device B, device C, and so on.

步骤104,后台服务器从消息中间件获取告警信息,根据告警信息于已注册的用户管理信息中查找该告警信息对应的设备信息。具体地说,后台服务器从STOMP中间件获取最新的告警信息,例如,后台服务器可以每隔三分钟从STOMP中间件获取三分钟内的告警信息,从告警信息中提取出设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。Step 104, the background server obtains the alarm information from the message middleware, and searches for the device information corresponding to the alarm information in the registered user management information according to the alarm information. Specifically, the background server obtains the latest alarm information from the STOMP middleware. For example, the background server can obtain the alarm information within three minutes from the STOMP middleware every three minutes, and extract the device information from the alarm information. Device ID Check whether there is the device ID and its corresponding user information in the registered user management information.

步骤105,于查找到该告警信息对应的设备信息及其对应的用户信息时,后台服务器通过WebSocket协议将告警信息发送到对应用户的前端。也就是说,当根据设备信息的设备编号于已注册的用户管理信息中查到找有该设备编号对应的用户信息时,后台服务器则通过WebSocket协议将告警信息发送到对应用户的前端页面。Step 105, when the device information corresponding to the alarm information and the corresponding user information are found, the background server sends the alarm information to the front end of the corresponding user through the WebSocket protocol. That is to say, when the user information corresponding to the device number is found in the registered user management information according to the device number of the device information, the background server sends the alarm information to the front-end page of the corresponding user through the WebSocket protocol.

较佳地,本发明一种云AC告警信息的推送方法,还包括如下步骤:Preferably, a method for pushing cloud AC alarm information of the present invention further includes the following steps:

前端实时或定期监测与后台服务器的WebSocket连接状态,在连接中断后,主动尝试利用WebSocket协议重连后台服务器。The front-end monitors the WebSocket connection status with the back-end server in real time or periodically, and actively tries to use the WebSocket protocol to reconnect to the back-end server after the connection is interrupted.

较佳地,本发明一种云AC告警信息的推送方法,还包括如下步骤:Preferably, a method for pushing cloud AC alarm information of the present invention further includes the following steps:

后台服务器定期向前端发送心跳以监测前端用户的连接状态,在确认前端用户连接断开后,注销用户管理信息,关闭连接通道。The backend server periodically sends heartbeats to the frontend to monitor the connection status of the frontend user. After confirming that the frontend user is disconnected, it logs out the user management information and closes the connection channel.

图2为本发明一种云AC告警信息的推送方法之较佳实施例的消息传送示意图。具体如下:1、前端通过WebSocket协议连接后台服务器,前端用户通过页面登陆注册,通过WebSocket协议在后台服务器注册用户管理信息,包括用户信息以及该用户信息对应的各设备信息,即每个用户可以管理几个AP设备,具体地说,本发明可利用NODE.JS建立多个用户,每个用户管理几个AP设备,后台服务器只是将告警信息发送给相关的用户;2、后台服务器从STOMP消息服务器(STOMP消息中间件)获取最新的告警信息,从告警信息中提取出设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号对应的用户信息,并于已注册的用户管理信息中查到找有该设备编号对应的用户信息时,通过WebSocket协议将告警信息发送到对应用户的前端页面,同时,后台服务器会定期向前端发送心跳以监测前端用户的连接状态,在确认前端用户连接断开后,注销用户管理信息,关闭连接通道;3、当AP设备上报告警事件,云AC的告警模块接收到告警事件后,根据业务规则生成告警详细信息,并把相关信息推送到STOMP消息中间件,由STOMP消息中间件定时将最新的告警信息推送至后台服务器。FIG. 2 is a schematic diagram of message transmission according to a preferred embodiment of a method for pushing alarm information of a cloud AC according to the present invention. The details are as follows: 1. The front end connects to the backend server through the WebSocket protocol, the frontend user logs in and registers through the page, and registers the user management information on the backend server through the WebSocket protocol, including the user information and the information of each device corresponding to the user information, that is, each user can manage Several AP devices, specifically, the present invention can use NODE.JS to establish multiple users, each user manages several AP devices, and the background server just sends the alarm information to the relevant users; 2. The background server sends the alarm information from the STOMP message server (STOMP message middleware) obtains the latest alarm information, extracts the device information from the alarm information, searches the registered user management information for the user information corresponding to the device number according to the device number of the device information, and registers it in the registered user management information. When the user information corresponding to the device number is found in the user management information of the device, the alarm information is sent to the front-end page of the corresponding user through the WebSocket protocol. At the same time, the back-end server will periodically send a heartbeat to the front-end to monitor the connection status of the front-end user. After confirming that the front-end user is disconnected, log out the user management information and close the connection channel; 3. When an alarm event is reported on the AP device, and the alarm module of the cloud AC receives the alarm event, it generates alarm details according to business rules, and records the relevant alarm events. The information is pushed to the STOMP message middleware, and the STOMP message middleware regularly pushes the latest alarm information to the background server.

图3为本发明一种云AC告警信息的推送系统的系统架构图。如图3所示,本发明一种云AC告警信息的推送系统,包括:告警信息生成单元301、第一推送单元302、用户管理信息建立单元303、检索单元304以及第二推送单元305。FIG. 3 is a system architecture diagram of a system for pushing alarm information of a cloud AC according to the present invention. As shown in FIG. 3 , a cloud AC alarm information push system of the present invention includes an alarm information generation unit 301 , a first push unit 302 , a user management information establishment unit 303 , a retrieval unit 304 and a second push unit 305 .

告警信息生成单元301,利用云AC接收AP设备上报的告警事件,根据业务规则生成告警详细信息。具体地说,当某一AP设备发生告警事件时,会向云AC上报该告警事件,告警信息生成单元401利用云AC的告警模块接收到该告警事件后,根据业务规则生成告警详细信息,该告警详细信息中至少包括有产生告警事件的设备信息(例如设备编号)、告警时间以及告警事件的内容等。The alarm information generating unit 301 uses the cloud AC to receive alarm events reported by the AP device, and generates alarm detailed information according to business rules. Specifically, when an alarm event occurs in an AP device, the alarm event will be reported to the cloud AC. After receiving the alarm event by using the alarm module of the cloud AC, the alarm information generating unit 401 generates alarm detailed information according to business rules. The alarm detailed information includes at least information of the device generating the alarm event (for example, the device number), the alarm time, the content of the alarm event, and the like.

第一推送单元302,将生成的告警详细信息推送到一消息中间件。在本发明较佳实施例中,第一推送单元302将告警详细信息推送至STOMP消息中间件。The first pushing unit 302 pushes the generated alarm detailed information to a message middleware. In a preferred embodiment of the present invention, the first push unit 302 pushes the alarm detailed information to the STOMP message middleware.

用户管理信息建立单元303,以于前端通过WebSocket协议与后台服务器连接时,通过WebSocket协议将前端用户在后台服务器注册,生成用户管理信息,该用户管理信息包括用户信息以及用户信息对应的设备信息,例如注册用户A,其对应的设备信息可包括设备A、设备B、设备C等。The user management information establishment unit 303 is configured to register the front-end user in the background server through the WebSocket protocol when the front-end is connected to the back-end server through the WebSocket protocol, and generate user management information, the user management information includes the user information and the device information corresponding to the user information, For example, for registered user A, the corresponding device information may include device A, device B, device C, and so on.

检索单元304,利用后台服务器从消息中间件获取告警信息,根据告警信息于已注册的用户管里信息中查找该告警信息对应的设备信息。具体地说,检索单元304利用后台服务器从STOMP中间件获取最新的告警信息,例如,可利用后台服务器每隔三分钟从STOMP中间件获取三分钟内的告警信息,然后从告警信息中提取出对应的设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。The retrieval unit 304 uses the background server to obtain the alarm information from the message middleware, and searches for the device information corresponding to the alarm information in the registered user management information according to the alarm information. Specifically, the retrieval unit 304 uses the background server to obtain the latest alarm information from the STOMP middleware. For example, the background server can be used to obtain the alarm information within three minutes from the STOMP middleware every three minutes, and then extract the corresponding alarm information from the alarm information. According to the device information of the device information, the registered user management information is searched for whether there is the device number and its corresponding user information.

第二推送单元305,于检索单元304的检索结果为查找到该告警信息对应设备对应的用户时,利用后台服务器通过WebSocket协议将该告警信息发送到对应用户的前端。也就是说,当检索单元304根据设备信息的设备编号于已注册的用户管理信息中查到找有该设备编号对应的用户信息时,第二推送单元305则利用后台服务器通过WebSocket协议将告警信息发送到对应用户的前端页面。The second push unit 305 uses the background server to send the alarm information to the front end of the corresponding user through the WebSocket protocol when the retrieval result of the retrieval unit 304 is to find the user corresponding to the device corresponding to the alarm information. That is to say, when the retrieval unit 304 finds the user information corresponding to the device number in the registered user management information according to the device number of the device information, the second push unit 305 uses the background server to send the alarm information through the WebSocket protocol. Sent to the front-end page of the corresponding user.

较佳地,本发明一种云AC告警信息的推送系统,还包括第一连接状态监测单元,该第一连接状态监测单元于前端实时或定期监测前端与后台服务器的WebSocket连接状态,在连接中断后,使前端主动尝试利用WebSocket协议重连后台服务器。Preferably, the present invention is a system for pushing cloud AC alarm information, further comprising a first connection state monitoring unit, the first connection state monitoring unit monitors the WebSocket connection state between the front end and the backend server in real time or periodically at the front end, and when the connection is interrupted, After that, make the front end actively try to use the WebSocket protocol to reconnect to the backend server.

较佳地,本发明一种云AC告警信息的推送系统,还包括:第二连接状态监测单元于后台服务器定期向前端发送心跳以监测前端用户的连接状态,在确认前端用户连接断开后,注销用户管理信息,关闭后台服务器与该前端的连接通道。Preferably, the present invention is a system for pushing cloud AC alarm information, further comprising: a second connection state monitoring unit periodically sends a heartbeat to the front end from the backend server to monitor the connection state of the frontend user, and after confirming that the frontend user is disconnected, Log out the user management information, and close the connection channel between the backend server and the frontend.

综上所述,本发明一种云AC告警信息的推送方法及系统,其通过将云AC告警模块生成的告警信息推送到消息中间件,由消息中间件将消息推送至后台服务器,并通过利用WebSocket技术,实现了后台服务器与前端页面的双向消息通讯,提高了消息推送系统的稳定性和及时性,减轻了后台服务器的压力。In summary, the present invention provides a method and system for pushing alarm information of a cloud AC. By pushing the alarm information generated by the cloud AC alarm module to a message middleware, the message middleware pushes the message to a background server, and uses the WebSocket technology realizes the two-way message communication between the backend server and the front-end page, improves the stability and timeliness of the message push system, and reduces the pressure on the backend server.

与现有技术相比,本发明具有如下优点:Compared with the prior art, the present invention has the following advantages:

1、本发明中消息是双向通讯,速度和稳定性能更高。1. The message in the present invention is two-way communication, with higher speed and stability.

2、本发明因为没有通过HTTP协议,长时间连接且没有消息通讯时通讯链路也不会被交换机强制断开。2. Because the present invention does not pass the HTTP protocol, the communication link will not be forcibly disconnected by the switch when it is connected for a long time and there is no message communication.

3、本发明通过心跳机制更好地监控和恢复连接通道。3. The present invention better monitors and restores the connection channel through the heartbeat mechanism.

任何本领域技术人员均可在不违背本发明的精神及范畴下,对上述实施例进行修饰与改变。因此,本发明的权利保护范围,应如权利要求书所列。Any person skilled in the art can modify and change the above embodiments without departing from the spirit and scope of the present invention. Therefore, the protection scope of the present invention should be as listed in the claims.

Claims (10)

1.一种云AC告警信息的推送方法,包括如下步骤:1. A method for pushing alarm information of a cloud AC, comprising the following steps: 步骤一,接收AP设备上报的告警事件,云AC根据业务规则生成告警信息;Step 1: Receive alarm events reported by AP devices, and cloud AC generates alarm information according to business rules; 步骤二,云AC将生成的告警信息推送至一消息中间件;Step 2, the cloud AC pushes the generated alarm information to a message middleware; 步骤三,前端通过WebSocket协议与后台服务器连接时,将前端用户于后台服务器注册,所述后台服务器生成用户管理信息;Step 3, when the front end is connected to the backend server through the WebSocket protocol, the frontend user is registered in the backend server, and the backend server generates user management information; 步骤四,后台服务器从所述消息中间件获取告警信息,根据所述告警信息于已生成的用户管理信息中查找所述告警信息对应的产生告警事件的设备信息;Step 4, the background server obtains the alarm information from the message middleware, and searches the generated user management information for the device information corresponding to the alarm information that generates the alarm event according to the alarm information; 步骤五,于查找到所述告警信息对应的设备信息所对应的用户信息时,所述后台服务器通过WebSocket协议将所述告警信息发送到对应用户的前端。In step 5, when the user information corresponding to the device information corresponding to the alarm information is found, the background server sends the alarm information to the front end of the corresponding user through the WebSocket protocol. 2.如权利要求1所述的一种云AC告警信息的推送方法,其特征在于:所述告警信息至少包括产生告警事件的设备信息、告警时间以及告警事件的相关内容。2 . The method for pushing alarm information of a cloud AC according to claim 1 , wherein the alarm information at least includes information of a device that generates an alarm event, an alarm time, and relevant content of the alarm event. 3 . 3.如权利要求2所述的一种云AC告警信息的推送方法,其特征在于:于步骤四中,所述后台服务器每隔若干时间从所述消息中间件获取最新的告警信息,从所述告警信息中提取出产生告警事件的设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。3 . The method for pushing alarm information of a cloud AC according to claim 2 , wherein in step 4, the background server obtains the latest alarm information from the message middleware every several times, and obtains the latest alarm information from the The device information that generates the alarm event is extracted from the alarm information, and according to the device number of the device information, the registered user management information is searched for whether there is the device number and its corresponding user information. 4.如权利要求1所述的一种云AC告警信息的推送方法,其特征在于:所述消息中间件为STOMP消息中间件。4 . The method for pushing alarm information of a cloud AC according to claim 1 , wherein the message middleware is STOMP message middleware. 5 . 5.如权利要求1所述的一种云AC告警信息的推送方法,其特征在于,该方法还包括:5. The method for pushing alarm information of a cloud AC according to claim 1, wherein the method further comprises: 所述前端实时或定期监测与所述后台服务器的WebSocket连接状态,在连接中断后,主动尝试利用WebSocket协议重连所述后台服务器。The front end monitors the WebSocket connection state with the backend server in real time or periodically, and after the connection is interrupted, actively tries to reconnect to the backend server by using the WebSocket protocol. 6.如权利要求1所述的一种云AC告警信息的推送方法,其特征在于,该方法还包括:6. The method for pushing alarm information of a cloud AC according to claim 1, wherein the method further comprises: 所述后台服务器定期向前端发送心跳以监测前端用户的连接状态,在确认所述前端用户连接断开后,注销用户管理信息,关闭连接通道。The back-end server periodically sends a heartbeat to the front-end to monitor the connection state of the front-end user, and after confirming that the front-end user is disconnected, logs out the user management information and closes the connection channel. 7.一种云AC告警信息的推送系统,包括:7. A system for pushing alarm information of a cloud AC, comprising: 告警信息生成单元,利用所述云AC接收AP设备上报的告警事件,根据业务规则生成告警信息;an alarm information generating unit, using the cloud AC to receive alarm events reported by AP devices, and generate alarm information according to business rules; 第一推送单元,将生成的告警信息推送至一消息中间件;a first push unit, which pushes the generated alarm information to a message middleware; 用户管理信息建立单元,以于前端通过WebSocket协议与后台服务器连接时,将前端用户于后台服务器注册,生成用户管理信息;The user management information establishment unit is used to register the front-end user with the back-end server when the front-end is connected to the back-end server through the WebSocket protocol to generate user management information; 检索单元,利用所述后台服务器从所述消息中间件获取告警信息,根据所述告警信息于已注册的用户管里信息中查找该告警信息对应的产生告警事件的设备信息;a retrieval unit, which uses the background server to obtain alarm information from the message middleware, and searches for the device information corresponding to the alarm information that generates the alarm event in the registered user management information according to the alarm information; 第二推送单元,于所述检索单元的检索结果为查找到所述告警信息对应的设备信息时,利用所述后台服务器通过WebSocket协议将该告警信息发送到对应用户的前端。The second push unit, when the retrieval result of the retrieval unit is that the device information corresponding to the alarm information is found, uses the background server to send the alarm information to the front end of the corresponding user through the WebSocket protocol. 8.如权利要求7所述的一种云AC告警信息的推送系统,其特征在于:所述检索单元利用所述后台服务器每隔若干时间从所述消息中间件获取最新的告警信息,从所述告警信息中提取出产生告警事件的设备信息,根据设备信息的设备编号于已注册的用户管理信息中查找是否有该设备编号及其对应的用户信息。8. The system for pushing alarm information of a cloud AC according to claim 7, wherein the retrieval unit uses the background server to obtain the latest alarm information from the message middleware every several times, and obtains the latest alarm information from the The device information that generates the alarm event is extracted from the alarm information, and according to the device number of the device information, the registered user management information is searched for whether there is the device number and its corresponding user information. 9.如权利要求8所述的一种云AC告警信息的推送系统,其特征在于:所述系统还包括第一连接状态监测单元,所述第一连接状态监测单元于前端实时或定期监测前端与后台服务器的WebSocket连接状态,在连接中断后,使前端主动尝试利用WebSocket协议重连后台服务器。9 . The system for pushing cloud AC alarm information according to claim 8 , wherein the system further comprises a first connection state monitoring unit, and the first connection state monitoring unit monitors the front end in real time or periodically at the front end. 10 . The status of the WebSocket connection with the backend server. After the connection is interrupted, the front end will actively try to reconnect to the backend server using the WebSocket protocol. 10.如权利要求8所述的一种云AC告警信息的推送系统,其特征在于:所述系统还包括第二连接状态监测单元,所述第二连接状态监测单元于所述后台服务器定期向所述前端发送心跳以监测前端用户的连接状态,在确认所述前端用户连接断开后,注销用户管理信息,关闭所述后台服务器与该前端的连接通道。10 . The system for pushing alarm information of cloud AC according to claim 8 , wherein the system further comprises a second connection state monitoring unit, and the second connection state monitoring unit sends a regular notification to the background server. 11 . The front-end sends a heartbeat to monitor the connection state of the front-end user, and after confirming that the front-end user is disconnected, logs out the user management information, and closes the connection channel between the back-end server and the front-end.
CN201610727818.2A 2016-08-25 2016-08-25 A method and system for pushing alarm information of cloud AC Active CN106100914B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201610727818.2A CN106100914B (en) 2016-08-25 2016-08-25 A method and system for pushing alarm information of cloud AC

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201610727818.2A CN106100914B (en) 2016-08-25 2016-08-25 A method and system for pushing alarm information of cloud AC

Publications (2)

Publication Number Publication Date
CN106100914A CN106100914A (en) 2016-11-09
CN106100914B true CN106100914B (en) 2020-02-21

Family

ID=57225294

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201610727818.2A Active CN106100914B (en) 2016-08-25 2016-08-25 A method and system for pushing alarm information of cloud AC

Country Status (1)

Country Link
CN (1) CN106100914B (en)

Families Citing this family (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN106851703B (en) * 2016-12-22 2021-03-02 金华市智甄通信设备有限公司 Method and device for processing alarm information by cloud access controller
CN106850283B (en) * 2017-01-19 2020-12-25 金华市智甄通信设备有限公司 Event-driven cloud AC alarm processing system and method
CN107231290A (en) * 2017-04-19 2017-10-03 中国建设银行股份有限公司 A kind of instant communicating method and system
CN109560949B (en) * 2017-09-26 2023-01-03 杭州海康威视系统技术有限公司 Data processing method, management server and business equipment
CN111427850A (en) 2019-11-06 2020-07-17 杭州海康威视数字技术股份有限公司 Method, device and system for displaying alarm file
CN111049846A (en) * 2019-12-20 2020-04-21 北京明略软件系统有限公司 Data processing method and device, electronic equipment and computer readable storage medium
CN111510325B (en) * 2020-04-07 2023-05-12 广州中石科技有限公司 Alarm information pushing method, server, client and system
CN114070712B (en) * 2021-07-14 2024-05-24 北京天元创新科技有限公司 Message non-landing network management alarm processing method and device
CN113778789B (en) * 2021-08-15 2025-07-08 新华三大数据技术有限公司 Alarm information processing method and device
CN114553944A (en) * 2021-12-30 2022-05-27 以萨技术股份有限公司 Early warning message pushing method and system
CN115412597B (en) * 2022-08-19 2024-07-09 江阴市富仁智能科技有限公司 Real-time data communication method

Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101729567A (en) * 2009-12-14 2010-06-09 北京神州泰岳软件股份有限公司 Web alarm monitoring system and method based on Socket protocol
CN105791036A (en) * 2014-12-15 2016-07-20 中国移动通信集团吉林有限公司 AP access detection method and device

Family Cites Families (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20070075848A1 (en) * 2005-10-05 2007-04-05 Pitt Lance D Cellular augmented vehicle alarm

Patent Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101729567A (en) * 2009-12-14 2010-06-09 北京神州泰岳软件股份有限公司 Web alarm monitoring system and method based on Socket protocol
CN105791036A (en) * 2014-12-15 2016-07-20 中国移动通信集团吉林有限公司 AP access detection method and device

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
云平台上资源告警系统的设计与实现;宋璐菲;《中国优秀硕士学位论文全文数据库》;20151231;全文 *

Also Published As

Publication number Publication date
CN106100914A (en) 2016-11-09

Similar Documents

Publication Publication Date Title
CN106100914B (en) A method and system for pushing alarm information of cloud AC
US10721135B1 (en) Edge computing system for monitoring and maintaining data center operations
CN111200538B (en) Monitoring method and device for intelligent equipment
CN104468244B (en) Domain name analysis system calamity is for constructing method and device
CN103605722B (en) Database monitoring method and device, equipment
CN107391276B (en) Distributed monitor method, interception control device and system
CN105991412B (en) Information push method and device
WO2015109443A1 (en) Method for processing network service faults, service management system and system management module
CN113742031A (en) Node state information acquisition method and device, electronic equipment and readable storage medium
CN106993043B (en) Data communication system and method based on agency
CN103546343A (en) Network flow display method and system for network flow analyzing systems
CN110928934A (en) Data processing method and device for business analysis
CN106411548A (en) Alarm information notification method and apparatus, and alarm information filtering device
WO2014056345A1 (en) Management method and apparatus for monitoring task
CN109818799A (en) Log collection analysis method and equipment
CN110674172A (en) Data query method and device
KR20200007912A (en) Methods, devices, and systems for monitoring data traffic
CN108809678B (en) Information pushing method and server
CN113194550A (en) Data channel construction method, server and data cluster system
CN105530137A (en) Flow data analysis method and flow data analysis system
CN108599978B (en) Cloud monitoring method and device
CN106656658A (en) Substation information pushing system
CN109831335B (en) Data monitoring method, monitoring terminal, storage medium and data monitoring system
CN109144919B (en) Interface switching method and device
CN106790339A (en) Metadata server, network device, and automatic resource management method

Legal Events

Date Code Title Description
C06 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
TR01 Transfer of patent right
TR01 Transfer of patent right

Effective date of registration: 20201124

Address after: Room 10242, No. 260, Jiangshu Road, Xixing street, Binjiang District, Hangzhou City, Zhejiang Province

Patentee after: Hangzhou Jiji Intellectual Property Operation Co.,Ltd.

Address before: 201616 Shanghai city Songjiang District Sixian Road No. 3666

Patentee before: Phicomm (Shanghai) Co.,Ltd.

TR01 Transfer of patent right

Effective date of registration: 20201211

Address after: Xinlian Creative Park, No.70, Matai street, Hunan Road Street, Gulou District, Nanjing City, Jiangsu Province

Patentee after: Shen Shuangli

Address before: Room 10242, No. 260, Jiangshu Road, Xixing street, Binjiang District, Hangzhou City, Zhejiang Province

Patentee before: Hangzhou Jiji Intellectual Property Operation Co.,Ltd.

TR01 Transfer of patent right
TR01 Transfer of patent right

Effective date of registration: 20210419

Address after: 313000 room 1019, Xintiandi commercial office, Yishan street, Wuxing District, Huzhou, Zhejiang, China

Patentee after: Huzhou YingLie Intellectual Property Operation Co.,Ltd.

Address before: Xinlian Creative Park, No.70, Matai street, Hunan Road Street, Gulou District, Nanjing City, Jiangsu Province

Patentee before: Shen Shuangli

TR01 Transfer of patent right
TR01 Transfer of patent right

Effective date of registration: 20241231

Address after: Room 02, 17th Floor, Building 1, Huajian Building, No. 12, 16, and 18 Keji East Road, Shangjie Town, Minhou County, Fuzhou City, Fujian Province, China 350000

Patentee after: Chuangweilai (Fuzhou) Technology Co.,Ltd.

Country or region after: China

Address before: 313000 room 1019, Xintiandi commercial office, Yishan street, Wuxing District, Huzhou, Zhejiang, China

Patentee before: Huzhou YingLie Intellectual Property Operation Co.,Ltd.

Country or region before: China

TR01 Transfer of patent right