[go: up one dir, main page]

CN106131138B - A real-time push system and method of display data based on non-blocking queue - Google Patents

A real-time push system and method of display data based on non-blocking queue Download PDF

Info

Publication number
CN106131138B
CN106131138B CN201610476340.0A CN201610476340A CN106131138B CN 106131138 B CN106131138 B CN 106131138B CN 201610476340 A CN201610476340 A CN 201610476340A CN 106131138 B CN106131138 B CN 106131138B
Authority
CN
China
Prior art keywords
data
request
listener
session
queue
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
CN201610476340.0A
Other languages
Chinese (zh)
Other versions
CN106131138A (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.)
Inspur Software Co Ltd
Original Assignee
Inspur Software 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 Inspur Software Co Ltd filed Critical Inspur Software Co Ltd
Priority to CN201610476340.0A priority Critical patent/CN106131138B/en
Publication of CN106131138A publication Critical patent/CN106131138A/en
Application granted granted Critical
Publication of CN106131138B publication Critical patent/CN106131138B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/55—Push-based network services
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/56—Provisioning of proxy services
    • H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Information Transfer Between Computers (AREA)

Abstract

本发明公开一种基于非阻塞队列的展示数据实时推送系统和方法,涉及数据通信中的数据推送技术，改进了原有数据推送到浏览器的方式，由轮询读取共享内存的方式，改为利用非阻塞队列监听公共数据的产生，在会话安全的情况下，并根据请求的会话信息，将计算结果数据有区别的实时主动推送到浏览器进行展示。该系统由WEB组件、数据路由、公共监听器、会话监听器、数据池以及缓存管理器六个技术组件构成。本发明可以在会话级别做到个性化的推送，有效的提高内存的使用率，提高数据推送的实时性，进而提高资源使用效率。

The invention discloses a real-time push system and method for display data based on non-blocking queues, relates to data push technology in data communication, improves the way of pushing original data to browsers, reads the shared memory by polling, and improves In order to use the non-blocking queue to monitor the generation of public data, in the case of session security, and according to the requested session information, the calculation result data is actively pushed to the browser in real time for display. The system consists of six technical components: WEB component, data routing, public listener, session listener, data pool and cache manager. The present invention can achieve personalized push at the session level, effectively improve the utilization rate of memory, improve the real-time performance of data push, and further improve the efficiency of resource use.

Description

