认识SpringCloud(一) 注册中心Eureka

news2024/11/20 12:37:27

  Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理。在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。

如何使用

  在springboot项目中使用Eureka十分简单，只需要以下几步就可以启动一个server了。
  pom文件中添加依赖：

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

  修改yml文件

server:
  port: 8610

spring:
  application:
    name: datax-eureka

eureka:
  instance:
    lease-renewal-interval-in-seconds: 20
    lease-expiration-duration-in-seconds: 60
    # 设置使用IP
    prefer-ip-address: true
    # 设置外网IP号
    ip-address: localhost
  client:
    register-with-eureka: false
    fetch-registry: false
    instance-info-replication-interval-seconds: 40
    service-url:
      defaultZone: http://${eureka.instance.ip-address}:${server.port}/eureka/

  启动类添加@EnableEurekaServer注解


@EnableEurekaServer
@SpringBootApplication
public class DemoEurekaApplication {

    public static void main(String[] args) {

        SpringApplication.run(DataxEurekaApplication.class, args);
    }

}

  浏览器访问http://127.0.0.1:8610/可以看到一个简单的EurekaServer已经搭建成功了
在这里插入图片描述
  过了一段时间出现了提示：EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY’RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.
   出现这个错误的原因是因为Eureka进入自我保护模式

自我保护模式

  默认情况下，如果在15分钟内超过85%的客户端节点都没有正常的心跳，那么Eureka就认为客户端与注册中心出现了网络故障(比如网络故障或频繁的启动关闭客户端)，Eureka Server自动进入自我保护模式。不再剔除任何服务，当网络故障恢复后，该节点自动退出自我保护模式。

  可以使用eureka.server.enable-self-preservation=false来禁用自我保护模式，生产环境不建议这么做。

  还有一种方式是把阈值因子eureka.server.renewalPercentThreshold调低，默认是0.85，如果阈值比最小值大，则自我保护模式开启

eureka:
  server:
    enable-self-preservation: true
    #eureka server清理无效节点的时间间隔，默认60000毫秒，即60秒
    eviction-interval-timer-in-ms: 60000
    #阈值更新的时间间隔，单位为毫秒，默认为15 * 60 * 1000
    renewal-threshold-update-interval-ms: 15 * 60 * 1000
    #阈值因子，默认是0.85，如果阈值比最小值大，则自我保护模式开启
    renewal-percent-threshold: 0.85
    #清理任务程序被唤醒的时间间隔，清理过期的增量信息，单位为毫秒，默认为30 * 1000
    delta-retention-timer-interval-in-ms: 30000

客户端健康检查

  默认情况下，Eureka使用客户端心跳来确定客户端是否已启动。在成功注册后，Eureka始终宣布应用程序处于“UP”状态，这就引发一个问题，客户端虽然是启动的，但是可能由于某种原因（比如数据库宕机）无法提供正确的服务。为了解决这个问题，需要引入健康检查机制。

  前置条件：启动一个server（本文端口为8610），下面开始创建client（端口为8611）

  Eureka的健康检查依赖于Springboot-actuator的/health，需要在pom.xml中引入​​spring-boot-starter-actuator​​模块的依赖

<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-actuator</artifactId>
    </dependency>
</dependencies>

   在eureka客户端中的​​application.properties​​或yml文件中配置:​​eureka.client.healthcheck.enabled=true​​,就可以改变eureka server对客户端健康检测的方式,改用actuator的/actuator/health端点来检测。

# 注册中心配置
eureka:
  instance:
    lease-renewal-interval-in-seconds: 20
    # 设置使用IP
    prefer-ip-address: true
    # 设置外网IP号
    ip-address: localhost
  client:
    healthcheck:
      enabled: true
    register-with-eureka: true
    fetch-registry: true
    instance-info-replication-interval-seconds: 30
    registry-fetch-interval-seconds: 3
    service-url:
      defaultZone: http://localhost:8610/eureka

# 暴露监控端点
management:
  endpoints:
    web:
      exposure:
        include: '*'
  endpoint:
    health:
      show-details: always

  新建HealthIndicatorImpl 并实现HealthIndicator，自定义监控的逻辑。

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.stereotype.Component;

@Component
public class HealthIndicatorImpl implements HealthIndicator {

    private boolean up = true;

