1 JMS
在介绍 之前，首先简要介绍一下 规范。
1.1 JMS
的基本构件
1
．
1
．
1
连接工厂
连接工厂是客户用来创建连接的对象，例如 提供的 。
1
．
1
．
2
连接
封装了客户与 提供者之间的一个虚拟的连接。
1
．
1
．
3
会话
是生产和消费消息的一个单线程上下文。会话用于创建消息生产者（ ）、消息消费者（ ）和
消息（）等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。
1
．
1
．
4
目的地
目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。 规范中定义了两种消息传递域：点对点
（）消息传递域和发布订阅消息传递域。 点对点消息传递域的特点如下：
每个消息只能有一个消费者。
消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态，它都可以提取消息。
发布订阅消息传递域的特点如下：
每个消息可以有多个消费者。
生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。 规范允许客户创建持
久订阅，这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息。
在点对点消息传递域中，目的地被成为队列（!）；在发布 订阅消息传递域中，目的地被成为主题（）。
1
．
1
．
5
消息生产者
消息生产者是由会话创建的一个对象，用于把消息发送到一个目的地。
1
．
1
．
6
消息消费者
消息消费者是由会话创建的一个对象，它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一：
同步消费。通过调用消费者的 方法从目的地中显式提取消息。 方法可以一直阻塞到消息到达。
异步消费。客户可以为消费者注册一个消息监听器，以定义在消息到达时所采取的动作。
1
．
1
．
7
消息
消息由以下三部分组成：
消息头。每个消息头字段都有相应的 和 方法。
消息属性。如果需要除消息头字段以外的值，那么可以使用消息属性。
消息体。 定义的消息类型有 "、、#、 和 $%&。
1
．
2 JMS
的可靠性机制
1
．
2
．
1
确认
JMS
消息
只有在被确认之后，才认为已经被成功地消费了。消息的成功消费通常包含三个阶段：客户接收消息、客户处理消息和消息被确
认。 在事务性会话中，当一个事务被提交的时候，确认自动发生。在非事务性会话中，消息何时被确认取决于创建会话时的应答
模式（'()）。该参数有以下三个可选值：
*$+,-$./0120。当客户成功的从 方法返回的时候，或者从 / 方法
成功返回的时候，会话自动确认客户收到的消息。
/30-+,-$./0120。客户通过消息的 '() 方法确认消息。需要注意的是，在这种模式中，确认是
在会话层上进行：确认一个被消费的消息将自动确认所有已被会话消费的消息。例如，如果一个消息消费者消费了 个消息，然
后确认第 4 个消息，那么所有 个消息都被确认。
1*+,-$./0120。该选择只是会话迟钝的确认消息的提交。如果 失败，那么可能会导致一些
重复的消息。如果是重复的消息，那么 必须把消息头的 5) 字段设置为 。
1
．
2
．
2
持久性
支持以下两种消息提交模式：
0530-。指示 持久保存消息，以保证消息不会因为 的失败而丢失。
-$-+0530-。不要求 持久保存消息。
1
．
2
．
3
优先级
可以使用消息优先级来指示 首先提交紧急的消息。优先级分 个级别，从 （最低）到 6（最高）。如果不指定
优先级，默认级别是 7。需要注意的是， 并不一定保证按照优先级的顺序提交消息。
1
．
2
．
4
消息过期
可以设置消息在一定时间后过期，默认是永不过期。
1
．
2
．
5
临时目的地
可以通过会话上的 方法和 方法来创建临时目的地。它们的存在时间只限于创
建它们的连接所保持的时间。只有创建该临时目的地的连接上的消息消费者才能够从临时目的地中提取消息。
1
．
2
．
6
持久订阅
首先消息生产者必须使用 0530- 提交消息。客户可以通过会话上的 1%)%% 方法来创建一个持久订阅，
该方法的第一个参数必须是一个 ，第二个参数是订阅的名称。 会存储发布到持久订阅对应的 上的消息。
如果最初创建持久订阅的客户或者任何其它客户使用相同的连接工厂和连接的客户 31、相同的主题和相同的订阅名再次调用会话
上的 1%)%% 方法，那么该持久订阅就会被激活。 会象客户发送客户处于非激活状态时所发布
的消息。 持久订阅在某个时刻只能有一个激活的订阅者。持久订阅在创建之后会一直保留，直到应用程序调用会话上的
%% 方法。
1
．
2
．
7
本地事务
在一个 客户端，可以使用本地事务来组合消息的发送和接收。 接口提供了 和 ))%' 方法。事务提
交意味着生产的所有消息被发送，消费的所有消息被确认；事务回滚意味着生产的所有消息被销毁，消费的所有消息被恢复并重
新提交，除非它们已经过期。 事务性的会话总是牵涉到事务处理中， 或 ))%' 方法一旦被调用，一个事务就结束了，
而另一个事务被开始。关闭事务性会话将回滚其中的事务。 需要注意的是，如果使用请求回复机制，即发送一个消息，同时希望
在同一个事务中等待接收该消息的回复，那么程序将被挂起，因为知道事务提交，发送操作才会真正执行。 需要注意的还有一个，
消息的生产和消费不能包含在同一个事务中。
1
．
3 JMS
规范的变迁
的最新版本的是 。它和同 版本之间最大的差别是， 通过统一的消息传递域简化了消息传递。这不仅简化了
3，也有利于开发人员灵活选择消息传递域，同时也有助于程序的重用和维护。 以下是不同消息传递域的相应接口：
公共 点对点域 发布订阅域
1
%)8
5 %%
2
．
ActiveMQ
2
．
1 Broker
2
．
1
．
1
运行
Broker
4的二进制发布包中 % 目录中包含一个名为 ! 的脚本，直接运行这个脚本就可以启动一个 %'。 此外
也可以通过 #'9*53 或 #':#*53 对 %' 进行配置，以下是一些命令行参数的例子：
0") 1
! 5 %'8;)<"%=!")<
8%'99)
!"%=9") 5%'89)9")8%'
99)8)8)8
!"%=9)=;%'") 5%'89)%'")8%'
99)8)8)9)8
;%'")
!
"%=9)==;%'")
5%'89)%'")8%'
9 9) 8 ) 8 %) 9)
8=;%'")
! %'=>=))8=???@
=))8=4AB"C
5%'(8(:
%)
! %'=>=))8=???@
('==))8=4ABC;)
5 %' (8
('(8%)
2
．
1
．
2
嵌入式
Broker
可以通过在应用程序中以编码的方式启动 %'，例如：
代码
#'%'C(#'>AD
%'>E=))8=???EAD
F%'>AD
如果需要启动多个 %'，那么需要为 %' 设置一个名字。例如：
代码
#'%'C(#'>AD
%'->E;EAD
F%'>E=))8=???EAD
7%'>AD
如果希望在同一个 G 内访问这个 %'，那么可以使用 G，*53 是：=%'-。关于更多的 %' 属
性，可以参考 8 的官方文档。 此外，也可以通过 #' 来创建 %'，例如：
代码
#'%'C#'#'>(*53>*53AAD
*53 的可选值如下：
*538 0") 1
"%= "%=!") 88)8;:/(8
8*53>!")8A(88())
8%8:)9
9)= 9)=;%!") / 8 9) > 8 ")
;%!")A8:)9
%'= %'==))8=??? *8#'9*5398
%'
当使用 :# 的配置方式的时候，需要指定一个 ") 配置文件，例如：
代码
#'%'C#'#'>(*53>E"%=!")EAAD
使用 的配置方式如下：
:) 代码
H%CE%'E)CE8!"%#'#EI
HCE9E)CE)8=8!"%!")EI
F HCEE)CEEI
7H%I
2
．
1
．
3
监控
Broker
2
．
1
．
3
．
1 JMX
在使用 : 监控 %' 之前，首先要启用 %' 的 : 监控功能，例如在配置文件中设置 "CEE，如下：
:) 代码
H%'"CEE%'-CE%'JI
H"I
FH"CEEI
7H"I
4
?H%'I
接下来运行 1, 自带的 &)。在运行了 &) 后，它会弹出对话框来选择需要连接到的 。如果是在启动 %' 的
主机上运行 &)，那么 %' 会出现在 &) 的 /)标签中。如果要连接到远程的 %'，那么可以在
标 签 中 指 定 : *5/ ， 以 下 是 一 个 连 接 到 本 机 的 : *5/ ：
=&"==&=))8=66&"
在 &) 的 # 标签中，可以查看详细信息，也可以执行相应的 。需要注意的是，在 &) 连接到
%' 的时候，并不需要输入用户名和密码，如果这存在潜在的安全问题，那么就需要为 : 配置密码保护（需要
使用 4 以上版本的 1,）。
首先要禁止 创建自己的 ，例如：
:) 代码
H%'")CE8=!9E%'-CE))8E"CEEI
H"I
FH"CE;)EI
7H"I
4H%'I
然后在 的 ; 目录下创建一个访问控制文件和密码文件，如下：
;&"：
K8E5)E)8)
K8E)5)E)8(
5))
)5)(
;&"(：
K8E5)E)8(E%FE
K8E)5)E)8(E%F7E
5)%F
)5)%F7
然后修改 的 % 目录下 ! 的启动脚本，查找包含E*-:CE的一行如下：
50*-:CL1&"C??
L1&"8C;)
L1&")C;)
把它替换成
*-:CL1&"C??
L1&"8C
L1&")C;)
L1&"(9)CM3G0+#0M;&"(
L1&"9)CM3G0+#0M;&"
最后重启 和 &)，这时候需要强制 )。如果在启动 ! 的过程中出现以下错误，那么需要为这个文件
增加访问控制。.( 平台上的具体解决方法请参考如下网址：
8=&&4L((8)N
0=(9)%=
1=O8L!L4O%O;&"(
2
．
1
．
3
．
2 Web Console
.%) 被 集 成 到 了 的 二 进 制 发 布 包 中 ， 因 此 缺 省 访 问 8=))8=P?
即 可 访 问 .%
)。 在配置文件中，可以通过修改 的 属性来修改 .%) 的缺省端口：
:) 代码
H&")CE8=%8&EI
HI
FHCEP?EI
7HI
4
?H&I
出于安全性或者可靠性的考虑，.%)可以被部署到不同于 的进程中。例如把 !L(%L)(
部 署 到 一 个 单 独 的 (% 容 器 中 （ ， 等 ） 。 在 4 的 二 进 制 发 布 包 中 不 包 含 !L(%L
)(，因此需要下载 的源码，然后进入到QR!%S!L(%L) 目录中执行
))。如果一切正常，那么缺省会在QR!%S!L(%L) 目录中生成 !L
(%L)L4( 。然 后 将 !L(%L)L4( 拷 贝 到 的 (% 目 录 中 ， 并 重 命 名 成
!L(%L)(。
需要注意的是，要将 !L))L4& 拷贝到 .0#L3-O)% 目录中（可能还需要拷贝 &&）。还要为 设置以
下五个系统属性（修改 )% 文件）：
G+$CMG+$ML1(%)CEE
G+$CMG+$ML1(%)&)CE=))8=???E
G+$CMG+$ML1(%)&")CE=&"==&=))8=66&"E
G+$CMG+$ML1(%)&")CEE
G+$CMG+$ML1(%)&"(CEE
如果 : 没有配置密码保护，那么 (%)&") 和 (%)&"( 设置成EE即可。如果 %' 被配置
成了 ) 模式，那么可以配置成使用 ;)，例如：
L1(%)&)C;)=>==???@=#=???A
顺便 说一下， 由于 (%) 属 性是 ， 因 此实际 上 起作用 的 .%) 的配 置 文件 是 .0#L3-
(%)L")。最后启动被监控的 ，访问 8=))8=PP!L(%L)，查看
显示是否正常。
2
．
1
．
3
．
3 Advisory Message
支持 ，它允许你通过标准的 消息来监控系统。目前的 支持：
@
%
