CN105282227A - High-efficiency and high-stability page real-time data refreshing method - Google Patents

Abstract

The present invention provides a high-efficiency, high-stability page real-time data refresh method, which improves the traditional method of pulling real-time displaying changed data by the client to actively push by the server when the background data changes; the message push adopts Comet-based " Server push" technology, adopting observer model: improving the traditional two-tier "request-service" architecture model into a three-tier service architecture; the message forwarding middleware is responsible for the network transmission of messages, and solves message congestion in high-concurrency and high-throughput applications , loss and other issues, and support distributed computing; the advantages of the present invention are: solve the problem of increased load on the server and increased network traffic caused by the traditional client regularly sending requests to the server to obtain the latest changed data; reduce the message push delay, Improve the quality of message push; support distributed computing, and solve the problems of message congestion and message distribution loss in high-concurrency and high-throughput applications.

Description

A high-efficiency, high-stability page real-time data refresh method

technical field

The invention belongs to the application field of a real-time system that needs to display the latest background change data in real time, and specifically relates to a high-efficiency and high-stability page real-time data refresh method.

Background technique

At present, there are mainly the following methods for displaying real-time changing data based on WEB:

HTTP pull method: mainly includes traditional polling method and Ajax polling. The traditional polling method is to use the refresh function of the meta tag in HTML to reprint the page after a certain time interval, and repeat this cycle. Its biggest disadvantage is that the experience it brings to people when the page is swiped is very poor, and the pressure on the server will be relatively high. The Ajax polling method is an asynchronous response mechanism. Although it can solve the visual experience brought by the above-mentioned traditional polling method, it still discovers the data changes of the server through the uninterrupted client Ajax request, so the delay of the client displaying data The shortcomings of time and server-side load pressure are still unresolved.

Socket implementation methods, such as using the XMLSocket class of Flash or Java Applet to establish a Socket connection, realize full-duplex server push, and then realize the final data push through the interface of Flash or Applet and JavaScript communication. But this method requires the support of Flash or JVM, which is also not suitable for end users.

In addition, most real-time application systems have the characteristics of high concurrency, high throughput, and heavy load applications. In the service of various messages, there are high requirements for the task processing efficiency of requests, data release efficiency, and stability. At present, all kinds of message services are mostly carried out in a two-tier architecture, that is, the requester directly sends a request to the service provider. The disadvantage of this type of processing method is that when the service provider crashes and restarts at a certain moment, the current message service processing The method cannot enable the data or service requester to obtain the data or service in a timely manner, and the requester must resubmit the request task before re-obtaining the data or service, which increases the burden on the requester and the service provider; in addition, the message request and service adopt two layers The way of architecture makes the coupling between system modules stronger and the scalability is poor. Therefore, the traditional two-tier message service solution has problems such as low message distribution efficiency, poor stability, and poor scalability.

Contents of the invention

The purpose of the present invention is to overcome the deficiencies in the prior art, and provide a high-efficiency, high-stability page real-time data refresh method.

Technical scheme of the present invention is realized in the following manner, and its characteristics are:

(1) The traditional method of pulling real-time display data changes by the client is improved, and the server actively pushes when the background data changes; the message push adopts Comet-based "server push" technology, and adopts the observer model: the client sends a request , subscribe to events of interest; the server assigns a session ID to each client as a marker, and the event source will multicast the newly generated event to the subscriber's event queue;

Adopt the open source framework pushlet;

(2) The traditional two-tier "request-service" architecture model has been improved to a three-tier service architecture, that is, the "request-message forwarding-service" three-tier architecture; the message forwarding middleware is responsible for the network transmission of messages, solving high concurrency, Problems such as message congestion and loss in high-throughput applications support distributed computing and have a message caching mechanism to ensure the stability of message transmission and improve the quality of message push;

The message distribution center mainly includes: message subscription, message distribution, message publishing and other modules;

The message subscription component is mainly responsible for the registration and sending of subscription requests and the correct return of subscription data;

The specific process is: after the subscription request task is sent, the subscription component registers the service request task, and sends the request information with the service code and filter conditions to the message distribution component; the message service subscription component receives the data returned by the message distribution component After that, according to the service code and registration information, return the returned data to the corresponding requester;

The main functions of the message distribution component include: message parsing, message distribution, subscription information registration and unsubscription.

