Spring Cloud（二）：Eureka 服务注册中心

时间  2020-01-01
标签 spring cloud eureka 服务 注册 中心 栏目 Spring 繁體版
原文   原文链接

前言

服务治理

随着业务的发展，微服务应用也随之增长，这些服务的管理和治理会愈来愈难，而且集群规模、服务位置、服务命名都会发生变化，手动维护的方式极易发生错误或是命名冲突等问题。而服务治理正是为了解决这个问题，服务治理是微服务架构中最为核心和基础的模块，它主要实现各个微服务实例的 自动化注册和发现。

服务注册

在服务治理框架中，都会构建一个或多个服务注册中心。

每一个服务模块向注册中心登记本身所提供的服务，将主机host、端口号、版本号、通讯协议等一些附加信息告知注册中心，注册中心按服务名分类组织服务清单。java

服务注册中心还须要以心跳的方式去监测清单中的服务是否可用，若不可用须要从服务清单中剔除，达到排除故障服务的效果。node

服务发现

服务间调用再也不经过指定具体实例地址来实现，而是经过向服务名发起请求调用实现。

服务调用方须要先从服务注册中心获取全部服务的实例清单，才能实现对具体服务实例的访问。git

服务调用方在发起调用时，会以某种策略取出一个具体的服务实例进行服务调用(客户端负载均衡)。github

在生产环境中为了考虑性能等因素，不会采用每次都向服务注册中心获取服务的方式，而且不一样的应用场景在缓存和服务剔除等机制上也会采用不一样的实现策略。spring

Spring Cloud Eureka

Spring Cloud Eureka 是基于 Netflix Eureka 来实现服务注册和发现的。它主要包括两个组件：windows

  • Eureka Server（服务端）：服务注册中心，支持高可用配置，依托于强一致性提供良好的服务实例可用性，服务注册中心之间能够经过异步模式互相复制各自的状态。
  • Eureka Client（客户端）：处理服务的注册与发现，客户端能够经过注解和参数配置的方式实现注册与发现，客户端向注册中心注册自身提供的服务并周期性地发送心跳来更新它的服务租约，Eureka客户端从服务端查询当前注册的服务信息并把它们缓存到本地并周期性的刷新服务状态。

Eureka 基础架构缓存

  • 服务注册中心（Eureka Server）：服务端，提供服务注册和发现功能。
  • 服务提供者（Service Provider）：提供服务的应用，将本身提供的服务注册到 Eureka Server，供其余应用发现。
  • 服务消费者（Service Consumer）：消费者应用从 Eureka Server 获取服务列表，从而调用对应的服务（ribbon或者feign）。

基础架构图

架构

快速搭建服务注册中心（Eureka Server）

1. 建立 Spring Boot 项目，添加依赖

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
    </properties>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

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

2. @EnableEurekaServer 注解启动服务注册中心

@SpringBootApplication
@EnableEurekaServer
public class SpringCloudEurekaServerApplication {

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

}

3. 配置文件 application.properties

server.port=9999
#eureka
eureka.instance.hostname=127.0.0.1
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
  • eureka.client.register-with-eureka：当前应用为服务注册中心，因此设置为false，表明不向注册中心注册本身。
  • eureka.client.fetch-registry：注册中心的职责主要是维护服务实例，因此设置为false，表明不去检索当前应用的服务。
  • eureka.client.serviceUrl.defaultZone：用于与 Eureka Server 交互的地址，注册服务和发现服务都须要依赖这个地址。

4.启动应用，访问：http://127.0.0.1:9999/

能够看到 Eureka 的信息面板，其中 Instances currently registered with Eureka 中列表显示 No instances available，说明该注册中心尚未注册任何服务。
app

服务提供者（Service Provider）

1. 建立 Spring Boot 项目，添加依赖

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
    </properties>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

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

2. @EnableDiscoveryClient 注解启动 Eureka 客户端

@SpringBootApplication
//@EnableEurekaClient  该注解在采用eureka做为注册中心时使用，场景较为单一
@EnableDiscoveryClient //场景更为普遍
public class SpringCloudEurekaServiceApplication {

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

}

@EnableEurekaClient 和 @EnableDiscoveryClient 在当前示例中使用效果好是同样的，@EnableEurekaClient 注解在采用eureka做为注册中心时使用，场景较为单一，@EnableDiscoveryClient 场景更为普遍。负载均衡

3. 配置文件 application.properties

server.port=8888
spring.application.name=spring-cloud-eureka-service
#info 应用信息
info.app.name=spring-cloud-eureka-service
info.app.version=v1.0.0
info.app.description=spring-cloud-eureka-service
#eureka
eureka.instance.hostname=127.0.0.1
#每隔5s心跳一次,证实本服务还活着
eureka.instance.lease-renewal-interval-in-seconds=5
#本服务10s内没有心跳,就将该服务从服务端剔除
eureka.instance.lease-expiration-duration-in-seconds=10
eureka.client.serviceUrl.defaultZone=http://127.0.0.1:9999/eureka/
  • eureka.instance.lease-renewal-interval-in-seconds：设置心跳间隔秒数
  • eureka.instance.lease-expiration-duration-in-seconds：设置秒数内无意跳，则剔除服务

4. 启动应用，访问：http://127.0.0.1:9999/

在服务注册中心的控制台中咱们能够看到以下输出，说明服务被注册成功了。

