文章目錄

一、Eureka基礎知識
二、單機Eureka構建步驟
三、集群Eurake構建步驟
四、actuator微服務資訊完善
五、服務發現Discovery
六、eureka自我保護

一、Eureka基礎知識

什么是服務治理

1.springcloud封裝了Netflix公司開發的Eureka模塊來實作服務治理，
2.在傳統的rpc遠程釣魚共框架中，管理每個服務與服務之間依賴關系比較復雜，管理比較復雜，所以需要使用服務治理，管理服務與服務之間依賴關系，可以實作服務呼叫、負載均衡、容錯等，實作服務發現與注冊，

什么是服務注冊與發現

1.Eureka采用了CS的設計架構，Eureka Server作為服務注冊功能的服務器，它是服務注冊中心，而系統中的其他微服務，使用Eureka的客戶端連接誒到Eureka Server并維持心跳連接，這樣系統的維護人員就可以通過Eureka Server來監控系統中各個微服務是否正常運行，
2.在服務注冊與發現中，有一個注冊中心，當服務器啟動的時候，會把當前自己服務器的資訊比如：服務地址通訊地址等以別名方式注冊到注冊中心上，另一方（消費者|服務提供者），以該別名的方式去注冊中心上獲取實際的服務通訊地址，然后再實作本地RPC呼叫RPC遠程呼叫框架核心設計思想：在于注冊中心，因為使用注冊中心管理每個服務與服務之間的一個依賴關系（服務治理概念），在任何rpc遠程框架中，都會有一個注冊中心（存放服務地址相關資訊（介面地址））

ps：下左圖是Eureka系統架構，右圖是Dubbo的架構，請對比：
在這里插入圖片描述

Eureka包含兩組件：Eureka Server和Eureka Client

1.Eureka Server提供服務注冊服務：
答：各個微服務節點通過配置啟動后，會在EurekaServer中進行注冊，這樣EurekaServer中的服務注冊表中將會存盤所有可用服務節點的資訊，服務節點的資訊可以在界面中直觀看到，
2.Eureka Client通過注冊中心進行訪問：
答：是一個java客戶端，用于簡化Eureka Server的互動，客戶端同時也具備一個內置的、使用輪詢（round-robin）負載演算法的負載均衡器，在應用啟動后，將會向Eureka Server發送心跳（默認周期為30秒），如果Eureka Server在多個心跳周期內沒有接收到某個節點的心跳，EurekaServer將會從服務注冊表中把這個服務節點移除（默認90秒），

二、單機Eureka構建步驟

1.IDEA生成eurekaServer端服務注冊中心
類似物業公司
ps:eureka Server服務端安裝
1.建立module

cloud-eureka-server7001

2.改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">
    <parent>
        <artifactId>mscloud03</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-eureka-server7001</artifactId>

    <dependencies>
        <!--eureka-server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!-- 引入自己定義的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!--boot web actuator-->
        <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>
        <!--一般通用配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
    </dependencies>
</project>

ps：1.x和2.x的對比說明

 
以前的老版本（當前使用2018）
<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
 
 
 
現在新版本（當前使用2020.2）
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

3.寫yml

server:
  port: 7001

eureka:
  instance:
    hostname: localhost #eureka服務端的實體名稱
  client:
    #false表示不向注冊中心注冊自己，
    register-with-eureka: false
    #false表示自己端就是注冊中心，我的職責就是維護服務實體，并不需要去檢索服務
    fetch-registry: false
    service-url:
    #設定與Eureka Server互動的地址查詢服務和注冊服務都需要依賴這個地址，
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

4.主啟動類

package com.atguigu.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**
 * @auther 
 * @create 2020-01-28 20:40
 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaMain7001
{
    public static void main(String[] args)
    {
        SpringApplication.run(EurekaMain7001.class,args);
    }
}

5.測驗

網址：http://localhost:7001/
結果：可以成功進入eureka界面說明安裝成功

2.EurekaClient端cloud-provider-payment8001
將注冊進EurekaServer成為服務提供者provider，類似尚硅谷學校對外提供授課服務
1.建立module

cloud-provider-payment8001

2.改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">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.itcast.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-provider-payment8001</artifactId>

    <dependencies>
        <!--eureka-client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency><!-- 引入自己定義的api通用包，可以使用Payment支付Entity -->
            <groupId>com.itcast.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </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>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <!--mysql-connector-java-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!--jdbc-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

3.寫yml

server:
  port: 8001

#服務名
spring:
  application:
    name: cloud-payment-service
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource            # 當前資料源操作型別
    driver-class-name: org.gjt.mm.mysql.Driver              # mysql驅動包 com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root

