从入门到精通的activemq

关键词：

这是关于消息中间件ActiveMQ的一个系列专题文章，将涵盖JMS、ActiveMQ的初步入门及API详细使用、两种经典的消息模式（PTP and Pub/Sub）、与Spring整合、ActiveMQ集群、监控与配置优化等。话不多说，我们来一起瞧一瞧！

JMS
首先来说较早以前，也就是没有JMS的那个时候，很多应用系统存在一些缺陷：

1.通信的同步性

client端发起调用后，必须等待server处理完成并返回结果后才能继续执行

2.client 和 server 的生命周期耦合太高

client进程和server服务进程都必须可用，如果server出现问题或者网络故障，那么client端会收到异常

3.点对点通信

client端的一次调用只能发送给某一个单独的服务对象，无法一对多

JMS，即Java Message Service，通过面向消息中间件（MOM：Message Oriented Middleware）的方式很好的解决了上面的问题。大致的过程是这样的：发送者把消息发送给消息服务器，消息服务器将消息存放在若干队列/主题中，在合适的时候，消息服务器会将消息转发给接受者。在这个过程中，发送和接受是异步的，也就是发送无需等待，而且发送者和接受者的生命周期也没有必然关系；在pub/sub模式下，也可以完成一对多的通信，即让一个消息有多个接受者。

JMS

需要注意的是，JMS只是定义了Java访问消息中间件的接口，其实就是在包javax.jms中，你会发现这个包下除了异常定义，其他都是interface。我们可以扫一眼，比如Message：
Message接口

我想你应该发现了，JMS只给出接口，然后由具体的中间件去实现，比如ActiveMQ就是实现了JMS的一种Provider，还有阿里巴巴的RocketMQ（后续专题中在为大家介绍）。这些消息中间件都符合JMS规范。说起规范，自然要定义一些术语：

Provider/MessageProvider：生产者

Consumer/MessageConsumer：消费者

PTP：Point To Point，点对点通信消息模型

Pub/Sub：Publish/Subscribe，发布订阅消息模型

Queue：队列，目标类型之一，和PTP结合

Topic：主题，目标类型之一，和Pub/Sub结合

ConnectionFactory：连接工厂，JMS用它创建连接

Connnection：JMS Client到JMS Provider的连接

Destination：消息目的地，由Session创建

Session：会话，由Connection创建，实质上就是发送、接受消息的一个线程，因此生产者、消费者都是Session创建的

初步来看，Session非常核心，因为很多东西都是它创建的，在后文中可以通过代码来进一步认识这些术语。

ActiveMQ QuickStart
ActiveMQ是Apache出品的，非常流行的消息中间件，可以说要掌握消息中间件，需要从ActiveMQ开始，要掌握更加强大的RocketMQ，也需要ActiveMQ的基础，因此我们来搞定它吧。官网地址：http://activemq.apache.org/，目前最新的版本是5.14.4，我这边将以最新版来讲解。这篇文章主要是ActiveMQ的初步，因此我这边暂时用windows版本，后期采用Linux。
ActiveMQ目录结构

bin下面存放的是ActiveMQ的启动脚本activemq.bat，注意分32、64位

conf里面是配置文件，重点关注的是activemq.xml、jetty.xml、jetty-realm.properties。在登录ActiveMQ Web控制台需要用户名、密码信息；在JMS CLIENT和ActiveMQ进行何种协议的连接、端口是什么等这些信息都在上面的配置文件中可以体现。

data目录下是ActiveMQ进行消息持久化存放的地方，默认采用的是kahadb，当然我们可以采用leveldb，或者采用JDBC存储到MySQL，或者干脆不使用持久化机制。

webapps，注意ActiveMQ自带Jetty提供Web管控台

lib中ActiveMQ为我们提供了分功能的JAR包，当然也提供了activemq-all-5.14.4.jar

在JDK安装没有问题的情况下，直接activemq.bat启动它，并访问Web控制台！
ActiveMQ Start

到这里，ActiveMQ就已经启动了，So easy~

访问ActiveMQ web控制台的用户名、密码在哪里配置的？URL当中的端口是在哪里配置的？
username/pwd 4 access web
port 4 web console

Write Code 4 ActiveMQ
来一个HelloWorld级别的例子，来感受下ActiveMQ。具体来说，我这边会写一个生产者用于发送消息，一个消费者用于接收消息。实际上，JMS是有“套路”的，下面我将以生产者为例详细说明。

第一步：创建ConnectionFactory连接工厂
ConnectionFactory

实际上，这里是存在安全隐患的，也就是任何人一旦知道MQ的地址，就可以连接访问了，我们可以在activemq.xml中配置指定的用户、密码才能访问ActiveMQ。

关于broker_bind_url，默认就是tcp://localhost:61616，说明是采用TCP协议，61616端口。其实对于ActiveMQ不仅仅支持TCP协议，还有其他协议，开启了多个端口。
第二步：创建Connection
Connection

Connection就代表了应用程序和消息服务器之间的通信链路。获得了连接工厂后，就可以创建Connection。

事实上，ConnectionFactory存在重载方法：

