Hello
I'm using cluster on JBoss 4.0.4.GA and I want to implement a custom load-balancing
policy. Unfortunately I faced a problem with the wrong list of targets in
FamilyClusterInfo. Below I'll try to explain the situation.
I have 2 EJB3 stateless beans FooBean and BarBean annotated with @Clustered(partition =
"ShamrockPartition", loadBalancePolicy = MyLoadBalancePolicy.class)
The policy is simple:
| public class MyLoadBalancePolicy extends FirstAvailableIdenticalAllProxies {
|
| public Object chooseTarget(FamilyClusterInfo clusterFamily) {
| return super.chooseTarget(clusterFamily);
| }
|
| public Object chooseTarget(FamilyClusterInfo clusterFamily, Invocation
routingDecision) {
| System.out.println("Family: " + clusterFamily.getFamilyName()
| + ", View: " + clusterFamily.getCurrentViewId() + ",
Targets: " + clusterFamily.getTargets());
| return super.chooseTarget(clusterFamily, routingDecision);
| }
| }
I deploy application onto 2 servers and then start them. A client is simply invokes each
bean many times consequently. Here is the output:
| Family: FooBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/]]
| iteration 0 success
| Family: FooBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/]]
| iteration 1 success
| Family: FooBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/]]
| iteration 2 success
|
As you can see, there is always wrong targets for bean BarBean. If I restart servers, the
situation changes, but usually one of the beans or both have wrong targets.
The only thing which help is hot redeploy of the application, after that all beans have
correct targets.
I've investigated a little and found that method
FamilyClusterInfoImpl.updateClusterInfo() is executed with correct targets after each bean
invocation and it updates the FamilyClusterInfo.
But when FamilyClusterInfo is obtained from ClusteringTargetsRepository, it is updated
again by old incorrect values. If I comment out the line (comment "should not happen:
possible if redeploy after undeploy fails" is not mine)
| family.updateClusterInfo (targets, viewId); // should not happen: possible if
redeploy after undeploy fails
|
everithing works fine and client output looks correct:
| Family: FooBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: 0, Targets: [InvokerLocator
[socket://192.168.3.71:3873/]]
| iteration 0 success
| Family: FooBeansocketShamrockPartition, View: -1211536571, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: -1211536571, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| iteration 1 success
| Family: FooBeansocketShamrockPartition, View: -1211536571, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| Family: BarBeansocketShamrockPartition, View: -1211536571, Targets: [InvokerLocator
[socket://192.168.3.71:3873/], InvokerLocator [socket://192.168.3.65:3873/]]
| iteration 2 success
|
I will appreciate very much any information regarding this...
Konstantin
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4039124#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...