eureka:
  client:
    #表示是否將自己注冊進EurekaServer默認為true，
    register-with-eureka: true
    #是否從EurekaServer抓取已有的注冊資訊，默認為true，單節點無所謂，集群必須設定為true才能配合ribbon使用負載均衡
    fetchRegistry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.itcast.springcloud.entities    # 所有Entity別名類所在包

4.主啟動

package com.itcast.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**
 * @author henry
 * @version 1.0
 * @date 2021/8/28 0028 16:33
 */
@SpringBootApplication
@EnableEurekaClient
public class PaymentMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8001.class,args);
    }
}

5.測驗

1.先啟動EurekaServer
2.http://localhost/7001
結果：

6.微服務注冊名配置說明
在這里插入圖片描述
7.自我保護機制

3.EurekaClient端cloud-consumer-order80
將注冊進EurekaServer成為服務消費者consumer，類似來尚硅谷上課消費的各位同學
1.建立模塊

cloud-consumer-order80

2.該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">
    <parent>
        <artifactId>mscloud03</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumer-order80</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency><!-- 引入自己定義的api通用包，可以使用Payment支付Entity -->
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </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>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

3.修改yml檔案

server:
  port: 80

spring:
  application:
    name: cloud-order-service

eureka:
  client:
    #表示是否將自己注冊進EurekaServer默認為true，
    register-with-eureka: true
    #是否從EurekaServer抓取已有的注冊資訊，默認為true，單節點無所謂，集群必須設定為true才能配合ribbon使用負載均衡
    fetchRegistry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

4.修改主啟動類

package com.itcast.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**
 * @author henry
 * @version 1.0
 * @date 2021/8/28 0028 21:11
 */
@SpringBootApplication
@EnableEurekaClient
public class OrderMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderMain80.class,args);
    }
}

5.測驗

1.先啟動EurekaServer，7001服務
2.再啟動服務提供者provider，8001服務
3.eureka服務器資訊如下：

4.輸入網址：http://localhost/consumer/payment/get/31展示的結果如下說明服務注冊成功：

4.bug

1.專案提示如下錯誤:
Failed to bind properties under ‘eureka.client.service-url’ to java.util.Map<java.lang.String, java.lang.String>
2.原因：

三、集群Eurake構建步驟

1.Eureka集群原理說明：
在這里插入圖片描述
問題：微服務RPC遠程服務呼叫最核心的是什么

高可用：高可用，試想你的注冊中心只有一個only one，它出故障了那就“呵呵”了，會導致整個微服務環境不可用，所以
解決辦法：搭建Eureka注冊中心集群，實作負載均衡+故障容錯，

ps：集群的注冊原理（一句話）：

互相注冊，相互守望

2.EurekaServer集群環境構建步驟：
1.新建cloud-eureka-server7002

參考cloud-eureka-server7001

2.改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">
    <parent>
        <artifactId>mscloud03</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-eureka-server7002</artifactId>


    <dependencies>
        <!--eureka-server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!-- 引入自己定義的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!--boot web actuator-->
        <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>
        <!--一般通用配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
    </dependencies>
</project>

3.修改映射配置

1.找到C:\Windows\System32\drivers\etc路徑下的hosts檔案

2.修改映射配置添加進hosts檔案
127.0.0.1 eureka7001.com
127.0.0.1 eureka7002.com

4.寫yml（以前單機）
ps：主要修改hostname引數和defaultZone引數
7001yml：

server:
  port: 7001


eureka:
  instance:
    hostname: eureka7001.com #eureka服務端的實體名稱
  client:
    register-with-eureka: false     #false表示不向注冊中心注冊自己，
    fetch-registry: false     #false表示自己端就是注冊中心，我的職責就是維護服務實體，并不需要去檢索服務
    service-url:
      defaultZone: http://eureka7002.com:7002/eureka/

7002yml：

server:
  port: 7002


eureka:
  instance:
    hostname: eureka7002.com #eureka服務端的實體名稱
  client:
    register-with-eureka: false     #false表示不向注冊中心注冊自己，
    fetch-registry: false     #false表示自己端就是注冊中心，我的職責就是維護服務實體，并不需要去檢索服務
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/

5.主啟動類

