轉自 https://blog.csdn.net/u012702547/article/details/77823434

這個系列我感覺真的太好了，可以一步一步的瞭解spring cloud 的搭建以及更深層次的東西，對想學這門技術的朋友真的入門特別的快，感謝這位大哥的分享，我也會持續的更新過來。

----------------------------------------------------------------------------------------------------------------------------------------------------------

通過前面兩篇文章(

如何實現

服務的發現和消費實際上是兩個行為，這兩個行為要由不同的物件來完成：服務的發現由Eureka客戶端來完成，而服務的消費由Ribbon來完成。Ribbo是一個基於HTTP和TCP的客戶端負載均衡器，當我們將Ribbon和Eureka一起使用時，Ribbon會從Eureka註冊中心去獲取服務端列表，然後進行輪詢訪問以到達負載均衡的作用，服務端是否線上這些問題則交由Eureka去維護。OK，下面我們將通過一個簡單的案例，來看看如何實現服務的發現與消費。

開啟註冊中心

這裡的服務註冊中心我們還是使用上篇文章中建立的eureka-server工程，為了測試方便，我這裡直接啟動一個單節點工程就OK了。

註冊服務

註冊服務也和上篇文章一樣，也使用provider工程，不同的是，這裡我將provider工程打成一個jar包，然後用命令啟動，啟動兩個例項，方便我一會觀察負載均衡的效果。打成jar的過程很簡單，雙擊package，然後在target目錄下找到對應的jar

然後通過下面兩行命令啟動兩個服務提供者的例項，如下：

java -jar provider-0.0.1-SNAPSHOT.jar --server.port=8080  
java -jar provider-0.0.1-SNAPSHOT.jar --server.port=8081
 

此時，在服務註冊中心我們可以看到有兩個服務提供者註冊成功了，如下：

（我這裡8081埠被佔用了 所以我用了8082）

OK,如此之後，服務提供者就準備好了，接下來我們來看看服務消費者要怎麼實現。

開發客戶端

建立Spring Boot專案

首先建立一個Spring Boot專案，然後新增Eureka和Ribbon依賴，pom.xml檔案如下：

<?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>

    <groupId>org.sang</groupId>
    <artifactId>ribbon-consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>ribbon-consumer</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Dalston.SR3</spring-cloud.version>
    </properties>

    <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>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

這裡重點是添加了spring-cloud-starter-eureka和spring-cloud-starter-ribbon依賴。

配置啟動入口類

入口類上我們需要做兩件事：

1.亮明Eureka客戶端身份  

首先在入口類上新增@EnableDiscoveryClient註解，表示該應用是一個Eureka客戶端應用，這樣該應用就自動具備了發現服務的能力。

2.提供RestTemplate的Bean  

RestTemplate可以幫助我們發起一個GET或者POST請求，這個我們在後文會詳細解釋，這裡我們只需要提供一個RestTemplate  Bean就可以了，在提供Bean的同時，新增@LoadBalanced註解，表示開啟客戶端負載均衡。

OK，基於以上兩點，我們的入口類如下：

@SpringBootApplication
@EnableDiscoveryClient
public class RibbonConsumerApplication {

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

建立Controller

建立一個Controller類，並向Controller類中注入RestTemplate物件，同時在Controller中提供一個名為/ribbon-consumer的介面，在該介面中，我們通過剛剛注入的restTemplate來實現對HELLO-SERVICE服務提供的/hello介面進行呼叫（上篇文章中我們有詳細介紹HELLO-SERVICE的實現）。在呼叫的過程中，我們的訪問地址是HELLO-SERVICE，而不是一個具體的地址。OK，基於以上理解，我們的Controller如下：

@RestController
public class ConsumerController {
    @Autowired
    RestTemplate restTemplate;
    @RequestMapping(value = "/ribbon-consumer",method = RequestMethod.GET)
    public String helloController() {
        return restTemplate.getForEntity("http://HELLO-SERVICE/hello", String.class).getBody();
    }
}

配置服務註冊中心的位置

最後我們需要在application.properties中配置服務註冊中心的位置，如下：

spring.application.name=ribbon-consumer  
server.port=8093
eureka.client.service-url.defaultZone=http://peer1:1111/eureka

注意服務消費者的埠號不要和前面的埠號衝突。

啟動並測試

此時我們就可以啟動我的客戶端了，啟動之後，我們首先在Eureka中看到了我的客戶端，如下：

然後我們向localhost:8093/ribbon-consumer地址發起請求，就可以看到provider工程中/hello介面返回的Hello World

那麼這個時候有小夥伴可能會有疑問，這個Hello World是由哪一個provider提供的？

重新整理幾次 http://localhost:8093/ribbon-consumer，可以看到倆個埠的日誌在交替，說明負載均衡起到了作用

小夥伴們看到Ribbon輸出了當前客戶端維護的HELLO-SERVICE的服務列表情況，每一個provider的位置都展示出來，Ribbon就是按照這個列表進行輪詢，進而實現基於客戶端的負載均衡。同時這裡的日誌還輸出了其他資訊，比如各個例項的請求總數量，第一次連線資訊，上一次連線資訊以及總的請求失敗數量等。

這一節學習完了，對服務者，消費者都有了瞭解，還對Ribbon實現負載均衡有了一個簡單的認識，接下來會持續更新。