负载均衡之Spring Cloud Ribbon

定义:  负载均衡是为了扩展服务器的带宽、吞吐量，加强应用的可用性和灵活性，搭架在现有的网络架构上。主要功能是根据一系列算法，将操作分配到不同的服务器上。常用的有硬件负载均衡，比如F5;软件负载均衡，比如Nginx。其架构如下图：

 

原理: 负载均衡服务器维护一系列可用的服务清单，通过心跳来检查服务器的健康情况。当客户端发送请求的时候，负载均衡服务根据相应的规则（轮询、加权轮询、最少连接、加权最少连接）来选择跳往的服务器.

 

服务器端负载均衡: 故名思意， 负载均衡配置在服务器端，客户端的所有请求都首先经过负载均衡服务器。然后根据具体的规则，决定访问某个具体的业务服务器。

 

客户端负载均衡(Spring cloud ribbon): 负载均衡的设置配置在客户端，客户端维护有服务器列表，且有一套规则，决定调用具体的服务器。

 

我们现在用Spring boot来构建一个Ribbon的实例。我们将创建两个project, 一个为service-provider, 这个为服务的提供方；另外一个为service-consumer, 这个将调用service-provider的api. 具体源代码请见(https://github.com/jessepys/springribbon)

 

搭建service-provider， 在和项目中创建HelloController， 提供hello API

@RestController
public class HelloController {
private static Logger LOG = LoggerFactory.getLogger(HelloController.class);

@RequestMapping(value = "/hello")
public String hello() {
LOG.info("Access /hello");
return "Hello";
}

@RequestMapping(value = "/")
public String home() {
return "welcome!";
}
}
~

 搭建service-consumer, 在这里我们将调用service-provider的API。Spring ribbon使用的是客户端负载均衡，所以我们在这里讲配置ribbon的相关参数

1. 配置Ribbon configuration

 

public class ConsumerConfiguration {

    @Autowired
    IClientConfig ribbonClientConfig;
    @Bean
    public IPing ribbonPing(IClientConfig config) {
        return new PingUrl();
    }

    @Bean
    public IRule ribbonRule(IClientConfig config) {
        return new AvailabilityFilteringRule();
  }

}

@SpringBootApplication
@RibbonClient(name = "service-provider", configuration = ConsumerConfiguration.class)
public class Application {
    @LoadBalanced
    @Bean
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

  2.  调用service服务：

 

 

@RestController
public class ConsumerController {
    @Autowired
    RestTemplate restTemplate;

    @RequestMapping("/hi")
    public String hi(@RequestParam(value="name", defaultValue="Artaban") String name) {
        String greeting = this.restTemplate.getForObject("http://service-provider/hello", String.class);
        return String.format("%s, %s!", greeting, name);
    }
}

 3. Spring application:

 

@SpringBootApplication
@RibbonClient(name = "service-provider", configuration = ConsumerConfiguration.class)
public class Application {
    @LoadBalanced
    @Bean
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

 4. Service的参数配置：

spring:
  application:
    name:service-consumer

server:
  port: 8888

service-provider:
  ribbon:
    eureka:
      enabled: false
    listOfServers: localhost:8097,localhost:8098,localhost:8099
    ServerListRefreshInterval: 15000

 

好了，现在可以启动服务。首先，我们启动service-provider:

SERVER_PORT=8097 ./gradlew bootRun

SERVER_PORT=8098 ./gradlew bootRun

SERVER_PORT=8099 ./gradlew bootRun

启动service-consumer:

./gradlew bootRun

 

在浏览器中输入： http://127.0.0.1:8888/hi?name=hahaha ， 看到返回结果：

Hello, hahaha!

关闭service-provider其中一个服务器，继续访问，看到相同的结果；

再关闭service-provider其中一个服务器，继续访问，看到相同的结果；

所有的都关闭，我们看到访问失败了。从上面的测试结果，表面Spring Ribbon功能已经生效了。