1.Eureka簡介
(1).CAP簡介
CAP原則又稱CAP定理,指的是在一個分布式系統中,Consistency(一致性)、 Availability(可用性)、Partition tolerance(磁區容錯性),三者不可兼得,
|
https://baike.baidu.com/item/CAP%E5%8E%9F%E5%88%99/5712863?fr=aladdin |
(2).Eureka簡介
Eureka是Netflix的一個子模塊,也是核心模塊之一,Eureka是一個基于REST的服務,用于定位服務,以實作云端中間層服務發現和故障轉移,服務注冊與發現對于微服務架構來說是非常重要的,有了服務發現與注冊,只需要使用服務的識別符號,就可以訪問到服務,而不需要修改服務呼叫的組態檔了,功能類似于dubbo的注冊中心,比如Zookeeper,
|
https://github.com/Netflix/eureka |

2.Eureka原理
(1).Eureka原理
[1].Eureka原理簡介
Spring Cloud 封裝了 Netflix 公司開發的 Eureka 模塊來實作服務注冊和發現(請對比Zookeeper),
Eureka 采用了 C-S 的設計架構,Eureka Server 作為服務注冊功能的服務器,它是服務注冊中心,
而系統中的其他微服務,使用 Eureka Client(Eureka客戶端)連接到 Eureka Server并維持心跳連接,這樣系統的維護人員就可以通過 Eureka Server 來監控系統中各個微服務是否正常運行,SpringCloud 的一些其他模塊(比如Zuul)就可以通過 Eureka Server 來發現系統中的其他微服務,并執行相關的邏輯,
Eureka和Dubbo的架構對比


[2].Eureka組件
Eureka包含兩個組件:Eureka Server和Eureka Client,Eureka Server提供服務注冊服務;各個節點啟動后,會在EurekaServer中進行注冊,這樣urekaServer中的服務注冊表中將會存盤所有可用服務節點的資訊,服務節點的資訊可以在界面中直觀的看到,
EurekaClient是一個Java客戶端,用于簡化Eureka Server的互動,客戶端同時也 具備一個內置的、使用輪詢(round-robin)負載演算法的負載均衡器,在應用啟動后,將會向Eureka Server發送心跳(默認周期為30秒),如果Eureka Server在多個心跳周期內沒有接收到某個節點的心跳,EurekaServer將會從服務注冊表中把這個服務節點移除(默認90秒),
(2).Eureka角色
Eureka Server 提供服務注冊和發現,
Service Provider服務提供方將自身服務注冊到Eureka,從而使服務消費方能夠找到,
Service Consumer服務消費方從Eureka獲取注冊服務串列,從而能夠消費服務,
(3).Eureka工程
總父工程
通用模塊api
服務提供者Provider
服務消費者Consumer
3.Eureka架構步驟
(1).創建服務注冊中心eureka
microservicecloud-eureka-7001 eureka服務注冊中心Module
[1].新建工程



[2].配置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"> <parent> <artifactId>microservicecloud</artifactId> <groupId>com.hosystem</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>microservicecloud-eureka-7001</artifactId> <dependencies> <!--eureka-server服務端 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> <!-- 修改后立即生效,熱部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies>
</project> |
[3].配合application.yml
|
server: port: 7001
eureka: instance: hostname: localhost #eureka服務端的實體名稱 client: register-with-eureka: false #false表示不向注冊中心注冊自己, fetch-registry: false #false表示自己端就是注冊中心,我的職責就是維護服務實體,并不需要去檢索服務 service-url: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #設定與Eureka Server互動的地址查詢服務和注冊服務都需要依賴這個地址, |
[4].EurekaServer7001_App主啟動類
|
package com.hosystem.springcloud;
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication @EnableEurekaServer //EurekaServer服務器端啟動類,接受其它微服務注冊進來 public class EurekaServer7001_App { public static void main(String[] args) { SpringApplication.run(EurekaServer7001_App.class, args); } } |
[5].Eureka Test
|
http://localhost:7001/ |

