SpringCloud組件--Eureka

• • • • 完整筆記
  • 一、Eureka基礎知識
  • • 1.1、什么是服務治理　？
    • 1.2、 什么是服務注冊與發現？
    • 1.3、Eureka兩組件：Eureka Server和Eureka Client
  • 二、單機Eureka構建步驟
  • • 2.1、IDEA生成eurekaServer端服務注冊中心類似物業公司
    • 2.2、EurekaClient端cloud-provider-payment8001
    • 2.3、EurekaClient端cloud-consumer-order80
  • 三、集群Eureka構建步驟
  • • 3.1、Eureka集群原理說明
    • 3.2、EurekaServer集群環境構建步驟
    • 3.3、將支付服務8001微服務發布到上面2臺Eureka集群配置中
    • 3.4、將訂單服務80微服務發布到上面2臺Eureka集群配置中
    • 3.5、測試
    • 3.6、支付服務提供者8001集群環境構建
    • 3.7、負載均衡
    • 3.8測試-2
  • 四、actuator微服務信息完善
  • • 4.1、主機名稱:服務名稱修改
    • 4.2、訪問信息有IP信息提示
  • 五、服務發現Discovery
  • • 對于注冊進eureka里面的微服務，可以通過服務發現來獲得該服務的信息
  • 六、Eureka自我保護
  • • 6.1、故障現象
    • 6.2、導致原因
    • 6.3、怎么禁止自我保護
  • 自言自語

完整筆記

一、Eureka基礎知識

1.1、什么是服務治理　？

• Spring Cloud 封裝了 Netflix 公司開發的 Eureka 模塊來實現服務治理

• 在傳統的rpc遠程調用框架中，管理每個服務與服務之間依賴關系比較復雜，管理比較復雜，所以需要使用服務治理，管理服務于服務之間依賴關系，可以實現服務調用、負載均衡、容錯等，實現服務發現與注冊。

1.2、 什么是服務注冊與發現？

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

1.3、Eureka兩組件：Eureka Server和Eureka Client

Eureka Server提供服務注冊服務

• 各個微服務節點通過配置啟動后，會在EurekaServer中進行注冊，這樣EurekaServer中的服務注冊表中將會存儲所有可用服務節點的信息，服務節點的信息可以在界面中直觀看到。

EurekaClient通過注冊中心進行訪問

• 是一個Java客戶端，用于簡化Eureka Server的交互，客戶端同時也具備一個內置的、使用輪詢(round-robin)負載算法的負載均衡器。在應用啟動后，將會向Eureka Server發送心跳(默認周期為30秒)。如果Eureka Server在多個心跳周期內沒有接收到某個節點的心跳，EurekaServer將會從服務注冊表中把這個服務節點移除（默認90秒）

二、單機Eureka構建步驟

2.1、IDEA生成eurekaServer端服務注冊中心類似物業公司

建Module

• cloud-eureka-server7001

改POM

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

寫YML

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

主啟動

@SpringBootApplication @EnableEurekaServer // 這個注解就是啟動EurekaServer public class EurekaMain7001 {public static void main(String[] args){SpringApplication.run(EurekaMain7001.class,args);} }

測試

• http://localhost:7001/

• 結果頁面

• No application available 沒有服務被發現 O(∩_∩)O 因為沒有注冊服務進來當然不可能有服務被發現

2.2、EurekaClient端cloud-provider-payment8001

將注冊進EurekaServer成為服務提供者provider

cloud-provider-payment8001

改POM

• <!--eureka-client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

寫YML

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

主啟動

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

測試

先要啟動EurekaServer

localhost:7001/

自我保護機制

• 自我保護機制的工作機制是：如果在15分鐘內超過85%的客戶端節點都沒有正常的心跳，那么Eureka就認為客戶端與注冊中心出現了網絡故障，Eureka Server自動進入自我保護機制。、

2.3、EurekaClient端cloud-consumer-order80

將注冊進EurekaServer成為服務消費者consumer。 和生產者一樣的修改。

cloud-consumer-order80

POM

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency>

YML

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

主啟動

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

測試

• 先要啟動EurekaServer，7001服務

• 再要啟動服務提供者provider，8001服務

