[CONF] Apache Camel > LoadBalancing Mina Example

[confluence]

LoadBalancing Mina Example Page edited by Claus Ibsen Changes (14) h2. Load balancing using Mina example This example show how you can easily use the [camel-mina|Mina] camel-mina component to design a solution allowing to distribute message allowing to distribute message workload on several servers. workload on several servers. Those These servers are simple TCP/IP servers created by the Apache MINA framework and running in separate Java Virtual Machine. The [Load balancer] EIP pattern of Camel which is used top of them allows to send in a Round Robin model mode the messages created from a [Bean] component respectively to each server running on {{localhost:9999}} and {{localhost:9998}}. separate JVMs. The load balancer pattern of Camel which is used top of them allows to send in a Round Robin model mode the messages created from a camel Bean component respectively to each server running on localhost:9991 and localhost:9992. MINA has been configured to send over the wire objects serialized and this is what is showed also in this example. The advantage of this approach is that you don't need to use CORBA or Java RMI for the communication between the different JVMs. The example has been configured to use InOut EIP pattern (sync=true on the Mina endpoint). The demo starts when every 5th seconds, a Report object is created from the camel load balancer server. This object is send by the camel load balancer to a MINA server and object is serialized. One of the two MINA servers (localhost:9991 and localhost:9992) receives the object and enrich the message by setting the field reply of the Report object. The reply is send back by the MINA server to the client, which then logs the reply on the console. The demo starts when every one minute, a {{Report}} object is created from the camel loadbalancer server. This object is send by the camel loadbalancer to a MINA server and object is serialized. One of the two MINA servers ({{localhost:9999}} and {{localhost:9998}}) receives the object and enrich it by setting the field reply of the {{Report}} object. The reply is send back by the MINA server to the waiting caller, who will display in its log the content of the {{Report}} object. h3. Description of the routes {code:xml|title=Load balancer (the caller)} <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd "> <bean id="service" class="org.apache.camel.example.service.Generator"/> {snippet:id=e1|lang=xml|title=Load balancer|url="" {snippet:id=e1|lang=xml|title=Mina Server 1|url="" {snippet:id=e1|lang=xml|title=Mina Server 2|url="" <camelContext xmlns="http://camel.apache.org/schema/spring" trace="false"> <!-- this is just a route to auto generate sample reports --> <route id="sendMessage"> <from uri="timer://org.apache.camel.example.loadbalancer?fixedRate=true&amp;period=60000"/> <bean ref="service" method="createReport"/> <to uri="direct:loadbalance"/> </route> <!-- this is the route with the load balancer which sends in round robin to the 2 mina endpoints --> <route id="loadbalancer"> <from uri="direct:loadbalance"/> <loadBalance> <roundRobin/> <to uri="mina:tcp://localhost:9999?sync=true&amp;allowDefaultCodec=true"/> <to uri="mina:tcp://localhost:9998?sync=true&amp;allowDefaultCodec=true"/> </loadBalance> <to uri="log:org.apache.camel.example?level=INFO"/> </route> </camelContext> </beans> {code} {code:xml|title=Mina Server 1} <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd "> <bean id="service" class="org.apache.camel.example.service.Reporting"/> <camelContext xmlns="http://camel.apache.org/schema/spring" trace="false"> <route id="mina1"> <from uri="mina:tcp://localhost:9999"/> <setHeader headerName="minaServer"><constant>localhost:9999</constant></setHeader> <bean ref="service" method="updateReport"/> </route> </camelContext> </beans> {code} {code:xml|title=Mina Server 2} <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd "> <bean id="service" class="org.apache.camel.example.service.Reporting"/> <camelContext xmlns="http://camel.apache.org/schema/spring" trace="false"> <route id="mina1"> <from uri="mina:tcp://localhost:9998"/> <setHeader headerName="minaServer"><constant>localhost:9999</constant></setHeader> <bean ref="service" method="updateReport"/> </route> </camelContext> </beans> {code} h3. How to run the example ... {code} and check the result in the log console of load balancer {code} [pache.camel.spring.Main.main()] MainSupport INFO Apache Camel 2.2.0 starting [pache.camel.spring.Main.main()] CamelNamespaceHandler INFO camel-osgi.jar/camel-spring-osgi.jar not detected in classpath [pache.camel.spring.Main.main()] DefaultCamelContext INFO Apache Camel 2.2.0 (CamelContext:camelContext) is starting [pache.camel.spring.Main.main()] DefaultCamelContext INFO JMX enabled. Using DefaultManagedLifecycleStrategy. [pache.camel.spring.Main.main()] DefaultCamelContext INFO Started 2 routes [pache.camel.spring.Main.main()] DefaultCamelContext INFO Apache Camel 2.2.0 (CamelContext:camelContext) started [che.camel.example.loadbalancer] example INFO Exchange[BodyType:org.apache.camel.example.model.Report, Body:>> *************** ******************************** >> Report id : 1 >> Report title : Report Title : 1 >> Report content : This is a dummy report >> Report reply : Report updated from MINA server running on : localhost:9999 >> *********************************************** ] [che.camel.example.loadbalancer] example INFO Exchange[BodyType:org.apache.camel.example.model.Report, Body:>> *************** ******************************** >> Report id : 2 >> Report title : Report Title : 2 >> Report content : This is a dummy report >> Report reply : Report updated from MINA server running on : localhost:9998 >> *********************************************** ] [che.camel.example.loadbalancer] example INFO Exchange[BodyType:org.apache.camel.example.model.Report, Body:>> *************** ******************************** >> Report id : 3 >> Report title : Report Title : 3 >> Report content : This is a dummy report >> Report reply : Report updated from MINA server running on : localhost:9999 >> *********************************************** ] ... {code} Full Content Load balancing using Mina example This example show how you can easily use the camel-mina component to design a solution allowing to distribute message workload on several servers. These servers are simple TCP/IP servers created by the Apache MINA framework and running in separate JVMs. The load balancer pattern of Camel which is used top of them allows to send in a Round Robin model mode the messages created from a camel Bean component respectively to each server running on localhost:9991 and localhost:9992. The demo starts when every 5th seconds, a Report object is created from the camel load balancer server. This object is send by the camel load balancer to a MINA server and object is serialized. One of the two MINA servers (localhost:9991 and localhost:9992) receives the object and enrich the message by setting the field reply of the Report object. The reply is send back by the MINA server to the client, which then logs the reply on the console. Description of the routes Load balancer <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> <bean id="service" class="org.apache.camel.example.service.Generator"/> <camelContext xmlns="http://camel.apache.org/schema/spring"> <route id="sendMessage"> <from uri="timer://org.apache.camel.example.loadbalancer?period=10s"/> <bean ref="service" method="createReport"/> <to uri="direct:loadbalance"/> </route> <route id="loadbalancer"> <from uri="direct:loadbalance"/> <loadBalance> <roundRobin/> <to uri="mina:tcp://localhost:9991?sync=true&amp;allowDefaultCodec=true"/> <to uri="mina:tcp://localhost:9992?sync=true&amp;allowDefaultCodec=true"/> </loadBalance> <log message="${body}"/> </route> </camelContext> </beans> Mina Server 1 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> <bean id="service" class="org.apache.camel.example.service.Reporting"/> <camelContext xmlns="http://camel.apache.org/schema/spring"> <route id="mina1"> <from uri="mina:tcp://localhost:9991"/> <setHeader headerName="minaServer"> <constant>localhost:9991</constant> </setHeader> <bean ref="service" method="updateReport"/> </route> </camelContext> </beans> Mina Server 2 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> <bean id="service" class="org.apache.camel.example.service.Reporting"/> <camelContext xmlns="http://camel.apache.org/schema/spring"> <route id="mina2"> <from uri="mina:tcp://localhost:9992"/> <setHeader headerName="minaServer"> <constant>localhost:9992</constant> </setHeader> <bean ref="service" method="updateReport"/> </route> </camelContext> </beans> How to run the example To compile and install the project in your maven repo, execute the following command on the root of the project: mvn clean install To run the example, execute now the following command in the respective folder: >mina1 mvn exec:java -Pmina1 >mina2 mvn exec:java -Pmina2 >loadbalancing mvn exec:java -Ploadbalancer and check the result in the console of load balancer Change Notification Preferences View Online | View Changes | Add Comment