Connection createConnection(String username,String password)

也就是说我们也可以在这里指定用户名、密码进行验证

第三步：创建Session
Session

Session，用于发送和接受消息，而且是单线程的，支持事务的。如果Session开启事务支持，那么Session将保存一组信息，要么commit到MQ，要么回滚这些消息。Session可以创建MessageProducer/MessageConsumer。

第四步：创建Destination
Destination

所谓消息目标，就是消息发送和接受的地点，要么queue，要么topic。

第五步：创建MessageProducer
MessageProducer

第六步：设置持久化方式
持久化方式设置

第七步：定义消息对象，并发送
Message

生产者和消费者之间传递的对象，由3个主要部分构成：

消息头（路由）+消息属性（消息选择器，以后介绍）+消息体（JMS规范的5种类型消息）
消息类型

第八步：释放连接
release resource

必须close connection，只有这样ActiveMQ才会释放资源！

消费者的代码和上面非常类似，只不过就是创建MessageConsumer进行receive而已，注意receive()/receive(long)/receiveNoWait()，这些说明消费者可以采用阻塞模式、非阻塞模式接受消息。

程序运行后，我们来看一下管控台：
ActiveMQ Web Info

Messages Enqueued：表示生产了多少条消息，记做P

Messages Dequeued：表示消费了多少条消息，记做C

Number Of Consumers：表示在该队列上还有多少消费者在等待接受消息

Number Of Pending Messages：表示还有多少条消息没有被消费，实际上是表示消息的积压程度，就是P-C

在说说Session
在通过Connection创建Session的时候，需要设置2个参数，一个是否支持事务，另一个是签收的模式。我们重点说一下签收模式：
签收模式

什么是签收？通俗点说，就是消费者接受到消息后，需要告诉消息服务器，我收到消息了。当消息服务器收到回执后，本条消息将失效。因此签收将对PTP模式产生很大影响。如果消费者收到消息后，并不签收，那么本条消息继续有效，很可能会被其他消费者消费掉！

AUTO_ACKNOWLEDGE：表示在消费者receive消息的时候自动的签收

CLIENT_ACKNOWLEDGE：表示消费者receive消息后必须手动的调用acknowledge()方法进行签收

DUPS_OK_ACKNOWLEDGE：签不签收无所谓了，只要消费者能够容忍重复的消息接受，当然这样会降低Session的开销

在实际中，我们应该采用哪种签收模式呢？CLIENT_ACKNOWLEDGE，采用手动的方式较自动的方式可能更好些，因为接收到了消息，并不意味着成功的处理了消息，假设我们采用手动签收的方式，只有在消息成功处理的前提下才进行签收，那么只要消息处理失败，那么消息还有效，仍然会继续消费，直至成功处理！

关于消息的priority/ttl/deliveryMode
消息有优先级及存活时间，在MessageProducer进行send的时候，存在多个重载方法，我们来看一下：
send

在上面的code当中，我们创建生产者的时候，指定了Destination，设置了持久化方式，实际上这些都可以不必指定的，而是到send的时候指定。而且在实际业务开发中，往往根据各种判断，来决定将这条消息发往哪个Queue，因此往往不会在MessageProducer创建的时候指定Destination。

TTL，消息的存活时间，一句话：生产者生产了消息，如果消费者不来消费，那么这条消息保持多久的有效期

priority，消息优先级，0-9。0-4是普通消息，5-9是加急消息，消息默认级别是4。注意，消息优先级只是一个理论上的概念，并不能绝对保证优先级高的消息一定被消费者优先消费！也就是说ActiveMQ并不能保证消费的顺序性！

deliveryMode，如果不指定，默认是持久化的消息。如果可以容忍消息的丢失，那么采用非持久化的方式，将会改善性能、减少存储的开销。

OK，Do you get it?See u next time~

从入门到精通的activemq

这是ActiveMQ系列的最后一篇文章，主要是关于ActiveMQ集群，这里采用的方式是：Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下：《从入门到精通的ActiveMQ（一）》、《从入门到精通的ActiveMQ（二）》。利用Zookeeper实现ActiveMQ的高可用... 查看详情

从入门到精通activemq

接上一篇《从入门到精通ActiveMQ（一）》，本篇主要讨论的话题是：消息的顺序消费、JMSSelectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。消息的顺序消费在上一篇文... 查看详情

从入门到精通activemq

接上一篇《从入门到精通ActiveMQ（一）》，本篇主要讨论的话题是：消息的顺序消费、JMSSelectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。消息的顺序消费在上一篇文... 查看详情

从入门到精通的activemq

这是关于消息中间件ActiveMQ的一个系列专题文章，将涵盖JMS、ActiveMQ的初步入门及API详细使用、两种经典的消息模式（PTPandPub/Sub）、与Spring整合、ActiveMQ集群、监控与配置优化等。话不多说，我们来一起瞧一瞧！JMS首先来说较早... 查看详情

es6从入门到精通系列学习笔记23篇（完结）