    @Override
    public Health health() {
        if (up) {
        
            return new Health.Builder().withDetail("status", "up").up().build();  //自定义监控内容
        } else {
    	
            return new Health.Builder().withDetail("error", "client is down").down().build();
        }
    }

    public boolean isUp() {
        return up;
    }

    public void setUp(boolean up) {
        this.up = up;
    }
}

  在启动类上添加注解@EnableDiscoveryClient 或@EnableEurekaClient（@EnableEurekaClient只适用于Eureka作为注册中心，@EnableDiscoveryClient 可以是其他注册中心）

  客户端启动后，sever端显示客户端服务状态为UP
在这里插入图片描述
   访问http://127.0.0.1:8611/actuator/health 查看客户端状态

{
  "status": "UP",
  "components": {
    "configServer": {
      "status": "UP",
      "details": {
        "repositories": [
          {
            "name": "app",
            "profiles": [
              "default"
            ],
            "label": null
          }
        ]
      }
    },
    "discoveryComposite": {
      "status": "UP",
      "components": {
        "discoveryClient": {
          "status": "UP",
          "details": {
            "services": [
              "datax-config"
            ]
          }
        },
        "eureka": {
          "description": "Remote status from Eureka server",
          "status": "UP",
          "details": {
            "applications": {
              "DATAX-CONFIG": 1
            }
          }
        }
      }
    },
    "diskSpace": {
      "status": "UP",
      "details": {
        "total": 107373129728,
        "free": 6842404864,
        "threshold": 10485760,
        "exists": true
      }
    },
    "healthIndicatorImpl": {
      "status": "UP",
      "details": {
        "status": "up"
      }
    },
    "hystrix": {
      "status": "UP"
    },
    "ping": {
      "status": "UP"
    },
    "refreshScope": {
      "status": "UP"
    }
  }
}

  为了方便模拟，创建个controller

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HealthController {

    @Autowired
    private HealthIndicatorImpl myHealthChecker;

    @RequestMapping("/up")
    public String up(@RequestParam("up") Boolean up) {
        myHealthChecker.setUp(up);
        return myHealthChecker.isUp() ? "UP" : "DOWN";
    }
}

  访问http://127.0.0.1:8611/up?up=false更改客户端状态， server端可以看到状态由UP变为DOWN了。
在这里插入图片描述

Eureka 工作流程

  1. Eureka Server 启动成功，等待服务端注册
  2. Eureka Client 启动时根据配置的 Eureka Server 地址去注册中心注册服务
  3. Eureka Client 会每 30 秒向 Eureka Server 发送一次心跳，证明客户端服务正常
  4. 当 Eureka Server90 秒内没有收到 Eureka Client 的心跳，注册中心则认为该节点失效，会注销该实例
  5. 单位时间内 Eureka Server 统计到大量的 Eureka Client 没有发送心跳，则认为可能为网络异常，进入自我保护机制，不再剔除没有发送心跳的客户端
  6. 当 Eureka Client 心跳恢复正常后，Eureka Server 自动退出自我保护机制
  7. Eureka Client 定时全量或者增量从注册中心获取服务注册表，并且将获取到的信息缓存在本地
  8. 服务调用时，Eureka Client 会先从本地缓存找寻调取的服务。如果获取不到，先从注册中心刷新注册表，再同步到本地缓存
  9. Eureka Client 获取到目标服务器信息，发起服务调用
    10.Eureka Client 程序关闭时向 Eureka Server 发送取消请求，Eureka Server 将实例从注册表中剔除

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

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

相关文章

（原创）getX+Dio实现Flutter悬浮置顶的页面效果

（原创）getX+Dio实现Flutter悬浮置顶的页面效果

前言 Flutter的开发相对已经比较成熟了&#xff0c;现在市面上不少商业应用也在使用这个技术 老实说&#xff0c;Flutter去实现一些基础的ui界面&#xff0c;效率还是很高的 当然前提是你对它要有一定的了解。 今天就演示一下&#xff0c;如何去实现一个基础悬浮置顶的页面效果…
阅读更多...
OSTrack 中的边界框回归策略

OSTrack 中的边界框回归策略

目录 一、裁剪和标签的设置 二、模型的预测输出的边界框回归 一、裁剪和标签的设置 1、添加偏移量&#xff0c;得到偏移后的边界框 jittered_anno [self._get_jittered_box(a, s) for a in data[s _anno]] 2、以偏移后的边界框为中心&#xff0c;进行裁剪 首先以偏移边界…
阅读更多...
Apache Pulsar入门指南

