Spring Cloud（二）：Eureka 服务注册中心-低调大师

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

2019-12-08 639

前言

服务治理

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

服务注册

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

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

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

服务发现

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

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

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

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

Spring Cloud Eureka

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

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，说明该注册中心还没有注册任何服务。

服务提供者（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 通过互相注册服务的方式，以实现服务清单的互相同步，达到高可用的效果。

双节点注册中心

搭建服务注册中心 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/

搭建服务注册中心 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/

在 /etc/hosts（windows系统路径为 C:WindowsSystem32driversetchosts）文件中添加 nodea 和 nodeb 的转换，如下：

127.0.0.1 nodea
127.0.0.1 nodeb

启动两个项目，分别访问http://nodea:9991/和http://nodeb:9992/，我们可以看到两个节点都已经被注册，如下图所示：

搭建完多节点服务注册中心之后，服务提供者也需要做一些简单的配置，以上面的服务提供者为例，修改如下:

eureka.client.serviceUrl.defaultZone=http://nodea:9991/eureka/,http://nodeb:9992/eureka/

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

这时我们关闭服务注册中心节点 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

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

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

关注下我的公众号，文章持续更新中...

微信关注我们

原文链接：https://yq.aliyun.com/articles/738396

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

12月09日云栖号头条：AI是否正在砸公务员的“铁饭碗”？

今日最新云头条快讯：面部识别技术已经越来越普遍地被用在我们的生活中；从人工智能技术的发展和应用方向来看，“机器人”砸公务员的“铁饭碗”只是时间问题；受益于虚拟现实（VR）技术的可能不仅仅是人类： Facebook开发反人脸识别技术，实时视频也同样可用每天，我们刷脸解锁手机，翻看相册里已根据人脸分类好的照片，甚至在上传图片到社交网络上时也不用自己填写人名，因为AI已经识别出你图片中人物的名字了。但如果有一天，AI也能欺骗AI，以假乱真呢？外媒VentureBeat报道称，近日，Facebook的人工智能实验室Facebook AI Research（FAIR）开发出一种“去识别”系统，该系统可以欺骗面部识别系统，例如，让面部识别系统将你识别为一位女明星。 AI正在砸公务员的“铁饭碗”？人工智能没有自身利益，立场绝对中立，也没有情绪波动的干扰，不折不扣地执行由法律法规转化而来的算法，大众心目中的完美公务员不过如此日前，印尼总统佐科·维多多宣布政府机构将在2020年取消两个公务员层级，并利用人工智能取代他们，以减少阻碍投资的繁文缛节和官僚主义。奶牛看VR能产更多更好牛奶？可能是一场营销...

2019-12-09

697

【鲁班H5】前后端都开源的h5快速制作平台，类似于开源版本的易企秀、人人秀，可以通过拖拽的形式，快速生成H5 1.7.2 (2019-12-08)更新的内容有 Bug Fixes replace router.place with window.open new tab to aviod could not save and preview the work when create the work; zh: 用 window.open new tab 替换 router.replace，避免最创建作品保存和预览无效的情况(cf953c2) build: set publicURL to index (abfb167) editor: update mutation type for undo-redo (0f4a2cb) preview: show qrcode in preview dialog if open from work list (8c62271) 更新说明：https://github.com/ly525/luban-h5/releases 相关链接鲁班 H5 的详...

2019-12-09

807

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。