说明ES6从入门到精通系列（全23讲）学习笔记。可以自行搜索B站，有小马哥的视频学习。目录ES6从入门到精通#01：ES6介绍ES6从入门到精通#02：let和const命令ES6从入门到精通#03：模板字符串ES6从入门到精通#04&... 查看详情

wpfmvvm从入门到精通3：数据绑定

原文:WPFMVVM从入门到精通3：数据绑定 ?WPFMVVM从入门到精通1：MVVM模式简介WPFMVVM从入门到精通2：实现一个登录窗口WPFMVVM从入门到精通3：数据绑定WPFMVVM从入门到精通4：命令和事件WPFMVVM从入门到精通5：PasswordBox的绑... 查看详情

oracle从入门到精通系列讲解-总目录(代码片段)

总目录欢迎大家来到Lucifer三思而后行的《Oracle从入门到精通系列》，开始前博主先列出Oracle学习的大纲，同时这也可以作为大家学习Oracle的参考。下面蓝字都是传送门，点击进入即可：学前必读Oracle从入门到精通... 查看详情

wpfmvvm从入门到精通8：数据验证(代码片段)

原文:WPFMVVM从入门到精通8：数据验证 WPFMVVM从入门到精通1：MVVM模式简介WPFMVVM从入门到精通2：实现一个登录窗口WPFMVVM从入门到精通3：数据绑定WPFMVVM从入门到精通4：命令和事件WPFMVVM从入门到精通5：PasswordBox的绑... 查看详情

用python2.7编的小游戏

...到了相关教程。自己用google搜：用Python和Pygame写游戏-从入门到精通（目录）就可以找到了。其是一系列的帖子：系统学习部分用Python和Pygame写游戏-从入门到精通（1）Pygame的历史，安装Pygame，第一个Pygame脚本用Python和Pygame写游戏... 查看详情

wpfmvvm从入门到精通7：关闭窗口和打开新窗口

原文:WPFMVVM从入门到精通7：关闭窗口和打开新窗口 WPFMVVM从入门到精通1：MVVM模式简介WPFMVVM从入门到精通2：实现一个登录窗口WPFMVVM从入门到精通3：数据绑定WPFMVVM从入门到精通4：命令和事件WPFMVVM从入门到精通5：... 查看详情

wpfmvvm从入门到精通4：命令和事件(代码片段)

原文:WPFMVVM从入门到精通4：命令和事件 ?WPFMVVM从入门到精通1：MVVM模式简介WPFMVVM从入门到精通2：实现一个登录窗口WPFMVVM从入门到精通3：数据绑定WPFMVVM从入门到精通4：命令和事件WPFMVVM从入门到精通5：PasswordBox的... 查看详情

wpfmvvm从入门到精通6：radiobutton等一对多控件的绑定(代码片段)

原文:WPFMVVM从入门到精通6：RadioButton等一对多控件的绑定 ?WPFMVVM从入门到精通1：MVVM模式简介WPFMVVM从入门到精通2：实现一个登录窗口WPFMVVM从入门到精通3：数据绑定WPFMVVM从入门到精通4：命令和事件WPFMVVM从入门到... 查看详情

《wireshark从入门到精通》

 视频选集3/20P1wireshark从入门到精通P2wireshark入门到精通2P3wireshark入门到精通3P4wireshark入门到精通4P5wireshark入门到精通5P6wireshark入门到精通6P7wireshark入门到精通7P8wireshark入门到精通8P9wireshark入门到精通9P10wireshark入门到精通10P11w... 查看详情

charles从入门到精通

Charles从入门到精通 发表于2015-11-1412:00文章目录1. 目录2. 简介3. 安装Charles4. 将Charles设置成系统代理5. Charles主界面介绍6. 过滤网络请求7. 截取iPhone上的网络封包7.1. Charles上的设置7.2. iPhone上的... 查看详情

cuda从入门到精通

CUDA从入门到精通转载 2013年10月17日11:22:30115411CUDA从入门到精通（零）：写在前面 在老板的要求下，本博主从2012年上高性能计算课程开始接触CUDA编程，随后将该技术应用到了实际项目中，使处理程序加速超过1K，可见基... 查看详情

javascript从入门到精通

1.heap:堆引用值stack:栈先进后出里面的值是copy的关系不可改变的原始值：NumberStringBooleanundefinednullstack引用值：arrayObjectfunction...dateRegExp(正则)heapvararr=[1,2];vararr1=arr;arr.push(3);console.log(arr1);==>1,2,3vararr=[1, 查看详情

python从入门到精通—初识python(代码片段)

Python从入门到精通—初识PythonPython基础知识学习系列博客，持续更新Python从入门到精通—初识PythonPython从入门到精通—初识Python1、Python简介2、认识"Python"3、Python版本4、Python的功能5、Python语言优点6、Python语言缺点1、Py... 查看详情

python从入门到精通—初识python(代码片段)

Python从入门到精通—初识PythonPython基础知识学习系列博客，持续更新Python从入门到精通—初识PythonPython从入门到精通—初识Python1、Python简介2、认识"Python"3、Python版本4、Python的功能5、Python语言优点6、Python语言缺点1、Py... 查看详情