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

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

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

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

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

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

使用Spring Cloud Ribbon實(shí)現(xiàn)服務(wù)消費(fèi)者

新建spring-cloud-sample-tutorial-consumer項(xiàng)目

在spring-cloud-sample-tutorial下新建spring-cloud-sample-tutorial-consumer子項(xiàng)目

添加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，注冊(cè)中心地址

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

編寫(xiě)UserController，添加@LoadBalanced注解，啟用Ribbon負(fù)載均衡

@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();
 }
}

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

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

集群部署Producer

為了模擬集群的Producer,在producer項(xiàng)目中新建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/

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

@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() ;
 }
}

啟動(dòng)測(cè)試

啟動(dòng)注冊(cè)中心

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