6.4. 保证交付

概述

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

图 6.4. 保证交付模式

保证交付模式

支持保证交付的组件

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

JMS

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

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

ActiveMQ

在 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

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