Spring Cloud構建微服務架構:服務消費(基礎)
通過上一篇《Spring Cloud構建微服務架構:服務注冊與發現》,我們已經成功地將服務提供者:eureka-client或consul-client注冊到了Eureka服務注冊中心或Consul服務端上了,同時我們也通過DiscoveryClient接口的getServices獲取了當前客戶端緩存的所有服務清單,那么接下來我們要學習的就是:如何去消費服務提供者的接口?
使用LoadBalancerClient
在Spring Cloud Commons中提供了大量的與服務治理相關的抽象接口,包括DiscoveryClient、這里我們即將介紹的LoadBalancerClient等。對于這些接口的定義我們在上一篇介紹服務注冊與發現時已經說過,Spring Cloud做這一層抽象,很好的解耦了服務治理體系,使得我們可以輕易的替換不同的服務治理設施。
從LoadBalancerClient接口的命名中,我們就知道這是一個負載均衡客戶端的抽象定義,下面我們就看看如何使用Spring Cloud提供的負載均衡器客戶端接口來實現服務的消費。
下面的例子,我們將利用上一篇中構建的eureka-server作為服務注冊中心、eureka-client作為服務提供者作為基礎。
- 我們先來創建一個服務消費者工程,命名為:eureka-consumer。并在pom.xml中引入依賴(這里省略了parent和dependencyManagement的配置):
- <dependencies>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-eureka</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-web</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-actuator</artifactId>
- </dependency>
- </dependencies>
- 配置application.properties,指定eureka注冊中心的地址:
- spring.application.name=eureka-consumer
- server.port=2101
- eureka.client.serviceUrl.defaultZone=http://localhost:1001/eureka/
- 創建應用主類。初始化RestTemplate,用來真正發起REST請求。@EnableDiscoveryClient注解用來將當前應用加入到服務治理體系中。
- @EnableDiscoveryClient
- @SpringBootApplication
- public class Application {
- @Bean
- public RestTemplate restTemplate() {
- return new RestTemplate();
- }
- public static void main(String[] args) {
- new SpringApplicationBuilder(Application.class).web(true).run(args);
- }
- }
- 創建一個接口用來消費eureka-client提供的接口:
- @RestController
- public class DcController {
- @Autowired
- LoadBalancerClient loadBalancerClient;
- @Autowired
- RestTemplate restTemplate;
- @GetMapping("/consumer")
- public String dc() {
- ServiceInstance serviceInstance = loadBalancerClient.choose("eureka-client");
- String url = "http://" + serviceInstance.getHost() + ":" + serviceInstance.getPort() + "/dc";
- System.out.println(url);
- return restTemplate.getForObject(url, String.class);
- }
- }
可以看到這里,我們注入了LoadBalancerClient和RestTemplate,并在/consumer接口的實現中,先通過loadBalancerClient的choose函數來負載均衡的選出一個eureka-client的服務實例,這個服務實例的基本信息存儲在ServiceInstance中,然后通過這些對象中的信息拼接出訪問/dc接口的詳細地址,***再利用RestTemplate對象實現對服務提供者接口的調用。
在完成了上面你的代碼編寫之后,讀者可以將eureka-server、eureka-client、eureka-consumer都啟動起來,然后訪問http://localhost:2101/consumer ,來跟蹤觀察eureka-consumer服務是如何消費eureka-client服務的/dc接口的。
consul版的示例,可查看git倉庫中的consul-client和consul-consumer
代碼示例
樣例工程將沿用之前在碼云和GitHub上創建的SpringCloud-Learning項目,重新做了一下整理。通過不同目錄來區分Brixton和Dalston的示例。
碼云:點擊查看
GitHub:點擊查看
具體工程說明如下:
- eureka的服務注冊中心:eureka-server
- eureka的服務提供方:eureka-client
- eureka的服務消費者:eureka-consumer
- consul的服務提供方:consul-client
- consul的服務消費者:consul-consumer
【本文為51CTO專欄作者“翟永超”的原創稿件,轉載請通過51CTO聯系作者獲取授權】