ActiveMQinAction中文 - CSDN文库

需积分: 10 112 浏览量更新于2023-06-09 评论收藏 392KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

1 JMS

在介绍 ActiveMQ 之前，首先简要介绍一下 JMS 规范。

1．1 JMS 的基本构件

1．1．1 连接工厂

连接工厂是客户用来创建连接的对象，例如 ActiveMQ 提供的

ActiveMQConnectionFactory。

1．1．2 连接

JMS Connection 封装了客户与 JMS 提供者之间的一个虚拟的连接。

1．1．3 会话

JMS Session 是生产和消费消息的一个单线程上下文。会话用于创建消息生产

者（producer）、消息消费者（consumer）和消息（message）等。会话提供了

一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操

作中。

1．1．4 目的地

目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。

JMS

1.0.2

规范中定义了两种消息传递域：点对点（PTP）消息传递域和发布/订阅

消息传递域。

点对点消息传递域的特点如下：



每个消息只能有一个消费者。



消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发

送消息的时候是否处于运行状态，它都可以提取消息。

发布/订阅消息传递域的特点如下：



每个消息可以有多个消费者。

Generated by Foxit PDF Creator © Foxit Software

http://www.foxitsoftware.com For evaluation only.

1．2．6 持久订阅

首先消息生产者必须使用 PERSISTENT 提交消息。客户可以通过会话上的

createDurableSubscriber 方法来创建一个持久订阅，该方法的第一个参数必须

是一个 topic。第二个参数是订阅的名称。

JMS provider 会存储发布到持久订阅对应的 topic 上的消息。如果最初创建

持久订阅的客户或者任何其它客户使用相同的连接工厂和连接的客户 ID、相同

的主题和相同的订阅名再次调用会话上的 createDurableSubscriber 方法，那么

该持久订阅就会被激活。JMS provider 会向客户发送客户处于非激活状态时所

发布的消息。

持久订阅在某个时刻只能有一个激活的订阅者。持久订阅在创建之后会一直

保留，直到应用程序调用会话上的 unsubscribe 方法。

1．2．7 本地事务

在一个 JMS 客户端，可以使用本地事务来组合消息的发送和接收。JMS Session

接口提供了 commit 和 rollback 方法。事务提交意味着生产的所有消息被发送，

消费的所有消息被确认；事务回滚意味着生产的所有消息被销毁，消费的所有

消息被恢复并重新提交，除非它们已经过期。

事务性的会话总是牵涉到事务处理中，commit 或 rollback 方法一旦被调用，

一个事务就结束了，而另一个事务被开始。关闭事务性会话将回滚其中的事务。

需要注意的是，如果使用请求/回复机制，即发送一个消息，同时希望在同一个

事务中等待接收该消息的回复，那么程序将被挂起，因为知道事务提交，发送

操作才会真正执行。

需要注意的还有一个，消息的生产和消费不能包含在同一个事务中。

1．3 JMS 规范的变迁

JMS 的最新版本的是 1.1。它和同 1.0.2 版本之间最大的差别是，JMS1.1 通过

统一的消息传递域简化了消息传递。这不仅简化了 JMS API，也有利于开发人员

灵活选择消息传递域，同时也有助于程序的重用和维护。

以下是不同消息传递域的相应接口：

JMS 公共点对点域发布/订阅域

ConnectionFactory

QueueConnectionFactory

TopicConnectionFactory

Generated by Foxit PDF Creator © Foxit Software

http://www.foxitsoftware.com For evaluation only.

剩余47页未读，继续阅读

评论0

alpha_zh

粉丝: 0
资源: 9

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