SpringCloud：Ribbon负载均衡

1.概述

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

简单的说，Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。

Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。

简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。

我们也很容易使用Ribbon实现自定义的负载均衡算法。

LB，即负载均衡(Load Balance)，在微服务或分布式集群中经常用的一种应用。

负载均衡简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA。

常见的负载均衡有软件Nginx，LVS，硬件 F5等。

相应的在中间件，例如：dubbo和SpringCloud中均给我们提供了负载均衡，SpringCloud的负载均衡算法可以自定义。

集中式LB

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

进程内LB

将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。

Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

关于负载均衡：https://www.cnblogs.com/danbing/p/7459224.html

2.Ribbon初步配置

修改microservicecloud-consumer-dept-80工程

1.修改pom.xml文件

1<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 　　xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
2      <modelVersion>4.0.0</modelVersion>
3      <parent>
4        <groupId>com.fdzang.springcloud</groupId>
5        <artifactId>microservicecloud</artifactId>
6           <version>0.0.1-SNAPSHOT</version>
7      </parent>
8      <artifactId>microservicecloud-consumer-dept-80</artifactId>
9    <description>部门微服务消费者</description>
10
11    <dependencies>
12        <dependency><!-- 自己定义的api -->
13            <groupId>com.fdzang.springcloud</groupId>
14            <artifactId>microservicecloud-api</artifactId>
15            <version>${project.version}</version>
16        </dependency>
17        <!-- Ribbon相关 -->
18        <dependency>
19            <groupId>org.springframework.cloud</groupId>
20            <artifactId>spring-cloud-starter-eureka</artifactId>
21        </dependency>
22        <dependency>
23            <groupId>org.springframework.cloud</groupId>
24            <artifactId>spring-cloud-starter-ribbon</artifactId>
25        </dependency>
26        <dependency>
27            <groupId>org.springframework.cloud</groupId>
28            <artifactId>spring-cloud-starter-config</artifactId>
29        </dependency>
30        <dependency>
31            <groupId>org.springframework.boot</groupId>
32            <artifactId>spring-boot-starter-web</artifactId>
33        </dependency>
34        <!-- 修改后立即生效，热部署 -->
35        <dependency>
36            <groupId>org.springframework</groupId>
37            <artifactId>springloaded</artifactId>
38        </dependency>
39        <dependency>
40            <groupId>org.springframework.boot</groupId>
41            <artifactId>spring-boot-devtools</artifactId>
42        </dependency>
43    </dependencies>
44</project>

2.修改application.yml 追加eureka的服务注册地址

1server:
2  port: 80
3
4
5eureka:
6  client:
7    register-with-eureka: false
8    service-url: 
9      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

3.对ConfigBean进行新注解@LoadBalanced 获得Rest时加入Ribbon的配置

1package com.fdzang.springcloud.cfgbeans;
2
3import org.springframework.cloud.client.loadbalancer.LoadBalanced;
4import org.springframework.context.annotation.Bean;
5import org.springframework.context.annotation.Configuration;
6import org.springframework.web.client.RestTemplate;
7
8import com.netflix.loadbalancer.IRule;
9import com.netflix.loadbalancer.RetryRule;
10
11@Configuration
12public class ConfigBean{  //boot -->spring   applicationContext.xml --- @Configuration配置   ConfigBean = applicationContext.xml
13
14    @Bean
15    @LoadBalanced//Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端       负载均衡的工具。
16    public RestTemplate getRestTemplate(){
17        return new RestTemplate();
18    }
19}

4.主启动类DeptConsumer80_App添加@EnableEurekaClient

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

5.修改DeptController_Consumer客户端访问类

1package com.fdzang.springcloud.controller;
2import java.util.List;
3
4import org.springframework.beans.factory.annotation.Autowired;
5import org.springframework.web.bind.annotation.PathVariable;
6import org.springframework.web.bind.annotation.RequestMapping;
7import org.springframework.web.bind.annotation.RestController;
8import org.springframework.web.client.RestTemplate;
9
10import com.fdzang.springcloud.entity.Dept;
11
12@RestController
13public class DeptController_Consumer
14{
15
16    //private static final String REST_URL_PREFIX = "http://localhost:8001";
17    private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
18
19    /**
20     * 使用 使用restTemplate访问restful接口非常的简单粗暴无脑。 (url, requestMap,
21     * ResponseBean.class)这三个参数分别代表 REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。
22     */
23    @Autowired
24    private RestTemplate restTemplate;
25
26    @RequestMapping(value = "/consumer/dept/add")
27    public boolean add(Dept dept){
28        return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
29    }
30
31    @RequestMapping(value = "/consumer/dept/get/{id}")
32    public Dept get(@PathVariable("id") Long id){
33        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
34    }
35
36    @SuppressWarnings("unchecked")
37    @RequestMapping(value = "/consumer/dept/list")
38    public List<Dept> list(){
39        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
40    }
41    
42    // 测试@EnableDiscoveryClient,消费端可以调用服务发现
43    @RequestMapping(value = "/consumer/dept/discovery")
44    public Object discovery()
45    {
46        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class);
47    }
48}

先启动3个eureka集群后，再启动microservicecloud-provider-dept-8001并注册进eureka

启动microservicecloud-consumer-dept-80

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

3.Ribbon负载均衡

工作原理

Ribbon在工作时分成两步

第一步先选择 EurekaServer ,它优先选择在同一个区域内负载较少的server.

第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。

其中Ribbon提供了多种策略：比如轮询、随机和根据响应时间加权。

参考microservicecloud-provider-dept-8001，新建两份，分别命名为8002，8003

新建8002/8003数据库，各自微服务分别连各自的数据库

修改8002/8003各自YML

　　只修改端口以及数据库连接，不修改实例名

启动3个eureka集群配置区

启动3个Dept微服务启动并各自测试通过

启动microservicecloud-consumer-dept-80

客户端通过Ribbo完成负载均衡并访问上一步的Dept微服务注意观察看到返回的数据库名字，各不相同，负载均衡实现

总结：Ribbon其实就是一个软负载均衡的客户端组件，

他可以和其他所需请求的客户端结合使用，和eureka结合只是其中的一个实例。

SpringCloud：Ribbon负载均衡

1.概述

2.Ribbon初步配置

3.Ribbon负载均衡

评论区

相关推荐