怎么理解消息中间件呢？我们可以把它理解为一个秘书，消息的发布者就是大老板，大老板下午三点要开个会，他只需跟秘书说一声，下午三点，我要开个会，就行了，老板不用管秘书是怎样通知各项目经理的，也不用管项目经理要带什么材料，他所做的只是告诉秘书一声而已。秘书负责与各个项目经理联系，告诉各个项目经理应该准备什么。MQ便相当于”秘书”这个角色。当添加一个商品时，商品服务只需要告诉消息中间件MQ，MQ便去通知其它服务做各自该做的事情，比如通知搜索服务去同步索引库，通知Redis服务去同步缓存，通知生成静态页面等等。

MQ是一个消息中间件，常见的作为MQ的中间件有：

1. ActiveMQ
2. RabbitMQ
3. Kafka

我们今天要学习的是ActiveMQ，其它的都大同小异。那什么时候我们需要用到MQ呢？为了实现系统之间通信，把系统之间调用的耦合度降低的情况下都可以使用MQ。 
下面我会为大家具体介绍一下ActiveMQ。

ActiveMQ

什么是ActiveMQ

ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1规范和J2EE1.4规范的JMS Provider实现，尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。ActiveMQ主要有如下特点：

1. 支持多种语言和协议编写的客户端。语言有Java、C、C++、C#、Ruby、Perl、Python、PHP，应用协议有OpenWire、Stomp REST、WS Notification、XMPP、AMQP。
2. 完全支持JMS1.1和J2EE1.4规范(持久化、XA消息、事务)。
3. 对Spring的支持。ActiveMQ可以很容易内嵌到使用Spring的系统里面去，而且也支持Spring2.0的特性。
4. 通过了常见J2EE服务器(如Geronimo、JBoss 4、GlassFish、WebLogic)的测试，其中通过JCA 1.5 resource adaptors的配置，可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4的商业服务器上。
5. 支持多种传送协议，如in-VM、TCP、SSL、NIO、UDP、JGroups、JXTA。
6. 支持通过JDBC和journal提供高速的消息持久化。
7. 从设计上保证了高性能的集群，客户端—服务器，点对点。
8. 支持Ajax。
9. 支持与Axis的整合。
10. 可以很容易的调用内嵌JMS provider进行测试。

ActiveMQ的消息形式

ActiveMQ对于消息的传递有两种类型：

1. 一种是点对点的，即一个生产者和一个消费者一一对应；
2. 另一种是发布/订阅模式，即一个生产者产生消息并进行发送后，可以由多个消费者进行接收。

JMS规范定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以下一些不同形式的数据，提供现有消息格式的一些级别的兼容性。

• StreamMessage：Java原始值的数据流。
• MapMessage：一套名称-值对。
• TextMessage：一个字符串对象。
• ObjectMessage：一个序列化的 Java对象。
• BytesMessage：一个字节的数据流。

注意：我们用的最多的也就是TextMessage而已。 
我们可以通过下面一张图来加深理解，图上半部分是”发布/订阅者”模式，两个发布者各自发布了一条消息，每条消息都可以被多个Consumer接收到。图下半部分是”面对面”模式，两个发布者各自发布了一条消息，压入队列当中，队列的特点是先进先出，一旦有某个消费者拿走了一条消息，队列中就少了一条消息，剩下的消费者就不可能再消费那条消息了，因此也就做到了一对一。