1. Dubbo中LoadBanace 关系
2. 负载均衡策略
2.1 随机算法
默认条件下就是随机算法
package com.alibaba.dubbo.rpc.cluster.loadbalance;
public class RandomLoadBalance extends com.alibaba.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance {
public static final java.lang.String NAME = "random";
private final java.util.Random random;
public RandomLoadBalance() { /* compiled code */ }
protected <T> com.alibaba.dubbo.rpc.Invoker<T> doSelect(java.util.List<com.alibaba.dubbo.rpc.Invoker<T>> invokers, com.alibaba.dubbo.common.URL url, com.alibaba.dubbo.rpc.Invocation invocation) { /* compiled code */ }
}
2.2 最少使用算法
package com.alibaba.dubbo.rpc.cluster.loadbalance;
public class LeastActiveLoadBalance extends com.alibaba.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance {
public static final java.lang.String NAME = "leastactive";
private final java.util.Random random;
public LeastActiveLoadBalance() { /* compiled code */ }
protected <T> com.alibaba.dubbo.rpc.Invoker<T> doSelect(java.util.List<com.alibaba.dubbo.rpc.Invoker<T>> invokers, com.alibaba.dubbo.common.URL url, com.alibaba.dubbo.rpc.Invocation invocation) { /* compiled code */ }
}
2.3 轮循算法
package com.alibaba.dubbo.rpc.cluster.loadbalance;
public class RoundRobinLoadBalance extends com.alibaba.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance {
public static final java.lang.String NAME = "roundrobin";
private final java.util.concurrent.ConcurrentMap<java.lang.String,com.alibaba.dubbo.common.utils.AtomicPositiveInteger> sequences;
public RoundRobinLoadBalance() { /* compiled code */ }
protected <T> com.alibaba.dubbo.rpc.Invoker<T> doSelect(java.util.List<com.alibaba.dubbo.rpc.Invoker<T>> invokers, com.alibaba.dubbo.common.URL url, com.alibaba.dubbo.rpc.Invocation invocation) { /* compiled code */ }
private static final class IntegerWrapper {
private int value;
public IntegerWrapper(int value) { /* compiled code */ }
public int getValue() { /* compiled code */ }
public void setValue(int value) { /* compiled code */ }
public void decrement() { /* compiled code */ }
}
}
2.4 Hash一致性算法
package com.alibaba.dubbo.rpc.cluster.loadbalance;
public class ConsistentHashLoadBalance extends com.alibaba.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance {
private final java.util.concurrent.ConcurrentMap<java.lang.String,com.alibaba.dubbo.rpc.cluster.loadbalance.ConsistentHashLoadBalance.ConsistentHashSelector<?>> selectors;
public ConsistentHashLoadBalance() { /* compiled code */ }
protected <T> com.alibaba.dubbo.rpc.Invoker<T> doSelect(java.util.List<com.alibaba.dubbo.rpc.Invoker<T>> invokers, com.alibaba.dubbo.common.URL url, com.alibaba.dubbo.rpc.Invocation invocation) { /* compiled code */ }
private static final class ConsistentHashSelector <T> {
private final java.util.TreeMap<java.lang.Long,com.alibaba.dubbo.rpc.Invoker<T>> virtualInvokers;
private final int replicaNumber;
private final int identityHashCode;
private final int[] argumentIndex;
ConsistentHashSelector(java.util.List<com.alibaba.dubbo.rpc.Invoker<T>> invokers, java.lang.String methodName, int identityHashCode) { /* compiled code */ }
public com.alibaba.dubbo.rpc.Invoker<T> select(com.alibaba.dubbo.rpc.Invocation invocation) { /* compiled code */ }
private java.lang.String toKey(java.lang.Object[] args) { /* compiled code */ }
private com.alibaba.dubbo.rpc.Invoker<T> selectForKey(long hash) { /* compiled code */ }
private long hash(byte[] digest, int number) { /* compiled code */ }
private byte[] md5(java.lang.String value) { /* compiled code */ }
}
}