服务注册中心 Eureka

news2024/11/24 19:48:59

服务注册中心 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” 字符串。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【Apollo学习笔记】——规划模块TASK之PATH_REUSE_DECIDER

【Apollo学习笔记】——规划模块TASK之PATH_REUSE_DECIDER

文章目录 前言PATH_REUSE_DECIDER功能简介PATH_REUSE_DECIDER相关配置PATH_REUSE_DECIDER总体流程PATH_REUSE_DECIDER相关子函数IsCollisionFreeTrimHistoryPathIsIgnoredBlockingObstacle和GetBlockingObstacleS Else参考 前言 在Apollo星火计划学习笔记——Apollo路径规划算…
阅读更多...
1克硬件变化+99%软件能力，点燃XR行业第二时代之战

1克硬件变化+99%软件能力，点燃XR行业第二时代之战

夕小瑶科技说 原创 作者 | 卖萌酱 你的下一代手表&#xff0c;可以是没有手表&#xff01;即将在8月26日发布空间计算新品的Rokid&#xff0c;近日发表路透视频&#xff1a;AR眼镜使用场景下&#xff0c;抬起手腕就能出现虚拟手表表盘&#xff0c;握一下拳即切换到天气模式。…
阅读更多...
0006Java程序设计-jsp婚恋交友网设计与实现

0006Java程序设计-jsp婚恋交友网设计与实现

摘 要 在线交友是互联网发展的必然产物&#xff0c;它改变了人们的网络交往形态&#xff0c;使得人们的即时通信变得更加的直观和亲切&#xff0c;并且具有良好的发展趋势。 婚恋交友网站我们使用 Microsoft公司的JSP开发工具&#xff0c;利用其提供的各种面向对象的开发工具…
阅读更多...
武汉凯迪正大—变比组别测试仪

武汉凯迪正大—变比组别测试仪

一、概述 在电力变压器的半成品、成品生产过程中&#xff0c;新安装的变压器投入运行之前以及根据国家电力部的预防性试验规程中&#xff0c;要求变压器进行匝数比或电压比测试。传统的变比电桥操作繁琐&#xff0c;读数不直观&#xff0c;且要进行必要的换算&#xff0c;测试时…
阅读更多...
关于 大屏项目的参考

关于 大屏项目的参考

1、自适应组件 &#xff1a; v-scale-screen https://huaweicloud.csdn.net/638eec6cdacf622b8df8dc59.html 2、参考项目&#xff1a; https://zhuanlan.zhihu.com/p/634382389
阅读更多...
leetcode 714. 买卖股票的最佳时机含手续费

leetcode 714. 买卖股票的最佳时机含手续费

2023.8.22 本题和买卖股票的最佳时机II 几乎一样&#xff0c;就是增加了一个手续费&#xff0c;需要在卖出股票的时候减去手续费fee即可。 代码如下&#xff1a; class Solution { public:int maxProfit(vector<int>& prices, int fee) {vector<vector<int&g…
阅读更多...
第十六课、利用 EnigmaVB 打包 Qt 应用程序

第十六课、利用 EnigmaVB 打包 Qt 应用程序

功能描述&#xff1a;详细介绍如何利用 EnigmaVB 打包 Qt 应用程序&#xff0c;从 EnigmaVB 软件下载、安装&#xff0c;到如何使用&#xff0c;一步步教你走进 EnigmaVB 软件&#xff0c;最后还介绍了一款针对 Enigma Virtual Box 制作的单文件程序进行解包的工具 EnigmaVBUnp…
阅读更多...
利用全志H616 MangoPi MQ Quad部署一个网络摄像头

利用全志H616 MangoPi MQ Quad部署一个网络摄像头

本文男二号海康威视720p USB摄像头出场&#xff0c;尊容如下&#xff1a; SBC需连接网络&#xff1a; rootorangepizero2:~# ifconfig wlan0: flags4163< UP,BROADCAST,RUNNING,MULTICAST > mtu 1500inet 192.168.99.217 netmask 255.255.255.0 broadcast 192.168.99…
阅读更多...
诺依框架ruoyi.js添加默认当年日期范围

诺依框架ruoyi.js添加默认当年日期范围

ruoyi.js添加方法 // 默认当年日期范围如&#xff1a;2023-01-01到2023-08-22&#xff08;至今&#xff09; export function defaultYearDate(data) {// this.dateDefaultShow new Date();// this.dateDefaultShow.setMonth(new Date().getMonth() - 1);const end new Date…
阅读更多...
Twinmotion电脑配置要求，如何低成本高效流畅运行Twinmotion

Twinmotion电脑配置要求，如何低成本高效流畅运行Twinmotion