• eureka服務器

• http://localhost/consumer/payment/get/1 看ok不

出bug 的話

Failed to bind properties under ‘eureka.client.service-url’ to java.util.Map<java.lang.String, java.lang.String>

三、集群Eureka構建步驟

3.1、Eureka集群原理說明

問題：微服務RPC遠程服務調用最核心的是什么
高可用，試想你的注冊中心只有一個only one， 它出故障了那就呵呵(￣▽￣)"了，會導致整個為服務環境不可用，所以

解決辦法：搭建Eureka注冊中心集群 ，實現負載均衡+故障容錯

3.2、EurekaServer集群環境構建步驟

參考cloud-eureka-server7001

新建cloud-eureka-server7002

導入的依賴和7001是一樣的。

因為我們要模擬兩臺eureka 如果在本機上模擬， 需要改一下本機的配置映射文件。

• 找到C:\Windows\System32\drivers\etc路徑下的hosts文件

• 修改映射配置添加進hosts文件 修改完 生效需要重啟電腦才可以。

  127.0.0.1 eureka7001.com 127.0.0.1 eureka7001.com

更改YML配置 讓兩臺機器相互注冊 相互守望

7001

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/

7002

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

主啟動

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

3.3、將支付服務8001微服務發布到上面2臺Eureka集群配置中

更改yml 配置

server:port: 8001spring:application:name: cloud-payment-servicedatasource:type: com.alibaba.druid.pool.DruidDataSource # 當前數據源操作類型driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=falseusername: rootpassword: 123456eureka:client:#表示是否將自己注冊進EurekaServer默認為true。register-with-eureka: true#是否從EurekaServer抓取已有的注冊信息，默認為true。單節點無所謂，集群必須設置為true才能配合ribbon使用負載均衡fetchRegistry: trueservice-url:#defaultZone: http://localhost:7001/eurekadefaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版mybatis:mapperLocations: classpath:mapper/*.xmltype-aliases-package: com.atguigu.springcloud.entities # 所有Entity別名類所在包

3.4、將訂單服務80微服務發布到上面2臺Eureka集群配置中

更改yml 配置

server:port: 80spring:application:name: cloud-order-service eureka:client:#表示是否將自己注冊進EurekaServer默認為true。register-with-eureka: true#是否從EurekaServer抓取已有的注冊信息，默認為true。單節點無所謂，集群必須設置為true才能配合ribbon使用負載均衡fetchRegistry: trueservice-url:#defaultZone: http://localhost:7001/eurekadefaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

3.5、測試

先要啟動EurekaServer，7001/7002服務

再要啟動服務提供者provider，8001

再要啟動消費者，80

http://localhost/consumer/payment/get/31

3.6、支付服務提供者8001集群環境構建

參考cloud-provider-payment8001

新建cloud-provider-payment8002

可以直接復制粘貼 ，只需要修改 yaml 文件中的端口號 和 啟動類名字即可。

不過了更方便查看到我們調用的是那個微服務 我們將Controller 修改一下

修改8001Controller

@RestController @Slf4j public class PaymentController {@Value("${server.port}")private String serverPort;@Resourceprivate PaymentService paymentService;@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);}} }

8002 Controller

@RestController @Slf4j public class PaymentController {@Value("${server.port}")private String serverPort;@Resourceprivate PaymentService paymentService;@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);}} }

3.7、負載均衡

1.出現bug 不能把訂單服務地址寫死

//public static final String PAYMENT_SRV = "http://localhost:8001";// 通過在eureka上注冊過的微服務名稱調用 public static final String PAYMENT_SRV = "http://CLOUD-PAYMENT-SERVICE";

2.使用@LoadBalanced注解賦予RestTemplate負載均衡的能力

3.ApplicationContextBean

