前言

算是正式開始學習 spring cloud 的專案知識了，大概的知道Springcloud 是由眾多的微服務組成的，所以我們現在一個一個的來學習吧。

註冊中心，在微服務中算是核心了。所有的服務都會註冊到註冊中心，請求服務的時候，並不會直接去請求服務地址，而是先通過註冊中心再轉到目的地址。雖然Eureka 已經停止維護了，但是我們暫時使用起來還是沒有問題的。

Eureka 主要有服務註冊中心、服務提供者和服務消費。很多時候服務消費者也是服務提供者。所以就 Eureka 而言，分為 Eureka 服務端和Eureka 客戶端，服務端就是註冊中心，客戶端就是服務提供者和消費者。

單機模式

好了，我們動手搭建一個Eureka 的服務端吧先，服務端有單機模式和叢集模式，我們先來單機模式。

更具上篇文章講的，我們使用maven 模組化開發，我們建立一個父級maven專案,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>

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

    <groupId>cn.quellanan</groupId>
    <artifactId>SpringCloud</artifactId>
    <version>1.0.0</version>
    <packaging>pom</packaging>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </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>
    
    <modules>
        <module>eureka-server-8000</module>
        <module>eureka-server-8001</module>
        <module>eureka-server-8002</module>
        <module>zlflovemm</module>
    </modules>

</project>
 

可以看到檔案中指定了spring boot 和Spring cloud 等基礎依賴的版本，這樣保證各個模組版本的一致性。

子模組

接下來我們建立一個eureka-server-8000 的子模組。

pom.xml

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>cn.quellanan</groupId>
        <artifactId>SpringCloud</artifactId>
        <version>1.0.0</version>
    </parent>
    <groupId>com.quellanan.springcloud</groupId>
    <artifactId>eureka-server-8000</artifactId>
    <version>1.0.0</version>
    <name>eureka-server-8000</name>
    <description>eureka project for Spring Boot</description>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

</project>
 

可以看到繼承了父級pom,額外的增加了 spring-cloud-starter-netflix-eureka-server 的依賴。

@EnableEurekaServer

在啟動類中增加@EnableEurekaServer 註解，表示啟用Eureka 服務端。

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

application.properties

配置檔案中增加如下配置

spring.application.name=spring-cloud-eureka-server-8000
server.port=8000

#表示是否將自己註冊到Eureka Server，預設為true。
eureka.client.register-with-eureka=true

# 表示是否從Eureka Server獲取註冊資訊，預設為true。
eureka.client.fetch-registry=true

#設定與Eureka Server互動的地址，查詢服務和註冊服務都需要依賴這個地址。多個地址可使用 , 分隔。
eureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka/

現在我們就可以啟動專案看看

可以看到我們將自身註冊到了服務中。

Eureka 客戶端

前面說了，服務提供者和服務消費者都是客戶端，其實就是我們具體的某一業務的專案。所以我們再建立一個子模組。我這裡分開吧，我們分別建立服務提供者和服務消費者。

服務提供者

我們建立一個eureka-client-provider的子模組，pom 檔案中引入spring-cloud-starter-netflix-eureka-client。

    <parent>
        <groupId>cn.quellanan</groupId>
        <artifactId>SpringCloud</artifactId>
        <version>1.0.0</version>
    </parent>
    groupId>com.quellanan.springcloud</groupId>
    <artifactId>eureka-client-provider</artifactId>
    <version>1.0.0</version>
    <name>eureka-client-provider</name>
    <description>eureka-client-provider 服務提供者</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>
    </dependencies>

啟動類中加入@EnableEurekaClient註解或者@EnableDiscoveryClient註解都可以。

@SpringBootApplication
@EnableDiscoveryClient
public class EurekaClientProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaClientProviderApplication.class, args);
    }

}

application.properties 中增加如下配置

server.port=9000
#服務名，在註冊時所用
spring.application.name=eureka-client-provider
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

這裡指定的eureka的服務中心的地址為8000。如上配置就可以將服務註冊到註冊中心啦。
我們在寫一個測試介面。
建立一個IndexController 類，內容如下：

@RestController
public class HelloController {
    @RequestMapping("/hello")
    public String hello(){
        return "hello world ";
    }
}

服務消費者

我們一樣的建立一個 eureka-client-consumer的模組。pom檔案如下：

<parent>
        <groupId>cn.quellanan</groupId>
        <artifactId>SpringCloud</artifactId>
        <version>1.0.0</version>
    </parent>

    <groupId>com.quellanan.springcloud</groupId>
    <artifactId>eureka-client-consumer</artifactId>
    <version>1.0.0</version>
    <name>eureka-client-consumer</name>
    <description>eureka-client-consumer 服務消費者</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-openfeign</artifactId>
        </dependency>
    </dependencies>

相對於服務提供者，我們增加了Feign 依賴，主要用來發現服務和實現客戶端負載均衡，我們這裡用來發現服務就可以了。

在啟動類中@EnableDiscoveryClient 用來發現服務，並注入RestTemplate 的例項bean 用來對服務提供的介面進行呼叫。@LoadBalanced 是開啟客戶端負載均衡的，最開始我沒有加這個註解，但是發現不加的話，服務消費者就不能通過服務名來獲取可用的服務提供者的例項。所以這裡大家可以試驗一下。

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

我們接下寫一個介面，呼叫服務消費者，我們建立一個IndexController，內容如下：

