（第三篇）Springcloud之Ribbon负载均衡

一、简介

1、介绍

Spring Cloud Ribbon是Netflix发布的开源项目，是基于Netflix Ribbon实现的一套客户端负载均衡的工具。主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

2、负载均衡

Load Balance：即负载均衡(LB)，在微服务或分布式集群中经常用的一种应用。就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA（高可用）。常见的负载均衡有软件Nginx，LVS，硬件F5等。例如：dubbo和SpringCloud中均提供了负载均衡，SpringCloud的负载均衡算法是可以自定义。

gitHub地址

二、配置使用

1、修改之前讲的80工程

（1）修改pom.xml文件

        <!-- eureka相关 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId></dependency><!-- Ribbon相关 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-ribbon</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-config</artifactId></dependency>

（2）修改application.yml文件

#   eureka配置
eureka:client:# false表示不向注册中心注册自己。register-with-eureka: falseservice-url:defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/,http://localhost:7003/eureka/

（3）修改RestTemplate配置类

@Configuration
public class ConfigBean {@Bean@LoadBalancedpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}

（4）修改启动类

@SpringBootApplication
@EnableEurekaClient
public class DeptConsumer80_App {public static void main(String[] args) {SpringApplication.run(DeptConsumer80_App.class, args);}
}

（5）修改controller

@RestController
@RequestMapping("/consumer/dept")
public class DeptConsumerController {//    private static final String REST_URL_PREFIX = "http://localhost:8001";private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";@Autowiredprivate RestTemplate restTemplate;@RequestMapping(value="/add")public boolean add(Dept dept) {return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, Boolean.class);}@RequestMapping(value="/get/{id}")public Dept get(@PathVariable("id") Long id) {return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, Dept.class);}@RequestMapping(value="/list")public List<Dept> list() {return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class);}   
}

（6）启动3个eureka集群和8001服务

（7）启动80服务测试

Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号

三、Ribbon负载均衡

1、架构说明

第一步先选择 EurekaServer ,优先选择在同一个区域内负载较少的server.
第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。其中Ribbon提供了多种策略：比如轮询、随机和根据响应时间加权。

2、创建多个数据库

hk-cloud-demo库的dept表

hk-cloud-demo2库的dept表

hk-cloud-demo3库的dept表

3、创建多个生产者

在之前8001服务的基础上复制8002服务和8003服务

4、修改8002和8003的application.yml文件

注意：8001、8002、8003的应用名要保持一致

spring:application:name: microservicecloud-dept

server:port: 8002mybatis:# mybatis配置文件所在路径config-location: classpath:mybatis/mybatis.cfg.xml# 所有Entity别名类所在包type-aliases-package: com.hk.clouddemo.entities# mapper映射文件mapper-locations:- classpath:mapper/**/*.xmlspring:application:name: microservicecloud-deptdatasource:# 当前数据源操作类型type: com.alibaba.druid.pool.DruidDataSource# mysql驱动包driver-class-name: com.mysql.cj.jdbc.Driver# 数据库名称url: jdbc:mysql://localhost:3306/hk-cloud-demo2username: rootpassword: rootdbcp2:# 数据库连接池的最小维持连接数min-idle: 5# 初始化连接数initial-size: 5# 最大连接数max-total: 5# 等待连接获取的最大超时时间max-wait-millis: 200eureka:client: #客户端注册进eureka服务列表内service-url:defaultZone: http://eureka-7001.com:7001/eureka/,http://eureka-7002.com:7002/eureka/,http://eureka-7003.com:7003/eureka/instance:# 自定义服务名称信息instance-id: microservicecloud-dept8002# 访问路径可以显示IP地址prefer-ip-address: trueinfo:app.name: microservicecloudcompany.name: microservicecloud.hk.combuild.artifactId: @project.artifactId@build.version: @project.version@

server:port: 8003mybatis:# mybatis配置文件所在路径config-location: classpath:mybatis/mybatis.cfg.xml# 所有Entity别名类所在包type-aliases-package: com.hk.clouddemo.entities# mapper映射文件mapper-locations:- classpath:mapper/**/*.xmlspring:application:name: microservicecloud-deptdatasource:# 当前数据源操作类型type: com.alibaba.druid.pool.DruidDataSource# mysql驱动包driver-class-name: com.mysql.cj.jdbc.Driver# 数据库名称url: jdbc:mysql://localhost:3306/hk-cloud-demo3username: rootpassword: rootdbcp2:# 数据库连接池的最小维持连接数min-idle: 5# 初始化连接数initial-size: 5# 最大连接数max-total: 5# 等待连接获取的最大超时时间max-wait-millis: 200eureka:client: #客户端注册进eureka服务列表内service-url:defaultZone: http://eureka-7001.com:7001/eureka/,http://eureka-7002.com:7002/eureka/,http://eureka-7003.com:7003/eureka/instance:# 自定义服务名称信息instance-id: microservicecloud-dept8003# 访问路径可以显示IP地址prefer-ip-address: trueinfo:app.name: microservicecloudcompany.name: microservicecloud.hk.combuild.artifactId: @project.artifactId@build.version: @project.version@

5、启动8002和8003

观察eureka