SpringCloud框架服務消費者-Ribbon
上文我們建立了註冊中心，以及服務的提供者microservice-provider-user，併成功
地將服務提供者註冊到了註冊中心上。
要想消費microservice-provider-user的服務是很簡單的，我們只需要使用
RestTemplate即可，或者例如HttpClient之類的http工具也是可以的。但是在叢集環
境下，我們必然是每個服務部署多個例項，那麼服務消費者消費服務提供者時的負
載均衡又要如何做呢？
1.準備工作
- 啟動註冊中心：microservice-discovery-eureka
- 啟動服務提供方：microservice-provider-user
- 修改microservice-provider-user的埠為8001，另外啟動一個例項
此時，訪問http://discovery:8761
可以在Eureka中看到microservice-provider-user有兩個例項在執行。
下面我們建立一個新的微服務（microservice-consumer-movie-*），負載均衡地消
費microservice-provider-user的服務。
2.Ribbon介紹
Ribbon是Netflix釋出的開源專案，主要功能是提供客戶端的軟體負載均衡演算法，將
Netflix的中間層服務連線在一起。Ribbon客戶端元件提供一系列完善的配置項如連
接超時，重試等。簡單的說，就是在配置檔案中列出Load Balancer後面所有的機
器，Ribbon會自動的幫助你基於某種規則（如簡單輪詢，隨即連線等）去連線這些
機器。我們也很容易使用Ribbon實現自定義的負載均衡演算法。簡單地說，Ribbon是
一個客戶端負載均衡器。
Ribbon工作時分為兩步：第一步先選擇 Eureka Server, 它優先選擇在同一個Zone
且負載較少的Server；第二步再根據使用者指定的策略，在從Server取到的服務註冊
列表中選擇一個地址。其中Ribbon提供了三種策略：輪詢、斷路器和根據響應時間
加權。
3.開發
建立一個Maven專案，並在pom.xml中加入如下內容：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="ht
tp://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://m
aven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</ - 啟動類：MovieRibbonApplication.java。使用
@LoadBalanced註解，為
RestTemplate開啟負載均衡的能力。
@SpringBootApplication
@EnableDiscoveryClient
public class MovieRibbonApplication {
/**
* 例項化RestTemplate，通過@LoadBalanced註解開啟均衡負載能力.
* @return restTemplate
*/
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(MovieRibbonApplication.class, args);
}
}
- 實體類：User.java
public class User {
private Long id;
private String username;
private Integer age;
...
// getters and setters
}
- Ribbon的測試類：RibbonService.java
@Service
public class RibbonService {
@Autowired
private RestTemplate restTemplate;
public User findById(Long id) {
// http://服務提供者的serviceId/url
return this.restTemplate.getForObject("http://microservice-p
rovider-user/" + id, User.class);
}
}
- controller：RibbonController.java
@RestController
public class RibbonController {
@Autowired
private RibbonService ribbonService;
@GetMapping("/ribbon/{id}")
public User findById(@PathVariable Long id) {
return this.ribbonService.findById(id);
}
}
- application.yml
server:
port: 8010
spring:
application:
name: microservice-consumer-movie-ribbon
eureka:
client:
serviceUrl:
defaultZone: http://discovery:8761/eureka/
instance:
preferIpAddress: true
啟動後，訪問多次http://localhost:8010/ribbon/1，返回結果：
{
"id": 1,
"username": "Tom",
"age": 12
}
然後開啟兩個microservice-provider-user例項的控制檯，發現兩個例項都輸出了類
似如下的日誌內容：
Hibernate: select user0_.id as id1_0_0_, user0_.age as age2_0_0_
, user0_.username as username3_0_0_ from user user0_ where user0
_.id=?
2016-09-13 21:38:56.719 TRACE 17404 --- [nio-8000-exec-1] o.h.ty
pe.descriptor.sql.BasicBinder : binding parameter [1] as [B
IGINT] - [1]
2016-09-13 21:38:56.720 TRACE 17404 --- [nio-8000-exec-1] o.h.ty
pe.descriptor.sql.BasicExtractor : extracted value ([age2_0_0_
] : [INTEGER]) - [12]
2016-09-13 21:38:56.720 TRACE 17404 --- [nio-8000-exec-1] o.h.ty
pe.descriptor.sql.BasicExtractor : extracted value ([username3
_0_0_] : [VARCHAR]) - [Tom]
2016-09-13 21:39:10.588 INFO 17404 --- [trap-executor-0] c.n.d.
s.r.aws.ConfigClusterResolver : Resolving eureka endpoints
via configuration
至此，我們已經通過Ribbon在客戶端側實現了均衡負載。
Ribbon程式碼地址：
http://git.oschina.net/itmuch/spring-cloud-study/tree/master/microserviceconsumer-movie-ribbon https://github.com/eacdy/spring-cloudstudy/tree/master/microservice-consumer-movie-ribbon