No application available(沒有服務被發現),因為沒有注冊服務進來當然不可能有服務被發現.
(2).注冊eureka服務中心
microservicecloud-provider-dept-8001將已有的部門微服務注冊進eureka服務中心,
[1].修改microservicecloud-provider-dept-8001
①.修改pom.xml
新添加的部分:
|
<!-- 將微服務provider側注冊進eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> |
完整的部分:
|
<?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>microservicecloud</artifactId> <groupId>com.hosystem</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>microservicecloud-provider-dept-8001</artifactId>
<dependencies> <dependency><!-- 引入自己定義的api通用包,可以使用Dept部門Entity --> <groupId>com.hosystem</groupId> <artifactId>microservicecloud-api</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jetty</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> </dependency> <!-- 修改后立即生效,熱部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency>
<!-- 將微服務provider側注冊進eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> </dependencies>
</project> |
②.修改application.yml
新添加的部分:
|
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka |
完整的部分:
|
server: port: 8001
mybatis: config-location: classpath:mybatis/mybatis.cfg.xml # mybatis組態檔所在路徑 type-aliases-package: com.hosytem.springcloud.entities # 所有Entity別名類所在包 mapper-locations: - classpath:mybatis/mapper/**/*.xml # mapper映射檔案
#name spring.application.name=microservicecloud-dept 很重要很重要很重要 spring: application: name: microservicecloud-dept datasource: type: com.alibaba.druid.pool.DruidDataSource # 當前資料源操作型別 driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包 url: jdbc:mysql://192.168.188.188:3306/cloudDB01 # 資料庫名稱 username: root password: 123456 dbcp2: min-idle: 5 # 資料庫連接池的最小維持連接數 initial-size: 5 # 初始化連接數 max-total: 5 # 最大連接數 max-wait-millis: 200 # 等待連接獲取的最大超時時間 eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka |
③.修改DeptProvider8001_App主啟動類
|
package com.hosystem.springcloud;
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@SpringBootApplication @EnableEurekaClient //本服務啟動后會自動注冊進eureka服務中 public class DeptProvider8001_App { public static void main(String[] args) { SpringApplication.run(DeptProvider8001_App.class, args); } } |
[2].測驗
①.啟動EurekaServer
需要先啟動EurekaServer在啟動provider

②.啟動DeptProvider 
③.顯示效果

Application中MICROSERVICECLOUD-DEPT如何得到.

(3).actuator與注冊微服務資訊完善
[1].主機名稱:服務名稱修改
如何去掉主機名稱

①.修改application.yml檔案
修改microservicecloud-provider-dept-8001的application.yml檔案,
修改部分:
|
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka instance: instance-id: microservicecloud-dept8001 |

完整部分:
|
server: port: 8001
mybatis: config-location: classpath:mybatis/mybatis.cfg.xml # mybatis組態檔所在路徑 type-aliases-package: com.hosytem.springcloud.entities # 所有Entity別名類所在包 mapper-locations: - classpath:mybatis/mapper/**/*.xml # mapper映射檔案
#name spring.application.name=microservicecloud-dept 很重要很重要很重要 spring: application: name: microservicecloud-dept datasource: type: com.alibaba.druid.pool.DruidDataSource # 當前資料源操作型別 driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包 url: jdbc:mysql://192.168.188.188:3306/cloudDB01 # 資料庫名稱 username: root password: 123456 dbcp2: min-idle: 5 # 資料庫連接池的最小維持連接數 initial-size: 5 # 初始化連接數 max-total: 5 # 最大連接數 max-wait-millis: 200 # 等待連接獲取的最大超時時間
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka instance: instance-id: microservicecloud-dept8001 |
②.顯示效果

[2].訪問資訊有IP資訊提示
如何設定訪問資訊有IP資訊提示

①.修改applicaiton.yml
修改microservicecloud-provider-dept-8001的application.yml檔案,
修改部分:
|
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka instance: instance-id: microservicecloud-dept8001 prefer-ip-address: true #訪問路徑可以顯示IP地址 |

完整代碼
|
server: port: 8001
mybatis: config-location: classpath:mybatis/mybatis.cfg.xml # mybatis組態檔所在路徑 type-aliases-package: com.hosytem.springcloud.entities # 所有Entity別名類所在包 mapper-locations: - classpath:mybatis/mapper/**/*.xml # mapper映射檔案
#name spring.application.name=microservicecloud-dept 很重要很重要很重要 spring: application: name: microservicecloud-dept datasource: type: com.alibaba.druid.pool.DruidDataSource # 當前資料源操作型別 driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包 url: jdbc:mysql://192.168.188.188:3306/cloudDB01 # 資料庫名稱 username: root password: 123456 dbcp2: min-idle: 5 # 資料庫連接池的最小維持連接數 initial-size: 5 # 初始化連接數 max-total: 5 # 最大連接數 max-wait-millis: 200 # 等待連接獲取的最大超時時間
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka instance: instance-id: microservicecloud-dept8001 prefer-ip-address: true #訪問路徑可以顯示IP地址 |
②.顯示效果