Apache Pulsar入门指南

1.概述 Apache Pulsar 是灵活的发布-订阅消息系统&#xff08;Flexible Pub/Sub messaging&#xff09;&#xff0c;采用计算与存储分离的架构。雅虎在 2013 年开始开发 Pulsar &#xff0c;于 2016 年首次开源&#xff0c;目前是 Apache 软件基金会的顶级项目。Pulsar 具有支…
阅读更多...
面试官：写一个单例模式

面试官：写一个单例模式

1. 什么是单例模式 了解单例模式之前&#xff0c;我们需要先了解什么是设计模式。 设计模式是一种抽象的编程思想&#xff0c;不局限于编程语言&#xff0c;简单来说&#xff0c;就是一些大佬程序猿针对一些典型的场景&#xff0c;给出一些典型的解决方案&#xff0c;只要按照这…
阅读更多...
04-CSS3-渐变色、2D转换、3D转换

04-CSS3-渐变色、2D转换、3D转换

一、渐变色 CSS渐变色&#xff08;Gradient&#xff09;是指在元素背景中使用两种或多种不同的颜色进行过渡&#xff0c;超过两个颜色可以形成更为细腻的渐变效果。常见的CSS渐变色有线性渐变和径向渐变。 1. 线性渐变&#xff1a;Linear Gradients 向下/向上/向左/向右/对角…
阅读更多...
SVN 修改URL路径-使用重新定位(relocate)命令和找不到问题解决

SVN 修改URL路径-使用重新定位(relocate)命令和找不到问题解决

当svn服务器url发生变更,又不想在本地重新进行checkout操作,这时候可以使用svn relocate命令进行url的重新定位; 在windows下以TortoiseSVN为例,在仓库文件夹上右键,TortoiseSVN-(重新定位)relocate, 1、Windows TortoiseSVN客户端: 在工作复本的根目录上右键->TortoiseSV…
阅读更多...
DOUBLETROUBLE: 1

DOUBLETROUBLE: 1

文章目录 DOUBLETROUBLE: 1实战演练一、前期准备1、相关信息 二、信息收集1、nmap探测目标靶机端口2、扫描目标网址目录3、访问网站&#xff0c;发现secret下有个图片4、将图片下载5、查看图片所含内容6、破解密码并查看7、登陆邮箱8、创建反弹shell9、上传反弹shell10、监听11…
阅读更多...
Jeecg-Boot 未授权SQL注入漏洞（CVE-2023-1454）

Jeecg-Boot 未授权SQL注入漏洞（CVE-2023-1454）

本文转载于&#xff1a;https://blog.csdn.net/qq_27536045/article/details/129944987 环境搭建 JDK: 1.8 (小于11) Maven: 3.5 MySql: 5.7 Redis: 3.2 Node Js: 10.0 Npm: 5.6.0 Yarn: 1.21.1 下载源码 后端源码 https://github.com/jeecgboot/jeecg-boot/tree/v…
阅读更多...
MongoDB安装教程—Ubuntu

MongoDB安装教程—Ubuntu

为啥用MongoDB&#xff0c;问就是客户要求。 为啥用Ubuntu&#xff0c;问就是客户只有Ubuntu的机器。 0. 环境 操作系统&#xff1a; Ubuntu 22.04.1 LTS (GNU/Linux 5.19.0-41-generic x86_64) 不同版本系统差异不同&#xff0c;其他版本系统未测试。 1. 安装 1.1 包管理公…
阅读更多...
深入探索SDL游戏开发

深入探索SDL游戏开发

前言 欢迎来到小K的SDL专栏第二小节&#xff0c;本节将为大家带来基本窗口构成、渲染器、基本图形绘制、贴图、事件处理等的详细讲解&#xff0c;看完后希望对你有收获 文章目录 前言一、简单窗口二、渲染器三、基本图形绘制1、点2、线3、矩形4、圆和椭圆 四、贴图五、事件处理…
阅读更多...
XR交互技术趋势：6DoF追踪、手势识别、眼动跟踪……

XR交互技术趋势：6DoF追踪、手势识别、眼动跟踪……

XR交互技术提供了用户与虚拟环境进行交互的方式和手段&#xff0c;而实时云渲染则提供了真三维、可交互、高沉浸的图形渲染和计算能力。结合这两者&#xff0c;用户可以通过XR设备获得更真实、更沉浸的虚拟体验&#xff0c;同时享受到优质的图形效果和流畅的交互响应。本篇文章…
阅读更多...
关于开发中对端口(port)的几点理解

