ActiveMQ使用教程_activemq原理资源-CSDN文库

ActiveMQ教程

需积分: 12 47 浏览量 2016-01-11 17:43:17 上传评论 1 收藏 160KB DOC 举报

资源推荐

资源详情

资源评论

目前最新版本是 ，很多开源项目都使用 作为

的收发

下载网址是：

一下是网上收集的资料



在介绍  之前，首先简要介绍一下  规范。

． 的基本构件

．．连接工厂

连接工厂是客户用来创建连接的对象，例如  提供的

 !"#。

．．连接

! 封装了客户与  提供者之间的一个虚拟的连接。

．．$会话

 是生产和消费消息的一个单线程上下文。会话用于创建消息生

产者（%）、消息消费者（%）和消息（）等。会

话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了

一个原子操作中。

．．&目的地

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

 规范中定义了两种消息传递域：点对点（'('）消息传递域和发布

订阅消息传递域。

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

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

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

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

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

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

)生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自

它订阅之后发布的消息。 规范允许客户创建持久订阅，这在一定程度上放

松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发

送的消息。

在点对点消息传递域中，目的地被成为队列（%%）；在发布订阅消息传

递域中，目的地被成为主题（）。

．．消息生产者

消息生产者是由会话创建的一个对象，用于把消息发送到一个目的地。

．．*消息消费者

消息消费者是由会话创建的一个对象，它用于接收发送到目的地的消息。

消息的消费可以采用以下两种方法之一：

)同步消费。通过调用消费者的  方法从目的地中显式提取消息。

 方法可以一直阻塞到消息到达。

)异步消费。客户可以为消费者注册一个消息监听器，以定义在消息到达时所

采取的动作。

．．+消息

 消息由以下三部分组成：

)消息头。每个消息头字段都有相应的  和  方法。

)消息属性。如果需要除消息头字段以外的值，那么可以使用消息属性。

)消息体。 定义的消息类型有

(,、、-#、 和

./0。

． 的可靠性机制

．．确认

 消息只有在被确认之后，才认为已经被成功地消费了。消息的成功消费

通常包含三个阶段：客户接收消息、客户处理消息和消息被确认。

在事务性会话中，当一个事务被提交的时候，确认自动发生；

在非事务性会话中，消息何时被确认取决于创建会话时的应答模式

（1）。

该参数有以下三个可选值：

)2(.3!45.6789:8。当客户成功的从  方法返回的时

候，或者从 7 方法成功返回的时候，会话自动

确认客户收到的消息。

)!7;85(3!45.6789:8。客户通过消息的 1 方法

确认消息。需要注意的是，在这种模式中，确认是在会话层上进行：确认一个

被消费的消息将自动确认所有已被会话消费的消息。例如，如果一个消息消费

者消费了  个消息，然后确认第  个消息，那么所有  个消息都被确认。

)92'3!45.6789:8。该选择只是会话迟钝第确认消息的提交。

如果  失败，那么可能会导致一些重复的消息。如果是重复的消

息，那么  必须把消息头的 < 字段设置为 %。

．．持久性

支持以下两种消息提交模式：

)'8<;(85(。指示  持久保存消息，以保证消息不会因为

 的失败而丢失。

)5.53'8<;(85(。不要求  持久保存消息。

．．$优先级

可以使用消息优先级来指示  首先提交紧急的消息。优先级分

 个级别，从 （最低）到 =（最高）。如果不指定优先级，默认级别是 &。

需要注意的是， 并不一定保证按照优先级的顺序提交消息。

．．&消息过期

可以设置消息在一定时间后过期，默认是永不过期。

．．临时目的地

