Spring Cloud Ribbon(服务消费者)

Spring Cloud Ribbon 是一个基于Http和TCP的客户端负载均衡工具,基于Netflix Ribbon实现的。它不像服务注册中心、配置中心、API网关那样独立部署，但是它几乎存在于每个微服务的基础设施中。

Ribbon架构图

1258b858-c697-32e3-8f9e-b2623f7c6862.png

Ribbon负载均衡策略

6944619-0355d316f5df9b3f.png

Ribbon默认的策略是轮询，我们可以自定义负载策略来覆盖默认的，当然也可以通过配置指定使用哪些策略。

负载均衡概念

负载均衡技术在现有网络结构之上提供了一种廉价、有效、透明的方法，来扩展网络设备和服务器的带宽、增加吞吐量、加强网络数据处理能力、提高网络的灵活性和可用性。它有两方面的含义：首先，大量的并发访问或数据流量分担到多台节点设备上分别处理，减少用户等待响应的时间；其次，单个重负载的运算分担到多台节点设备上做并行处理，每个节点设备处理结束后，将结果汇总，返回给用户，系统处理能力得到大幅度提高。

负载均衡是对系统的高可用，网络压力的缓解和处理能力扩容的重要手段之一。

硬件负载均衡:

主要通过在服务节点之间安装专门的负载均衡设备，比如F5
详细参照百度百科:https://baike.baidu.com/item/F5%E6%96%B9%E6%A1%88/1121377?fr=aladdin

软件负载均衡

实现方式有两种，分别是服务端的负载均衡和客户端的负载均衡
服务端负载均衡：在服务端安装一些具有均衡负载功能或者模块的软件来完成请求的分发工作，比如Nginx。

当浏览器向后台发出请求的时候，会首先向反向代理服务器发送请求，反向代理服务器会根据客户端部署的ip：port映射表以及负载均衡策略，来决定向哪台服务器发送请求，一般会使用到nginx反向代理技术。

QQ截图20180626191547.png

客户端负载均衡：当浏览器向后台发出请求的时候，客户端会向服务注册器(例如Eureka Server)，拉取注册到服务器的可用服务信息，然后根据负载均衡策略，直接命中哪台服务器发送请求。这整个过程都是在客户端完成的，并不需要反向代理服务器的参与。

在微服务中最基本的两个角色是服务提供者与服务消费者。
服务提供者：服务的被调用方（为其他服务提供服务的服务）
服务消费者：服务的调用方（依赖其他服务的服务）

之前我们已经尝试了好几种服务注册方式，注册了服务，肯定需要被调用的，也就是消费。
服务调用方式实现方式RestTemplate+Ribbon
使用RestTemplate消费SpringBoot的Restful服务

前提

需要一个服务注册中心，两个服务提供者和一个消费者
因为只有两个以上的服务提供者提供相同的服务才可以体现出负载均衡
服务注册中心和服务提供者都使用Spring Cloud Eureka

实现服务提供者的Restful接口

之前已经实现过服务注册中心和服务提供者
不过之前的服务提供者并没有提供接口给消费者使用

@RestController
public class DiscoveryController {
    @Autowired
    private DiscoveryClient discoveryClient;
    @Value("${server.port}")
    private String ip;

    @GetMapping("/client")
    public String client() {
        String services = "调用的服务是: " + discoveryClient.getServices()+" 对应的端口号 :"+ip;
        System.out.println("调用的服务是: " + discoveryClient.getServices()+" 对应的端口号 :"+ip);
        return services;
    }
}

实现服务消费者Ribbon

一开始肯定打算是引入Spring Cloud Ribbon依赖，不过Spring Cloud Eureka依赖中已经有
Ribbon的依赖了。单独引入Ribbon依赖可能注册不了服务

QQ截图20180626163952.png

在项目的外部Jar包目录中可以发现Spring Cloud Eureka依赖中已经有Ribbon的依赖了
所以，主要引入的依赖和Eureka客户端的一样

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

在项目启动类上添加@EnableEurekaClient注解，消费者和服务提供者一样，都需要到注册中心中注册
并且使用@bean像Spring容器中注入一个restTemplate对象，@LoadBalanced注解表明这个
restRemplate开启负载均衡的功能。

@SpringBootApplication
@EnableEurekaClient
public class SpringcloudConsumerRibbonApplication {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(SpringcloudConsumerRibbonApplication.class, args);
    }
}

下面来写一个简单的服务消费类

@RestController
public class RibbonController {
    @Autowired
    RestTemplate restTemplate;
    @GetMapping("/consumer")
    public String getMsg() {

        return restTemplate.getForObject("http://springcloud-eureka-client/client", String.class);
    }
}

restTemplate可以发送Get，Post，Put，Delete等请求
Get调用getForEntity()方法
Post调用postForObject()方法
Put调用put()方法
Delete调用delete()方法

getForEntity的第一个参数为我要调用的服务的地址，这里我调用了服务提供者提供的
/client接口(Eureka客户端中已写好)，getForEntity第二个参数String.class表示我希望返回的body类型是String

注意这里是通过服务名调用而不是服务地址，如果写成服务地址就没法实现客户端负载均衡了。
调用spring boot服务的时候，需要将服务的URL写死或者是写在配置文件中,一旦ip地址发生了变化，都需要改动程序，并重新部署服务，使用Ribbon的时候，可以有效的避免这个问题。

restTemplate的所有用法可以参考
官方说明文档:https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/web/client/RestTemplate.html
在配置文件中加入相关配置

spring:
  application:
    name: eureka-consumer-ribbon
server:
  port: 9999
eureka:
  client:
    service-url:
      defaultZone: http://localhost:9090/eureka