[3].微服務info內容詳細資訊
如何配置服務報告info

①.修改microservicecloud-provider-dept-8001
修改microservicecloud-provider-dept-8001的Pom檔案
修改部分:
|
<!-- actuator監控資訊完善 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> |

完整部分:
|
<?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>microservicecloud</artifactId> <groupId>com.hosystem</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>microservicecloud-provider-dept-8001</artifactId>
<dependencies> <dependency><!-- 引入自己定義的api通用包,可以使用Dept部門Entity --> <groupId>com.hosystem</groupId> <artifactId>microservicecloud-api</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jetty</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> </dependency> <!-- 修改后立即生效,熱部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency>
<!-- 將微服務provider側注冊進eureka --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency>
<!-- actuator監控資訊完善 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> </dependencies>
</project> |
②.修改父工程microservicecloud
總的父工程microservicecloud修改pom.xml添加構建build資訊,
修改部分:
|
<!--構建的build資訊--> <build> <finalName>microservicecloud</finalName> <resources> <resource> <directory>src/main/resources</directory> <filtering>true</filtering> </resource> </resources> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <configuration> <delimiters> <delimit>$</delimit> </delimiters> </configuration> </plugin> </plugins> </build> |

完整部分:
|
<?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>com.hosystem</groupId> <artifactId>microservicecloud</artifactId> <version>1.0-SNAPSHOT</version> <packaging>pom</packaging> <!--注:這行最開始創建的時候是不存在的--> <modules> <module>microservicecloud-api</module> <module>microservicecloud-provider-dept-8001</module> <module>microservicecloud-consumer-dept-80</module> <module>microservicecloud-eureka-7001</module> </modules>
<properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> <junit.version>4.12</junit.version> <log4j.version>1.2.17</log4j.version> <lombok.version>1.16.18</lombok.version> </properties>
<dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Dalston.SR1</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>1.5.9.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.0.4</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.0.31</version> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.0</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> <version>1.2.3</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>${log4j.version}</version> </dependency> </dependencies> </dependencyManagement>
<!--構建的build資訊--> <build> <finalName>microservicecloud</finalName> <resources> <resource> <directory>src/main/resources</directory> <filtering>true</filtering> </resource> </resources> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <configuration> <delimiters> <delimit>$</delimit> </delimiters> </configuration> </plugin> </plugins> </build>
</project> |
③.修改microservicecloud-provider-dept-8001
修改microservicecloud-provider-dept-8001的yml檔案,
修改部分:
|
info: app.name: hosystem-microservicecloud company.name: www.hosystem.com build.artifactId: $project.artifactId$ build.version: $project.version$ |

完整部分:
|
server: port: 8001
mybatis: config-location: classpath:mybatis/mybatis.cfg.xml # mybatis組態檔所在路徑 type-aliases-package: com.hosytem.springcloud.entities # 所有Entity別名類所在包 mapper-locations: - classpath:mybatis/mapper/**/*.xml # mapper映射檔案
#name spring.application.name=microservicecloud-dept 很重要很重要很重要 spring: application: name: microservicecloud-dept datasource: type: com.alibaba.druid.pool.DruidDataSource # 當前資料源操作型別 driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包 url: jdbc:mysql://192.168.188.188:3306/cloudDB01 # 資料庫名稱 username: root password: 123456 dbcp2: min-idle: 5 # 資料庫連接池的最小維持連接數 initial-size: 5 # 初始化連接數 max-total: 5 # 最大連接數 max-wait-millis: 200 # 等待連接獲取的最大超時時間
eureka: client: #客戶端注冊進eureka服務串列內 service-url: defaultZone: http://localhost:7001/eureka instance: instance-id: microservicecloud-dept8001 prefer-ip-address: true #訪問路徑可以顯示IP地址 info: app.name: hosystem-microservicecloud company.name: www.hosystem.com build.artifactId: $project.artifactId$ build.version: $project.version$ |
④.顯示效果
(4).eureka自我保護
[1].效果演示
[2].現象原因
簡單來說,某時刻某個微服務不可用,eureka不會立刻清理,依舊會對該微服務的資訊進行保存,
[3].自我保護簡介
默認情況下,如果EurekaServer在一定時間內沒有接收到某個微服務實體的心跳,EurekaServer將會注銷該實體(默認90秒),但是當網路磁區故障發生時,微服務與EurekaServer之間無法正常通信,以上行為可能變得非常危險了——因為微服務本身其實是健康的,此時本不應該注銷這個微服務,Eureka通過“自我保護模式”來解決這個問題——當EurekaServer節點在短時間內丟失過多客戶端時(可能發生了網路磁區故障),那么這個節點就會進入自我保護模式,一旦進入該模式,EurekaServer就會保護服務注冊表中的資訊,不再洗掉服務注冊表中的資料(也就是不會注銷任何微服務),當網路故障恢復后,該Eureka Server節點會自動退出自我保護模式,
在自我保護模式中,Eureka Server會保護服務注冊表中的資訊,不再注銷任何服務實體,當它收到的心跳數重新恢復到閾值以上時,該Eureka Server節點就會自動退出自我保護模式,它的設計哲學就是寧可保留錯誤的服務注冊資訊,也不盲目注銷任何可能健康的服務實體,
綜上,自我保護模式是一種應對網路例外的安全保護措施,它的架構哲學是寧可同時保留所有微服務(健康的微服務和不健康的微服務都會保留),也不盲目注銷任何健康的微服務,使用自我保護模式,可以讓Eureka集群更加的健壯、穩定,
在Spring Cloud中,可以使用eureka.server.enable-self-preservation = false 禁用自我保護模式,
(5).服務發現Discovery
microservicecloud-provider-dept-8001服務發現Discovery,
對于注冊進eureka里面的微服務,可以通過服務發現來獲得該服務的資訊

[1].修改microservicecloud-provider-dept-8001
修改microservicecloud-provider-dept-8001工程的DeptController
修改部分:
|
//注:如果Autowired顯示 could not autowired.there is more than one bean of 'DiscoveryClient' type; 使用一下兩種方法都行 //方法1:那么只需要添加@Qualifier("discoveryClient")即可 //方法2::當然也可以修改成 private DiscoveryClient discoveryClient; 但是我們也需要修改discovery()方法中client為discoveryClient @Qualifier("discoveryClient") @Autowired private DiscoveryClient client;
@RequestMapping(value = https://www.cnblogs.com/HOsystem/p/"/dept/discovery", method = RequestMethod.GET) public Object discovery() { List<String> list = client.getServices(); System.out.println("**********" + list);
List<ServiceInstance> srvList = client.getInstances("MICROSERVICECLOUD-DEPT"); for (ServiceInstance element : srvList) { System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t" + element.getUri()); } return this.client; } |
完整部分:
|
package com.hosystem.springcloud.controller;
import com.hosystem.springcloud.entities.Dept; import java.util.List;
import com.hosystem.springcloud.service.DeptService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController;
@RestController public class DeptController { @Autowired private DeptService service;
//注:如果Autowired顯示 could not autowired.there is more than one bean of 'DiscoveryClient' type; 使用一下兩種方法都行 //方法1:那么只需要添加@Qualifier("discoveryClient")即可 //方法2::當然也可以修改成 private DiscoveryClient discoveryClient; 但是我們也需要修改discovery()方法中client為discoveryClient @Qualifier("discoveryClient") @Autowired private DiscoveryClient client;
@RequestMapping(value = https://www.cnblogs.com/HOsystem/p/"/dept/add", method = RequestMethod.POST) public boolean add(@RequestBody Dept dept) { return service.add(dept); }
@RequestMapping(value = https://www.cnblogs.com/HOsystem/p/"/dept/get/{id}", method = RequestMethod.GET) public Dept get(@PathVariable("id") Long id) { return service.get(id); }
@RequestMapping(value = https://www.cnblogs.com/HOsystem/p/"/dept/list", method = RequestMethod.GET) public List<Dept> list() { return service.list(); }
@RequestMapping(value = https://www.cnblogs.com/HOsystem/p/"/dept/discovery", method = RequestMethod.GET) public Object discovery() { List<String> list = client.getServices(); System.out.println("**********" + list);
List<ServiceInstance> srvList = client.getInstances("MICROSERVICECLOUD-DEPT"); for (ServiceInstance element : srvList) { System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t" + element.getUri()); } return this.client; }
} |
[2].修改DeptProvider8001_App主啟動類
|
package com.hosystem.springcloud;
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@SpringBootApplication @EnableEurekaClient //本服務啟動后會自動注冊進eureka服務中 @EnableDiscoveryClient public class DeptProvider8001_App { public static void main(String[] args) { SpringApplication.run(DeptProvider8001_App.class, args); } } |
[3].本地檢測
①.啟動EurekaServer
②.啟動DeptProvider8001_App主啟動類
③.啟動DeptProvider8001_App主啟動類
|
http://localhost:8001/dept/discovery |

④.DeptProvider8001_App Console

[4].修改microservicecloud-consumer-dept-80
修改microservicecloud-consumer-dept-80工程的DeptController_Consumer
修改部分:
|
//測驗@EnableDiscoveryClient,消費端可以呼叫服務發現 @RequestMapping(value="https://www.cnblogs.com/consumer/dept/discovery") public Object discovery() { return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery", Object.class); } |
完整部分:
|
package com.hosystem.springcloud.controller;
import com.hosystem.springcloud.entities.Dept; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate;
@RestController //注:這里一定不能忘記注解@RestController 否則出現404; public class DeptController_Consumer {
/** * 使用restTemplate訪問restful介面非常的簡單; * (url, requestMap, ResponseBean.class)三個引數代表REST請求地址、請求引數、HTTP回應轉換被轉換成的物件型別 */ private static final String REST_URL_PREFIX = "http://localhost:8001";
@Autowired private RestTemplate restTemplate;
@RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/add") public boolean add(Dept dept) { return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, Boolean.class); }
@RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/get/{id}") public Dept get(@PathVariable("id") Long id) { return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, Dept.class); }
//@SuppressWarnings("unchecked"):壓制警告,因為我們使用了過期的方法 @SuppressWarnings("unchecked") @RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/list") public List<Dept> list() { return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class); }
//測驗@EnableDiscoveryClient,消費端可以呼叫服務發現 @RequestMapping(value=https://www.cnblogs.com/HOsystem/p/"/consumer/dept/discovery") public Object discovery() { return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery", Object.class); } } /** * JDBC Spring JDBCTemplate * Spring RestTemplate */ |
[5].顯示效果

4.集群配置

(1).Eureka集群原理

上圖是來自eureka的官方架構圖,這是基于集群配置的eureka;
- 處于不同節點的eureka通過Replicate進行資料同步
- Application Service為服務提供者
- Application Client為服務消費者
- Make Remote Call完成一次服務呼叫
服務啟動后向Eureka注冊,Eureka Server會將注冊資訊向其他Eureka Server進行同步,當服務消費者要呼叫服務提供者,則向服務注冊中心獲取服務提供者地址,然后會將服務提供者地址快取在本地,下次再呼叫時,則直接從本地快取中取,完成一次呼叫,
當服務注冊中心Eureka Server檢測到服務提供者因為宕機、網路原因不可用時,則在服務注冊中心將服務置為DOWN狀態,并把當前服務提供者狀態向訂閱者發布,訂閱過的服務消費者更新本地快取,
服務提供者在啟動后,周期性(默認30秒)向Eureka Server發送心跳,以證明當前服務是可用狀態,Eureka Server在一定的時間(默認90秒)未收到客戶端的心跳,則認為服務宕機,注銷該實體,
(2).新建工程
新建microservicecloud-eureka-7002/microservicecloud-eureka-7003
[1].新建microservicecloud-eureka-7002
[2].新建microservicecloud-eureka-7003


(3).配置pom檔案
[1].eureka-7002 pom檔案
配置microservicecloud-eureka-7002的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>microservicecloud</artifactId> <groupId>com.hosystem</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>microservicecloud-eureka-7002</artifactId> <dependencies> <!--eureka-server服務端 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> <!-- 修改后立即生效,熱部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies>
</project> |
[2].eureka-7003 pom檔案
配置microservicecloud-eureka-7002的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>microservicecloud</artifactId> <groupId>com.hosystem</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion>
<artifactId>microservicecloud-eureka-7003</artifactId> <dependencies> <!--eureka-server服務端 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> <!-- 修改后立即生效,熱部署 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency> </dependencies>
</project> |
(4).配置主啟動類
[1].EurekaServer7003_App.java
|
package com.hosystem.springcloud;
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication @EnableEurekaServer //EurekaServer服務器端啟動類,接受其它微服務注冊進來 public class EurekaServer7002_App { public static void main(String[] args) { SpringApplication.run(EurekaServer7002_App.class, args); } } |
[2].EurekaServer7003_App.java
|
package com.hosystem.springcloud;
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication @EnableEurekaServer //EurekaServer服務器端啟動類,接受其它微服務注冊進來 public class EurekaServer7003_App { public static void main(String[] args) { SpringApplication.run(EurekaServer7003_App.class, args); } } |
(5).修改hosts檔案

|
127.0.0.1 eureka7001.com 127.0.0.1 eureka7002.com 127.0.0.1 eureka7003.com |

(6).配置application.yml
[1].配置eureka7001 application.yml檔案
|
server: port: 7001
eureka: instance: hostname: eureka7001.com #eureka服務端的實體名稱 client: register-with-eureka: false #false表示不向注冊中心注冊自己, fetch-registry: false #false表示自己端就是注冊中心,我的職責就是維護服務實體,并不需要去檢索服務 service-url: #單機 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #設定與Eureka Server互動的地址查詢服務和注冊服務都需要依賴這個地址(單機), defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ |
[2].配置eureka7002 application.yml檔案
|
server: port: 7002
eureka: instance: hostname: eureka7002.com #eureka服務端的實體名稱 client: register-with-eureka: false #false表示不向注冊中心注冊自己, fetch-registry: false #false表示自己端就是注冊中心,我的職責就是維護服務實體,并不需要去檢索服務 service-url: #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #設定與Eureka Server互動的地址查詢服務和注冊服務都需要依賴這個地址, defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/ |
[3].配置eureka7003 application.yml檔案
|
server: port: 7003
eureka: instance: hostname: eureka7003.com #eureka服務端的實體名稱 client: register-with-eureka: false #false表示不向注冊中心注冊自己, fetch-registry: false #false表示自己端就是注冊中心,我的職責就是維護服務實體,并不需要去檢索服務 service-url: #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #設定與Eureka Server互動的地址查詢服務和注冊服務都需要依賴這個地址, defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/ |
(7).microservicecloud-provider-dept-8001
配置microservicecloud-provider-dept-8001的applicaiton.yml檔案
|
server: port: 8001
mybatis: config-location: classpath:mybatis/mybatis.cfg.xml # mybatis組態檔所在路徑 type-aliases-package: com.hosytem.springcloud.entities # 所有Entity別名類所在包 mapper-locations: - classpath:mybatis/mapper/**/*.xml # mapper映射檔案
#name spring.application.name=microservicecloud-dept 很重要很重要很重要 spring: application: name: microservicecloud-dept datasource: type: com.alibaba.druid.pool.DruidDataSource # 當前資料源操作型別 driver-class-name: org.gjt.mm.mysql.Driver # mysql驅動包 url: jdbc:mysql://192.168.188.188:3306/cloudDB01 # 資料庫名稱 username: root password: 123456 dbcp2: min-idle: 5 # 資料庫連接池的最小維持連接數 initial-size: 5 # 初始化連接數 max-total: 5 # 最大連接數 max-wait-millis: 200 # 等待連接獲取的最大超時時間
eureka: client: #客戶端注冊進eureka服務串列內 service-url: # defaultZone: http://localhost:7001/eureka defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ instance: instance-id: microservicecloud-dept8001 prefer-ip-address: true #訪問路徑可以顯示IP地址 info: app.name: hosystem-microservicecloud company.name: www.hosystem.com build.artifactId: $project.artifactId$ build.version: $project.version$ |
(8).test
[1].啟動eureka7001、eureka7002、eureka7003
在IDEA的Run Dashboard中運行eureka7001、eureka7002、eureka7003

[2].顯示效果

5.Eureka和Zookeeper比較
作為服務注冊中心,Eureka比Zookeeper好在哪里,

CAP:https://baike.baidu.com/item/CAP%E5%8E%9F%E5%88%99/5712863?fr=aladdin
參考檔案:https://baike.baidu.com/item/CAP%E5%8E%9F%E5%88%99/5712863?fr=aladdin
https://github.com/Netflix/eureka
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/230883.html
標籤:Java
上一篇:29 常用工具類(一)
下一篇:03網路編程從之異步服務器



