在 Java EE 組件中使用 Camel Routes

摘要：你可以經過集成 Camel 和 WildFly 應用server（使用 WildFly-Camel 子系統）在 Java EE 組件中開始使用 Apache Camel Routes。

【編者按】做者 Markus Eisele 是 Red Hat 的 Developer Advocate。主要從事 JBoss Middleware 相關研究，擁有超過14年的 Java EE 工做經驗。本篇博文中， Markus 主要分享了基於 Java EE 組件的 Camel Routes 應用實踐。

下面爲譯文:

在生產環境中使用 Camel 有一段時間後，我愈發的喜歡上它的簡單。

在 Java EE 上使用它確實存在一些挑戰，而在近期一次演講中我也提到了怎樣實現這一點。在 Java EE 中，咱們可以經過不一樣的途徑來使用 Camel 的。當中比較推薦的是使用 WildFly-Camel 子系統。在接下來的一個系列中。我將探索實現它的不一樣方法。並提供一些在演講中沒有涉及的樣例。

很是期待可以經過留言或者在 Twitter上@myfear 的方式得到你的反饋和提問。

Camel On WildFly 8.2入門

WildFly-Camel 子系統提供了 Apache Camel 和 WildFly 應用server的集成環境。它贊成你加入 Camel Routes（路由）做爲 WildFly 配置的一部分。

Routes 可以做爲 Java EE 應用程序的一部分部署。Java EE 組件可以使用 Camel 的核心 API 和多個 Camel Component APIs。你的企業級集成解決方式可以架構於 Java EE 和 Camel 的聯合功能之上。

備註：最新的 WildFly9 預期將由 WildFly-Camel 的 3.x 版本號支持。

準備階段

下載並解壓 WildFly 8.2.0.Final 到你指定的文件夾下，下載並解壓 wildfly-camel patch(2.3.0) 到 wildfly 文件夾下。經過下面命令啓動 WildFly：

bin/standalone[.bat|.sh] -c standalone-camel.xml

最高速的啓動和執行方式是使用 Docker 和 WildFly Camel image。

這裏的 image 需要預先安裝好 WindFly8.1 和 Camel 子系統。

定義和使用Camel Context

CamelContext 表明着一個 Camel 路由規則庫。

使用 CamelContext 和使用 Spring ApplicationContext 的方式是十分相似的。

它包括針對你應用的所有路由。

你可以依據需求使用隨意數量的 CamelContext，固然它們需要使用不一樣的名稱來定義。

WildFly-Camel 可以經過下面3種不一樣的方式定義和部署：

1. 在 standalone-camel.xml 和 domain.xml 中做爲子系統的一部分來定義；
2. 在一個支持它們的 deployment artifact 進行部署。固然這個 deployment artifact 必須包括後綴爲 -camel-context.xml 的文件；
3. 經過 RouteBilder 和 CDI integration 定義部署並提供路由信息。

一個定義的 CamelContext 可以經過兩種不一樣的方式被使用：

1. 經過Camel-CDI注入
2. 經過 JNDI 樹進入。

Context 和 Route 演示樣例

在接下來的樣例中，我將使用一個關聯路由的 context。經過 CDI 和 RouteBuilder 提供。是一個應用級別的 bean。在應用啓動的時候本身主動啓動。@ContextName 註解給了 CamelContext 一個特定的名字。

@ApplicationScoped
@Startup
@ContextName("cdi-context")
public class HelloRouteBuilder extends RouteBuilder {

    @Inject
    HelloBean helloBean;

    @Override
    public void configure() throws Exception {
        from("direct:start").transform(body().prepend(helloBean.sayHello()).append(" user."));
    }
 }

路由自己並不真的具備挑戰性。

它有一個空的信息主體 from direct:start 並且用 CDI bean 方法 「sayHello」 prepends 輸出。再 append 字符串」 user.」。做爲參照，完整的代碼可以在個人GitHub（https://github.com/myfear/camel-javaee）中找到。所以，接下來咱們需要知道的是。怎樣在各類Java EE組件中使用這個路由。

在 CDI 中使用 Camel

Camel 自從2.10 版本號即支持 CDI。在沒有子系統以前，它需要被 bootstrapped。

不過現在不需要了。你可以只用一個已部署或者已定義的 CamelContext 在 @Named CDI bean 中經過簡單的 @Injecting 注入它的 name 實現。

@Inject
    @ContextName("cdi-context")
    private CamelContext context;

在 JSF、JAX-RS 和 EJBs 中使用 Camel

有了對在 CDI 中怎樣使用 CamelContext 的瞭解。你可能會想，在 相似 JSF 中使用應該同樣的簡單，事實卻並不如此——你沒法將它注入 ManagedBeans 或者和 JSF 組件綁定的 CDI　Beans。

此外。它在 EJB 中也不能使用。這裏我並無深挖細節，但是以爲它在邊界控制上確實需要改進。一個合理的解決方法，其實，更好的應用程序設計是將一個完整的 Camel 邏輯放入一個單獨的 CDI bean 並且注入。

@Named
public class HelloCamel {

    @Inject
    @ContextName("cdi-context")
    private CamelContext context;

    private final static Logger LOGGER = Logger.getLogger(HelloCamel.class.getName());

    public String doSomeWorkFor(String name) {

        ProducerTemplate producer = context.createProducerTemplate();
        String result = producer.requestBody("direct:start", name, String.class);
        LOGGER.log(Level.INFO, result);
        return result;
    }
}

ProducerTemplate 接口贊成你從 Java 代碼發送信息交換到 endpoint。經過多種不一樣的方式使得同 Camel Endpoint 實例協做很是easy。

在這樣的特殊狀況下，它不過啓動路由並且加入上表明我使用組件名稱的字符串到 body 中。

CDI Bean，對於使用它的組件來講扮演着 backing-bean 的角色：

@Inject
    HelloCamel helloCamel;

    public String getName() {
        return helloCamel.doSomeWorkFor("JSF");
}

返回的字符串是 「Hello JSF user.」，同一時候也寫進了 WildFly 的server日誌。對於其它 Java EE 組件來說這種方法相同是最好的。

在 EJB 中使用 Camel

假設你正在使用EJB做爲你的主要應用組件模塊，那麼使用JNDI方法也是合理的：

CamelContext camelctx = 
             (CamelContext) inicxt.lookup("java:jboss/camel/context/cdi-context");

Hawtio：一個 Camel 控制檯

在子系統中還有一個隱藏的寶貝就是 Hawtio 控制檯。這是一個模塊化的 Web 控制檯。用來管理你的 Java 組件，它有一個 Apache Camel 插件來可視化你的上下文和路由信息。記住，它是本身主動配置的。安全起見，你在使用它以前需要先加入一個管理用戶。

原文地址：Using Camel Routes In Java EE Components

本文系 OneAPM project師編譯整理。OneAPM 是應用性能管理領域的新興領軍企業，能幫助企業用戶和開發人員輕鬆實現：緩慢的程序代碼和 SQL 語句的實時抓取。想閱讀不少其它技術文章，請訪問 OneAPM 官方博客。