Twinmotion是一款专门面向建筑、工程、城市规划和景观园林领域而设计的实时可视化渲染软件。与传统较为漫长的渲染过程相比&#xff0c;它可以在几秒钟内轻松制作高品质的图像、全景图、规格图或360VR视频文件。 并且&#xff0c;作为市面上备受欢迎的交互式实时可视化软件&am…
阅读更多...
mysql 8.0 窗口函数 之 前后函数、收尾函数、其它函数 与 sql server （2017以后支持） 一样

mysql 8.0 窗口函数 之 前后函数、收尾函数、其它函数 与 sql server （2017以后支持） 一样

前后函数 LAG(expr,n) 返回当前行的前n行的expr的值LEAD(expr,n) 返回当前行的后n行的expr的值 收尾函数 FIRST_VALUE(expr) 返回第一个expr的值LAST_VALUE(expr) 返回最后一个expr的值 其它函数 1.NTH_Value(expr,n) 返回第N个expr的值 2. NTILE(n) 将分区中的有序数据分为…
阅读更多...
Java课题笔记~ MyBatis分页查询插件

Java课题笔记~ MyBatis分页查询插件

1.添加依赖 <!-- https://mvnrepository.com/artifact/com.github.pagehelper/pagehelper --> <dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper</artifactId><version>5.2.0</version> </de…
阅读更多...
三种插槽的基本使用

三种插槽的基本使用

为什么要用插槽&#xff1f; 为了实现父组件每次使用组件时&#xff0c;有不一样的呈现 设置的时候比我们props传值更简单 子组件引用时可以写更加复杂的结构 简单地说就是你自定义的组件在被父组件引用时&#xff0c;本身是有一部分是给你开放的&#xff0c;里面是可以添加其他…
阅读更多...
Lua之Lua源文件批量转换为luac字节码文件

Lua之Lua源文件批量转换为luac字节码文件

准备的工具：luac.exe CSDNhttps://mp.csdn.net/mp_download/manage/download/UpDetailed Unity版: using System; using System.Collections; using System.Collections.Generic; using System.IO; using UnityEditor; using UnityEngine;public static class Batch_LuaToLu…
阅读更多...
基于Jenkins自动打包并部署Tomcat环境-------从小白到大神之路之学习运维第85天

基于Jenkins自动打包并部署Tomcat环境-------从小白到大神之路之学习运维第85天

第四阶段提升 时 间&#xff1a;2023年8月22日 参加人&#xff1a;全班人员 内 容&#xff1a; 基于Jenkins自动打包并部署Tomcat环境 目录 一、传统网站部署的流程 &#xff08;一&#xff09;传统代码上线的过程 &#xff08;二&#xff09;目前主流网站部署的流程 …
阅读更多...
在mac下，使用Docker安装达梦数据库

在mac下，使用Docker安装达梦数据库

前言&#xff1a;因为业务需要安装达梦数据库 获取官网下载tar包&#xff08;达梦官网的下载页面https://www.dameng.com/list_103.html&#xff09;&#xff0c;或者通过命令 一、下载tar包 命令下载&#xff1a;wget -O dm8_docker.tar -c https://download.dameng.com/eco/…
阅读更多...
matlab将数组值划分为两类

matlab将数组值划分为两类

例如&#xff1a;大于0的处理为1&#xff0c;小于0的处理为-1. 当然&#xff0c;可以选择循环结构和选择结构&#xff0c;但是效率会很低。 这里直接使用逻辑语句完成。 % 不使用循环语句&#xff0c;将数组内值划分为两类 clc; clearvars; a[-0.1422 , -0.0433 , 0.1131 …
阅读更多...
[ MySQL ] — 如何理解索引以及索引的操作

[ MySQL ] — 如何理解索引以及索引的操作

目录 初识索引 认识磁盘 MySQL与存储 了解磁盘 mysql与磁盘的交互 索引的理解 理解单个Page 理解多个Page 页目录 单页情况 多页情况 索引结构 - B树 聚簇索引 和 非聚簇索引 索引操作 创建主键索引 唯一索引的创建 ​编辑 普通索引的创建 全文索引的创建 查询…
阅读更多...
outlook等客户端报错：-ERR Login fail. Please using weixin token to login

outlook等客户端报错：-ERR Login fail. Please using weixin token to login

使用outlook配置腾讯邮箱后&#xff0c;无法收取邮件&#xff0c;点击接收/发送所有文件夹&#xff0c; 提示报错&#xff1a; 任务“testqq.com - 正在接收”报告了错误(0x800CCC92):“电子邮件服务器拒绝您登录。请在“帐户设置”中验证此帐户的用户名及密码。 响应服务器:…
阅读更多...
软件配置安装（破解）--- jdk下载配置

软件配置安装（破解）--- jdk下载配置

下载jdk 如果有oracle账号的话直接登录下载你想要的版本 不然可以尝试镜像站 HUAWEI镜像&#xff1a;https://repo.huaweicloud.com/java/jdk/ 安装 配置&#xff08;细节&#xff09; 这里的JAVA_HOME就是java的家&#xff0c;也就是解压(或安装)之后的java的目录&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023