04负载均衡及Ribbon自定义负载均衡算法

负载均衡及Ribbon

ribbon是什么&＃xff1f;

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。

ribbon能干吗&＃xff1f;

• LB&＃xff0c;即负载均衡(Load Balance)&＃xff0c;在微服务或分布式集群中经常用的一种应用。
• 负载均衡简单的说就是将用户的请求平摊的分配到多个服务上&＃xff0c;从而达到系统的HA&＃xff08;高可用)。
• 常见的负载均衡软件有Nginx, Lvs等等
• dubbo、SpringCloud中均给我们提供了负载均衡&＃xff0c;SpringCloud的负载均衡算法可以自定义

第一步、80项目 加依赖

<dependency><groupId>org.springframework.cloudgroupId><artifactId>spring-cloud-starter-ribbonartifactId><version>1.4.6.RELEASEversion>dependency><dependency><groupId>org.springframework.cloudgroupId><artifactId>spring-cloud-starter-eurekaartifactId><version>1.4.6.RELEASEversion>dependency>


第二步、80 application.xml加配置

#erueka配置
eureka:client:register-with-eureka: false #不再eureka注册自己service-url:defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

第三步、80 com.tian.springcloud.config;

• 配置类

&＃64;Configuration
public class ConfigBean { //&＃64;Configuration --- spring applicationContext.xml//配置负载均衡实现Template&＃64;LoadBalanced //Ribbon&＃64;Beanpublic RestTemplate getRestTemplate(){return new RestTemplate();}
}


第四步、controller

&＃64;Autowiredprivate RestTemplate restTemplate;//提供多种便捷访问远程http服务的方法&＃xff0c;简单的restful服务模板~//这里的地址&＃xff0c;一百个该市一个变量&＃xff0c;通过服务名来访问//private static final String REST_URL_PREFIX&＃61;"http://localhost:8001";private static final String REST_URL_PREFIX&＃61;"http://SPRINGCLOUD-PROVIDER-DEPT";


第五步、主启动类加注解 &＃64;EnableEurekaClient

//ribbon 和 eureka 整合以后&＃xff0c;客户端可以直接调用&＃xff0c;不用IP地址
&＃64;SpringBootApplication
&＃64;EnableEurekaClient
public class DeptConsumer_80 {public static void main(String[] args) {SpringApplication.run(DeptConsumer_80.class,args);}
}

使用Ribbon实现负载均衡

第一步、创建db02 db03数据库 数据和db01一样&＃xff0c;db_source不一样

第二步、new module 8002 8003

copypom依赖
resource下面的资源
application.xml 里面更改对应的数据库和端口号和 instance-id三个application&＃xff1a;name 是一样的 copy DeptMapper.xml
copy java 代码 &＃xff08;dao service controller&＃xff09;
改一下主启动类 即可


7001 8001 8002 8003 启动 80启动~

测试访问 轮询

自定义负载均衡算法

默认是轮询

所以不和主启动类放在一个包下

第一步、自定义一个算法类 TianRandomRule

package com.tian.myrule;import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.AbstractLoadBalancerRule;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.Server;
import java.util.List;
import java.util.concurrent.ThreadLocalRandom;public class TianRandomRule extends AbstractLoadBalancerRule {/*每个服务&＃xff0c;访问5次 换下一个服务&＃xff08;3个&＃xff09;* total&＃61;0 默认&＃61;0 如果等于5 就指向下一个服务节点* index&＃61;0 默认为0 如果total&＃61;5 index&＃43;1* */private int total&＃61;0; //被调用的次数private int currentIndex&＃61;0; //当前是谁在提供服务public Server choose(ILoadBalancer lb, Object key) {if (lb &＃61;&＃61; null) {return null;} else {Server server &＃61; null;while(server &＃61;&＃61; null) {if (Thread.interrupted()) {return null;}List<Server> upList &＃61; lb.getReachableServers();List<Server> allList &＃61; lb.getAllServers();int serverCount &＃61; allList.size();if (serverCount &＃61;&＃61; 0) {return null;}
//-----------------if (total<5){server&＃61;upList.get(currentIndex);total&＃43;&＃43;;}else {total&＃61;0;currentIndex&＃43;&＃43;;if(currentIndex>upList.size()-1){currentIndex&＃61;0;}}
//-------------
// int index &＃61; this.chooseRandomInt(serverCount);
// server &＃61; (Server)upList.get(index);if (server &＃61;&＃61; null) {Thread.yield();} else {if (server.isAlive()) {return server;}server &＃61; null;Thread.yield();}}return server;}}protected int chooseRandomInt(int serverCount) {return ThreadLocalRandom.current().nextInt(serverCount);}public Server choose(Object key) {return this.choose(this.getLoadBalancer(), key);}public void initWithNiwsConfig(IClientConfig clientConfig) {}
}

第二步、配置到spring中~

return new TianRandomRule();