快捷導(dǎo)航

Spring Cloud Ribbon實現(xiàn)客戶端負載均衡的示例

更新時間：2018年02月07日 16:33:55 作者：馬軍偉

本篇文章主要介紹了Spring Cloud Ribbon實現(xiàn)客戶端負載均衡的示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

前面我們已經(jīng)完成了注冊中心和服務(wù)提供者兩個基礎(chǔ)組件。本文就介紹使用Spring Cloud Ribbon在客戶端負載均衡的調(diào)用服務(wù)。

對于大型應(yīng)用系統(tǒng)負載均衡(LB:Load Balancing)是首要被解決一個問題。在微服務(wù)之前LB方案主要是集中式負載均衡方案，在服務(wù)消費者和服務(wù)提供者之間又一個獨立的LB，LB通常是專門的硬件，如F5，或者是基于軟件的，如VS、HAproxy等。LB上有所有服務(wù)的地址映射表，當服務(wù)消費者調(diào)用某個目標服務(wù)時，它先向LB發(fā)起請求，由LB以某種策略（比如：Round-Robin）做負載均衡后將請求轉(zhuǎn)發(fā)到目標服務(wù)。

而微服務(wù)的出現(xiàn)，則為LB的實現(xiàn)提供了另外一種思路：把LB的功能以庫的方式集成到服務(wù)消費方的進程內(nèi)，而不是由一個集中的設(shè)備或服務(wù)器提供。這種方案稱為軟負載均衡（Soft Load Balancing）或者客戶端負載均衡。在Spring Cloud中配合Eureka的服務(wù)注冊功能，Ribbon子項目則為REST客戶端實現(xiàn)了負載均衡。

使用Spring Cloud Ribbon實現(xiàn)服務(wù)消費者

新建spring-cloud-sample-tutorial-consumer項目

在spring-cloud-sample-tutorial下新建spring-cloud-sample-tutorial-consumer子項目

添加ribbon和eureka依賴

<dependencies>
 <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-eureka</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-ribbon</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
</dependencies>

配置applicatioin.properties，注冊中心地址

spring.application.name=consumer
server.port=30001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

編寫UserController，添加@LoadBalanced注解，啟用Ribbon負載均衡

@Controller
@RequestMapping("user")
public class UserController {
 
 @Bean
 @LoadBalanced
 RestTemplate initRestTemplate(){
  return new RestTemplate();
 }
 
 @Autowired
 private RestTemplate restTemplate;
 
 @RequestMapping("add")
 @ResponseBody
 public String add(String userName, String age){
  return restTemplate.getForEntity("http://PRODUCER/user/add",String.class,userName,age).getBody();
 }
}

編寫ConsumerApplication，添加@EnableEurekaClient，啟用服務(wù)注冊

@EnableEurekaClient
@SpringBootApplication
public class ConsumerApplication {
 public static void main(String[] args) {
  SpringApplication.run(ConsumerApplication.class,args);
 }
}

集群部署Producer

為了模擬集群的Producer,在producer項目中新建application-profile1.properties和application-profile2.properties。

application-profile1.properties

spring.application.name=producer
server.port=20001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

application-profile2.properties

spring.application.name=producer
server.port=20002
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

為了測試負載的效果，我們把被調(diào)用服務(wù)的端口打出來

@Controller
@RequestMapping("user")
public class UserController {
 private Logger logger = LoggerFactory.getLogger(getClass());
 
 @Autowired
 private DiscoveryClient client;
 @RequestMapping("add")
 @ResponseBody
 public String addUser(String userName, String age) {
  return "Success from " + client.getLocalServiceInstance().getHost() + ":" + client.getLocalServiceInstance().getPort() ;
 }
}

啟動測試

啟動注冊中心

分別配置Active Profiles為profile1和profile2，啟動兩次，完成注冊中心集群的服務(wù)啟動。