6.4. 保证交付

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

图 6.4. 保证交付模式

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

在 JMS 中，deliveryPersistent 查询选项指示是否启用了消息的持久性存储。通常，设置这个选项是不需要的，因为默认行为是启用持续交付。要配置保证交付的所有详情，需要在 JMS 提供程序上设置配置选项。这些详情会根据您使用的 JMS 供应商的不同而有所不同。例如, MQSeries、TibCo、BEA、Sunic 等，它们都提供各种服务质量来支持保证交付。

如需了解更多详细信息，请参阅 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 中的所有 peer，如下所示：

<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 协议，它连接到嵌入式代理实例。如果所需名称的代理不存在，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 组件针对特殊的用例进行了优化，其中多个并发制作者将消息写入队列，但只有一个活跃的使用者。消息存储在滚动日志文件中，并并发写入聚合在一起，以提高效率。