SpringCloud系列七：使用Ribbon實現客戶端側負載均衡

本文轉載自查看原文 2018-03-26 15:08 957

1. 回顧

　　在前面，已經實現了微服務的注冊與發現。啟動各個微服務時，Eureka Client會把自己的網絡信息注冊到Eureka Server上。

　　但是，在生成環境中，各個微服務都會部署多個實例，因此還行繼續進行優化。

2. Ribbon簡介

　　Ribbon是Netflix發布的負載均衡器，它有助於控制HTTP和TCP客戶端的行為。為Ribbon配置服務提供者地址列表后，Ribbon就可基於某種負載均衡算法，

　　自動地幫助服務消費者去請求。Ribbon默認為我們提供了很多的負載均衡算法，例如輪詢、隨機等。我們也可為Ribbon實現自定義的負載均衡算法。

　　在Spring Cloud中，當Ribbon與Eureka配合使用時，Ribbon可自動從Eureka Server獲取服務提供者地址列表，並基於負載均衡算法，請求其中一個服務提供者實例。

3. 為服務消費者整合Ribbon

　　> 復制項目 microservice-consumer-movice，修改ArtifactId為 microservice-consumer-movie-ribbon

　　> 為項目microservice-consumer-movie添加Ribbon的依賴。但是前文已經為該服務添加spring-cloud-starter-netflix-eureka-client依賴，

　　　　該依賴已經包含了 spring-cloud-starter-netflix-ribbon 依賴，所以無需再次引入。

　　> 在啟動類中，為RestTemplate添加@LoadBalanced注解。

package com.itmuch.cloud.microserviceconsumermovie; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.web.client.RestTemplate; @SpringBootApplication @EnableDiscoveryClient public class MicroserviceConsumerMovieApplication { public static void main(String[] args) { SpringApplication.run(MicroserviceConsumerMovieApplication.class, args); } @Bean @LoadBalanced // 實現負載均衡
    public RestTemplate restTemplate() { return new RestTemplate(); } }

　　> 修改MovieController類，便於發現是否實現負載均衡

package com.itmuch.cloud.microserviceconsumermovie.controller; import com.itmuch.cloud.microserviceconsumermovie.pojo.User; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.loadbalancer.LoadBalancerClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController public class MovieController { private static final Logger LOGGER = LoggerFactory.getLogger(MovieController.class); @Autowired private RestTemplate restTemplate; @Autowired private LoadBalancerClient loadBalancerClient; @GetMapping("/user/{id}") public User findById(@PathVariable Long id) { return this.restTemplate.getForObject("http://microservice-provider-user/" + id, User.class); } @GetMapping("/log-instance") public void logUserInstance() { ServiceInstance serviceInstance = this.loadBalancerClient.choose("microservice-provider-user"); // 打印當前選擇的是哪個節點
        MovieController.LOGGER.info("{}:{}:{}", serviceInstance.getServiceId(), serviceInstance.getHost(), serviceInstance.getPort()); } }