zoukankan      html  css  js  c++  java
  • 负载均衡算法C#版

    public class LoadBalance
        {
            /// <summary>
            /// 锁对象
            /// </summary>
            private static readonly object locker = new object();
    
            /// <summary>
            /// 服务器权重列表
            /// </summary>
            private static List<int> weightList= new List<int>();
    
            /// <summary>
            /// 当前索引
            /// </summary>
            private static int currentIndex;
    
            /// <summary>
            /// 当前权重
            /// </summary>
            private static int currentWeight;
    
            private static int maxWeight;
    
            /// <summary>
            /// 最大公约数
            /// </summary>
            private static int gcd;
    
            static LoadBalance()
            {
                currentIndex = -1;
                currentWeight = 0;
    
                //获取服务器权重列表,从配置文件
                weightList = GetWeightList();
                maxWeight = GetMaxWeight(weightList);
                gcd = GetMaxGCD(weightList);
            }
            private static List<int> GetWeightList()
            {
                List<int> list= new List<int>();
                list.Add(3);
                list.Add(1);
                list.Add(1);
                list.Add(4);
                list.Add(1);
                list.Add(7);
                
                return list;
            }
    
            [MethodImpl(MethodImplOptions.Synchronized)]
            public static int Start()
            {
                lock (locker)
                {
                    int? iWeight = RoundRobin();
                    if (iWeight != null)
                    {
                        return (int)iWeight;
                    }
                    return weightList[0];
                }
            }
    
    
            /// <summary>
            /// 获取最大公约数
            /// </summary>
            /// <param name="list">要查找的int集合</param>
            /// <returns>返回集合中所有数的最大公约数</returns>
            private static int GetMaxGCD(List<int> list)
            {
                list.Sort(new WeightCompare());
    
                int iMinWeight = weightList[0];
    
                int gcd = 1;
                
                for (int i = 1; i < iMinWeight; i++)
                {
                    bool isFound = true;
                    foreach (int iWeight in list)
                    {
                        if(iWeight %  i != 0)
                        {
                            isFound = false;
                            break;
                        }
                    }
                    if (isFound) gcd = i;
                }
                return gcd;
            }
    
    
            /// <summary>
            /// 获取服务器权重集合中的最大权重
            /// </summary>
            /// <param name="list"></param>
            /// <returns></returns>
            private static int GetMaxWeight(List<int> list)
            {
                int iMaxWeight = 0;
                foreach (int i in list)
                {
                    if (iMaxWeight < i) iMaxWeight = i;
                }
                return iMaxWeight;
            }
    
            private static int? RoundRobin()
            {
                while (true)
                {
                    currentIndex = (currentIndex + 1)%weightList.Count;
                    if(0 == currentIndex)
                    {
                        currentWeight = currentWeight - gcd;
                        if(0 >= currentWeight)
                        {
                            currentWeight = maxWeight;
                            if (currentWeight == 0) return null;
                        }
                    }
                
                    if(weightList[currentIndex] >= currentWeight)
                    {
                        return weightList[currentIndex];
                    }
                }
            }
    
        }
    
        public class WeightCompare : IComparer<int>
        {
            public int Compare(int x, int y)
            {
                return x - y;
            }
        }
    
    调用如下:
        static class Program
        {
            /// <summary>
            /// 应用程序的主入口点。
            /// </summary>
            [STAThread]
            static void Main()
            {
                Console.WriteLine("开始......");
                int iweight ;
                for (int i = 0; i < 17; i++)
                {
                    iweight = LoadBalance.Start();
                    Console.WriteLine(iweight);
                }
                Console.ReadLine();
            }
        }
    
  • 相关阅读:
    redis使用lua脚本遇到的问题
    redis使用scan count 返回数量不准确
    window系统下搭建本地的NuGet Server
    windows10使用docker发布.netcore程序
    windows10使用docker安装mysql
    windows10搭建redis4.0集群
    windows10配置redis主从复制
    windows10安装redis4.0
    mysql 共享排他锁
    mysql drop表以后恢复数据
  • 原文地址:https://www.cnblogs.com/rainnight/p/2019037.html
Copyright © 2011-2022 走看看