6.4. guaranteed Delivery

保证发送 意味着，当消息被放入消息频道后，消息传递系统会保证消息将到达其目的地，即使应用程序的部分应该失败。通常，消息传递系统在试图将它们传送到目的地前，通过将信息写入持久性存储来实现保证的交付模式。

图 6.4. 保证交付模式

以下 Apache Camel 组件支持保证交付模式：

在 JMS 中，deliveryPersistent query 选项指示是否启用消息的持久存储。通常，设置这个选项是不必要的，因为默认行为是启用永久发送。若要配置保证发送的所有详细信息，需要对 JMS 提供程序设置配置选项。这些详细信息会根据您使用的 JMS 提供程序而有所不同。例如： MQ 系列、TibCo、BEA、S Sonic 等，它们都提供各种服务质量来支持保证的交付。

如需了解更多详细信息，请参阅 Apache Camel 组件参考指南 > 中的 Jms。

在 ActiveMQ 中，消息持久性默认为启用。从版本 5 开始，ActiveMQ 使用 AMQ 消息存储作为默认的持久性机制。在 ActiveMQ 中，您可以使用几种不同的方法来布放消息持久性。

最简单的选项（与 图 6.4 “保证交付模式” 不同）是在中央代理中启用持久性，然后使用可靠的协议连接到该代理。将消息发送到中央代理后，可以保证向消费者发送。例如，在 Apache Camel 配置文件中 META-INF/spring/camel-context.xml，您可以将 ActiveMQ 组件配置为使用 OpenWire/TCP 协议连接到中央代理，如下所示：

<beans ... >
  ...
  <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="brokerURL" value="tcp://somehost:61616"/>
  </bean>
  ...
</beans>

如果您希望实现在发送到远程端点（与 图 6.4 “保证交付模式” 相似）前保存消息的架构，您可以在 Apache Camel 应用程序中实例化嵌入的代理来实现这个目标。实现此目的的一个简单方法是使用 ActiveMQ Peer-to-Peer 协议，它隐式创建一个嵌入式代理来与其他对等端点通信。例如，在 camel-context.xml 配置文件中，您可以将 ActiveMQ 组件配置为连接到组 GroupA 中的所有对等点，如下所示：

<beans ... >
  ...
  <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="brokerURL" value="peer://GroupA/broker1"/>
  </bean>
  ...
</beans>

其中 broker1 是嵌入式代理的代理名称（组中的其他对等点应该使用不同的代理名称）。Peer-to-Peer 协议的一个限制功能是它依赖于 IP 多播来在其组中定位其他对等点。这使得在广域网络（以及一些未启用 IP 多播的局域网中）使用不合适。

在 ActiveMQ 组件中创建嵌入式代理的一种更灵活的方式是利用 ActiveMQ 的虚拟机协议来连接嵌入式代理实例。如果所需名称的代理不存在，VM 协议会自动创建。您可以使用此机制创建带有自定义配置的嵌入式代理。例如：

<beans ... >
  ...
  <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="brokerURL" value="vm://broker1?brokerConfig=xbean:activemq.xml"/>
  </bean>
  ...
</beans>

其中 activemq.xml 是 ActiveMQ 文件，用于配置嵌入式代理实例。在 ActiveMQ 配置文件中，您可以选择启用以下持久性机制之一：

如需了解更多详细信息，请参阅 Apache Camel 组件参考指南 中的 ActiveMQ。

ActiveMQ Journal 组件针对特殊用例进行了优化，其中多个并发生产者将消息写入到队列，但只有一个活跃的消费者。消息存储在滚动日志文件中，并聚合并发写入以提高效率。