淘淘商城系列——ActiveMQ的介绍

时间 2021-01-19

我们在之前学习将搜索功能切换到Solr集群版的时候，每当添加一个商品后，都要把数据库中的数据全部重新导入到索引库中，特别消耗性能和时间，这显然是我们所不能忍受的，这就需要优化我们的方案，最好是在商品添加的时候就单独将该商品同步到索引库中，这样便简单快捷地实现了数据库与索引库的同步。摆在我们面前的方案有三个：

在taotao-manager中，添加商品的业务逻辑中，添加一段同步索引库的业务逻辑。
缺点：很明显，这样会导致业务逻辑耦合度很高，业务拆分不明确，这与我们当初拆分工程，职能单一、明确的原则相违背，故不可采用。
业务逻辑在taotao-search中实现，调用服务在taotao-manager实现，业务逻辑分开。
缺点：服务与服务之间耦合度变高，服务的启动有先后顺序。服务设计的原则便是各自干各自的活儿，启动要保证互不依赖，服务之间不应该有调用行为，一旦有调用行为，依赖的一方便会因被依赖一方出现故障而无法工作。
使用消息队列，MQ是一个消息中间件，如下图所示。

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

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

ActiveMQ
RabbitMQ
Kafka

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

ActiveMQ

什么是ActiveMQ

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

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

ActiveMQ的消息形式

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

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

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

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

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