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