Spring Cloud学习之负载均衡-Ribbon

1、Ribbon简介

负载均衡是指负载分到到多个执行单元上，常见的负载均衡有两种方式，一种是独立进程单元，通过均衡负载策略，将请求转发到不同的执行单元上，例如Ngnix。另外一种是将负载均衡逻辑以代码的形式封装到服务消费者的客户端上，客户端维护了一份服务提供者的信息列表，根据信息列表，通过负载均衡策略将请求分摊给多个服务提供者，从而达到负载均衡的目的。

Ribbon作为一款负载均衡组件，属于上述的第二种方式，是一款非常优秀和稳定的IPC库，可以很好提供HTTP和TCP的负载均衡。

在Spring Cloud构建的微服务系统中，Ribbon有两种使用方式，一种是结合RestTemplate相结合使用，一种是和Feign（已集成Ribbon）相结合使用。

2、使用RestTemplate和Ribbon消费服务

在上节案例的基础上，代码进行改造，将eureka-client分成开启实例（实例名称一致），端口分别是8764和8765，eureka-server开启一个实例8761，启动server实例，然后依次启动client两个实例，效果如下图所示：

创建一个新的module，命名为：eureka-ribbon-client 作为服务消费者，对上述client提供的接口进行消费。

工程的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.hzlitai</groupId>
        <artifactId>eureka-memo</artifactId>
        <version>1.1-SNAPSHOT</version>
    </parent>
    <groupId>com.hzlitai</groupId>
    <artifactId>eureka-ribbon-client</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-ribbon-client</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>
           

配置文件application-yml代码如下：

spring:
  application:
    name: eureka-ribbon-client
server:
  port: 8766
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka
           

增加Ribbon的配置类，代码如下：

package com.hzlitai.eurekaribbonclient.configuration;

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;
@Configuration
public class RibbonConfig {
    @Bean
    @LoadBalanced
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
}
           

然后依次增加Service和Controller，代码如下：

package com.hzlitai.eurekaribbonclient.Service.impl;

import com.hzlitai.eurekaribbonclient.Service.RibbonService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class RibbonServiceImpl implements RibbonService {
    @Autowired
    RestTemplate restTemplate;

    @Override
    public String hi(String name) {
        return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
    }
}
           

package com.hzlitai.eurekaribbonclient.controller;

import com.hzlitai.eurekaribbonclient.Service.RibbonService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class RibbonController {
    @Autowired
    RibbonService ribbonService;
    @GetMapping("/sayHi")
    public String sayHi(@RequestParam String name){
        return ribbonService.hi(name);
    }
}
           

最后访问http://localhost:8766/sayHi?name=zhuheliang，得到如下结果

刷新后的效果：

如果其中一个服务提供者挂了，Ribbon会根据PING机制每隔10秒（默认）发送心跳，如果注册的服务列表有变更，就更新缓存的服务列表信息。