微服务架构-Ribbon

Ribbon介绍

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

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

步骤：

1.修改cloud-consumer-80 pom文件

<?xml version="1.0" encoding="UTF-8"?>

<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">
  <parent>
    <artifactId>cloud-parent</artifactId>
    <groupId>com.el.cloud</groupId>
    <version>1.0-SNAPSHOT</version>
  </parent>
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.el.cloud</groupId>
  <artifactId>cloud-consumer-80</artifactId>

  <name>cloud-consumer-80</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>

  <description>部门微服务消费者</description>

  <dependencies>
    <dependency><!-- 自己定义的api -->
      <groupId>com.el.cloud</groupId>
      <artifactId>cloud-api</artifactId>
      <version>${project.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- 修改后立即生效，热部署 -->
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>springloaded</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-devtools</artifactId>
    </dependency>

    <!-- 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>
  </dependencies>
</project>

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

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

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

package com.el.consumer.cloud.configure;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @Auther: roman.zhang
 * @Date: 2019/3/19 13:59
 * @Version:V1.0
 * @Description:ConfigBean
 */
@Configuration
public class ConfigBean {

  @Bean
  @LoadBalanced
  public RestTemplate getRestTemplate(){
    return new RestTemplate();
  }

}

主启动类DeptConsumer80_App添加@EnableEurekaClient

package com.el.consumer.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

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

修改DeptController_Consumer客户端访问类

package com.el.consumer.cloud.controller;

import com.el.consumer.cloud.entities.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * @Auther: roman.zhang
 * @Date: 2019/3/19 14:02
 * @Version:V1.0
 * @Description:DeptController_Consumer
 */
@RestController
public class DeptController_Consumer {
  //private static final String REST_URL_PREFIX = "http://localhost:8002";
  private static final String REST_URL_PREFIX = "http://cloud-dept";
  @Autowired
  private RestTemplate restTemplate;

  @RequestMapping(value = "/consumer/dept/add")
  public boolean add(Dept dept){
    return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,boolean.class);
  }

  @RequestMapping(value="/consumer/dept/get/{id}")
  public Dept get(@PathVariable("id") Long id){
    return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class);
  }

  @RequestMapping(value="/consumer/dept/list")
  public List<Dept> list(){
    return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class);
  }
}

测试：

1. 先启动3个eureka集群后，再启动cloud-provider-8001并注册进eureka。

2.启动cloud-consumer-80

3.访问接口：http://localhost/consumer/dept/get/1 http://localhost/consumer/dept/list http://localhost/consumer/dept/add?dname=大数据部

总结：

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

Ribbon负载均衡

架构说明：

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

步骤：

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

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

3.修改8002/8003各自YML

4.启动3个eureka集群配置区

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

6.启动cloud-consumer-80

7.客户端通过Ribbo完成负载均衡并访问上一步的Dept微服务

总结：Ribbon其实就是一个软负载均衡的客户端组件，
他可以和其他所需请求的客户端结合使用，和eureka结合只是其中的一个实例。