可以通过会话上的 (# %% 方法和

(#( 方法来创建临时目的地。它们的存在时间只限于创建

它们的连接所保持的时间。只有创建该临时目的地的连接上的消息消费者才能

够从临时目的地中提取消息。

．．*持久订阅

首先消息生产者必须使用 '8<;(85( 提交消息。客户可以通过会话上的

9%/%// 方法来创建一个持久订阅，该方法的第一个参数

必须是一个 。第二个参数是订阅的名称。

 会存储发布到持久订阅对应的  上的消息。如果最初创

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

同的主题和相同的订阅名再次调用会话上的 9%/%// 方法，

那么该持久订阅就会被激活。 会象客户发送客户处于非激活状态

时所发布的消息。

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

保留，直到应用程序调用会话上的 %%// 方法。

．．+本地事务

在一个  客户端，可以使用本地事务来组合消息的发送和接收。

 接口提供了  和 /1 方法。事务提交意味着生产的所有消

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

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

事务性的会话总是牵涉到事务处理中， 或 /1 方法一旦被调用，

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

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

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

操作才会真正执行。

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

．$规范的变迁

 的最新版本的是 。

它和同  版本之间最大的差别是， 通过统一的消息传递域简化了消

息传递。这不仅简化了 ';，也有

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

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



公共点对点域发布订阅域

!"# %%!"

#

(!"#

! %%! (!

9 %% (

 %% (

'% %% ('%/

!% %%< (%//

 

．-1

．．<%-1

 的二进制发布包中 / 目录中包含一个名为  的脚

本，直接运行这个脚本就可以启动一个 /1。

此外也可以通过 -1!>%2<; 或 -1?-2<; 对

/1 进行配置，以下是一些命令行参数的例子：

8,9

<%/1%@%A,/,A

/1>%>

,/#>,<%/1%>

#>,/1>%>



,/>@/1,<%/1%>

/1,/1>%>

>@/1,

,/>! @/1,<%/1

%>/1,/1>%>

/%>! @/1,

/1B***CDE

%,F%<%/1?

/

/1B***C

1DEF@<%/1

1

/

．．8/-1

可以通过在应用程序中以编码的方式启动 /1，例如：

 代码

-1/1F-1BDG

/1!BH***HDG

$/1BDG

如果需要启动多个 /1，那么需要为 /1 设置一个名字。例如：

 代码

-1/1F-1BDG

/15BH@HDG

$/1!BH***HDG

&/1BDG

如果希望在同一个 I 内访问这个 /1，那么可以使用 I

(，2<; 是：/15。关于更多的 /1 属性，可以参

考  的官方文档。

此外，也可以通过 -1"# 来创建 /1，例如：

 代码

-1/1F-1"#-1B

2<;B2<;DDG

2<; 的可选值如下：

2<;8,9

,/,/,@?7

%2<;B,D

/%?!>%

>>@/,7>B,

@/,D?!>%

/1/1***2-1!>%

2<;>%/1

当使用 ?- 的配置方式的时候，需要指定一个 , 配置文件，例如：

 代码

-1/1F-1"#-1B

2<;BH,/,HDDG

使用  的配置方式如下：

? 代码

J/FH/1H

FH,/-1"#-HK

J#FH>H

%FH,/,HK

$J#FHH%FH%HK

&J/K

．．$-1

．．$．?

在使用 ? 监控 /1 之前，首先要启用 /1 的 ? 监控功能，例如

在配置文件中设置 %,FH%H，如下：

? 代码

J/1%,FH%H/15FH/1K

J!,K

$J!,!FH%HK

&J!,K



*J/1K

接下来运行 94 自带的 0。在运行了 0 后，它会弹出对话框

剩余31页未读，继续阅读

评论收藏

内容反馈

samphin

粉丝: 6
资源: 37

ActiveMQ使用教程

ActiveMQ使用手册（中文版）

百度网盘-ActiveMQ视频教程

ActiveMQ集群实战视频教程

一头扎进 activemq 视频教程 java1234出品

CentOS安装Activemq图文教程

2018-SACC-基于大数据平台的应用实践

ActiveMQ教程

ActiveMQ详细教程

ActiveMQ简单教程

ActiveMQ使用Demo

ActiveMQ使用笔记

ActiveMQ的安装与使用

ActiveMQ安装和使用

Apache_ActiveMQ教程

ActiveMQ使用经验

使用ActiveMQ示例

ActiveMQ培训教程

ActiveMQ安装包和教程

ActiveMQ使用文档

Apache+ActiveMQ教程

ActiveMQ开发教程

使用ActiveMQ 5.X

Java第十五届蓝桥杯大赛软件JavaB组真题

SwitchHosts

安卓期末大作业（AndroidStudio开发），垃圾分类助手app，分为前台后台，代码有注释，均能正常运行

Notepad++安装包

2024北森能力测评题库.7z

最新资源