@RestController
public class IndexController {
    private static final String applicationName = "eureka-client-provider";
    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping("/index")
    public String getHello(){
        String url = "http://"+ applicationName +"/hello";
        return  restTemplate.getForObject(url,String.class);
    }
}

這裡我們可以看到applicationName 就是服務提供者的服務名。實際中，一種型別的服務可能有好幾臺伺服器，可能實體地址和ip不一樣，但是保證他們的服務名一樣就可以了，這樣服務消費者就可以通過服務名獲取可用的列表，再通過複雜均衡策略選擇其中一個例項訪問。

最後我們在application中加上如下配置：

server.port=9001
#服務名，在註冊時所用
spring.application.name=eureka-client-consumer
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

測試

現在我們啟動註冊中心和客戶端這兩個專案來看下。啟動後，我們輸入

http://localhost:8000

可以發現我們的客戶端已經註冊到註冊中心啦。服務提供者和服務消費者都已經註冊到了註冊中心啦。我們再來調介面試試。我們輸入如下：

http://localhost:9001/index

可以看到其實獲取了9000服務提供者的介面。這樣就實現了服務的註冊和發現啦，並實現遠端呼叫。

叢集模式（高可用）

上面我們我們搭建的註冊中心只是單機模式，只有一個Eureka 服務端，單實際應用中註冊中心其實是尤為重要的，所以就需要搭建叢集環境，其實Eureka 對叢集模式是天然的支援的，我們搭建也非常簡單。
為什麼這麼說呢，我們前面可以看到只要配置了eureka.client.serviceUrl.defaultZone 就就會被對應的註冊中線檢測到，所以我們程式碼完全一樣，只需要將eureka.client.serviceUrl.defaultZone相互指引就可以了，就就可以簡單的搭建一個高可用的環境。
下面我們來搭建一個，因為我們就一臺伺服器，所以就用不同的埠，其實程式碼完全一樣的，只是配置檔案中配置不一樣，我們分別把三個分配置檔案貼出來。
8000埠的

spring.application.name=spring-cloud-eureka-server-8000
server.port=8000

#表示是否將自己註冊到Eureka Server，預設為true。
eureka.client.register-with-eureka=true

# 表示是否從Eureka Server獲取註冊資訊，預設為true。
eureka.client.fetch-registry=true

#設定與Eureka Server互動的地址，查詢服務和註冊服務都需要依賴這個地址。多個地址可使用 , 分隔。
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/,http://localhost:8002/eureka/

8001埠：

spring.application.name=spring-cloud-eureka-server-8001
server.port=8001
#表示是否將自己註冊到Eureka Server，預設為true。
eureka.client.register-with-eureka=true
# 表示是否從Eureka Server獲取註冊資訊，預設為true。
eureka.client.fetch-registry=true
#設定與Eureka Server互動的地址，查詢服務和註冊服務都需要依賴這個地址。多個地址可使用 , 分隔。
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/,http://localhost:8002/eureka/

8002 埠

spring.application.name=spring-cloud-eureka-server-8002
server.port=8002
#表示是否將自己註冊到Eureka Server，預設為true。
eureka.client.register-with-eureka=true
# 表示是否從Eureka Server獲取註冊資訊，預設為true。
eureka.client.fetch-registry=true
#設定與Eureka Server互動的地址，查詢服務和註冊服務都需要依賴這個地址。多個地址可使用 , 分隔。
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/,http://localhost:8001/eureka/

我們現在分別啟動這個這三個配置檔案，你們可以用profile 來指向，我這為了分明，直接建立了三個模組。啟動後，我們分別訪問

http://localhost:8000/
http://localhost:8001/
http://localhost:8002/

這裡可以看到其實已經相互監控了。我們瞭解一下這兩個配置引數。

#定義服務續約任務的呼叫時間間隔，預設30s
eureka.instance.lease-renewal-interval-in-seconds=30
#定義服務失效的時間預設90s
eureka.instance.lease-expiration-duration-in-seconds=90

我們現在再將我們的服務提供者和服務消費者註冊進來，但是這裡，需要修改的地方也是eureka.client.serviceUrl.defaultZone。將服務註冊到叢集中。

eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/,http://localhost:8001/eureka/,http://localhost:8002/eureka/

然後啟動專案可，可以看到註冊到了註冊中心，並且可以呼叫服務提供者提供的介面。

總結

最後畫了一張圖來說明整個註冊中心的架構圖。

可以看到註冊服務端可以是一個叢集。相互註冊監控。服務消費者和服務提供者都是服務客戶端，都會將服務註冊到服務中心，同時這些服務也都可以使是叢集或者分散式的。服務提供者會從服務端獲取服務提供者可用的服務例項列表，通過負載均衡策略選擇其中某一例項進行呼叫。這個算是Eureka 的總結吧哈哈

番外

好啦，總是是寫完了，這篇文章真是是卡了我好幾天，有的地方寫的不是很好，歡迎大家指點。
程式碼上傳到github：
https://github.com/QuellanAn/SpringCloud

後續加油♡

歡迎大家關注個人公眾號 "程式設計師愛酸奶"

分享各種學習資料，包含java，linux，大資料等。資料包含視訊文件以及原始碼，同時分享本人及投遞的優質技術博文。

如果大家喜歡記得關注和分享喲❤

相關推薦