七、curator recipes之阻塞队列SimpleDistributedQueue

简介

Java在单机环境实现了BlockQueue阻塞队列，与之类似的curator实现了分布式场景下的阻塞队列，SimpleDistributedQueue

官方文档：http://curator.apache.org/curator-recipes/simple-distributed-queue.html

javaDoc：http://curator.apache.org/apidocs/org/apache/curator/framework/recipes/queue/SimpleDistributedQueue.html

注意：zookeeper虽然可以实现队列，但是官方并不推荐使用zookeeper来做队列，主要原因在于zookeeper的空间大小设计的比较小，且对于大量数据的处理性能比较低，所以比较适合用户处理一些元数据以及应用协调，对于大量数据的建议使用其它分布式队列，比如redisson之类的，或者采用共享存储来实现。

代码示例

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.queue.SimpleDistributedQueue;
import org.apache.curator.retry.ExponentialBackoffRetry;public class SimpleQueueDemo {private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 2));private static String path = "/queue/path001";public static void main(String[] args) throws InterruptedException {client.start();System.out.println("started");SimpleDistributedQueue queue = new SimpleDistributedQueue(client, path);new Thread(() -> {try {System.out.println("sleeping");Thread.sleep(3000);System.out.println("sleep end");new SimpleDistributedQueue(client, path).offer("lay".getBytes("utf-8"));System.out.println("offered");} catch (Exception e) {System.out.println("exception");e.printStackTrace();}}).start();System.out.println("polling");String data = null;try {data = new String(queue.take());} catch (Exception e) {e.printStackTrace();}System.out.println("data=" + data);client.close();}
}

输出结果

started
polling
sleeping
sleep end
offered
data=lay

主线程会阻塞直到offer了数据

转载于:https://www.cnblogs.com/lay2017/p/10264503.html

七、curator recipes之阻塞队列SimpleDistributedQueue相关推荐

聊聊并发（七）——Java中的阻塞队列
1. 什么是阻塞队列? 阻塞队列(BlockingQueue)是一个支持两个附加操作的队列.这两个附加的操作是:在队列为空时,获取元素的线程会等待队列变为非空.当队列满时,存储元素的线程会等待队列可用 ...
无界阻塞队列 LinkedBlockingQueue 原理探究
2019独角兽企业重金招聘Python工程师标准>>> 一.前言本文介绍下使用独占锁实现的阻塞队列LinkedBlockingQueue的实现. 二. LinkedBlocking ...
并发队列-无界非阻塞队列 ConcurrentLinkedQueue 原理探究
并发队列-无界非阻塞队列 ConcurrentLinkedQueue 原理探究 http://www.importnew.com/25668.html 一. 前言常用的并发队列有阻塞队列和非阻塞队列 ...
《Java并发编程的艺术》之阻塞队列
阻塞队列是一个支持两个附加操作的队列.这两个附加的操作支持阻塞的插入和移除方法: 1) 支持阻塞的插入方法:当队列满时,队列会阻塞执行插入的线程 2) 支持阻塞的移除方法:当队列空时,队列会阻塞执行移 ...
Java面试之阻塞队列
阻塞队列概念队列队列就可以想成是一个数组,从一头进入,一头出去,排队买饭(FIFO),和栈是一样的FIFO 阻塞队列 BlockingQueue 阻塞队列,排队拥堵,首先它是一个队列,而一个阻塞 ...
java多线程12：阻塞队列Queue
本篇主要内容如下: 本篇主要内容帮你总结好的阻塞队列: 18种Queue总结一.Queue自我介绍队列原理图 1.1 Queue自我介绍 hi,大家好,我的英文名叫Queue,中文名叫队列,无论 ...
BlockingQueue(阻塞队列)
BlockingQueue 阻塞队列(BlockingQueue) 是一个支持两个附加操作的队列.这两个附加的操作是:在队列为空时,获取元素的线程会等待队列变为非空.当队列满时,存储元素的线程会等待队 ...
并发编程5：Java 阻塞队列源码分析（下）
上一篇并发编程4:Java 阻塞队列源码分析(上) 我们了解了 ArrayBlockingQueue, LinkedBlockingQueue 和 PriorityBlockingQueue,这篇文 ...
J.U.C 学习（三）之 “阻塞队列”
生产者消费者的实际使用相信大家都有使用过分布式消息队列,比如 ActiveMQ. kafka.RabbitMQ 等等,消息队列的是有可以使得程序之间实现解耦,提升程序响应的效率. 如果我们把多线程环 ...
并发编程（十三）：阻塞队列之ArrayBlockingQueue
一,关联源码链接 * 并发编程(四):AbstractQueuedSynchronizer源码分析 * 并发编程(五):AQS之重入锁ReentrantLock * 并发编程(七):AQS之Condi ...

七、curator recipes之阻塞队列SimpleDistributedQueue

简介

代码示例

七、curator recipes之阻塞队列SimpleDistributedQueue相关推荐

最新文章

热门文章