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

在此,Camel 應用程式將開始監聽名為**orderQueue**的佇列,此佇列本身設定在本地主機上執行並偵聽埠 61000 的 activeMQ 訊息伺服器中。完成此操作後,您的應用程式可以從應用程式中定義的任一端點向此佇列傳送或接收訊息。

最後,現在是時候將所有內容整合到一個專案中,以更深入地瞭解如何建立 Camel 應用程式。

廣告
© . All rights reserved.