我们的常用的系统中，程序的工作通常是有事件驱动和消息驱动两种方式，在Android系统中，Java应用程序是靠消息驱动来工作的。消息驱动的原理就是：1\.有一个消息队列，可以往这个队列中投递消息;2\.有一个消息循环，不断从消息队列中取出消息，然后进行处理。在Android中通过Looper来封装消息循环，同时在其中封装了一个消息队

1.RabbitMQ简介消息中间件也可以称消息队列，是指用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息队列模型，可以在分布式环境下扩展进程的通信。RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由（包

AMQP消息模型RabbitMQ是基于AMQP（高级消息队列协议）的一个开源实现，其内部实际也是AMQP的基本概念。AMQP的消息发送流程有如下几个步骤：1.消息生产者（producer）将消息发布到Exchange中；2.Exchange根据队列的绑定关系将消息分发到不同的队列（Queue

JMS消息传送模型    点对点消息传送模型　　在点对点消息传送模型中，应用程序由消息队列，发送者，接收者组成。每一个消息发送给一个特殊的消息队列，该队列保存了所有发送给它的消息(除了被接收者消费掉的和过期的消息)。点对点消息模型有一些特性，如下：每个消息只有一个接收者；消息发送者和接收者并没有时间依

!(https://oscimg.oschina.net/oscnet/up4977ee0fbc770c92e22d1c7e77c69a7528d.png)前言Redis5新特性中，Streams数据结构的引入，可以说它是在本次迭代中最大特性。它使本次5.x版本迭代中，Redis作为消息队列使用时，得到更完善，更强大的原生

1、场景作用削峰填谷，异步解耦。2、如何保证消息不被重复消费呢？这个问题可以换个思路，保证消息重复消费，其实是保证程序的幂等性。无论消息如何重复，程序运行的结果是一致的。比如消费消息后做数据库插入操作，为了防止消息重复消费，可以在插入前先查询一下有没有对应的数据。3、怎么保证从消息队列里拿到的数据按顺序执

当前笔记中的内容针对的是thinkphpqueue的v1.1.2版本，现在官方已经更新到了v1.1.3版本，下文中提到的几个Bug在最新的master分支上均已修复。笔记中的部分内容还未更新。传统的程序执行流程一般是即时|同步|串行的，在某些场景下，会存在并发低，吞吐量低，响应时间长等问题。在大型系统中，一般会引入消息队列的组件，将流