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://localhost:61000" />
      </bean>
   </property>
</bean>

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

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