A kind of real-time supplying system of display data and method based on non-obstruction queue
Technical field
The present invention relates to the data-pushing technology in data communication, specifically a kind of displaying based on non-obstruction queue The real-time supplying system of data and method.
Background technique
Currently, in application server end and client data push technology, push technology for long-polling and Two kinds of data-pushing implementations of websocket are there are relatively big difference, and long-polling shares based on memory, polling request Data in audit memory；Websocket is based on monitoring in real time, establishes after monitoring, after data variation, real-time calling interface is pushed away It send.Current push technology is supported the data of two ways and disunity, is often required to realize two sets of backstages, moreover, The push mode of websocket, data-pushing is excessively frequent, can server-side network plug is dead, influences whether Client browse The normal operation of device.
Summary of the invention
The present invention is directed to the demand and shortcoming of current technology development, provides a kind of displaying number based on non-obstruction queue Supplying system and method when factually.
A kind of real-time supplying system of display data and method based on non-obstruction queue of the present invention, solves above-mentioned technology Problem is the technical solution adopted is as follows: a kind of real-time supplying system of display data based on non-obstruction queue, system tray Structure specifically includes that WEB component, data routing, public monitor, session monitor, data pool and six skills of cache manager Art component；Wherein, WEB component is responsible for communicating with client browser, and WEB component receives the http request of browser, data road By receiving the request of WEB component, and judge request type, forwards requests to corresponding monitor；Public monitor is responsible for prison Readjustment global data is listened, receives the request that data routing forwarding comes, and when data change, respond request；The meeting Words monitor is responsible for monitoring readjustment detailed data, receives the request that data routing forwarding comes；The data pool is responsible for generating number According to index, cache manager is called to carry out data storage；The cache manager is responsible for receiving data, executes serializing, and root It is stored according to caching rank, the data after unserializing is provided according to data directory.
Preferably, WEB component receives the http request of browser, gets parms from http request, and calls other skills Art component；After other technologies component returns to request content, return request content is assembled according to format and sends back to browser.
Preferably, the data routing is responsible for receiving the request of WEB component, stores the request routing table of monitor, and root Request type is judged according to the parameter of request, and corresponding monitor is forwarded to according to request routing table.
Preferably, when global data has any variation, public monitor starting is triggered, built-in non-obstruction monitors queue； When data change in data pool, data directory actively can be put into non-obstruction and monitor queue by data pool.
Preferably, the corresponding prison when request needs the detailed data monitored to change, in meeting triggering session monitor Listen thread；Receive the request that data routing forwarding comes, individually establish thread, creates non-obstruction and monitor queue, monitored；? When data in data pool change, data directory is actively put into non-obstruction and monitors queue by data pool, and session monitor is rung It should request.
Preferably, the data pool is responsible for the calculated result of other assemblies in reception system, establishes the data of calculated result Index, and be distributed in corresponding monitor；After calculated result serializing, data storage is carried out by cache manager；Work as prison When device being listened to be triggered, holds data directory and obtain data from data pool, data pool is according to data directory, from cache manager Obtain data respond request.
A kind of real-time method for pushing of display data based on non-obstruction queue monitors common data using non-obstruction queue It generates, and according to the session information of request, the distinguishing real-time active push of calculation result data is shown to browser； Detailed process includes the following steps:
1) client browser initiates request, the real-time calculation result data of request；
2) WEB component receives request, and necessary parameter is obtained from request, after assembling, calls data routing；It carries out complete Office monitors or personalized monitoring.
Preferably, global monitor includes the following steps:
Branch line process a1: data route the content according to request monitoring, judge this request according to request routing table, need road By to public monitor；
Branch line process a2: after public monitor receives request, request is added in readjustment list；When data pool sends number After indexing monitor, monitor calls data pool, obtains data；
Branch line process a3: data pool calls cache manager to obtain data according to incoming index information；
Branch line process a4: cache manager after unserializing data, returns to public monitoring according to incoming index information Device；
Branch line process a5: the data obtained from cache manager are returned to WEB component by public monitor；
After branch line process a6:WEB component receives data, data are assembled according to the format of agreement and return to browser.
Preferably, personalized monitor includes the following steps:
Branch line process b1: data route the content according to request monitoring, judge that this request needs road according to request routing table By to session monitor；
Branch line process b2: after session monitor receives request, according to the session id carried in request, corresponding non-resistance is obtained Plug monitors queue；After data pool sends data directory to monitor, monitor calls data pool, obtains data.
Branch line process b3: data pool calls cache manager to obtain data according to incoming data directory；
Branch line process b4: cache manager after unserializing data, returns to session monitoring according to incoming index information Device；
Branch line process b5: the data obtained from cache manager are returned to WEB component by session monitor；
After branch line process b6:WEB component receives data, data are assembled according to the format of agreement and return to browser.
Preferably, in branch line process b2, if obtaining less than for new session, the non-obstruction of creation monitors queue, request New creation is added to monitor in the readjustment list of queue；If can get, request is directly added to corresponding monitoring queue It adjusts back in list.
A kind of real-time supplying system of display data and method and prior art phase based on non-obstruction queue of the present invention Than having the beneficial effect that the present invention for calculating in development process in real time, shows that application is (clear from server end to client Look at device) the real-time calculation result data of push conversation rank；It can effectively solve the problem that the technical problems existing in the prior art, it can It avoids overlapping development, improve development efficiency；It can accomplish personalized push, the effective use for improving memory in session-level Rate improves the real-time of data-pushing, and then improves resource utilization.
Figure of description
Attached drawing 1 is the operation schematic diagram of the real-time supplying system of display data based on non-obstruction queue.
Specific embodiment
To make the objectives, technical solutions, and advantages of the present invention clearer, below in conjunction with specific embodiment, to this hair A kind of bright real-time supplying system of display data and method further description based on non-obstruction queue.
In order to solve under real-time computing technique frame, how efficiently, accurately, in session-level realize that data push in real time The problem of to client, the invention discloses a kind of real-time supplying systems of display data and method based on non-obstruction queue, change It is pushed to the mode of browser into legacy data, the mode of shared drive is read by poll, is changed to monitor team using non-obstruction Column are realized as core technology.The present invention monitors the generation of common data using non-obstruction queue, in the feelings of secure session Under condition, and according to the session information of request, the distinguishing real-time active push of calculation result data is shown to browser.
Embodiment:
A kind of real-time supplying system of display data based on non-obstruction queue, system architecture described in the present embodiment are mainly wrapped It includes: WEB component, data routing, public monitor, session monitor, data pool and the big component of cache manager technology six；Its In, the WEB component is responsible for communicating with client browser, and WEB component receives the http request of browser, and data routing receives The request of WEB component, and judge request type, forward requests to corresponding monitor；The public monitor is responsible for monitoring Global data is adjusted back, receives the request that data routing forwarding comes, and when data change, respond request；The session Monitor is responsible for monitoring readjustment detailed data, receives the request that data routing forwarding comes；The data pool is responsible for generating data Index calls cache manager to carry out data storage；The cache manager is responsible for receiving data, executes serializing, and according to Caching rank is stored, and the data after unserializing are provided according to data directory.
The WEB component is responsible for communicating with client browser.WEB component receives the http request of browser, from http It gets parms in request, and calls other technologies component；After other technologies component returns to request content, assembles and return according to format Request content sends back to browser.Here, agreement format when format is each project implementation, each project are different；Usually all Using json data format.
The data routing is responsible for receiving the request of WEB component, stores the request routing table of monitor, and according to request Parameter judges request type, is forwarded to corresponding monitor according to request routing table.It is opened by public monitor and session monitor When dynamic, the information that Active Registration can be monitored is into request routing table.
The public monitor is responsible for the monitoring readjustment of global data；Public affairs can be all triggered when global data has any variation Monitor altogether；When starting, built-in non-obstruction monitors queue, and when data change in data pool, data pool can be actively data Index is put into non-obstruction and monitors queue.Receive the request that data routing forwarding comes, and when data change, response is asked It asks.It is 10 seconds that public monitor requests the longest retention time every time, more than the request of this time, can actively be disconnected, to keep The performance of monitor.The global data includes: the data of listening components generating state variation, the highest total amount of abstraction hierarchy According to, need the detailed data broadcasted, global data is by data pool management.
The session monitor is the monitor according to conversation establishing, is responsible for the monitoring readjustment of detailed data；When request needs It, all can correspondence listening thread in triggering session monitor when the detailed data to be monitored changes；Receive data routing to turn Thread is individually established in the request sent, is created non-obstruction and is monitored queue, monitored, and the data in data pool occur When variation, data directory actively can be put into non-obstruction and monitor queue by data pool, and session monitor at this time can respond request.Session It is 10 seconds that monitor requests the longest retention time every time, more than the request of this time, can actively be disconnected, to keep monitor Performance.The detailed data refers to that in addition to global data, the data in other data pools, detailed data is by data pool management.
The data pool is responsible for the calculated result of other assemblies in reception system, establishes the data directory of calculated result, and It is distributed in corresponding monitor, after calculated result serializing, data storage is carried out by cache manager.When monitor is touched When hair, holds data directory and obtain data from data pool, data pool obtains data according to data directory from cache manager Respond request.
The cache manager is responsible for receiving data, serializing is executed, and stored according to caching rank, according to data Index provides the data after unserializing；Caching rank divides three-level: local file storage, local memory storage, cache Storage.Data referencing and incoming index information after cache manager storage establish key-value pair, save in memory.Data pool Holding index information calls cache manager to obtain the data after unserializing.
Using the real-time supplying system of display data described in the present embodiment, a kind of real-time method for pushing of display data is realized, it should Method specific implementation process includes the following steps:
1) client browser initiates request, the real-time calculation result data of request；Here request is long- What polling or websocket technology was realized, long-polling realizes the http calling referred to through rest style, passes through The mode of poll is continual to obtain real-time calculation result data；Websocket realization refers to by establishing browser and service The socket connection at device end, is connected, server active push data to browser end by socket；
2) WEB component receives request, and necessary parameter is obtained from request, after assembling, calls data routing；Such as attached drawing Shown in 1: being divided into global monitor and monitor two kinds of monitoring types with personalized.
Global monitor mainly comprises the following processes: branch line process a1, branch line process a2, branch line process a3, branch line mistake Journey a4, branch line process a5 and branch line process a6；It is as shown in Fig. 1:
Branch line process a1: data route the content according to request monitoring, judge this request according to request routing table, need road By to public monitor.Active note of the data source of request routing table when public monitor and session monitor start Volume；
Branch line process a2: after public monitor receives request, request is added in readjustment list；When data pool sends number After indexing monitor, monitor calls data pool, obtains data；
Branch line process a3: data pool calls cache manager to obtain data according to incoming index information；
Branch line process a4: cache manager after unserializing data, returns to public monitoring according to incoming index information Device；
Branch line process a5: the data obtained from cache manager are returned to WEB component by public monitor；
After branch line process a6:WEB component receives data, data are assembled according to the format of agreement and return to browser.
Personalized monitor mainly comprises the following processes: branch line process b1, branch line process b2, branch line process b3, branch line Process b4, branch line process b5 and branch line process b6；It is as shown in Fig. 1:
Branch line process b1: data route the content according to request monitoring, judge this request according to request routing table, need road By to session monitor；
Branch line process b2: after session monitor receives request, according to the session id carried in request, corresponding non-resistance is obtained Plug monitors queue.If obtaining less than for new session, the non-obstruction of creation monitors queue, and request is added to new creation and is monitored In the readjustment list of queue；If can get, directly request is added in the corresponding readjustment list for monitoring queue.Work as data After pond sends data directory to monitor, monitor calls data pool, obtains data.
Branch line process b3: data pool calls cache manager to obtain data according to incoming index information；
Branch line process b4: cache manager after unserializing data, returns to session monitoring according to incoming index information Device；
Branch line process b5: the data obtained from cache manager are returned to WEB component by session monitor；
After branch line process b6:WEB component receives data, data are assembled according to the format of agreement and return to browser.
Above-mentioned specific embodiment is only specific case of the invention, and scope of patent protection of the invention includes but is not limited to Above-mentioned specific embodiment, any person of an ordinary skill in the technical field that meet claims of the present invention and any The appropriate change or replacement done to it, all shall fall within the protection scope of the present invention.

