zoukankan      html  css  js  c++  java
  • 今日份奇思妙想——根据权重负载均衡

    public class WeightProcessor {
    
        private final Map<Integer, List<String>> map = new HashMap<>(); //保存权重值和地址
        private final Integer[] weight; //保存权重值,用于负载均衡
        private final Random random = new Random();
    
        WeightProcessor(Map<String, Integer> map) {
            List<Integer> list = new ArrayList<>();
    
            map.forEach((k, v) -> {
                for (int i = 0; i < v; i++) {
                    list.add(v);
                }
                if (this.map.get(v) == null) {
                    this.map.put(v, new ArrayList<String>(){{add(k);}});
                } else {
                    this.map.get(v).add(k);
                }
            });
    
            this.weight = list.toArray(new Integer[list.size()]);
        }
    
        public String getAddress() {
            int num = random.nextInt(weight.length);
            List<String> list = map.get(weight[num]);
            num = random.nextInt(list.size());
            return list.get(num);
        }
    
        public static void main(String[] args) {
    
            Map<String, Integer> map = new HashMap<String, Integer>(){{
                put("127.0.0.1:8080", 2);
                put("127.0.0.1:8888", 8);
                put("127.0.0.1:6666", 2);
            }};
    
            WeightProcessor processor = new WeightProcessor(map);
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
            System.out.println(processor.getAddress());
        }
    }

    主方法中的是测试方法,思路是将配置文件中的数据以Map的形式读取出来,然后创建负载处理器,根据负载会选择一个节点的地址进行访问。

  • 相关阅读:
    C#发送邮件的实现实例解析
    抄录一下别人的经验
    centos学习一
    关于百度地图API批量转换成坐标的方法
    js和PHP等脚本语言for循环和if语句里面定义变量的作用域
    关于js中去取数组中的重复字符串
    关于handler返回的数据处理
    通过定义任务委托的方法处理 action
    关于点击按钮图片左右切换的随笔
    关于网站内容分享到新浪微博等的代码
  • 原文地址:https://www.cnblogs.com/wxdmw/p/14889806.html
Copyright © 2011-2022 走看看