微服務架構--服務消費者（Rest+Ribbon）

服務消費者（Rest+Ribbon）

• • 簡介
  • Ribbon簡介
  • 準備工作
  • 建立一個服務消費者
  • • 第一步：建立一個普通的Spring Boot工程
    • 第二步：引入依賴
    • 第三步：在application.yml配置檔案當中配置
    • 第四步：在入口類application當中，注入RestTemplate的bean
    • 第五步:寫一個HelloServer類來調用服務提供者的接口
    • 第六步：寫一個Controller，提供對外通路的接口
    • 第七步：啟動項目并通路

簡介

在服務架構單中，業務會被拆分成一個一個獨立的服務，服務與服務之間的通訊是通過Http Rest的，Spring cloud有兩種服務調用方式，一種是

ribbon+restTemplate

，另一種是

feign

。

Ribbon簡介

Ribbon 是一個基于HTTP和TCP用戶端的負載均衡器

。Feign中也使用Ribbon，後續會介紹Feign的使用。Ribbon可以在通過用戶端中配置的ribbonServerList服務端清單去輪詢通路以達到均衡負載的作用。

當 Ribbon 與 Eureka 聯合使用時，ribbonServerList會被DiscoveryEnabledNIWSServerList重寫，擴充成從Eureka注冊中心中擷取服務端清單。同時它也會用NIWSDiscoveryPing來取代IPing，它将職責委托給Eureka來确定服務端是否已經啟動。

下面我們通過執行個體看看如何使用Ribbon來調用服務，并實作用戶端的均衡負載。

準備工作

本篇文章是基于上一篇文章【微服務架構–服務注冊與發現元件 Eureka】的基礎之上進行實作的，是以需要三個工程的支援。spring-cloud-eureka 和 spring-cloud-provide 已不必多說。

spring-cloud-provid 我們可以建立多個執行個體，注意并不是建立兩個項目，而是一個工程啟動兩次，通過端口來進行區分，這樣的話，我們來建立一個小的叢集，以達到負載均衡的目的，端口分别是8081和8083。

除了上述之外，我們隻需要再建立一個消費者服務工程即可。

建立一個服務消費者

第一步：建立一個普通的Spring Boot工程

建立一個普通的Spring Boot工程，并命名為：spring-cloud-consumer-ribbon

第二步：引入依賴

在它的pom.xml繼承了父pom檔案，并引入了以下依賴：

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.brimen</groupId>
        <artifactId>spring-cloud-brimen-consumer</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath/>
    </parent>
    <groupId>com.brimen</groupId>
    <artifactId>spring-cloud-consumer-ribbon</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>spring-cloud-consumer</name>
    <description>Spring Cloud 消費者服務</description>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>
           

第三步：在application.yml配置檔案當中配置

在工程的配置檔案當中指明服務注冊中心的位址為：http://localhost:8080/eureka/，服務名稱為：spring-cloud-consumer-ribbon，端口為：8082，配置如下：

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8080/eureka/ #1
server:
  port: 8082
spring:
  application:
    name: spring-cloud-consumer-ribbon #2
#1、服務注冊中心的位址
#2、服務的名稱，作為其它服務調用的服務名
           

第四步：在入口類application當中，注入RestTemplate的bean

在入口類application當中，注入RestTemplate的bean，@LoadBalanced注解表明這個RestRemplate開啟負載均衡的功能。

package com.brimen.springcloudconsumerribbon;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class SpringCloudConsumerRibbonApplication {


    public static void main(String[] args) {
        SpringApplication.run(SpringCloudConsumerRibbonApplication.class, args);
    }
    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
           

第五步:寫一個HelloServer類來調用服務提供者的接口

寫一個HelloService，并通過之前注入的RestTemplate來消費“spring-cloud-provide”的“gethello”接口，在這裡我們用具體的服務名來替代url位址，在ribbon中它會根據服務名來選擇具體的服務執行個體，根據服務執行個體在請求的時候會用具體的url替換掉服務名，代碼如下：

package com.brimen.springcloudconsumerribbon.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class HelloService {
    @Autowired
    RestTemplate restTemplate;
    public String sayHelloFromProvider(String name) {
        return restTemplate.getForObject("http://spring-cloud-provide/hello/gethello?name=" + name, String.class);
    }
}
           

第六步：寫一個Controller，提供對外通路的接口

寫一個具體的Controller，提供對外通路的接口，并調用Service的方法，代碼如下：

package com.brimen.springcloudconsumerribbon.controller;
import com.brimen.springcloudconsumerribbon.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/hello")
public class HelloController {

    @Autowired
    public HelloService helloService;


    @GetMapping(value = "/gethello")
    public String getHello(@RequestParam(value = "name", defaultValue = "ribbon") String name) {
        return helloService.sayHelloFromProvider(name);
    }
}
           

第七步：啟動項目并通路

啟動三個工程，spring-cloud-eureka、spring-cloud-provide和spring-cloud-consumer-ribbon，然後打開浏覽器，通路消費者服務（spring-cloud-consumer-ribbon）的接口“gethello”，http://localhost:8082/hello/gethello ，連續進行重新整理，會發現通路不同的服務提供者（spring-cloud-provide）8081和8083

轉載自–《Spring Cloud建構微服務架構（二）服務消費者（Rest+Ribbon）》