服务注册中心 Eureka

服务注册中心 Eureka

Spring Cloud Eureka 是 Netflix 公司开发的注册发现组件，本身是一个基于 REST 的服务。提供注册与发现，同时还提供了负载均衡、故障转移等能力。

Eureka 有 3 个角色

在这里插入图片描述

  • 服务中心（Eureka Server）：服务器端。它提供服务的注册和发现功能，即实现服务的治理。
  • 服务提供者（Service Provider）：服务提供者。它将自身服务注册到 服务中心，以便 服务消费者 能够通过服务器提供的服务清单（服务注册列表）来调用它。
  • 服务消费者（Service Consumer）：服务消费者。它从 服务中心 获取已注册的服务列表，从而消费服务。

Eureka 是 AP 架构（可用性和分区容错性），Zookeeper 是 CP 架构（一致性和分区容错性）。Eueka 优先保证服务的可用性，Zookeeper 在 Master 节点因为网络故障与其他节点失去联系时，剩余节点选取 leader 的时间太长，这就导致在选举期间注册服务瘫痪。

1. 搭建单机Eureka注册中心

首先需要创建一个 spring-cloud 工程，删除 src 目录，然后在 pom.xml 文件中加入以下依赖：

<!-- 统一管理jar包版本 -->
<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <spring-cloud.version>2021.0.0</spring-cloud.version>
    <spring-boot.version>2.6.3</spring-boot.version>
</properties>
<!-- 子模块继承之后,提供作用:锁定版本,子modlue不用写groupId和version -->
<dependencyManagement>
    <dependencies>
        <!--spring boot 2.6.3-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <!--spring cloud 2021.0.0-->
        <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-server-7001 模块，然后在 pom.xml 文件中加入以下依赖：

<!--  服务注册发现Eureka-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

写 application.yaml 配置文件，具体如下：

server:
  port: 7001
eureka:
  instance:
    # eureka服务端的实例名字
    hostname: localhost
  client:
    # 是否将自己注册到eureka server
    register-with-eureka: false
    # 是否从eureka server获取注册的服务信息
    fetch-registry: false
    # 设置与eureka server交互的地址
    service-url:
      defalutZone: http://${eureka.instance.hostname}:${server.port}/eureka/

最后在启动类上加上 @EnableEurekaServer 注解即可

@EnableEurekaServer

启动访问 localhost:7001 即可访问到 Eureka 注册中心的界面。

2. 创建服务提供者与服务消费者

创建服务提供者 provider-8001 和服务消费者 consumer-80 模块，然后在 pom.xml 文件中加入以下依赖：

<!--   引入Eureka 客户端依赖     -->
<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-web</artifactId>
</dependency>

服务提供者和消费者的依赖是一样的，都是 eureka-client。

写 application.yaml 配置文件，具体如下：

server:
  port: 8001
spring:
  application:
    name: cloud-provider-8001
eureka:
  client:
    # eureka服务地址
    service-url:
      defaultZone: http://localhost:7001/eureka/

server:
  port: 80
spring:
  application:
    name: cloud-consumer-80
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/

最后在启动类上面加 @EnableEurekaClient 注解即可。

@EnableEurekaClient

先启动 Eureka 注册中心，然后在分别启动服务提供者和服务消费者，即可在 Eureka 服务注册中心看到相关信息。

3. Eureka 注册中心界面说明

访问上面我们搭建的注册中心（localhost:7001），界面如下：

在这里插入图片描述

其中最重要的是中间服务信息的那一栏，实例的状态有以下几种：

  • UP：服务正常运行，特殊情况当进入自我保护模式，所有的服务依然是 UP 状态，所以需要做好熔断重试等容错机制应对灾难性网络出错情况
  • OUT_OF_SERVICE：不再提供服务，其他的 Eureka Client 将调用不到该服务，一般有人为的调用接口设置的，如：强制下线。
  • UNKNOWN：未知状态
  • STARTING：表示服务正在启动中
  • DOWN：表示服务已经宕机，无法继续提供服务

4. 服务自保和服务剔除机制

服务自保机制（Service Self-Preservation Mechanism）：是指 Eureka Server 中的一种机制，用于保护在 Eureka 注册中心上注册的微服务实例免受意外删除的影响。当微服务实例在心跳超时时间内没有发送心跳信号给 Eureka Server 时，Eureka Server 不会立即将其从服务注册表中删除，而是认为该实例可能处于网络故障等临时异常情况，会将其保留在注册表中，提供一定的自我保护，防止误删健康的实例。这样可以避免因网络抖动、服务器负载或其他临时问题导致服务实例被误删，从而提高服务的稳定性和可用性。

