You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by he...@apache.org on 2011/06/14 11:20:39 UTC
svn commit: r1135430 - in /synapse/trunk/java:
repository/conf/sample/synapse_sample_59.xml
src/site/xdoc/Synapse_Samples.xml
Author: heshan
Date: Tue Jun 14 09:20:39 2011
New Revision: 1135430
URL: http://svn.apache.org/viewvc?rev=1135430&view=rev
Log:
Fix for SYNAPSE-778.
Thanks Miyuru for the contribution.
Added:
synapse/trunk/java/repository/conf/sample/synapse_sample_59.xml
Modified:
synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
Added: synapse/trunk/java/repository/conf/sample/synapse_sample_59.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/synapse_sample_59.xml?rev=1135430&view=auto
==============================================================================
--- synapse/trunk/java/repository/conf/sample/synapse_sample_59.xml (added)
+++ synapse/trunk/java/repository/conf/sample/synapse_sample_59.xml Tue Jun 14 09:20:39 2011
@@ -0,0 +1,83 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<!-- Weighted Round-Robin loadbalancing between 3 endpoints-->
+<definitions xmlns="http://ws.apache.org/ns/synapse">
+ <sequence name="errorHandler">
+ <makefault response="true">
+ <code xmlns:tns="http://www.w3.org/2003/05/soap-envelope" value="tns:Receiver"/>
+ <reason value="COULDN'T SEND THE MESSAGE TO THE SERVER."/>
+ </makefault>
+ <send/>
+ </sequence>
+ <sequence name="fault">
+ <log level="full">
+ <property name="MESSAGE" value="Executing default "fault" sequence"/>
+ <property name="ERROR_CODE" expression="get-property('ERROR_CODE')"/>
+ <property name="ERROR_MESSAGE" expression="get-property('ERROR_MESSAGE')"/>
+ </log>
+ <drop/>
+ </sequence>
+ <sequence name="main" onError="errorHandler">
+ <in>
+ <send>
+ <endpoint>
+ <loadbalance
+ algorithm="org.apache.synapse.endpoints.algorithms.WeightedRoundRobin">
+ <endpoint>
+ <address uri="http://localhost:9001/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="1"/>
+ </endpoint>
+ <endpoint>
+ <address uri="http://localhost:9002/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="2"/>
+ </endpoint>
+ <endpoint>
+ <address uri="http://localhost:9003/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="3"/>
+ </endpoint>
+ </loadbalance>
+ </endpoint>
+ </send>
+ <drop/>
+ </in>
+ <out>
+ <send/>
+ </out>
+ </sequence>
+</definitions>
Modified: synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml?rev=1135430&r1=1135429&r2=1135430&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml Tue Jun 14 09:20:39 2011
@@ -166,7 +166,9 @@
<li>
<a href="#Sample57">Sample 57: Dynamic load balancing between 3 nodes</a></li>
<li>
-<a href="#Sample58">Sample 58: Static load balancing between 3 nodes</a></li></ul></li>
+<a href="#Sample58">Sample 58: Static load balancing between 3 nodes</a></li>
+<li>
+<a href="#Sample59">Sample 59: Weighted load balancing between 3 endpoints</a></li></ul></li>
<li>
<a href="#MessageMediationQoS">Quality of Service addition or deduction samples in message mediation</a>
<ul>
@@ -1654,8 +1656,101 @@ Content-ID:
[java] Request: 67 ==> Response from server: MyServer3
...</pre>
<p>Now restart MyServer1. You can observe that requests will be again sent to all three servers. </p>
-<h1>
-<a name="MessageMediationQoS" id="MessageMediationQoS">Quality of Service addition or deduction samples in message mediation</a> </h1>
+<h2><a name="Sample59">Sample 59: Weighted load balancing between 3
+endpoints</a> </h2>
+<pre xml:space="preserve"><?xml version="1.0" encoding="UTF-8"?>
+<definitions xmlns="http://ws.apache.org/ns/synapse">
+ <sequence name="main" onError="errorHandler">
+ <in>
+ <send>
+ <endpoint>
+ <loadbalance
+ algorithm="org.apache.synapse.endpoints.algorithms.WeightedRoundRobin">
+ <endpoint>
+ <address uri="http://localhost:9001/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="1"/>
+ </endpoint>
+ <endpoint>
+ <address uri="http://localhost:9002/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="2"/>
+ </endpoint>
+ <endpoint>
+ <address uri="http://localhost:9003/services/LBService1">
+ <enableAddressing/>
+ <suspendOnFailure>
+ <initialDuration>20000</initialDuration>
+ <progressionFactor>1.0</progressionFactor>
+ </suspendOnFailure>
+ </address>
+ <property name="loadbalance.weight" value="3"/>
+ </endpoint>
+ </loadbalance>
+ </endpoint>
+ </send>
+ <drop/>
+ </in>
+ <out>
+ <send/>
+ </out>
+ </sequence>
+ <sequence name="errorHandler">
+ <makefault response="true">
+ <code xmlns:tns="http://www.w3.org/2003/05/soap-envelope" value="tns:Receiver"/>
+ <reason value="COULDN'T SEND THE MESSAGE TO THE SERVER."/>
+ </makefault>
+ <send/>
+ </sequence>
+</definitions></pre>
+
+<p><strong>Objective: Demonstrate the weighted load balancing among a set of
+endpoints</strong> </p>
+
+<p><strong>Prerequisites:</strong> </p>
+
+<p>Start ESB with sample configuration 59. (i.e. wso2esb-samples -sn 59) </p>
+
+<p>Deploy the LoadbalanceFailoverService and start three instances of sample Axis2 server as mentioned in sample 52.</p>
+
+<p>Above configuration sends messages with the weighted loadbalance behaviour. Weight of each leaf
+address endpoint is defined by integer value of "loadbalance.weight" property associated with each endpoint.
+If weight of a endpoint is x, x number of requests will send to that endpoint before switch to next active endpoint.
+<br/>To test this, run the loadbalancefailover client to send 100 requests as follows: </p>
+<pre xml:space="preserve">ant loadbalancefailover -Di=100</pre>
+
+<p>This client sends 100 requests to the LoadbalanceFailoverService through
+ESB. ESB will distribute the load among the three endpoints mentioned in the
+configuration in weighted round-robin manner. LoadbalanceFailoverService appends the
+name of the server to the response, so that client can determine which server
+has processed the message. If you examine the console output of the client,
+you can see that requests are processed by three servers as follows: </p>
+<pre xml:space="preserve">[java] Request: 1 ==> Response from server: MyServer1
+[java] Request: 2 ==> Response from server: MyServer2
+[java] Request: 3 ==> Response from server: MyServer2
+[java] Request: 4 ==> Response from server: MyServer3
+[java] Request: 5 ==> Response from server: MyServer3
+[java] Request: 6 ==> Response from server: MyServer3
+[java] Request: 7 ==> Response from server: MyServer1
+[java] Request: 8 ==> Response from server: MyServer2
+[java] Request: 9 ==> Response from server: MyServer2
+[java] Request: 10 ==> Response from server: MyServer3
+[java] Request: 11 ==> Response from server: MyServer3
+[java] Request: 12 ==> Response from server: MyServer3
+...</pre>
+<p>As logs, endpoint with weight 1 received a 1 request and endpoint with weight 2 received 2
+requests and etc... in a cycle</p>
+<h1><a name="MessageMediationQoS" id="MessageMediationQoS">Quality of Service addition or deduction samples in message mediation</a> </h1>
<h2>
<a name="Sample100" id="Sample100">Sample 100: Using WS-Security for outgoing messages</a></h2>
<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
@@ -2211,7 +2306,7 @@ Connection: Keep-Alive
<p>
<strong>Objective: Using synapse to integrate services.</strong> </p>
-<p>
+<p/>
<p>
<strong>Prerequisites:</strong>
<br/> We will be using two services in this sample; i.e. SimpleStockQuoteService and SecureStockQuoteService. Therefore the prerequisites of sample 100 is also applied here.</p>