ActiveMQ总结

1、1. 背景 当前，CORBA、DCOM、RMI等RPC中间件技术已广泛应用于各个领域。但是面对规模和复杂度都越来越高的分布式系统，这些技术也显示出其局限性：（1）同步通信：客户发出调用后，必须等待服务对象完成处理并返回结果后才能继续执行；（2）客户和服务对象的生命周期紧密耦合：客户进程和服务对象进程 都必须正常运行；如果由于服务对象崩溃或者网络故障导致客户的请求不可达，客户会接收到异常；（3）点对点通信：客户的一次调用只发送给某个单独的目标对象。 面向消息的中间件（Message Oriented Middleware，MOM）较好的解决了以上问题。发送者将消息发送给消息服务器，消息服务器将消息存放在若干队列中，在合适的时候再将消息转发给接收者。这种模式下，发送和接收是异步的，发送者无需等待；二者的生命周期未必相同：发送消息的时候接收者不一定运行，接收消息的时候发送者也不一定运行； 一对多通信：对于一个消息可以有多个接收者。 已有的MOM系统包括IBM的MQSeries、Microsoft的MSMQ和BEA的MessageQ等。由于没有一个通用的标准，这些系统很难实现互操作和无缝连接。

2、Java Message Service（JMS）是SUN提出的旨在统一各种MOM系统接口的规范，它包含点对点（Point to Point，PTP）和发布/订阅（Publish/Subscribe，pub/sub）两种消息模型，提供可靠消息传输、事务和消息过滤等机制。2JMS概述2.1 JMS规范JAVA 消息服务(JMS)定义了Java 中访问消息中间件的接口。JMS 只是接口，并没有给予实现，实现JMS 接口的消息中间件称为JMS Provider，例如ActiveMQ。2.2 术语 JMS Provider：实现JMS 接口的消息中间件；PTP：Point to Point，即点对点的消息模型； Pub/Sub：Publish/Subscribe，即发布/订阅的消息模型；Queue：队列目标；Topic：主题目标；ConnectionFactory：连接工厂，JMS 用它创建连接；Connection：JMS 客户端到JMS Provider 的连接；Destination：消息的目的地；Session：会话，一个发送或接收消息的线程；MessageProducer：由Sess

3、ion 对象创建的用来发送消息的对象；MessageConsumer：由Session 对象创建的用来接收消息的对象;Acknowledge：签收；Transaction：事务。2.3 JMS编程模型在 JMS 编程模型中，JMS 客户端（组件或应用程序）通过 JMS 消息服务交换消息。消息生产者将消息发送至消息服务，消息消费者则从消息服务接收这些消息。这些消息传送操作是使用一组实现 JMS 应用编程接口 (API) 的对象（由 JMS Provide提供）来执行的。在 JMS 编程模型中，JMS 客户端使用 ConnectionFactory 对象创建一个连接，向消息服务发送消息以及从消息服务接收消息均是通过此连接来进行。Connection 是客户端与消息服务的活动连接。创建连接时，将分配通信资源以及验证客户端。这是一个相当重要的对象，大多数客户端均使用一个连接来进行所有的消息传送。连接用于创建会话。Session 是一个用于生成和使用消息的单线程上下文。它用于创建发送的生产者和接收消息的消费者，并为所发送的消息定义发送顺序。会话通过大量确认选项或通过事务来支持可靠传送。客户端使用

4、 MessageProducer 向指定的物理目标（在 API 中表示为目标身份对象）发送消息。生产者可指定一个默认传送模式（持久性消息与非持久性消息）、优先级和有效期值，以控制生产者向物理目标发送的所有消息。同样，客户端使用 MessageConsumer 对象从指定的物理目标（在 API 中表示为目标对象）接收消息。消费者可使用消息选择器，借助它，消息服务可以只向消费者发送与选择标准匹配的那些消息。消费者可以支持同步或异步消息接收。异步使用可通过向消费者注册 MessageListener 来实现。当会话线程调用 MessageListener 对象的 onMessage 方法时，客户端将使用消息。2.4 JMS编程域JMS 支持两种截然不同的消息传送模型：PTP（即点对点模型）和Pub/Sub（即发布/订阅模型），分别称作：PTP Domain 和Pub/Sub Domain。PTP（使用Queue即队列目标） 消息从一个生产者传送至一个消费者。在此传送模型中，目标是一个队列。消息首先被传送至队列目标，然后根据队列传送策略，从该队列将消息传送至向此队列进行注册的某一个消费者，一次