/**
 * @author henry
 * @version 1.0
 * @date 2021/9/4 0004 21:31
 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaMain7002 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaMain7002.class,args);
    }
}

6.測驗
通過如下如下域名可以成功訪問（7002埠同理，相互注冊）
在這里插入圖片描述

3.將支付服務8001微服務發布到上面2臺Eureka集群配置中：
1.修改yml檔案

修改引數：
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

4.將訂單服務80微服務發布到上面2臺Eureka集群配置中：
1.修改yml檔案

修改引數：
defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

5.測驗01：

1.先要啟動EurekaServer，7001/7002服務
2.再要啟動服務提供者provider，8001
3.再要啟動消費者，80
4.輸入http://eureka7002.com:7002/和http://eureka7001.com:7001/可以看到8001服務和80服務都注冊到服務中心了
5.輸入網址http://localhost/consumer/payment/get/31可以正常回傳資料

6.支付服務提供者8001集群環境的搭建：
1.新建模塊cloud-provider-payment8002

參考cloud-provider-payment8001

2.改pom（參考8001）
3.寫yml（參考8001）
4.主啟動（參考8001）
5.業務類（直接從8001粘）
6.修改8001/8002的Controller（主要是將當前服務名注入，并列印出來可以直觀看到呼叫的是哪個服務）

package com.itcast.springcloud.controller;

import com.itcast.springcloud.entities.CommonResult;
import com.itcast.springcloud.entities.Payment;
import com.itcast.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

/**
 * @author rui
 * @version 1.0
 * @date 2021/8/28 0028 17:53
 */
@RestController
@Slf4j     //列印日志
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    /*采用restful風格請求*/
    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment){
       int result  = paymentService.create(payment);
       log.info("*****插入結果："+result);
       if (result > 0){
           return new CommonResult(200,"插入資料庫成功,serverPort:"+serverPort,result);
       }else {
           return new CommonResult(444,"插入資料庫失敗",null);
       }
    }

    @GetMapping(value = "/payment/get/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
        Payment payment  = paymentService.getPaymentById(id);
        log.info("*****插入結果："+payment);
        if (payment != null){
            return new CommonResult(200,"查詢成功,serverPort:"+serverPort,payment);
        }else {
            return new CommonResult(444,"沒有對應記錄，查詢ID："+id,null);
        }
    }
}

7.負載均衡：
1.出現的bug（消費者類中訂單服務訪問地址不能寫死）

//private static final String PAYMENT_URL = "http://localhost:8001";
    // 通過在eureka上注冊過的微服務名稱呼叫
    private static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

2.使用@LoadBalanced注解賦予RestTemplate負載均衡的能力
3.ApplicationContextBean（添加@LoadBalanced注解）

package com.itcast.springcloud.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @author henry
 * @version 1.0
 * @date 2021/8/28 0028 21:23
 */
@Configuration
public class ApplicationContextConfig {

    @Bean
    @LoadBalanced //使用@LoadBalanced注解賦予RestTemplate負載均衡的能力
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}
//以上的@bean注解類似于以下的組態檔，將此物件加入到spring容器中
//applicationtext.xml <bean id = "" class="">

8.測驗02：

1.先要啟動EurekaServer，7001/7002服務
2.再要啟動服務提供者provider，8001/8002服務
3.http://localhost/consumer/payment/get/31
4.結果：
負載均衡效果達到（8001/8002埠交替出現）
5.Ribbon和Eureka整合后Consumer可以直接呼叫服務而不用再關心地址和埠號，且該服務還有負載功能了，（后面的章節）

四、actuator微服務資訊完善

1.主機名稱：服務名稱修改
1.當前問題：
在這里插入圖片描述
含有主機名
2.修改修改cloud-provider-payment8001的yml檔案
ps：添加了instance屬性：

eureka:
  client:
    #表示是否將自己注冊進EurekaServer默認為true，
    register-with-eureka: true
    #是否從EurekaServer抓取已有的注冊資訊，默認為true，單節點無所謂，集群必須設定為true才能配合ribbon使用負載均衡
    fetchRegistry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
      #defaultZone: http://localhost:7001/eureka  # 單機版
  instance:
    instance-id: payment8001

3.修改后狀態
在這里插入圖片描述

2.訪問資訊有IP資訊提示
1.當前問題：
沒有ip提示
2.修改cloud-provider-payment8001
ps:在instance屬性下添加prefer-ip-address屬性

eureka:
  client:
    #表示是否將自己注冊進EurekaServer默認為true，
    register-with-eureka: true
    #是否從EurekaServer抓取已有的注冊資訊，默認為true，單節點無所謂，集群必須設定為true才能配合ribbon使用負載均衡
    fetchRegistry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
      #defaultZone: http://localhost:7001/eureka  # 單機版
  instance:
    instance-id: payment8001
    prefer-ip-address: true     #訪問路徑可以顯示IP地址

3.修改之后
在這里插入圖片描述

五、服務發現Discovery

1.對于注冊進eureka里面的微服務，可以通過服務發現來獲得該服務的資訊
2.修改cloud-provider-payment8001的Controller
ps：添加discovery獲取服務資訊

package com.atguigu.springcloud.controller;

