Spring Cloud 构建(一) Eureka

http://blog.didispace.com/

Spring Cloud Netflix提供了多个Spring Cloud的功能组件

eureka 是一个基于REST服务的服务发现中心

创建服务注册中心

1. pom文件配置(指定项目版本)

<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服务发现引入 -->
<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>

2. 配置文件

spring:
  application:
    name: cloud-discovery-service # 服务中心注册时的服务名称
server:
  port: 8000
eureka:
  client:
    fetch-registry: false # 关闭从服务注册中心获取服务注册表,默认为true
    register-with-eureka: false # 该服务是否可以在服务中心被发现,默认为true

3. 启动类

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }

}

增加@EnableEurekaServer作为一个Eureka服务端来启动

4. 启动成功后

   image

服务注册

创建一个服务生产应用并注册到eureka注册中心

1. 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>

2. application.yml

spring:
  application:
    name: producer-service
server:
  port: 8040
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8000/eureka/

3. 启动类

@SpringBootApplication
@EnableDiscoveryClient
public class ServiceProducerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceProducerApplication.class, args);
    }

}

增加@EnableDiscoveryClient来注册到服务注册中心

4.启动后

image

这时可以看到服务已经注册到注册中心了

创建高可用服务注册中心

运行多个服务中心实例,并相互注册,来保证当任一注册中心挂掉后系统还能正常运行

1. 修改hosts,仅单机测试使用,实际生产中使用Ip地址

   127.0.0.1 peer1
   127.0.0.1 peer2
   127.0.0.1 peer3
   

2. 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

3. 使用 mvn clean package

可能打包失败

4. 运行打包出来的jar包,使用spring.profiles.active执行不同配置文件

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.执行结果

image

创建时发现每个服务中心注册自身时都比较慢

6. 此时注册服务

使用启动producer-service将defaultZone改为任一节点地址

image image image

可以看到当服务在一个服务中心注册后其他服务中心也会进行注册该服务

服务注册传播

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

image

• Peer2

image

• Peer3

image

可以发现仅peer1,peer2成功注册服务

更改producer-service的defaultZone指向peer2

发现仅peer2,peer3成功注册服务

image

Eureka的实例注册表

A->B B->C C->A ->注册地址

S(待注册服务)，A,B,C eureka服务

S在A注册后，B列表中也会有S ，但是C没有。但是重启C后C列表中有S。

猜测可能是在eureka启动的时候会从Replicas复制一份注册实例列表出来。

关闭producer-service服务后,peer1,peer2正确注销服务注册,但peer3服务实例仍然存在。

重启peer2节点的eureka,发现注册实例列表中包含了已经关闭的producer-service服务,说明当服务启动的时候会复制一份replicas节点的服务注册信息。

image

根据上图证实了猜测。eureka是从注册的地址中的eureka拷贝的实例列表，且不会对拷贝的实例列表做有效性检测。

示例：https://github.com/Marccccc/spring-cloud-demo