（04）SpringCloud实战之Ribbon负载均衡

　　一、负载均衡概述

　　1、Ribbon 简介

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

　　2、负载均衡简介

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

　　（1）集中式LB：

　　在服务的消费方和提供方之间使用独立的LB设施(可以是硬件，如F5, 也可以是软件，如nginx), 该设施负责把访问请求通过某种策略转发至服务的提供方；

　　（2）进程内LB：

　　将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

　　二、Ribbon配置初步

　　1、修改微服务 microservicecloud-consumer-dept-80

　　pom.xml 添加 Ribbon 相关依赖

<!-- Ribbon相关 -->
   <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-eureka</artifactId>
   </dependency>
   <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>

　　application.yml 添加 eureka 的服务注册地址

eureka:
  client:
    register-with-eureka: false
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

　　创建 RestTemplate 时添加 @LoadBalanced 注解，第12行为新增的

 1 package com.atguigu.springcloud.cfgbeans;
 2 
 3 import org.springframework.cloud.client.loadbalancer.LoadBalanced;
 4 import org.springframework.context.annotation.Bean;
 5 import org.springframework.context.annotation.Configuration;
 6 import org.springframework.web.client.RestTemplate;
 7  
 8 @Configuration
 9 public class ConfigBean
10 {
11     @Bean
12     @LoadBalanced
13     public RestTemplate getRestTemplate()
14     {
15          return new RestTemplate();
16     }
17 }

　　80微服务启动类 DeptConsumer80_App.java 添加 @EnableEurekaClient 注解（第 8 行）

 1 package com.atguigu.springcloud;
 2  
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 6  
 7 @SpringBootApplication
 8 @EnableEurekaClient
 9 public class DeptConsumer80_App
10 {
11   public static void main(String[] args)
12   {
13    SpringApplication.run(DeptConsumer80_App.class, args);
14   }
15 }

　　修改DeptController_Consumer客户端访问类，将 http://localhost:8001 换成微服务名 MICROSERVICECLOUD-DEPT

//private static final String REST_URL_PREFIX = "http://localhost:8001";
  private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";

　　依次启动 7001、7002、7003、8001、80 并验证下列地址均能正常访问。

　　http://localhost/consumer/dept/get/1

（04）SpringCloud实战之Ribbon负载均衡

　　http://localhost/consumer/dept/list

（04）SpringCloud实战之Ribbon负载均衡

　　http://localhost/consumer/dept/add?dname=大数据部

（04）SpringCloud实战之Ribbon负载均衡

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

　　三、Ribbon负载均衡

　　1、架构说明及工作步骤

（04）SpringCloud实战之Ribbon负载均衡

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

　　2、参考微服务8001新建微服务8002、8003

　　8001、8002、8003连各自的数据库，创建数据库的脚本如下：

 
DROP DATABASE IF EXISTS cloudDB02;
 
CREATE DATABASE cloudDB02 CHARACTER SET UTF8;
 
USE cloudDB02;
 
CREATE TABLE dept
(
  deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,
  dname VARCHAR(60),
  db_source   VARCHAR(60)
);
 
INSERT INTO dept(dname,db_source) VALUES('开发部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('财务部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('市场部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('运维部',DATABASE());
 
SELECT * FROM dept;

View Code