/*** @auther zzyy* @create 2020-01-28 16:22*/ @Configuration public class ApplicationContextBean {@Bean@LoadBalanced //使用@LoadBalanced注解賦予RestTemplate負載均衡的能力public RestTemplate getRestTemplate(){return new RestTemplate();} }

3.8測試-2

先要啟動EurekaServer，7001/7002服務

再要啟動服務提供者provider，8001/8002服務

http://localhost/consumer/payment/get/1

結果

負載均衡效果達到

8001/8002端口交替出現

Ribbon和Eureka整合后Consumer可以直接調用服務而不用再關心地址和端口號，且該服務還有負載功能了。O(∩_∩)O

四、actuator微服務信息完善

4.1、主機名稱:服務名稱修改

• 修改cloud-provider-payment8001

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

• 修改之后

4.2、訪問信息有IP信息提示

當前問題 沒有IP提示

修改cloud-provider-payment8001

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

修改之后

8002 是一樣的操作，大家自己實操啊

五、服務發現Discovery

對于注冊進eureka里面的微服務，可以通過服務發現來獲得該服務的信息

修改cloud-provider-payment8001的Controller

@RestController @Slf4j public class PaymentController {@Value("${server.port}")private String serverPort;@Resourceprivate PaymentService paymentService;@Resourceprivate 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;} }

8001主啟動類

@SpringBootApplication @EnableEurekaClient @EnableDiscoveryClient //服務發現 public class PaymentMain8001 {public static void main(String[] args){SpringApplication.run(PaymentMain8001.class,args);} }

自測

先要啟動EurekaServer

再啟動8001主啟動類，需要稍等一會兒

http://localhost:8001/payment/discovery

8002 如果想要實現 一樣的操作

六、Eureka自我保護

6.1、故障現象

概述
保護模式主要用于一組客戶端和Eureka Server之間存在網絡分區場景下的保護。一旦進入保護模式，
Eureka Server將會嘗試保護其服務注冊表中的信息，不再刪除服務注冊表中的數據，也就是不會注銷任何微服務。

6.2、導致原因

• 為什么會產生Eureka自我保護機制？

  為了防止EurekaClient可以正常運行，但是 與 EurekaServer網絡不通情況下，EurekaServer不會立刻將EurekaClient服務剔除

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

• 在自我保護模式中，Eureka Server會保護服務注冊表中的信息，不再注銷任何服務實例。
  它的設計哲學就是寧可保留錯誤的服務注冊信息，也不盲目注銷任何可能健康的服務實例。一句話講解：好死不如賴活著

綜上，自我保護模式是一種應對網絡異常的安全保護措施。它的架構哲學是寧可同時保留所有微服務（健康的微服務和不健康的微服務都會保留）也不盲目注銷任何健康的微服務。使用自我保護模式，可以讓Eureka集群更加的健壯、穩定。

屬于CAP里面的AP分支

6.3、怎么禁止自我保護

注冊中心eureakeServer端7001

• 出廠默認，自我保護機制是開啟的 eureka.server.enable-self-preservation=true

• 使用eureka.server.enable-self-preservation = false 可以禁用自我保護模式

  server:port: 7001spring:application:name: eureka-cluster-servereureka:instance:hostname: eureka7001.comclient:register-with-eureka: falsefetch-registry: falseservice-url:#defaultZone: http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eurekadefaultZone: http://eureka7001.com:7001/eurekaserver:#關閉自我保護機制，保證不可用服務被及時踢除enable-self-preservation: falseeviction-interval-timer-in-ms: 2000

• 關閉效果

生產者客戶端eureakeClient端8001

eureka:client: #服務提供者provider注冊進eureka服務列表內service-url:register-with-eureka: truefetch-registry: true# cluster version#defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka# singleton versiondefaultZone: http://eureka7001.com:7001/eureka #心跳檢測與續約時間 #開發時設置小些，保證服務關閉后注冊中心能即使剔除服務instance:#Eureka客戶端向服務端發送心跳的時間間隔，單位為秒(默認是30秒)lease-renewal-interval-in-seconds: 1#Eureka服務端在收到最后一次心跳后等待時間上限，單位為秒(默認是90秒)，超時將剔除服務lease-expiration-duration-in-seconds: 2

測試

• 7001和8001都配置完成

• 先啟動7001再啟動8001

• 先關閉8001 我們可以看到立馬就被刪除啦。

自言自語

繼續干活。

總結

以上是生活随笔為你收集整理的SpringCloud--Eureka服务注册与发现 Eureka 集群搭建 详细案例！！！的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。