服务剔除机制（Service Eviction Mechanism）：与服务自保相对应，是指当服务实例连续长时间未发送心跳信号、或注册中心发现某个服务实例心跳连续失败的次数超过一定阈值时，Eureka Server 会将该服务实例从服务注册表中剔除。通过服务剔除机制，可以排除不健康、异常或故障状态的服务实例，防止其他服务继续调用故障的实例，减少错误的传播范围，提高系统的稳定性。

Eureka 中的服务自保机制是为了保护健康、可能出现临时异常的服务实例免受误删的影响，而服务剔除机制则是为了及时剔除不健康、长时间未发送心跳或心跳连续失败的服务实例，保障整个服务治理系统的正常运行。这两个机制的存在都是为了提高服务的可靠性和稳定性。

服务自保是默认开启的，可以使用以下配置来关闭，在 Eureka Server 的 application.yaml 配置文件中加入以下配置：

eureka:  
  server:
    # 参数来关闭保护机制,已确保注册中心可以将不可用的实例正确剔除,默认为true
    enable-self-preservation: false

5. Actuator 微服务信息完善

SpringCloud 体系里的服务实体向 Eureka 注册时，注册名默认是 IP名:应用名:应用端口名。

我们可以通过 actuator 来修改完善注册名，在服务提供者或消费者的 pom.xml 文件中加入以下配置：

<!-- actuator监控信息完善 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

然后在 application.yaml 配置文件中加入以下配置：

eureka:
  instance:
    # 实例名称
    instance-id: cloud-consumer01-80

6. 服务注册发现 Discovery

注册进入 Eureka 里面的微服务，可以通过服务发现来获取该服务的信息。

在服务提供者模块controller类，具体如下：

@Slf4j
@RestController
@RequestMapping("/provider")
public class ProviderController {
    @Autowired
    private DiscoveryClient discoveryClient;
    
    @GetMapping("/discovery")
    public Object discovery() {
        // 获取所有微服务信息
        List<String> services = discoveryClient.getServices();
        for (String service : services) {
            log.info("service:={}", service);
        }
        return this.discoveryClient;
    }

    /**
     * 供消费者调用
     */
    @GetMapping("/index")
    public String getMsg() {
        return "success";
    }
}

RestTemplate 是从 Spring3.0 开始支持的一个 HTTP 请求工具，它提供了常见的REST请求方案的模版，例如 GET 请求、POST 请求、PUT 请求、DELETE 请求以及一些通用的请求执行方法 exchange() 以及 execute()。

在服务消费者模块中添加配置类，具体如下：

@Configuration
public class CloudConfig {
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

最后在服务消费者模块添加对应调用方法，具体如下：

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/index")
    public String index() {
        // 远程微服务调用地址: 微服务名称
        String host = "http://cloud-provider-8001";
        // 具体URL
        String url = "/provider/index";
        // 发起远程调用
        // getForObject: 返回响应体中数据转化成的对象, 可以理解为json
        // getForEntity: 返回的是ResponseEntity的对象包含了一些重要的信息
        return restTemplate.getForObject(host + url, String.class);
    }
}

浏览器访问：http://localhost:80/consumer/index 地址，即出现在服务提供者模块中返回的 “success” 字符串。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/90894.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Java学数据结构（3）——树Tree B树 红黑树 Java标准库中的集合Set与映射Map 使用多个映射Map的案例

Java学数据结构（3）——树Tree B树 红黑树 Java标准库中的集合Set与映射Map 使用多个映射Map的案例

目录 引出B树插入insert删除remove 红黑树(red black tree)自底向上的插入自顶向下红黑树自顶向下的删除 标准库中的集合Set与映射Map关于Set接口关于Map接口TreeSet类和TreeMap类的实现使用多个映射Map&#xff1a;一个词典的案例方案一&#xff1a;使用一个Map对象方案二&…
阅读更多...
[管理与领导-49]：IT基层管理者 - 8项核心技能 - 4 - 团队激励

[管理与领导-49]：IT基层管理者 - 8项核心技能 - 4 - 团队激励

