摘要:你可以经过集成 Camel 和 WildFly 应用server(使用 WildFly-Camel 子系统)在 Java EE 组件中開始使用 Apache Camel Routes。html
【编者按】做者 Markus Eisele 是 Red Hat 的 Developer Advocate。主要从事 JBoss Middleware 相关研究,拥有超过14年的 Java EE 工做经验。本篇博文中, Markus 主要分享了基于 Java EE 组件的 Camel Routes 应用实践。java
下面为译文:git
在生产环境中使用 Camel 有一段时间后,我愈发的喜欢上它的简单。github
在 Java EE 上使用它确实存在一些挑战,而在近期一次演讲中我也提到了怎样实现这一点。在 Java EE 中,咱们可以经过不一样的途径来使用 Camel 的。当中比較推荐的是使用 WildFly-Camel 子系统。在接下来的一个系列中。我将探索实现它的不一样方法。并提供一些在演讲中没有涉及的样例。bootstrap
很是期待可以经过留言或者在 Twitter上@myfear 的方式得到你的反馈和提问。安全
WildFly-Camel 子系统提供了 Apache Camel 和 WildFly 应用server的集成环境。它赞成你加入 Camel Routes(路由)做为 WildFly 配置的一部分。markdown
Routes 可以做为 Java EE 应用程序的一部分部署。Java EE 组件可以使用 Camel 的核心 API 和多个 Camel Component APIs。你的企业级集成解决方式可以架构于 Java EE 和 Camel 的联合功能之上。架构
备注:最新的 WildFly9 预期将由 WildFly-Camel 的 3.x 版本号支持。app
下载并解压 WildFly 8.2.0.Final 到你指定的文件夹下,下载并解压 wildfly-camel patch(2.3.0) 到 wildfly 文件夹下。经过下面命令启动 WildFly:java-ee
bin/standalone[.bat|.sh] -c standalone-camel.xml
最高速的启动和执行方式是使用 Docker 和 WildFly Camel image。
这里的 image 需要预先安装好 WindFly8.1 和 Camel 子系统。
CamelContext 表明着一个 Camel 路由规则库。
使用 CamelContext 和使用 Spring ApplicationContext 的方式是十分相似的。
它包括针对你应用的所有路由。
你可以依据需求使用随意数量的 CamelContext,固然它们需要使用不一样的名称来定义。
WildFly-Camel 可以经过下面3种不一样的方式定义和部署:
一个定义的 CamelContext 可以经过两种不一样的方式被使用:
在接下来的样例中,我将使用一个关联路由的 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组件中使用这个路由。
Camel 自从2.10 版本号即支持 CDI。在没有子系统以前,它需要被 bootstrapped。
不过现在不需要了。你可以只用一个已部署或者已定义的 CamelContext 在 @Named CDI bean 中经过简单的 @Injecting 注入它的 name 实现。
@Inject @ContextName("cdi-context") private CamelContext context;
有了对在 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做为你的主要应用组件模块,那么使用JNDI方法也是合理的:
CamelContext camelctx = (CamelContext) inicxt.lookup("java:jboss/camel/context/cdi-context");
在子系统中还有一个隐藏的宝贝就是 Hawtio 控制台。这是一个模块化的 Web 控制台。用来管理你的 Java 组件,它有一个 Apache Camel 插件来可视化你的上下文和路由信息。记住,它是本身主动配置的。安全起见,你在使用它以前需要先加入一个管理用户。
原文地址:Using Camel Routes In Java EE Components
本文系 OneAPM project师编译整理。OneAPM 是应用性能管理领域的新兴领军企业,能帮助企业用户和开发人员轻松实现:缓慢的程序代码和 SQL 语句的实时抓取。想阅读不少其它技术文章,请訪问 OneAPM 官方博客。