Queue：基本上，一个队列就是一个先入先出（FIFO）的数据结构Queue接口与List、Set同一级别，都是继承了Collection接口。LinkedList实现了Deque接口。Queue的实现1、没有实现的阻塞接口的LinkedList：实现了java.util.Queue接口和java.util

1、Action的使用        Action类似于mutation，不同之处在于Action提交的是mutation，而不是直接更改状态，Action可以包含任何的异步操作。2、定义以及使用Action代码3、分发Action代码代码action4、Action函数参数

!(http://t10.baidu.com/it/u228874995,3824892753&fm173&s6790ED23D28C78EB1C745CCC000050B0&w640&h331&img.JPEG)Java的Executors框架提供的定长线程池内部默认使用LinkedBlockingQueue作为任务的容器，这个队列是没有

 1.首先kafka会将接收到的消息分区（partition），每个主题（topic）的消息有不同的分区，这样一方面消息的存储就不会受到单一服务器存储空间大小的限制，另一方面消息的处理也可以在多个服务器上并行。 2.其次为了保证高可用，每个分区都会有一定数量的副本(replica)。这样如果有部分服务器不可用，副本所在的服务器就会接替上来，保证应用的

应用ES6的内置对象Promise,让异步函数按顺序执行的例子如下：!(https://oscimg.oschina.net/oscnet/9d7da385127c5df3cdf50b984cc4bca58c7.jpg)上边是四个用Promise处理过的异步执行的函数：fn1、fn2、fn3、fn4下面，让其按顺序执行

示例如下：1、新建Maven项目 asyncexecutor2、pom.xml<projectxmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchemainstance"xsi:sch

RabbitMQ简介AMQP，即AdvancedMessageQueuingProtocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。R

        本书一切灵感均来自于<RabbitMQ实战 高效部署分布式消息队列这本书,书中知识会尽量复现验证,然我们一起学习,一起成长,当然有兴趣的同学还是拜读原著,收益颇丰.消息队列的成长史(是不是看不清,就算看清了也没啥用哈哈哈):!(https://static.oschina.net/uploads/space/2018/031

参考文档http://kafka.apachecn.org/https://www.cnblogs.com/linjiqin/p/11950758.htmlhttps://blog.csdn.net/dayonglove2018/article/details/106925513https://blog.csdn.net/valad

前言我在刚接触使用中间件的时候，发现，中间件的使用并不是最难的，反而是中间件的下载，安装，配置才是最难的。所以，这篇文章我们从头开始学习RabbitMq，真正的从头开始。关于消息队列其实消息队列没有那么神秘，我们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，通过网络传输到主机的某个端口上的。那么，接收数据