目录 前言&#xff1a; 一、什么是团队激励 二、为什么需要激励 三、激励的误区 3.1 常见误区 3.2 以下是一些常见的激励错误做法&#xff1a; 四、如何正确地激励 五、关于激励的一些理念 六、常见障碍 前言&#xff1a; 管理者存在的价值就是制定目标&#xff0c;即…
阅读更多...
CV:边缘检测的算法包含 Prewitt、Sobel、Laplacian 和 Canny。

CV:边缘检测的算法包含 Prewitt、Sobel、Laplacian 和 Canny。

目录 1. 边缘检测&#xff08;Prewitt&#xff09; 2. 边缘检测&#xff08;Sobel&#xff09; 3. 边缘检测&#xff08;Laplacian&#xff09; 3. 边缘检测&#xff08;Canny&#xff09; 边缘检测的算法包含 Prewitt、Sobel、Laplacian 和 Canny。 人在图像识别上具有难…
阅读更多...
IDEA 配置注释模板

IDEA 配置注释模板

目录 一、配置类模板注释 二、配置方法注释 一、配置类模板注释 打开IDEA&#xff0c;打开settings(快捷键&#xff1a;Ctrl Alt s)&#xff0c;选择Editor&#xff0c;找到File and Code Templates&#xff0c;设置需要配置注释的文件类型&#xff0c;如下图所示&#xf…
阅读更多...
Redis 为什么这么快？

Redis 为什么这么快？

前言 作为一名后端软件工程师&#xff0c;工作中你肯定和 Redis 打过交道。但是Redis 为什么快呢&#xff1f;很多人只能答出Redis 因为它是基于内存实现的&#xff0c;但是对于其它原因都是模棱两可。 那么今天就一起来看看是Redis 为什么快吧&#xff1a; Redis 为什么这么快…
阅读更多...
Ubuntu释放VMware虚拟磁盘未使用空间

Ubuntu释放VMware虚拟磁盘未使用空间

By: Ailson Jack Date: 2023.08.26 个人博客&#xff1a;http://www.only2fire.com/ 本文在我博客的地址是&#xff1a;http://www.only2fire.com/archives/152.html&#xff0c;排版更好&#xff0c;便于学习&#xff0c;也可以去我博客逛逛&#xff0c;兴许有你想要的内容呢。…
阅读更多...
C++通过JNI调用JAVA方法返回ArrayList对象

C++通过JNI调用JAVA方法返回ArrayList对象

运行效果: JAVA实现: 获取系统已安装应用列表并返回List<String>对象 //使用系统API获取安装包列表public List<String> getAppList(MainActivity act) {List<String> packages = new ArrayList<String>();try {//取包信息列表List<PackageInf…
阅读更多...
Unity项目如何上传Gitee仓库

Unity项目如何上传Gitee仓库

前言 最近Unity项目比较多&#xff0c;我都是把Unity项目上传到Gitee中去&#xff0c;GitHub的话我用的少&#xff0c;可能我还是更喜欢Gitee吧&#xff0c;毕竟Gitee仓库用起来更加方便&#xff0c;注意Unity项目上传时最佳的方式是把 Asste ProjectSetting 两个文件夹上传上…
阅读更多...
蓝牙耳机语音信号处理之ENC算法

蓝牙耳机语音信号处理之ENC算法

+他V hezkz17进数字音频系统研究开发交流答疑群(课题组) 1 什么是单麦谱减法降噪？ 单麦谱减法降噪是一种音频信号处理技术，用于在单声道录音中减少噪音的方法。它基于频域分析和减法混叠原理。首先，通过将音频信号转换为频域表示（如快速傅立叶变换），可以将音频信号分解…
阅读更多...
二叉树、红黑树、B树、B+树

二叉树、红黑树、B树、B+树

二叉树 一棵二叉树是结点的一个有限集合&#xff0c;该集合或者为空&#xff0c;或者是由一个根节点加上两棵别称为左子树和右子树的二叉树组成。 二叉树的特点&#xff1a; 每个结点最多有两棵子树&#xff0c;即二叉树不存在度大于2的结点。二叉树的子树有左右之分&#xf…
阅读更多...
ant design自定义展开折叠查看子项和点击行查看详情

ant design自定义展开折叠查看子项和点击行查看详情

实现思路&#xff1a;通过配置rowSelection&#xff0c;列表项是否可选择来实现。 页面内容&#xff1a; <a-table :dataSource"integrationBonds" :columns"columns" :customRow"customintegrationBondsRow":pagination"{hideOnSingle…
阅读更多...
使用Pytorch和OpenCV实现视频人脸替换

使用Pytorch和OpenCV实现视频人脸替换