Claims (8)

1.一种基于非阻塞队列的展示数据实时推送系统，其特征在于,其系统架构主要包括：WEB组件、数据路由、公共监听器、会话监听器、数据池以及缓存管理器六个技术组件；其中，WEB组件负责与客户端浏览器通讯，WEB组件接受浏览器的http请求，数据路由接收WEB组件的请求，并判断请求类型，将请求转发到对应的监听器；公共监听器负责监听回调全局数据，接受数据路由转发过来的请求，并在数据发生变化时，响应请求；所述会话监听器负责监听回调明细数据，接受数据路由转发过来的请求；所述数据池负责生成数据索引，调用缓存管理器进行数据存储；所述缓存管理器负责接收数据，执行序列化，并根据缓存级别进行存储，根据数据索引提供反序列化之后的数据。1. a display data real-time push system based on non-blocking queue, is characterized in that, its system architecture mainly comprises: WEB component, data routing, public listener, session listener, data pool and six technical components of cache manager; Among them, the WEB component is responsible for communicating with the client browser, the WEB component accepts the http request of the browser, the data routing receives the request of the WEB component, judges the request type, and forwards the request to the corresponding listener; the public listener is responsible for monitoring the global callback Data, accept the request forwarded by the data route, and respond to the request when the data changes; the session listener is responsible for monitoring the callback detailed data and accepting the request forwarded by the data route; the data pool is responsible for generating the data index and calling the cache The manager performs data storage; the cache manager is responsible for receiving data, performing serialization, storing according to the cache level, and providing the deserialized data according to the data index. 2.根据权利要求1所述一种基于非阻塞队列的展示数据实时推送系统，其特征在于,WEB组件接受浏览器的http请求，从http请求中获取参数，并调用其他技术组件；其他技术组件返回请求内容后，按照格式组装返回请求内容发回给浏览器。2. a kind of display data real-time push system based on non-blocking queue according to claim 1, is characterized in that, WEB component accepts the http request of browser, obtains parameter from http request, and calls other technical components; Other technical components After returning the requested content, assemble the returned request content according to the format and send it back to the browser. 3.根据权利要求2所述一种基于非阻塞队列的展示数据实时推送系统，其特征在于,所述数据路由负责接收WEB组件的请求，存储监听器的请求路由表，并根据请求的参数判断请求类型，根据请求路由表转发到对应的监听器。3. a kind of display data real-time push system based on non-blocking queue according to claim 2, is characterized in that, described data route is responsible for receiving the request of WEB component, the request routing table of storage listener, and judges according to the parameter of request The request type is forwarded to the corresponding listener according to the request routing table. 4.根据权利要求3所述一种基于非阻塞队列的展示数据实时推送系统，其特征在于,当全局数据有任何变化时，触发公共监听器启动，内建非阻塞监听队列；当数据池中数据有变化时，数据池会主动把数据索引放入非阻塞监听队列。4. a kind of display data real-time push system based on non-blocking queue according to claim 3, is characterized in that, when global data has any change, trigger public listener to start, built-in non-blocking monitoring queue; When the data changes, the data pool will actively put the data index into the non-blocking listening queue. 5.根据权利要求4所述一种基于非阻塞队列的展示数据实时推送系统，其特征在于,当请求需要监听的明细数据发生变化时，会触发会话监听器中的对应监听线程；接受数据路由转发过来的请求，单独建立线程，创建非阻塞监听队列，进行监听；在数据池中的数据发生变化时，数据池主动把数据索引放入非阻塞监听队列，会话监听器响应请求。5. a kind of display data real-time push system based on non-blocking queue according to claim 4, is characterized in that, when the detailed data that request needs to monitor changes, can trigger the corresponding monitor thread in the session monitor; Accept data routing For the forwarded request, a separate thread is created to create a non-blocking listening queue for monitoring; when the data in the data pool changes, the data pool actively puts the data index into the non-blocking monitoring queue, and the session listener responds to the request. 6.根据权利要求5所述一种基于非阻塞队列的展示数据实时推送系统，其特征在于,所述数据池负责接收系统中其他组件的计算结果，建立计算结果的数据索引，并分发到对应的监听器中；计算结果序列化后，通过缓存管理器进行数据存储；当监听器被触发时，持有数据索引从数据池中获取数据，数据池根据数据索引，从缓存管理器中获取数据响应请求。6. a kind of display data real-time push system based on non-blocking queue according to claim 5, is characterized in that, described data pool is responsible for receiving the calculation result of other components in the system, establishes the data index of calculation result, and distributes to corresponding In the listener; after the calculation result is serialized, the data is stored through the cache manager; when the listener is triggered, it holds the data index to obtain data from the data pool, and the data pool obtains data from the cache manager according to the data index Respond to requests. 7.一种基于非阻塞队列的展示数据实时推送方法，其特征在于,利用非阻塞队列监听公共数据的产生，并根据请求的会话信息，将计算结果数据有区别的实时主动推送到浏览器进行展示；具体过程包括如下步骤：7. A real-time push method of display data based on non-blocking queue, is characterized in that, utilizes non-blocking queue to monitor the generation of public data, and according to the session information of request, the real-time active push of calculation result data is different to browser for carrying out. Display; the specific process includes the following steps: 1)客户端浏览器发起请求，请求获取实时计算结果数据；1) The client browser initiates a request to obtain real-time calculation result data; 2)WEB组件接受请求，并从请求中获取必要的参数，组装后，调用数据路由；进行全局监听或个性化监听；2) The WEB component accepts the request, obtains the necessary parameters from the request, and calls the data routing after assembly; performs global monitoring or personalized monitoring; 所述全局监听包括如下步骤：The global monitoring includes the following steps: 支线过程a1：数据路由根据请求监听的内容，根据请求路由表判断此请求需要路由到公共监听器；Branch process a1: The data routing determines that the request needs to be routed to the public listener according to the content of the request to monitor according to the request routing table; 支线过程a2：公共监听器接受请求后，把请求加入到回调列表中；当数据池发送数据索引到监听器后，监听器调用数据池，获取数据；Branch process a2: After the public listener accepts the request, it adds the request to the callback list; when the data pool sends the data index to the listener, the listener calls the data pool to obtain the data; 支线过程a3：数据池根据传入的索引信息，调用缓存管理器获取数据；Branch process a3: The data pool calls the cache manager to obtain data according to the incoming index information; 支线过程a4：缓存管理器根据传入的索引信息，反序列化数据后，返回给公共监听器；Branch process a4: The cache manager deserializes the data according to the incoming index information, and returns it to the public listener; 支线过程a5：公共监听器把从缓存管理器获取的数据返回给WEB组件；Branch process a5: The public listener returns the data obtained from the cache manager to the WEB component; 支线过程a6：WEB组件接受数据后，根据约定的格式组装数据并返回给浏览器；Branch process a6: After the WEB component accepts the data, it assembles the data according to the agreed format and returns it to the browser; 所述个性化监听包括如下步骤：The personalized monitoring includes the following steps: 支线过程b1：数据路由根据请求监听的内容，根据请求路由表判断此请求需要路由到会话监听器；Branch line process b1: The data routing determines that the request needs to be routed to the session listener according to the content of the request monitoring according to the request routing table; 支线过程b2：会话监听器接受请求后，根据请求中携带的会话ID，获取对应的非阻塞监听队列；当数据池发送数据索引到监听器后，监听器调用数据池，获取数据；Branch process b2: After the session listener accepts the request, it obtains the corresponding non-blocking listening queue according to the session ID carried in the request; after the data pool sends the data index to the listener, the listener calls the data pool to obtain the data; 支线过程b3：数据池根据传入的数据索引，调用缓存管理器获取数据；Branch process b3: The data pool calls the cache manager to obtain data according to the incoming data index; 支线过程b4：缓存管理器根据传入的索引信息，反序列化数据后，返回给会话监听器；Branch process b4: The cache manager deserializes the data according to the incoming index information, and returns it to the session listener; 支线过程b5：会话监听器把从缓存管理器获取的数据返回给WEB组件；Branch process b5: The session listener returns the data obtained from the cache manager to the WEB component; 支线过程b6：WEB组件接受数据后，根据约定的格式组装数据并返回给浏览器。Branch line process b6: After the WEB component accepts the data, it assembles the data according to the agreed format and returns it to the browser. 8.根据权利要求7所述的一种基于非阻塞队列的展示数据实时推送方法，其特征在于,支线过程b2中，若获取不到，则为新的会话，创建非阻塞监听队列，把请求加入到新创建监听队列的回调列表中；若能获取到，则直接把请求加入到对应监听队列的回调列表中。8. a kind of display data real-time push method based on non-blocking queue according to claim 7, is characterized in that, in branch line process b2, if not obtained, then be new session, create non-blocking monitoring queue, request Add it to the callback list of the newly created listening queue; if it can be obtained, directly add the request to the callback list of the corresponding listening queue.
CN201610476340.0A 2016-06-27 2016-06-27 A real-time push system and method of display data based on non-blocking queue Active CN106131138B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201610476340.0A CN106131138B (en) 2016-06-27 2016-06-27 A real-time push system and method of display data based on non-blocking queue

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201610476340.0A CN106131138B (en) 2016-06-27 2016-06-27 A real-time push system and method of display data based on non-blocking queue