5、只传送一条消息。可以向队列目标发送消息的生产者的数量没有限制，但每条消息只能发送至、并由一个消费者成功使用。如果没有已经向队列目标注册的消费者，队列将保留它收到的消息，并在某个消费者向该队列进行注册时将消息传送给该消费者。Pub/Sub（使用Topic即主题目标） 消息从一个生产者传送至任意数量的消费者。在此传送模型中，目标是一个主题。消息首先被传送至主题目标，然后传送至所有已订阅此主题的活动消费者。可以向主题目标发送消息的生产者的数量没有限制，并且每个消息可以发送至任意数量的订阅消费者。主题目标也支持持久订阅的概念。持久订阅表示消费者已向主题目标进行注册，但在消息传送时此消费者可以处于非活动状态。当此消费者再次处于活动状态时，它将接收此信息。如果没有已经向主题目标注册的消费者，主题不保留其接收到的消息，除非有非活动消费者注册了持久订阅。这两种消息传送模型使用表示不同编程域的 API 对象（其语义稍有不同）进行处理，如下所示：基本类型（统一域） PTP域 Pub/Sub域 ConnectionFactory QueueConnectionFactory TopicConnectionF

6、actory Connection QueueConnection TopicConnection Session QueueSession TopicPublisher Destination（Queue或 Topic） Queue Topic MessageProducer QueueSender MessageConsumer QueueReceiver,QueueBrowser TopicSubscriber 使用图表第一列中列出的统一域对象编写点对点和发布/订阅消息传送。这是首选方法（JMS 1.1规范）。然而，为了符合早期的 JMS 1.02b 规范，可以使用PTP域对象编写点对点消息传送，使用Pub/Sub域对象编制发布/订阅消息传送。2.5 JMS消息结构JMS 消息由以下几部分组成：消息头，属性和消息体。2.5.1 消息头(Header)消息头包含消息的识别信息和路由信息，消息头包含一些标准的属性如：JMSDestination，JMSMessageID等。 消息头 由谁设置 JMSDestination send方法 JMSDeliveryMode send方法 J

7、MSExpiration send方法 JMSPriority send方法 JMSMessageID send方法 JMSTimestamp send方法 JMSCorrelationID 客户 JMSReplyTo 客户 JMSType 客户 JMSRedelivered JMS Provider 2.5.2 属性(Properties)除了消息头中定义好的标准属性外，JMS 提供一种机制增加新属性到消息头中，这种新属性包含以下几种： 1. 应用需要用到的属性; 2. 消息头中原有的一些可选属性; 3. JMS Provider 需要用到的属性。 标准的JMS 消息头包含以下属性： 消息头 描述 JMSDestination 消息发送的目的地 JMSDeliveryMode 传送模式， 有两种模式： PERSISTENT 和NON_PERSISTENT，PERSISTENT 表示该消息一定要被送到目的地，否则会导致应用错误。NON_PERSISTENT 表示偶然丢失该消息是被允许的，这两种模式使开发者可以在消息传送的可靠性和吞吐量之间找到平衡点。 JMSExpiration 消息过

8、期时间，等于Destination 的send 方法中的timeToLive 值加上发送时刻的GMT 时间值。如果timeToLive值等于零，则JMSExpiration 被设为零，表示该消息永不过期。如果发送后，在消息过期时间之后消息还没有被发送到目的地，则该消息被清除。 JMSPriority 消息优先级，从0-9 十个级别，0-4 是普通消息，5-9 是加急消息。JMS 不要求JMS Provider 严格按照这十个优先级发送消息，但必须保证加急消息要先于普通消息到达。 JMSMessageID 唯一识别每个消息的标识，由JMS Provider 产生。 JMSTimestamp 一个消息被提交给JMS Provider 到消息被发出的时间。 JMSCorrelationID 用来连接到另外一个消息，典型的应用是在回复消息中连接到原消息。 JMSReplyTo 提供本消息回复消息的目的地址 JMSType 消息类型的识别符。 JMSRedelivered 如果一个客户端收到一个设置了JMSRedelivered 属性的消息，则表示可能客户端曾经在早些时候收到过该消息，但并没有签

9、收(acknowledged)。 2.5.3 消息体(Body)JMS API 定义了5种消息体格式，也叫消息类型，可以使用不同形式发送接收数据并可以兼容现有的消息格式，下面描述这5种类型：消息类型 消息体 TextMessage java.lang.String对象，如xml文件内容 MapMessage 名/值对的集合，名是String对象，值类型可以是Java任何基本类型 BytesMessage 字节流 StreamMessage Java中的输入输出流 ObjectMessage Java中的可序列化对象 Message 没有消息体，只有消息头和属性 2.6 PTP模型PTP(Point-to-Point)模型是基于队列的，生产者发消息到队列，消费者从队列接收消息，队列的存在使得消息的异步传输成为可能。和邮件系统中的邮箱一样，队列可以包含各种消息，JMS Provider 提供工具管理队列的创建、删除。JMS PTP 模型定义了客户端如何向队列发送消息，从队列接收消息，浏览队列中的消息。 下面描述JMS PTP 模型中的主要概念和对象：名称 描述 ConnectionFactory 客户端用ConnectionFactory 创建Connection 对象。 Connection 一个到JMS Provider 的连接，客户端可以用Connection 创

《ActiveMQ总结》由会员博****1分享，可在线阅读，更多相关《ActiveMQ总结》请在金锄头文库上搜索。