实时警报通知:微信告警通知的重要性解析
693
2022-09-13
在 Java EE 组件中使用 Camel Routes(在线之家)
以下为译文:
在生产环境中使用 Camel 有一段时间后,我愈发的喜欢上它的简单。在 Java EE 上使用它确实存在一些挑战,而在最近一次演讲中我也提到了如何实现这一点。在 Java EE 中,我们可以通过不同的途径来使用 Camel 的,其中比较推荐的是使用 WildFly-Camel 子系统。在接下来的一个系列中,我将探索实现它的不同方法,并提供一些在演讲中没有涉及的例子。很期待能够通过留言或者在 Twitter上@myfear 的方式获得你的反馈和提问。
Camel On WildFly 8.2入门
WildFly-Camel 子系统提供了 Apache Camel 和 WildFly 应用服务器的集成环境。它允许你添加 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
定义和使用 Camel Context
CamelContext 代表着一个 Camel 路由规则库。使用 CamelContext 和使用 Spring ApplicationContext 的方式是十分相似的。它包含针对你应用的所有路由。你可以根据需求使用任意数量的 CamelContext,当然它们需要使用不同的名称来定义。
WildFly-Camel 可以通过下面3种不同的方式定义和部署:
在 standalone-camel.xml 和 domain.xml 中作为子系统的一部分来定义; 在一个支持它们的 deployment artifact 进行部署,当然这个 deployment artifact 必须包含后缀为 -camel-context.xml 的文件; 通过 RouteBilder 和 CDI integration 定义部署并提供路由信息。
一个定义的 CamelContext 可以通过两种不同的方式被使用:
通过Camel-CDI注入 通过 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.")); } }
在 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 并且注入。
@Namedpublic 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; }}
CDI Bean,对于使用它的组件来说扮演着 backing-bean 的角色:
@Inject HelloCamel helloCamel; public String getName() { return helloCamel.doSomeWorkFor("JSF");}
返回的字符串是 "Hello JSF user.",同时也写进了 WildFly 的服务器日志。对于其他 Java EE 组件来讲这个方法同样是最好的。
在 EJB 中使用 Camel
如果你正在使用 EJB 作为你的主要应用组件模块,那么使用 JNDI 方法也是合理的:
CamelContext camelctx = (CamelContext) inicxt.lookup("java:jboss/camel/context/cdi-context");
Hawtio:一个 Camel 控制台
发表评论
暂时没有评论,来抢沙发吧~