如何在ApacheCamel中为http4组件添加负载平衡。对于http4组件代码，请检查下面的代码

Question

rules.getRules().forEach(x->{
            from("jetty:http://0.0.0.0:"+rules.getPort()+"/"+x.getFrom()+"??matchOnUriPrefix=true")
            .to("http4://"+x.getTo()+"?bridgeEndpoint=true&throwExceptionOnFailure=false");
            System.out.println(“Ieration Route:  ”+x);});

Ieration Route:  {"RouteRule":{ "from":"posts", "to":"jsonplaceholder.typicode.com/posts/?"}}
Ieration Route:  {"RouteRule":{ "from":"users", "to":"reqres.in/api/users"}}
Ieration Route:  {"RouteRule":{ "from":"countries", "to":"restcountries.eu/rest/v2/"}}

Application.yml 文件

routes:
  port: 8088
  route:
    -
      from: posts
      to: jsonplaceholder.typicode.com/posts/?
    -
      from: users
      to: reqres.in/api/users
    -
      from: countries
      to: restcountries.eu/rest/v2/

在上面的场景中，我们可以在哪里添加多台服务器？在yml文件配置中，如果是，我们如何添加它。

感谢你的帮助。

谢谢

Answer 1

根据camel doc负载均衡器模式允许您使用各种不同的负载平衡策略委托给多个endpoint之一。camel-urlrewrite组件将允许您插件url重写机制。

此故障转移负载平衡器可以通过以下方式进行配置：

from("jetty:http://{host}:{{port}}/{context_1}?matchOnUriPrefix=true")
.loadBalance().failover(Exception.class)
.to("jetty:http://{host}:{{port2}}/context_2?bridgeEndpoint=true&urlRewrite=#myRewrite")
.to("jetty:http://{host}:{{port2}}/{other_context}?bridgeEndpoint=true&urlRewrite=#myRewrite");

详细代码可以在这里找到:https://github . com/Apache/camel/tree/master/components/camel-URL rewrite/src/test/Java/org/Apache/camel/component/URL rewrite

*该组件要求您的Camel routes从基于servlet的endpoint开始，如< code>Jetty等。你的代码已经有了。

相关Camel文档@http://camel.apache.org/load-balancer.html