“DeepFaceLab”项目已经发布了很长时间了&#xff0c;作为研究的目的&#xff0c;本文将介绍他的原理&#xff0c;并使用Pytorch和OpenCV创建一个简化版本。 本文将分成3个部分&#xff0c;第一部分从两个视频中提取人脸并构建标准人脸数据集。第二部分使用数据集与神经网络一…
阅读更多...
【C++心愿便利店】No.3---内联函数、auto、范围for、nullptr

【C++心愿便利店】No.3---内联函数、auto、范围for、nullptr

文章目录 前言&#x1f31f;一、内联函数&#x1f30f;1.1.面试题&#x1f30f;1.2.内联函数概念&#x1f30f;1.3.内联函数特性 &#x1f31f;二、auto关键字&#x1f30f;2.1.类型别名思考&#x1f30f;2.2.auto简介&#x1f30f;2.3.auto的使用细节&#x1f30f;2.4.auto不能…
阅读更多...
【matlab利用shp文件制作mask白化文件】

【matlab利用shp文件制作mask白化文件】

matlab白化文件 mask文件的作用matlab制作mask文件mask结果 mask文件的作用 地理信息绘图中的 “mask” 通常指的是遮罩或掩膜&#xff0c;用于在地图或图像上隐藏、高亮或标记特定区域。 数据可视化&#xff1a; 地理信息绘图 mask 可以用于突出显示特定地理区域&#xff0c;使…
阅读更多...
【水平垂直居中布局】CSS实现水平垂直居中的5种方法（附源码）

【水平垂直居中布局】CSS实现水平垂直居中的5种方法（附源码）

文章目录 写在前面涉及知识点1、子绝对定位父相对定位&#xff0c;子节点设置位移实现1.1效果1.2实现源码 2、子绝对定位父相对定位&#xff0c;子节点设置上下边距2.1 效果2.2 实现源码 3、利用flex布局实现3.1 效果3.2 实现源码 4、利用行高和文本水平居中设置4.1 效果4.2 实…
阅读更多...
中国移动秋招攻略，网申测评和面试

中国移动秋招攻略，网申测评和面试

中国移动秋招简介 按照往年的惯例来看&#xff0c;移动会在每年的8月份发布相关秋招信息&#xff0c;紧接着考生并进行网申&#xff0c;面试的时间跨度也非常的长&#xff0c;大概是9~12月份。整个招聘流程&#xff0c;包括投递简历网申&#xff0c;笔试测评&#xff0c;面试录…
阅读更多...
[Linux]进程概念

[Linux]进程概念

[Linux]进程概念 文章目录 [Linux]进程概念进程的定义进程和程序的关系Linux下查看进程Linux下通过系统调用获取进程标示符Linux下通过系统调用创建进程-fork函数使用 进程的定义 进程是程序的一个执行实例&#xff0c;是担当分配系统资源&#xff08;CPU时间&#xff0c;内存…
阅读更多...
HAProxy+nginx搭建负载均衡群集

HAProxy+nginx搭建负载均衡群集

目录 一、常见的Web集群调度器 二、HAProxy群集介绍 1、Haproxy的特性 : 2、Haproxy常用的调度算法 ① 轮询调度&#xff08;Round Robin&#xff09; ② 最小连接数&#xff08;Least Connections&#xff09; ③ 基于来源访问调度算法&#xff08;Source Hashing&am…
阅读更多...
Java“牵手”天猫店铺所有商品API接口数据，通过店铺ID获取整店商品详情数据，天猫API申请指南

Java“牵手”天猫店铺所有商品API接口数据，通过店铺ID获取整店商品详情数据，天猫API申请指南

天猫商城是一个网上购物平台&#xff0c;售卖各类商品&#xff0c;包括服装、鞋类、家居用品、美妆产品、电子产品等。天猫商品详情可以帮助消费者更好的了解宝贝信息&#xff0c;从而做出购买决策。同时&#xff0c;消费者也可以通过商品详情了解其他买家对宝贝的评价&#xf…
阅读更多...
神经网络入门

神经网络入门

前言 本文主要介绍最基础的神经网络&#xff0c;包括其结构&#xff0c;学习方法&#xff0c; C \texttt{C} C 的实现代码。 Python \texttt{Python} Python 的代码可以搜索互联网得到。 前排提示&#xff1a;本人涉及一丁点数学知识。 神经网络的结构 神经网络包括多个层…
阅读更多...
最新文章

Copyright @ 2022~2023