import com.atguigu.springcloud.entities.CommonResult;
import com.atguigu.springcloud.entities.Payment;
import com.atguigu.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * @auther zzyy
 * @create 2020-01-27 21:17
 */
@RestController
@Slf4j
public class PaymentController
{
    @Value("${server.port}")
    private String serverPort;

    @Resource
    private PaymentService paymentService;

    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment)
    {
        int result = paymentService.create(payment);
        log.info("*****插入操作回傳結果:" + result);

        if(result > 0)
        {
            return new CommonResult(200,"插入成功,回傳結果"+result+"\t 服務埠："+serverPort,payment);
        }else{
            return new CommonResult(444,"插入失敗",null);
        }
    }

    @GetMapping(value = "/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
    {
        Payment payment = paymentService.getPaymentById(id);
        log.info("*****查詢結果:{}",payment);
        if (payment != null) {
            return new CommonResult(200,"查詢成功"+"\t 服務埠："+serverPort,payment);
        }else{
            return new CommonResult(444,"沒有對應記錄,查詢ID: "+id,null);
        }
    }

    @GetMapping(value = "/payment/discovery")
    public Object discovery()
    {
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
            System.out.println(element);
        }

        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance element : instances) {
            System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
                    + element.getUri());
        }
        return this.discoveryClient;
    }
}

3.8001主啟動類

添加@EnableDiscoveryClient注解

4.自測

1.先要啟動EurekaServer
2.再啟動8001主啟動類，需要稍等一會兒
3.http://localhost:8001/payment/discovery
理想結果：
前臺出現如下兩服務：

后臺可以列印出相應日志：

六、eureka自我保護

1.故障現象

1.概述
保護模式主要用于一組客戶端和Eureka Server之間存在網路磁區場景下的保護，一旦進入保護模式，Eureka Server將會嘗試保護其服務注冊表中的資訊，不再洗掉服務注冊表中的資料，也就是不會注銷任何微服務，
2.如果在Eureka Server的首頁看到以下這段提示，則說明Eureka進入了保護模式：
EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY’RE NOT.
RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE

2.導致原因

1.為什么會產生Eureka自我保護機制？
為了防止EurekaClient可以正常運行，但是與 EurekaServer網路不通情況下，EurekaServer不會立刻將EurekaClient服務剔除
2.什么是自我保護模式？
默認情況下，如果EurekaServer在一定時間內沒有接收到某個微服務實體的心跳，EurekaServer將會注銷該實體（默認90秒），但是當網路磁區故障發生(延時、卡頓、擁擠)時，微服務與EurekaServer之間無法正常通信，以上行為可能變得非常危險了——因為微服務本身其實是健康的，此時本不應該注銷這個微服務，Eureka通過“自我保護模式”來解決這個問題——當EurekaServer節點在短時間內丟失過多客戶端時（可能發生了網路磁區故障），那么這個節點就會進入自我保護模式，

3.在自我保護模式中，Eureka Server會保護服務注冊表中的資訊，不再注銷任何服務實體，
它的設計哲學就是寧可保留錯誤的服務注冊資訊，也不盲目注銷任何可能健康的服務實體，一句話講解：好死不如賴活著
4.綜上，自我保護模式是一種應對網路例外的安全保護措施，它的架構哲學是寧可同時保留所有微服務（健康的微服務和不健康的微服務都會保留）也不盲目注銷任何健康的微服務，使用自我保護模式，可以讓Eureka集群更加的健壯、穩定，

ps：1.一句話：某時刻一個微服務不可用了，Eureka不會like清理，依舊會對微服務的資訊進行保存
2.屬于CAP里面對的AP分支

3.怎么禁止自我保護

1.注冊中心eureakeServer端7001

1.出廠默認，自我保護機制是開啟的
2.使用eureka.server.enable-self-preservation = false 可以禁用自我保護模式

3.關閉效果

4.在eurekaServer端7001處設定關閉自我保護機制

2.生產者客戶端eureakeClient端8001

1.默認
eureka.instance.lease-renewal-interval-in-seconds=30（默認30秒）
eureka.instance.lease-expiration-duration-in-seconds=90（默認90秒）
2.配置

3.測驗
7001和8001都配置完成；
先啟動7001再啟動8001

先關閉8001（馬上被洗掉）

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/298076.html

標籤：其他

上一篇：補一篇墨跡了好久的閱讀小結

下一篇：4.HTML5新特性：拖拽API與本地資料庫

第五章 Eureka服務注冊與發現（尚硅谷SpringCloud）

文章目錄

一、Eureka基礎知識

二、單機Eureka構建步驟

三、集群Eurake構建步驟

四、actuator微服務資訊完善

五、服務發現Discovery

六、eureka自我保護