Method, device and system for realizing high-available distributed queue service

Abstract

This invention discloses a method and a device for realizing high-available distributed queue service. The method comprises the following steps: when a queue interface server receives data sent by a client, requesting Zookeeper server cluster to create persistent sequence nodes of the data; after the nodes are created, storing the data into a local memory queue; when a request for acquiring the data sent by the client is received, extracting queue head data from the local memory queue and requesting the Zookeeper server cluster to delete the persistent sequence nodes of the data; after the nodes are deleted successfully, feeding back the extracted data to the client; and when a node change in the Zookeeper server cluster is monitored, synchronizing a data change caused by the node change into the local memory queue. This invention provides a high available, high extensible and high subsequent queue service realizing plan, and provides a reliable choice for the enterprise application integration and the distributed business collaboration.

Description

technical field [0001] The present invention relates to the communication field, in particular to a method, device and system for realizing high-availability distributed queue service. Background technique [0002] The interface service provides an open platform for third-party developers to use the website provided by the website service provider. The existing interface service provision methods mainly include: [0003] Solution 1: stand-alone version; the queue service data and interface services implemented in this solution are deployed on the same machine, and only one interface server provides external services, and stores data in local memory, files or databases. [0004] Solution 2: Single storage, multi-interface service; this solution has multiple external interface servers, which can provide high concurrency. But the data is stored in a separate cache server or database server. [0005] Solution 3: multi-machine storage, multi-interface server; the data in this ...

AI Technical Summary

Problems solved by technology

[0007] For option 1, there is a single point of failure problem and low concurrency;

[0008] For solution two, data storage may have a single point problem, and if there is no synchronization lock mechanism, data consistency cannot be guaranteed, and if a synchronization lock mechanism is added, efficiency will be reduced

[0009] For scheme three, when accessing the interface, an addressing process is required, which reduces concurrency

And although the data are stored in different machines, for each machine, there is still a stand-alone problem

Images