关于开发中对端口(port)的几点理解

一、服务端的端口是固定的&#xff0c;客户端的端口是随机的 客户端端口是随机的&#xff0c;比如访问百度&#xff0c;系统为浏览器分配了个端口1024。过一会重开电脑&#xff0c;访问了新浪&#xff0c;可能还是用1024端口&#xff0c;我不关浏览器&#xff0c;还要再开一个浏…
阅读更多...
CenterFusion数据处理函数__getitem__()解析

CenterFusion数据处理函数__getitem__()解析

CenterFusion数据处理函数__getitem__解析 1. 图像数据处理1.1 通过利用nuScence_COCO实例化对象获取图像以及相关数据的信息1.2 获取图像数据增强的相关参数&#xff1a;中心点c&#xff0c;尺度scale&#xff0c;旋转rotia和翻转flip1.3 根据生成的参数生成仿射矩阵来对图像进…
阅读更多...
spring boot 集成 swagger3

spring boot 集成 swagger3

Swagger 3是一种开源的API描述工具&#xff0c;它可以帮助开发人员设计、构建、文档化和测试API。Swagger 3支持多种编程语言和框架&#xff0c;包括Java、Node.js、Python、Ruby等&#xff0c;并提供了许多集成工具和插件&#xff0c;例如Postman、Apigee等。 Swagger 3使用Op…
阅读更多...
北京君正应用案例：双镜头双画面乔安枪球联动摄像头

北京君正应用案例：双镜头双画面乔安枪球联动摄像头

你是否遇到过这种问题&#xff1f; 既要看店铺又要看柜台 既要看车又要看大门 雷龙发展提供原厂技术支持&#xff0c;并提供君正集成电路完整解决方案&#xff0c;大大降低你的开发难度及开发时间。 单镜头摄像头一台不够广 出现监控盲区&#xff0c;让小偷有可趁之机 只能装两…
阅读更多...
sql语句---left join or right join

sql语句---left join or right join

1068. 产品销售分析 I 销售表 Sales&#xff1a; -------------------- | Column Name | Type | -------------------- | sale_id | int | | product_id | int | | year | int | | quantity | int | | price | int | -------------------- (s…
阅读更多...
JS文字转语音技术实现

JS文字转语音技术实现

前言 最近在做排队叫号系统&#xff0c;涉及到文字转语音播报&#xff0c;因此总结了几种前端文字转语音发声的方法。 一、Web Speech API h5新提供的一个原生语音识别技术的API&#xff0c;可以将文本转成语音并播放。 作为官方的api&#xff0c;实现的效果是比较符合理想的…
阅读更多...
Windows平台下用例图中包含(include)、扩展(extend)和泛化(generalization）介绍

Windows平台下用例图中包含(include)、扩展(extend)和泛化(generalization）介绍

我是荔园微风&#xff0c;作为一名在IT界整整25年的老兵&#xff0c;今天总结一下Windows平台下用例图中包含(include)、扩展(extend)和泛化(generalization&#xff09;介绍。 用例图是解决用户需求的图&#xff0c;画好用例图一定要理清用例之间的关系。用例之间有三种关系&…
阅读更多...
LabVIEWCompactRIO 开发指南33 测试和调试LabVIEW FPGA代码

LabVIEWCompactRIO 开发指南33 测试和调试LabVIEW FPGA代码

LabVIEWCompactRIO 开发指南33 测试和调试LabVIEW FPGA代码 如前所述&#xff0c;应在仿真模式下开发LabVIEWFPGA VI&#xff0c;以快速迭代设计并避免冗长的编译时间。当需要测试和调试VI时&#xff0c;可以保持仿真模式或利用其他几个选项。应该根据功能验证与性能的要求以…
阅读更多...
【LeetCode】 复制带随机指针的链表

【LeetCode】 复制带随机指针的链表

Leetcode 138.复制带随机指针的链表 文章目录 题目描述解题思路运行代码 题目描述 给你一个长度为 n 的链表&#xff0c;每个节点包含一个额外增加的随机指针 random &#xff0c;该指针可以指向链表中的任何节点或空节点。 构造这个链表的 深拷贝。 深拷贝应该正好由 n 个 全…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023