异步发送
消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker 已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称为同步发送。但有一个例外，当发送方法在一个事物上下文中时，被阻塞的是 commit 方法而不是 send 方法。commit 方法成功返回意味着所有的持久消息都以被写到二级存储中。 同步发送持久消息能够提供更好的可靠性，但这潜在地影响了程序的相应速度，因为在接受到 broker 的确认消息之前应用程序或线程会被阻塞。如果应用程序能够容忍一些消息的丢失，那么可以使用异步发送。异步发送不会在受到 broker 的确认之前一直阻塞 Producer.send 方法。如果想启动异步传送可以把 connector uri 的 jms.useAsyncSend 选项设为 true，如下所示： tcp://localhost:61616?jms.useAsyncSend=true 从 ActiveMQ 5 开始可以控制异步发送流。也就是说，在受到 broker 的确认应答之前，生产者能够传送消息给 broker 的最大信息量。即使是异步发送消息，生产者也是在收到 broker 的确认应答后才把下一条消息传送给 broker。当使用异步传送的时候，可以设置 jms.producerWindowSize（单位为字节）属性，当生产者中等待发送的信息量到达设置的值时，即使没有收到 broker 的应答消息，生产者同样会把这些消息发给 broker。如下面的示例设置： tcp://localhost:61616?jms.useAsyncSend=true&jms.producerWindowSize=1024000 单独确认 在 ActiveMQ 5.2 中添加了一个新的确认模式，这种确认模式是特定于 ActiveMQ 的，jms 规范暂时并不支持这种确认模式。这种确认模式由 ora.apache.activemq.ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE 表示，用来确认一个单独的消息。这中确认模式是相对于 Session.CLIENT_ACKNOWLEDGE 的，在 CLIENT_ACKNOWLEDGE 模式下，调用消息的 acknowledge() 方法会确认由此 session 消费的所有消息，而在 INDIVIDUAL_ACKNOWLEDGE 模式下，仅会确认调用 acknowledge() 方法的消息。 企业集成模式 通过 ，ActiveMQ 支持《 》一书中提到的企业集成模式。参见 。 消息游标 在 ActiveMQ 的之前版本中，broker 会把正在传输的消息保存在内存中。使用这种内存模型，当一个消费者消费消息的速度跟不上生产者生产消息的速度的时候，会是 broker 内存中维护的正在传输的消息数量迅速增长，最终到达最大限额。当到达此最大限额后，broker 就不能接受来自客户端的消息，这样生产者就会被阻塞直到 broker 的内存中有保存消息的空间为止。 从 5.0 版本开始，ActiveMQ 实现了一种新的内存模型以防止慢速的消费者阻塞运行速度更快的生产者。这种内存模型使用了消息游标，详情请查看 。 对 spring 的支持 请查看 ActiveMQ 的 页面，查看如何在 spring 中配置 ActiveMQ 的 jms 客户端。 连接池 org.apache.activemq.pool 包中提供了一个服务提供者对象 PooledConnectionFactory，通过这个类应用程序可以缓存 Connection、Session 以及 MessageProducer。更详细的信息可以查看 PooledConnectionFactory 的文档。 PooledConnectionFactory 主要用来与其它一些框架或工具集成使用，例如 spring。 消息转换器 从 ActiveMQ 5 开始，ActiveMQ 允许开发人员把他们的消息转换对象添加到 ActiveMQ 的消息总线上。一个ActiveMQ 转换对象（或者是转换器）必须实现 org.apache.activemq.MessageTransformaer 接口。 如果要设置一个消息转换器，可以调用一下对象的 setTransformaer() 方法设置一个消息转换器：ActiveMQConnectionFactory、ActiveMQConnection、 ActiveMQSession、ActiveMQMessageConsumer 和 ActiveMQMessageProducer。消息转化器是可继承的，也就是说当设置了 ActiveMQConenctionFactory 的消息转化器后，由此 ActiveMQConnectionFacttory 创建的连接、会话、消费者和生产者都会继承 ActiveMQConnectionFactory 的消息转换器。组合目的
组合目的是 ActiveMQ 特有的一个特性，jms 规范并不支持。组合目的是指多个物理目的被映射到一个虚目的，当生产者向虚目的发送一条消息时，这条消息会被转发到映射到此虚目的地物理目的上。组合目的分为客户端组合目的以及消息代理端组合目的。 客户端组合目的 在客户端可以通过 jndi 给一个虚目的配置多个物理目的。如下面的 jndi.properties 示例文件所示，生产者向目的 Q.BLAST 发送一条消息后，这条消息会被转发到物理目的 Q.REQ、Q.FOO 和 Q.TEST。 java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory connectionFactoryNames=local connection.local.brokerURL=tcp://localhost:61616 queue.Q.BLAST=Q.REQ, Q.FOO, Q.TEST