The advantages of the present invention are:

(1) Solve the problem of increased load on the server and increased network traffic caused by the traditional client regularly sending requests to the server to obtain the latest changed data.

(2) The delay of message push is reduced, and the quality of message push is improved.

(3) It supports distributed computing and solves the problems of message congestion and message distribution loss in high-concurrency and high-throughput applications.

(4) The three-tier "request-service" architecture model is adopted, which effectively improves the problem of message loss instability caused by the service provider crashing and restarting at a certain point in the traditional two-tier architecture model.

(5) Adopting a three-layer "request-message forwarding-service" framework model, which effectively improves the modularity of the system and enhances the scalability of the system.

detailed description

A high-efficiency, high-stability page real-time data refreshing method of the present invention will be described in detail below.

A high-efficiency, high-stability page real-time data refresh method of the present invention is characterized in that:

(1) The traditional method of pulling real-time displaying changed data by the client is improved, and the server actively pushes it when the background data changes. Message push adopts the "server push" technology based on Comet, and adopts the observer model: the client sends a request and subscribes to the event of interest; the server assigns a session ID to each client as a tag, and the event source will send the newly generated event Sent to the subscriber's event queue in a multicast manner. The specific implementation adopts the open source framework pushlet.

Using "server push" technology has the following advantages:

Reduced the push delay of the client displaying the latest changes.

The client does not need to send requests regularly to obtain the latest change data, and the server-side load pressure is small.

The client does not need to install any plug-ins.

(2) The traditional two-tier "request-service" architecture model is improved to a three-tier service architecture, that is, the "request-message forwarding-service" three-tier architecture. The message forwarding middleware is responsible for the network transmission of messages, solves problems such as message congestion and loss in high-concurrency and high-throughput applications, supports distributed computing, has a message cache mechanism, ensures the stability of message transmission, and improves the quality of message push.

The message distribution middleware mainly includes: message subscription, message distribution, message publishing and other modules.

The message subscription component is mainly responsible for the registration and sending of subscription requests and the correct return of subscription data. The specific process is: after the subscription request task is sent, the subscription component registers the service request task, and sends the request information with the service code and filter conditions to the message distribution component; the message service subscription component receives the data returned by the message distribution component Finally, according to the service code and registration information, return the returned data to the corresponding requester.

The main functions of the message distribution component include: message parsing, message distribution, subscription information registration and unsubscription.

The message service publishing component mainly implements the receiving and parsing of subscription requests and the return of subscription data.

Using a separate module message distribution middleware to solve network transmission problems has the following advantages:

Support for distributed processing.

It has a message caching mechanism, which can effectively avoid the problem of message loss caused by the crash of one end.

Support high concurrency and high throughput.

Good scalability.

The high-efficiency and high-stability page real-time data refreshing method of the present invention has very simple and convenient processing and production, and can be processed as shown in the manual.

Except for the technical features described in the description, all are known technologies by those skilled in the art.

Claims (1)

1. a page real time data method for refreshing for high efficiency, high stability, is characterized in that:

(1), improve traditional client and pull the real-time delta data mode that shows for the server end active push when back-end data changes; Message push adopts " server push " technology based on Comet, adopts observer's model: client sends request, and subscribes to interested event; Server end is that each client distributes a session id as mark, and event source can be sent in the event queue of subscriber in the mode of multicast the new event produced;

Adopt Open Framework pushlet;

(2), to improve traditional two-layer " request-service " architecture mode be three layers of service architecture, i.e. " request-message forwards-serves " three-tier architecture; Message forwards the Internet Transmission that middleware is responsible for message, solves the problem such as clogged with messages, loss in high concurrent, large throughput application, supports Distributed Calculation, have message buffering mechanism, ensure the stability of transmission of messages, improve message push quality;

Mainly comprise in the middle of message distribution: the modules such as message subscribing, message distribution, news release;

The registration of message subscribing component primary responsibility subscribe request, transmission and subscription data correctly return;

Detailed process is: after subscribe request task sends, and subscribes to component and service request task is registered, and the solicited message with service codes and filter condition is sent to message distribution component; After messenger service subscription component receives the return data of message distribution component, according to service codes and log-on message, return data are returned to corresponding requestor;

Message distribution component major function comprises: message parse, message distribution, subscription information are registered and cancelled subscriptions.