负载均衡之Spring Cloud Ribbon

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


负载均衡之Spring Cloud Ribbon
 

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

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

客户端负载均衡(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功能已经生效了。

相关推荐