Publications (2)

Publication Number Publication Date
CN106131138A CN106131138A (en) 2016-11-16
CN106131138B true CN106131138B (en) 2019-06-04

Family

ID=57267240

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201610476340.0A Active CN106131138B (en) 2016-06-27 2016-06-27 A real-time push system and method of display data based on non-blocking queue

Country Status (1)

Country Link
CN (1) CN106131138B (en)

Families Citing this family (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN107241425B (en) * 2017-06-26 2020-11-27 中国石油大学(华东) A non-blocking terminal information hopping method based on Web service
CN107239237A (en) * 2017-06-28 2017-10-10 阿里巴巴集团控股有限公司 Method for writing data and device and electronic equipment
CN109286642A (en) * 2017-07-20 2019-01-29 武汉楚鼎信息技术有限公司 A kind of method of Push active push speed-optimization
CN109976923B (en) * 2019-03-12 2020-12-18 深圳点猫科技有限公司 Component communication implementation method and device based on WeChat applet
CN110321358A (en) * 2019-06-26 2019-10-11 深圳供电局有限公司 User data editing method and device
CN110730305A (en) * 2019-10-28 2020-01-24 北京旷视科技有限公司 Multi-source snapshot image processing and accessing method and device based on blocking queue
CN111262923B (en) * 2020-01-14 2022-08-19 深圳壹账通智能科技有限公司 Data synchronization method and device, computer equipment and storage medium
CN114756357B (en) * 2022-06-14 2022-10-14 浙江保融科技股份有限公司 Non-blocking distributed planned task scheduling method based on JVM (Java virtual machine)

Family Cites Families (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7103890B2 (en) * 2003-03-24 2006-09-05 Microsoft Corporation Non-blocking buffered inter-machine data transfer with acknowledgement
US9141481B1 (en) * 2010-08-06 2015-09-22 Open Invention Network, Llc System and method for reliable non-blocking messaging for multi-process application replication
CN101470773A (en) * 2007-12-25 2009-07-01 山东易通商业经纪有限公司 Method for implementing web page game system based on WEB browser
CN102880475B (en) * 2012-10-23 2015-08-12 普元信息技术股份有限公司 Based on the real-time event disposal system of cloud computing and method in computer software
CN104468649B (en) * 2013-09-16 2018-06-05 北大方正集团有限公司 Server, terminal, data delivery system and data push method
US10257316B2 (en) * 2014-03-30 2019-04-09 Cisco Technology, Inc. Monitoring of node.js applications
CN105426326A (en) * 2015-11-05 2016-03-23 上海斐讯数据通信技术有限公司 High-concurrency queue storage method and system

Also Published As

Publication number Publication date
CN106131138A (en) 2016-11-16

Similar Documents

Publication Publication Date Title
CN106131138B (en) A real-time push system and method of display data based on non-blocking queue
US8838792B2 (en) Identity provider instance discovery
CN101969391B (en) Cloud platform supporting fusion network service and operating method thereof
US20110307541A1 (en) Server load balancing and draining in enhanced communication systems
WO2019206296A1 (en) Fault handling method and device for gateway server
US10812598B2 (en) Unified, browser-based enterprise collaboration platform
CN106453288A (en) Asynchronous mode supporting distributed micro service framework system and implementation method thereof
CN101795222B (en) Multi-stage forward service system and method
CN104011701A (en) content delivery network
CN102045270A (en) Chat server system, method for constructing chat server system and chat system
US20120036208A1 (en) Polling-based secure network message notification system and method with performance enhancing features
CN102215266B (en) The implementation method and persistence service system of persistence service
CN113630366A (en) Internet of things equipment access method and system
CN102118325B (en) Method and device for configuring chat client terminal, as well as chat client terminal
CN104519088A (en) Buffer memory system realization method and buffer memory system
CN105656974B (en) A method and system for processing satellite observation data
WO2008082775A1 (en) Method and system for a context manager for a converged services framework
CN103812940A (en) Centralized management method for cluster sessions
CN104168176B (en) A kind of instant communication method, client, server and system
CN106330953A (en) An intelligent router device, server device and data processing method thereof
CN108076111B (en) System and method for distributing data in big data platform
CN106254346B (en) Security policy update method and system
WO2014048110A1 (en) Processing method and system for proxy relationship, proxy server and terminal
EP3031196B1 (en) Mirror presence between websites
CN114844988A (en) Service processing method, device, system and storage medium of virtualized color ring platform

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant