Spring Cloud Netflix提供了多個(gè)Spring Cloud的功能組件
eureka 是一個(gè)基于REST服務(wù)的服務(wù)發(fā)現(xiàn)中心
創(chuàng)建服務(wù)注冊(cè)中心
- pom文件配置(指定項(xiàng)目版本)
<properties>
<java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<spring-cloud.version>Edgware.SR2</spring-cloud.version>
</properties>
<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>
<!-- eureka服務(wù)發(fā)現(xiàn)引入 -->
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter</artifactId>
</dependency>
</dependencies>
- 配置文件
spring:
application:
name: cloud-discovery-service # 服務(wù)中心注冊(cè)時(shí)的服務(wù)名稱
server:
port: 8000
eureka:
client:
fetch-registry: false # 關(guān)閉從服務(wù)注冊(cè)中心獲取服務(wù)注冊(cè)表,默認(rèn)為true
register-with-eureka: false # 該服務(wù)是否可以在服務(wù)中心被發(fā)現(xiàn),默認(rèn)為true
- 啟動(dòng)類
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
增加@EnableEurekaServer作為一個(gè)Eureka服務(wù)端來(lái)啟動(dòng)
-
啟動(dòng)成功后
image
服務(wù)注冊(cè)
創(chuàng)建一個(gè)服務(wù)生產(chǎn)應(yīng)用并注冊(cè)到eureka注冊(cè)中心
- pom配置
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter</artifactId>
</dependency>
</dependencies>
- application.yml
spring:
application:
name: producer-service
server:
port: 8040
eureka:
client:
service-url:
defaultZone: http://localhost:8000/eureka/
- 啟動(dòng)類
@SpringBootApplication
@EnableDiscoveryClient
public class ServiceProducerApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceProducerApplication.class, args);
}
}
增加@EnableDiscoveryClient來(lái)注冊(cè)到服務(wù)注冊(cè)中心
4.啟動(dòng)后
這時(shí)可以看到服務(wù)已經(jīng)注冊(cè)到注冊(cè)中心了
創(chuàng)建高可用服務(wù)注冊(cè)中心
運(yùn)行多個(gè)服務(wù)中心實(shí)例,并相互注冊(cè),來(lái)保證當(dāng)任一注冊(cè)中心掛掉后系統(tǒng)還能正常運(yùn)行
-
修改hosts,僅單機(jī)測(cè)試使用,實(shí)際生產(chǎn)中使用Ip地址
127.0.0.1 peer1 127.0.0.1 peer2 127.0.0.1 peer3 application.yml
eureka:
client:
serviceUrl:
defaultZone: http://peer1:8001/eureka/,http://peer2:8002/eureka/,http://peer3:8003/eureka/
---
spring:
application:
name: cloud-discovery-service
profiles: one
server:
port: 8001
eureka:
instance:
hostname: peer1
---
spring:
application:
name: cloud-discovery-service
profiles: two
server:
port: 8002
eureka:
instance:
hostname: peer2
---
spring:
application:
name: cloud-discovery-service
profiles: three
server:
port: 8003
eureka:
instance:
hostname: peer3
- 使用 mvn clean package
可能打包失敗
- 運(yùn)行打包出來(lái)的jar包,使用spring.profiles.active執(zhí)行不同配置文件
java -jar cloud-registry-service-1.0.0-SNAPSHOT.jar --spring.profiles.active=one
java -jar cloud-registry-service-1.0.0-SNAPSHOT.jar --spring.profiles.active=two
java -jar cloud-registry-service-1.0.0-SNAPSHOT.jar --spring.profiles.active=three
5.執(zhí)行結(jié)果
創(chuàng)建時(shí)發(fā)現(xiàn)每個(gè)服務(wù)中心注冊(cè)自身時(shí)都比較慢
- 此時(shí)注冊(cè)服務(wù)
使用啟動(dòng)producer-service將defaultZone改為任一節(jié)點(diǎn)地址
可以看到當(dāng)服務(wù)在一個(gè)服務(wù)中心注冊(cè)后其他服務(wù)中心也會(huì)進(jìn)行注冊(cè)該服務(wù)
服務(wù)注冊(cè)傳播
cloud-registry-service更改為如下配置
---
spring:
application:
name: cloud-discovery-service
profiles: one
server:
port: 8001
eureka:
instance:
hostname: peer1
client:
serviceUrl:
defaultZone: http://peer2:8002/eureka/
---
spring:
application:
name: cloud-discovery-service
profiles: two
server:
port: 8002
eureka:
instance:
hostname: peer2
client:
serviceUrl:
defaultZone: http://peer3:8003/eureka/
---
spring:
application:
name: cloud-discovery-service
profiles: three
server:
port: 8003
eureka:
instance:
hostname: peer3
client:
serviceUrl:
defaultZone: http://peer1:8001/eureka/
更改producer-service的defaultZone指向peer1
defaultZone: http://peer1:8001/eureka/
- Peer1
- Peer2
- Peer3
可以發(fā)現(xiàn)僅peer1,peer2成功注冊(cè)服務(wù)
更改producer-service的defaultZone指向peer2
發(fā)現(xiàn)僅peer2,peer3成功注冊(cè)服務(wù)
Eureka的實(shí)例注冊(cè)表
A->B B->C C->A ->注冊(cè)地址
S(待注冊(cè)服務(wù))，A,B,C eureka服務(wù)
S在A注冊(cè)后儡嘶，B列表中也會(huì)有S ，但是C沒(méi)有。但是重啟C后C列表中有S尉姨。
猜測(cè)可能是在eureka啟動(dòng)的時(shí)候會(huì)從Replicas復(fù)制一份注冊(cè)實(shí)例列表出來(lái)。
關(guān)閉producer-service服務(wù)后,peer1,peer2正確注銷服務(wù)注冊(cè),但peer3服務(wù)實(shí)例仍然存在。
重啟peer2節(jié)點(diǎn)的eureka,發(fā)現(xiàn)注冊(cè)實(shí)例列表中包含了已經(jīng)關(guān)閉的producer-service服務(wù),說(shuō)明當(dāng)服務(wù)啟動(dòng)的時(shí)候會(huì)復(fù)制一份replicas節(jié)點(diǎn)的服務(wù)注冊(cè)信息血当。
image
根據(jù)上圖證實(shí)了猜測(cè)翘贮。eureka是從注冊(cè)的地址中的eureka拷貝的實(shí)例列表赊窥，且不會(huì)對(duì)拷貝的實(shí)例列表做有效性檢測(cè)。
