自定义Ribbon的负载均衡策略

自定义负载均衡策略

官方文档指出：自定义的负载均衡配置类不能放在 @componentScan 所扫描的当前包下及其子包下，不然咱们自定义的这个配置类就会被全部的Ribbon客户端所共享，也就是说咱们达不到特殊化定制的目的了；

 

要求自定义的算法：依旧是轮询策略，可是每一个服务器被调用5次后轮到下一个服务，即之前是每一个服务被调用1次，如今是每一个被调用5次。

 

打开消费者工程：

1、自定义算法类必须继承 AbstractLoadBalanceRule 类

启动类在com.yufeng.springcloud 包下，因此咱们新建一个包: con.yufeng.myrule，并在该包下新建一个类：CustomeRule 

public class CustomeRule extends AbstractLoadBalancerRule { /* total = 0 // 当total==5之后，咱们指针才能往下走， index = 0 // 当前对外提供服务的服务器地址， total须要从新置为零，可是已经达到过一个5次，咱们的index = 1 */

    private int total = 0;             // 总共被调用的次数，目前要求每台被调用5次
    private int currentIndex = 0;    // 当前提供服务的机器号

    public Server choose(ILoadBalancer lb, Object key) { if (lb == null) { return null; } Server server = null; while (server == null) { if (Thread.interrupted()) { return null; } List<Server> upList = lb.getReachableServers(); //当前存活的服务
            List<Server> allList = lb.getAllServers();  //获取所有的服务

            int serverCount = allList.size(); if (serverCount == 0) { return null; } //int index = rand.nextInt(serverCount); //server = upList.get(index);
            if(total < 5) { server = upList.get(currentIndex); total++; }else { total = 0; currentIndex++; if(currentIndex >= upList.size()) { currentIndex = 0; } } if (server == null) { Thread.yield(); continue; } if (server.isAlive()) { return (server); } // Shouldn't actually happen.. but must be transient or a bug.
            server = null; Thread.yield(); } return server; } @Override public Server choose(Object key) { return choose(getLoadBalancer(), key); } @Override public void initWithNiwsConfig(IClientConfig clientConfig) { } }

二、主启动类添加 @RibbonClient 注解，name和configuration参数很重要；

在启动该微服务的时候就能去加载咱们自定义的Ribbon配置类，从而使配置生效：

　　@RibbonClient(name="microservicecloud-dept", configuration=CustomeRule .class)

　　name指定针对哪一个服务 进行负载均衡，而configuration指定负载均衡的算法具体实现类。

三、启动该消费者服务，而后访问：http://localhost/consumer/dept/get/1，能够看到先访问生产者1服务5次，而后访问生产者2服务5次......