首页 > 代码库 > Camel运行示例
Camel运行示例
这是一个很简单的Camel例子,代码如下:
public static void main(String[] args) throws Exception { //创建Camel上下文 DefaultCamelContext camelContext = new DefaultCamelContext(); //添加一个路由,参数为路由建造者 camelContext.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { this.from("file:H:/temp/in").process(new Processor() { @Override public void process(Exchange exchange) throws Exception { GenericFile<File> gf = exchange.getIn().getBody(GenericFile.class); File file = gf.getFile(); PrintStream ps = new PrintStream(System.out); BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(file))); String line = null; while((line=br.readLine())!=null) { ps.println(line); } ps.close(); br.close(); } }).to("file:H:/temp/out"); } }); //启动上下文 camelContext.start(); //防止主线程退出 Object object = new Object(); synchronized (object) { object.wait(); } }
写这个例子的原因不在于说通过这个例子的表面能学到多少东西,而是要通过这个例子挖掘出其背后的运行机制与原理。这里配置的路由很简单,一个起始节点,一个处理器,一个目的节点,其目的就是将一个目录下的文件搬运到另一个文件夹,处理器只是将文件(限于文本文件)的内容打印到控制台。
这个例子虽然简单,但这也足以通过它来了解Camel的核心运行机制,且待下回分解。
Camel运行示例
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。