本章先讲解优先级队列和二叉堆的结构。下一篇代码实现从一个需求开始假设有这样一个需求：在一个子线程中，不停的从一个队列中取出一个任务，执行这个任务,直到这个任务处理完毕，再取出下一个任务，再执行。其实和Android的Handler机制中的Looper不停的从MessageQueue中取出一个消息然后处理是一样的。不过这个需

什么是异步模式？不会等待当前任务执行完毕，才会去执行下一个任务，这就是异步模式（Asynchronous）。开启异步后，就会跳过本任务，开始执行下一个任务，后续的逻辑一般会通过回调函数的方式定义。异步模式执行中，涉及到调用栈（Callstack）、消息队列

根据官方文档，所有自己编写的任务类需继承抽象类app/Jobs/Job.php，内容如下：php<?phpnamespaceApp\Jobs;useIlluminate\Bus\Queueable;useIlluminate\Contracts\Queue\ShouldQueue;useIlluminate\Queue\{In

1、Kafka是什么ApacheKafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。 Kafka最初是由LinkedIn开发，并于2011年初开源。2012年10月从ApacheIncubator毕业。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。

在Java多线程应用中，队列的使用率很高，多数生产消费模型的首选数据结构就是队列。Java提供的线程安全的Queue可以分为阻塞队列和非阻塞队列，其中阻塞队列的典型例子是BlockingQueue，非阻塞队列的典型例子是ConcurrentLinkedQueue，在实际应用中要根据实际需要选用阻塞队列或者非阻塞队列。注：什么叫线程安全？这个首先要明确。

几种类型的BlockingQueueArrayBlockingQueue：一个由数组结构组成的有界阻塞队列。LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列。PriorityBlockingQueue：一个支持优先级排序的无界阻塞队列。DelayQueue：一个使用优先级队列实现的无界阻塞队列。Synchro

RabbitMQ是一款使用Erlang开发的开源消息队列。本文假设读者对RabbitMQ是什么已经有了基本的了解，如果你还不知道它是什么以及可以用来做什么，建议先从官网的RabbitMQTutorials(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fwww.rabbitmq.com

RabbitMQ数据丢失分析简要系统流程场景图!简要系统流程场景图(http://wx1.sinaimg.cn/mw690/9e2b10fagy1fst744xqz0j20jf03a746.jpg)数据丢失场景以下场景分析前提是队列持久化，交换器持久化，消息持久化，非持久化场

阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加操作支持阻塞地插入和移除方法。支持阻塞插入的方法是指当队列满时会阻塞插入元素的线程，直到队列不满；支持阻塞移除的方法是指当队列为空时获取元素的线程无法继续获取元素直到队列不空。可以发现阻塞队列非常适合消费者和生产者场景下进行使用，生产者生产数据就是向阻塞队列中插入元素，消费者消