Apache Camel - 消息队列

大部分集成项目使用消息传递，因为它有助于创建松散耦合的应用程序体系结构。消息传递可以是同步或异步的。JMS 支持**点对点**和**发布-订阅**模型。您对点对点使用**队列**，对发布-订阅模型使用**主题**。在 Java 平台上，JMS - Java 消息服务为消息传递服务器提供一个接口。Apache activeMQ 是一个这样的开源 JMS 提供程序。Camel 不附带 JMS 提供程序；但是，可以将其配置为使用 activeMQ。要使用此组件，您需要在项目中包含以下 jar 包 - activemq、camel-spring 和 camel-jms。

以下代码片段展示了如何为 activeMQ 配置 Camel。

<bean id = "jms" class = "org.apache.camel.component.jms.JmsComponent">
   <property name = "connectionFactory">
      <bean class="org.apache.activemq.ActiveMQConnectionFactory">
         <property name = "orderQueue" value = "tcp://127.0.0.1:61000" />
      </bean>
   </property>
</bean>

在此，Camel 应用程序将开始监听名为**orderQueue**的队列，此队列本身设置在本地主机上运行并侦听端口 61000 的 activeMQ 消息服务器中。完成此操作后，您的应用程序可以从应用程序中定义的任一端点向此队列发送或接收消息。

最后，现在是时候将所有内容整合到一个项目中，以更深入地了解如何创建 Camel 应用程序。