SpringCloud 註冊與發現 之 註冊中心高可用叢集 Eureka
阿新 • • 發佈：2018-11-01
SpringCloud 註冊與發現 之 註冊中心高可用叢集 Eureka
1、註冊中心的存在
- 服務提供者啟動會註冊到註冊中心，並會定期發起心跳通知，告知註冊中心“我還活著，別把我幹掉”。
- 服務消費者到註冊中心訂閱服務，並拉取呼叫的服務列表到本地快取，這是服務消費者發現服務提供者的過程。
- 服務消費者從服務列表中呼叫服務進行消費。
- 註冊中心 是微服務治理的一部分。
2、註冊中心叢集
先看效果圖：
以本機模擬兩臺伺服器部署註冊中心應用的場景，兩臺伺服器對應埠分別為9001，9000.
下面看下配置
- 建立一個專案 spring cloud
- eureka-server module （埠9000）
- eureka-server2 module （埠9001）
專案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"> <modelVersion>4.0.0</modelVersion> <groupId>cn.zhjw</groupId> <artifactId>cn.zhjw.cloud</artifactId> <version>1.0-SNAPSHOT</version> <packaging>pom</packaging> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.14.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <!-- Guava 工具類 --> <guava.version>23.6-jre</guava.version> <!-- Protobuf Version --> <protobuf.version>2.5.0</protobuf.version> <!-- Aliyun Logging --> <aliyun.logging.version>0.1.6</aliyun.logging.version> <!-- Fast Json Version--> <fastjson.version>1.2.40</fastjson.version> <!-- Lombok 工具 --> <lombok.version>1.16.20</lombok.version> <!-- Mysql 配置 --> <mysql.version>6.0.6</mysql.version> <!-- 連線池 --> <druid.version>1.1.6</druid.version> <!-- Spring Cloud Version --> <spring-cloud.version>Edgware.SR2</spring-cloud.version> <!-- jodd mail Version --> <jodd-mail.version>3.8.5</jodd-mail.version> <!-- freemarker Version --> <freemarker.version>2.3.25-incubating</freemarker.version> <!-- 基本配置 --> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <springboot.version>1.5.14.RELEASE</springboot.version> <spring-test.version>4.3.13.RELEASE</spring-test.version> </properties> <modules> <!-- 註冊中心 1--> <module>eureka-server</module> <!-- 註冊中心 2--> <module>eureka-server2</module> </modules> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> <version>${springboot.version}</version> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>${lombok.version}</version> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> <version>1.3.3.RELEASE</version> </dependency> <!-- Spring Cloud 依賴 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring-test.version}</version> </dependency> </dependencies> </dependencyManagement> <dependencies> <!-- Logger Api --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> </dependency> <!--<!– Devtools –> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <optional>true</optional> <scope>runtime</scope> </dependency>--> <!-- Testing --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <version>${springboot.version}</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.5.1</version> <configuration> <source>${java.version}</source> <target>${java.version}</target> <encoding>${project.build.sourceEncoding}</encoding> </configuration> </plugin> </plugins> </build> </project>
- module eureka-server
- 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"> <modelVersion>4.0.0</modelVersion> <groupId>cn.zhjw</groupId> <artifactId>eureka-server</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>eureka-server</name> <description>Demo project for Spring Boot</description> <parent> <groupId>cn.zhjw</groupId> <artifactId>cn.zhjw.cloud</artifactId> <version>1.0-SNAPSHOT</version> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-deploy-plugin</artifactId> <configuration> <skip>true</skip> </configuration> </plugin> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <mainClass>cn.zhjw.eurekaserver.EurekaServerApplication</mainClass> </configuration> <executions> <execution> <goals> <goal>repackage</goal> </goals> </execution> </executions> </plugin> </plugins> </build> </project> - application.properties
server.port=9000 spring.application.name=eurekaServer #註冊中心例項名稱 eureka.instance.appname=eurekaServer #例項以ip地址展示 eureka.instance.prefer-ip-address=true #註冊中心例項hostname 設定為ip eureka.instance.hostname=${spring.cloud.client.ipAddress} #例項id 以 IP地址+服務埠號 eureka.instance.instance-id=${spring.cloud.client.ipAddress}:${server.port} #叢集 #向註冊中心註冊自己 eureka.client.register-with-eureka=true #拉取註冊中心註冊項 eureka.client.fetch-registry=true #註冊中心叢集地址，多個server地址以英文逗號隔開 eureka.client.service-url.defaultZone=http://127.0.0.1:9001/eureka/,http://127.0.0.1:9000/eureka/ - main 入口啟動類
package cn.zhjw.eurekaserver; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication //加入註冊中心服務註解 @EnableEurekaServer public class EurekaServerApplication { public static void main(String[] args) { SpringApplication.run(EurekaServerApplication.class, args); } }
- module eureka-server1 相關配置及程式碼 類似 上面的配置，不再一一寫了。
搞完程式碼後，啟動server及server1專案，兩者就構成了註冊中心叢集。在實際部署時，請將eureka.client.service-url.defaultZone 屬性中的ip、埠號替換為實際伺服器ip及埠號。
3、加入安全認證
我們可能有這樣一個需求：外部服務想要註冊進來時需要認證通過後才能註冊到註冊中心來。那麼針對EurekaServer 需要滿足下面的做法：
- pom檔案中加入依賴安全配置：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
- properities配置檔案中修改的屬性項如下：
eureka.client.service-url.defaultZone=http://${security.user.name}:${security.user.password}@127.0.0.1:9001/eureka/,http://${security.user.name}:${security.user.password}@127.0.0.1:9000/eureka/
#安全認證
security.basic.enabled=true
security.user.name=username
security.user.password=password- 啟動eureka server1 與 eureka server2 ，在瀏覽器url輸入 localhost:9000，回車
- 各個服務註冊到註冊中心時，也需要在其配置檔案中加入配置項，比如Client1服務中：
register.server.user.name=username
register.server.user.password=password
#安全認證
eureka.client.service-url.defaultZone=http://${register.server.user.name}:${register.server.user.password}@127.0.0.1:9001/eureka/,http://${register.server.user.name}:${register.server.user.password}@127.0.0.1:9000/eureka/
- 驗證註冊成功
4、結束
最後說下注冊進來的例項。
可以看下下圖
- Application 的名字：這個取配置項 eureka.instance.appname得屬性值；
- Avaliability Zones: 數字2，代表相同的應用名字的例項數，Ribbon 負載均衡的效果就在請求多例項的服務時體現的。
- Status：Up指的線上的數量，後面的ip+port 拉取的eureka.instance.instance-id 的屬性。
