聊聊artemis的ConnectionLoadBalancingPolicy

public final class ServerLocatorImpl implements ServerLocatorInternal, DiscoveryListener {
​
   //......
​
   private TransportConfiguration selectConnector() {
      Pair<TransportConfiguration, TransportConfiguration>[] usedTopology;
​
      flushTopology();
​
      synchronized (topologyArrayGuard) {
         usedTopology = topologyArray;
      }
​
      synchronized (this) {
         if (usedTopology != null && useTopologyForLoadBalancing) {
            if (logger.isTraceEnabled()) {
               logger.trace("Selecting connector from topology.");
            }
            int pos = loadBalancingPolicy.select(usedTopology.length);
            Pair<TransportConfiguration, TransportConfiguration> pair = usedTopology[pos];
​
            return pair.getA();
         } else {
            if (logger.isTraceEnabled()) {
               logger.trace("Selecting connector from initial connectors.");
            }
​
            int pos = loadBalancingPolicy.select(initialConnectors.length);
​
            return initialConnectors[pos];
         }
      }
   }
​
   //......
}

public interface ConnectionLoadBalancingPolicy {
​
   /**
    * Returns the selected index according to the policy implementation.
    *
    * @param max maximum position index that can be selected
    */
   int select(int max);
}

public final class FirstElementConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy {
​
   /**
    * @param max param is ignored
    * @return 0
    */
   @Override
   public int select(final int max) {
      return 0;
   }
}

public final class RandomConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy {
​
   /**
    * Returns a pseudo random number between {@code 0} (inclusive) and {@code max} exclusive.
    *
    * @param max the upper limit of the random number selection
    * @see java.util.Random#nextInt(int)
    */
   @Override
   public int select(final int max) {
      return RandomUtil.randomInterval(0, max);
   }
}

public final class RoundRobinConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy, Serializable {
​
   private static final long serialVersionUID = 7511196010141439559L;
​
   private boolean first = true;
​
   private int pos;
​
   @Override
   public int select(final int max) {
      if (first) {
         // We start on a random one
         pos = RandomUtil.randomInterval(0, max);
​
         first = false;
      } else {
         pos++;
​
         if (pos >= max) {
            pos = 0;
         }
      }
​
      return pos;
   }
}

public final class RandomStickyConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy {
​
   private int pos = -1;
​
   /**
    * @see java.util.Random#nextInt(int)
    */
   @Override
   public int select(final int max) {
      if (pos == -1) {
         pos = RandomUtil.randomInterval(0, max);
      }
​
      return pos;
   }
}