Apache Camel框架之HTTP路由
阿新 • • 發佈:2019-02-16
繼介紹完Camel如何處理FTP,JMS介面之後,今天介紹一下系統整合的時候經常遇到的另一個介面,HTTP,一個示例需求如下圖所示:(圖片來源於Camel in Action)
本文給出一個簡單的程式碼示例如何用Camel來實現這樣一個應用:
1,在一個JAVA類裡配置如下路由:這裡只示例了HTTP的部分,其他功能實現可以參見Apache Camel框架系列的其他部落格.
[java] view plaincopyprint?- publicclass HttpPollWithQuartzCamel {
- publicstaticvoid main(String args[]) throws
- CamelContext context = new DefaultCamelContext();
- context.addRoutes(new RouteBuilder() {
- publicvoid configure() {
- from("quartz://report?cron=10 * * * * ?&stateful=true")
- .to("http://localhost:8080/prjWeb/test.camelreq")
- .to("file:d:/temp/outbox?fileName=http.csv");
- );
- }
- });
- context.start();
- boolean
- while (loop) {
- Thread.sleep(25000);
- }
- context.stop();
- }
- }
public class HttpPollWithQuartzCamel { public static void main(String args[]) throws Exception { CamelContext context = new DefaultCamelContext(); context.addRoutes(new RouteBuilder() { public void configure() { from("quartz://report?cron=10 * * * * ?&stateful=true") .to("http://localhost:8080/prjWeb/test.camelreq") .to("file:d:/temp/outbox?fileName=http.csv"); ); } }); context.start(); boolean loop = true; while (loop) { Thread.sleep(25000); } context.stop(); } }
對上面程式碼的簡單解釋: from("quartz://report?cron=10 * * * * ?&stateful=true"),配置一個quartz Job,每隔10秒傳送一個HTTP request,將收到的內容儲存為檔案.
這裡的http url可以是任何可以訪問的http url,如果在http訪問時候需要代理可以這麼配置:"http://www.baidu.com?proxyHost=proxy.xxx.com&proxyPort=8080"
這個例子需要用到quartz,和httpclient等jar包,可以從這裡下載: http://download.csdn.net/detail/kkdelta/4051072