c.n.e.registry.AbstractInstanceRegistry  : Registered instance SPRING-CLOUD-EUREKA-SERVICE/192.168.101.201:spring-cloud-eureka-service:8888 with status UP (replication=false)

而在 Eureka 的信息面板上，在 Instances currently registered with Eureka 列表中一样能够看到服务的注册信息。以下图：

高可用注册中心（集群）

上面介绍了单节点模式的服务注册中心，不过在实际生产环境中，一般不会采用这种模式。在分布式系统中，服务注册中心是很是重要的组成部分，若是是单节点模式，发生故障的话将会是毁灭性的灾害。因此为了维护服务的高可用性，一般采用集群的解决方案。

Eureka 的服务治理设计中，全部的节点既是服务提供方，也是服务消费方，服务注册中心也不例外。Eureka 经过互相注册服务的方式，以实现服务清单的互相同步，达到高可用的效果。

双节点注册中心

  1. 搭建服务注册中心 A，配置文件以下：
server.port=9991
spring.application.name=eureka-server
spring.profiles.active=nodea
#eureka
eureka.instance.hostname=nodea
#设置微服务调用地址为IP优先（缺省为false）
#eureka.instance.prefer-ip-address=true
eureka.client.serviceUrl.defaultZone=http://nodeb:9992/eureka/
  1. 搭建服务注册中心 B，配置文件以下：
server.port=9992
spring.application.name=eureka-server
spring.profiles.active=nodeb
#eureka
eureka.instance.hostname=nodeb
#设置微服务调用地址为IP优先（缺省为false）
#eureka.instance.prefer-ip-address=true
eureka.client.serviceUrl.defaultZone=http://nodea:9991/eureka/
  1. 在 /etc/hosts（windows系统路径为 C:WindowsSystem32driversetchosts） 文件中添加 nodea 和 nodeb 的转换，以下：
127.0.0.1 nodea
127.0.0.1 nodeb
  1. 启动两个项目，分别访问http://nodea:9991/和http://nodeb:9992/，咱们能够看到两个节点都已经被注册，以下图所示：

  1. 搭建完多节点服务注册中心以后，服务提供者也须要作一些简单的配置，以上面的服务提供者为例，修改以下:
eureka.client.serviceUrl.defaultZone=http://nodea:9991/eureka/,http://nodeb:9992/eureka/

启动项目后，访问两个服务注册中心，咱们看到服务被注册到这两个节点内。

  1. 这时咱们关闭服务注册中心节点 A，咱们能够看到服务注册中心节点 B 依然能够提供服务，而节点 A 从 available-replicas（能够分片） 变为 unavailable-replicas（不可用分片）。

服务消费者（Service Consumer）

使用 Ribbon 调用服务

1. pom 相关依赖配置
<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
    </dependencies>

    <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>
2. 配置文件 application.properties
spring.application.name=spring-cloud-ribbon-consumer
server.port=8081
eureka.client.serviceUrl.defaultZone=http://nodea:9991/eureka/,http://nodeb:9992/eureka/
3. 启动类配置

经过 @EnableDiscoveryClient 注解将应用注册为 Eureka 客户端，得到服务发现能力。

建立 RestTemplate 的 Spring Bean 实例用来调用服务。

经过 @LoadBalanced 注解来开启客户端的负载均衡。

@SpringBootApplication
@EnableDiscoveryClient
public class SpringCloudRibbonConsumerApplication {

    @Bean
    @LoadBalanced
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
    
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudRibbonConsumerApplication.class, args);
    }

}
4. ConsumerController 来实现服务调用
@RestController
public class ConsumerController {

    @Autowired
    RestTemplate restTemplate;
    
    @RequestMapping("/test")
    public String test() {
        return restTemplate.getForEntity("http://spring-cloud-eureka-service/test", String.class).getBody();
    }
}

spring-cloud-eureka-service 为服务注册中心的应用名称，大小写都可。

使用 Feign 调用服务

1. pom 相关依赖配置
<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

    <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>
2. 配置文件 application.properties
spring.application.name=spring-cloud-feign-consumer
server.port=8080
eureka.client.serviceUrl.defaultZone=http://nodea:9991/eureka/,http://nodeb:9992/eureka/
3. 启动类配置

经过 @EnableDiscoveryClient 注解将应用注册为 Eureka 客户端，得到服务发现能力。

经过 @EnableFeignClients 注解来启用feign进行远程调用。

@SpringBootApplication
@EnableDiscoveryClient//启用服务注册与发现
@EnableFeignClients//启用feign进行远程调用
public class SpringCloudFeignConsumerApplication {

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

}
4. 实现服务调用接口
@FeignClient(name = "spring-cloud-eureka-service")
public interface TestService {

    @RequestMapping("/test")
    public String test();
}

spring-cloud-eureka-service 为服务注册中心的应用名称，大小写都可。

此接口中的方法和远程服务中contoller中的方法名和参数需保持一致。

5. ConsumerController 来实现服务调用
@RestController
public class ConsumerController {

    @Autowired
    private TestService testService;
    
    @RequestMapping("/test")
    public String test() {
        return testService.test();
    }
}

示例代码

github

码云

非特殊说明，本文版权归 朝雾轻寒 全部，转载请注明出处.

原文标题：Spring Cloud（二）：Eureka 服务注册中心

原文地址： https://www.zwqh.top/article/info/28

若是文章有不足的地方，欢迎提点建议，后续会完善~

若是文章对您有帮助，请给我点个赞哦~

关注下个人公众号，文章持续更新中...

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程