使Apache的駱駝聽端口和加載balnce請求到其他的URI

我在這裏有一個代碼是從駱駝的官方網站上的示例代碼：使Apache的駱駝聽端口和加載balnce請求到其他的URI

package org.apache.camel.processor; 

import org.apache.camel.AsyncCallback; 
import org.apache.camel.ContextTestSupport; 
import org.apache.camel.Exchange; 
import org.apache.camel.builder.RouteBuilder; 
import org.apache.camel.component.mock.MockEndpoint; 
import org.apache.camel.processor.loadbalancer.LoadBalancerSupport; 

public class CustomLoadBalanceTest extends ContextTestSupport { 
    protected MockEndpoint x; 
    protected MockEndpoint y; 
    protected MockEndpoint z; 

    @Override 
    protected void setUp() throws Exception { 
     super.setUp(); 

     x = getMockEndpoint("mock:x"); 
     y = getMockEndpoint("mock:y"); 
     z = getMockEndpoint("mock:z"); 
    } 

    protected RouteBuilder createRouteBuilder() { 
     return new RouteBuilder() { 
      public void configure() { 
       // START SNIPPET: e1 
       from("direct:start") 
        // using our custom load balancer 
        .loadBalance(new MyLoadBalancer()) 
        .to("mock:x", "mock:y", "mock:z"); 
       // END SNIPPET: e1 
      } 
     }; 
    } 

    public void testCustomLoadBalancer() throws Exception { 
     x.expectedBodiesReceived("x", "x", "x"); 
     y.expectedBodiesReceived("y", "y"); 
     z.expectedBodiesReceived("foo", "bar", "baz"); 

     template.sendBody("direct:start", "x"); 
     template.sendBody("direct:start", "y"); 
     template.sendBody("direct:start", "foo"); 
     template.sendBody("direct:start", "bar"); 
     template.sendBody("direct:start", "y"); 
     template.sendBody("direct:start", "x"); 
     template.sendBody("direct:start", "x"); 
     template.sendBody("direct:start", "baz"); 

     assertMockEndpointsSatisfied(); 
    } 

    // START SNIPPET: e2 
    public static class MyLoadBalancer extends LoadBalancerSupport { 

     public boolean process(Exchange exchange, AsyncCallback callback) { 
      String body = exchange.getIn().getBody(String.class); 
      try { 
       if ("x".equals(body)) { 
        getProcessors().get(0).process(exchange); 
       } else if ("y".equals(body)) { 
        getProcessors().get(1).process(exchange); 
       } else { 
        getProcessors().get(2).process(exchange); 
       } 
      } catch (Throwable e) { 
       exchange.setException(e); 
      } 
      callback.done(true); 
      return true; 
     } 
    } 
    // END SNIPPET: e2 

}

該代碼可用於使用進行定製的負載均衡阿帕奇駱駝。我希望Apache駱駝聽本地主機和端口，並平衡通過IP地址和端口號指定的服務器之間的負載。服務器端安裝了tomcat，它會監聽請求。

那麼我如何修改下面的代碼來滿足我的要求。我有點新駱駝。任何幫助將非常感激。

提前感謝一噸。乾杯！

來源

2012-08-07 Spaniard89

這裏有一些路由代碼，使負載平衡器的工作但是，我沒有檢查您的自定義負載平衡類的內部，但應該是相當直接。

from("jetty://http://0.0.0.0:8080/test") 
    .loadBalance(new MyLoadBalancer()) 
    .to("http://tcserver1:8080/hello","http://tcpserver2:8080/hello","http://tcpserver3:8080/hello");

來源

2012-08-07 13:33:59

如果我不確定，我將不得不安裝碼頭在負載平衡系統，這將傳遞請求到駱駝。如果是這樣，那麼有沒有其他的方式可以配置駱駝，它本身就像一個TCP端口監聽器？如果沒有，是否還有其他選項留給我？ – Spaniard89 2012-08-08 08:15:50

實際上，Camel啓動了一個創建HTTP偵聽器的小型Jetty實例，因此偵聽器將處於HTTP級別。你沒有做任何事情，但提供依賴關係。您可以使用更原始的TCP偵聽器（查看camel中的mina或netty組件）來做到這一點，但是它會有點棘手，因爲您需要能夠解析TCP流並提取每個HTTP請求。如果你仍然有興趣，看看這裏：http://mina.apache.org/report/trunk/xref/org/apache/mina/example/httpserver/codec/ 我會去與駱駝/碼頭，它會沒有「安裝」，除了你的駱駝應用程序。 – 2012-08-08 09:19:04

使Apache的駱駝聽端口和加載balnce請求到其他的URI

回答

相關問題