A Distributed Environment Coordinated Consumption Queue Method and Device
A distributed environment and queue technology, which is applied in the field of distributed environment coordinated consumption queues and distributed environment coordinated consumption queue devices, can solve problems such as inaccurate consumption results and repeated data consumption
- Summary
- Abstract
- Description
- Claims
- Application Information
AI Technical Summary
Problems solved by technology
Method used
Image
Examples
Embodiment 1
[0034] refer to figure 1 , which shows a flow chart of the steps of an embodiment of a method for coordinating a consumption queue in a distributed environment of the present application, which may specifically include the following steps:
[0035] Step 110, for a queue segment to be consumed, the status data of the queue segment obtained based on the lease agreement;
[0036] The embodiment of this application provides a set of leasing protocols for each shard in the multi-consumer cooperative consumption queue in a distributed environment, and realizes the process of multi-computing nodes cooperatively consuming data in multiple shards.
[0037]According to the lease agreement, when a client consumes a shard, it will record its consumption progress in a persistent storage space and update the state data of the shard. The status data of the shard is used to determine whether the shard is being consumed by clients.
[0038] Then for the current client worker A, if it preempt...
Embodiment 2
[0288] refer to figure 2 , which shows a structural block diagram of a system embodiment of a distributed environment coordinated consumption queue of the present application, which may specifically include the following modules:
[0289] A status data acquisition module 310, configured to obtain status data of the queue segment based on a lease agreement for a queue segment to be consumed;
[0290] A consumption judging module 320, configured to judge whether other clients are consuming the queue fragments according to the status data;
[0291]A progress acquiring module 330, configured to update the state data of the queue slice and obtain the current consumption progress of the queue slice if it is determined that no other client is consuming the queue slice;
[0292] The consumption module 340 is configured to continue to consume the queue fragments according to the current consumption progress, and record the new consumption progress of the queue fragments.
[0293] In...
PUM
Abstract
Description
Claims
Application Information
- R&D Engineer
- R&D Manager
- IP Professional
- Industry Leading Data Capabilities
- Powerful AI technology
- Patent DNA Extraction
Browse by: Latest US Patents, China's latest patents, Technical Efficacy Thesaurus, Application Domain, Technology Topic, Popular Technical Reports.
© 2024 PatSnap. All rights reserved.Legal|Privacy policy|Modern Slavery Act Transparency Statement|Sitemap|About US| Contact US: help@patsnap.com