洛阳做网站哪家专业/产品网络推广怎样做

洛阳做网站哪家专业,产品网络推广怎样做,小程序定制开发中心,香港代理服务器ip免费从零构建高可用 Eureka 集群 | Spring Cloud 微服务架构深度实践指南 本文核心内容基于《Spring Cloud 微服务架构开发》第1版整理,结合生产级实践经验优化 实验环境:IntelliJ IDEA 2024 | JDK 1.8| Spring Boot 2.1.7.RELEASE | Spring Cloud Greenwich…

从零构建高可用 Eureka 集群 | Spring Cloud 微服务架构深度实践指南

本文核心内容基于《Spring Cloud 微服务架构开发》第1版整理,结合生产级实践经验优化
实验环境:IntelliJ IDEA 2024 | JDK 1.8| Spring Boot 2.1.7.RELEASE | Spring Cloud Greenwich.SR2

项目源码:本文完整示例代码已开源至 GitHub,建议结合实践阅读
🔗 https://github.com/hongmengchen/spring-cloud-eureka-ha-demo


前言:为什么需要高可用Eureka集群?

在微服务架构中,注册中心是服务发现与治理的核心枢纽。单节点Eureka Server存在单点故障风险,一旦宕机将导致整个系统服务发现失效。高可用集群通过多节点互备,实现服务注册表同步与故障自动转移,保障系统99.99%的可用性

本文是《从零到一!Spring Cloud Eureka 微服务注册中心手把手搭建指南》的进阶篇,将带领读者完成以下目标:

  1. 集群架构设计:基于CAP理论(一致性、可用性、分区容错性)选择AP模式,确保网络波动时仍可提供服务发现。
  2. 实战搭建:通过双节点互注册实现数据同步,结合Hosts配置模拟多服务器环境。
  3. 全链路改造:覆盖服务提供者、消费者的集群适配,并验证故障切换能力。

实施路线图

基本流程:

  1. 系统环境准备(Hosts配置)
  2. Eureka Server 双节点改造
  3. 服务提供者集群适配
  4. 改造服务消费者
  5. 测试运行

1. 系统环境准备(Hosts配置)

作用:通过域名映射实现本地多节点模拟

以 Windows 系统为例,如果要构建集群,需要修改 hosts 文件,为其添加主机名的映射。

Windows系统操作指南

  1. 以管理员身份运行记事本
  2. 打开 C:\Windows\System32\drivers\etc\hosts
  3. 添加以下映射规则:
# Eureka 集群节点映射
127.0.0.1 server1  # 主节点域名
127.0.0.1 server2  # 备用节点域名

image-20250327172416199

image-20250327172958058

在修改 hosts 文件时,部分同学可能会遇到无法修改的问题,我另写了一篇博客以解决大家的问题:Windows 系统 hosts 文件无法保存?三步搞定权限设置!

建议:大家在修改 hosts 文件权限之后,建议使用完再改会来,也是为了安全考虑嗷

关键验证命令

ping server1  # 应返回127.0.0.1
ping server2  # 应返回127.0.0.1

2. Eureka Server 双节点改造

核心逻辑:节点间互相注册形成环形依赖

按照搭建 eureka-server 的方式,再搭建一个名为 eureka-server-another 的 Eureka Server。

eureka-server-another 的 application.yml 配置文件内容如下:

节点2配置(server2:7009)

server:port: 7009
spring:application:name: eurake-server-another
eureka:client:fetch-registry: falseregister-with-eureka: falseservice-url:defaultZone: http://server1:7000/eureka/  # 指向节点1instance:hostname: server2 # 必须与Hosts配置一致

创建项目每次都差不多

image-20250327174004712

接下来就是补齐这个初创项目的框架

  1. 补充 pom.xml
  2. 添加目录结构
  3. 完善配置文件 application.yml
  4. 写上启动类
  1. eureka-server-another 和 eureka-server 一样都是 Eureka Server,因此 pom.xml 文件内容也是一样的,大家复制粘贴过来就行,记得点击更新

image-20250327174712214

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!-- 父项目 --><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.7.RELEASE</version><relativePath/></parent><!-- 基本信息 --><groupId>cn.hmck</groupId><artifactId>eureka-server-another</artifactId><version>1.0-SNAPSHOT</version><!-- 属性 --><properties><!-- jdk版本 --><java.version>1.8</java.version><!-- spring-cloud版本 --><spring-cloud.version>Greenwich.SR2</spring-cloud.version><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><!-- 依赖 --><dependencies><!-- spring-boot-starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><!-- spring-boot-starter-test --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!-- spring-cloud-starter-netflix-eureka-server --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies><!-- spring-cloud依赖管理 --><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><!-- 构建 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
  1. 添加目录结构和之前也是一样的

PixPin_2025-03-27_17-49-22

  1. 接着就是补充 application.yml 配置文件

image-20250327175308942

  1. 最后就是写上启动类 EurekaServerApplication.java

新项目的启动类命名与之前一样或者不一样都可以

注意:启动类外层必须加上一个包名,否则会报错无法运行,这也是 Spring Cloud 默认规则

image-20250327180043288

这部分代码和之前依然没什么区别,可以直接复制粘贴

package cn.hmck.eurekaserveranother;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication.class, args);}}

修改项目 eureka-server 的全局配置文件 application.yml。

注意哦!这里是指修改一开始的 eureka-server 项目

eureka-server 的 application.yml 配置文件内容如下:

节点1配置(server1:7000)

server:port: 7000
spring:application:name: eurake-server
eureka:client:fetch-registry: falseregister-with-eureka: falseservice-url:defaultZone: http://server2:7009/eureka/  # 指向节点2instance:hostname: server1 # 必须与Hosts配置一致

关键配置解析

  • fetch-registry: false:Server节点不获取注册表(仅Client需要)
  • register-with-eureka: false:Server节点不自我注册
  • 必须保证:集群节点使用相同的spring.application.name

image-20250327181051949


简单解释一下

image-20250327181523737


3. 服务提供者集群适配

目标:实现服务多实例注册与负载均衡

按照搭建 eureka-provider 的方式,搭建一个名为 eureka-provider-another 的服务提供者。

eureka-provider-another 的 application.yml 配置文件内容如下:

server:port: 7007
spring:application:name: eureka-provider
eureka:client:service-url:defaultZone: http://localhost:7000/eureka/instance:hostname: localhost

为了体现集群,所以我们还需要再搭建一个服务提供者 eureka-provider-another,流程和前面搭建第二个服务器是一样的。并且主要代码和原来的服务提供者 eureka-provider 是一样的。

  1. 创建项目 eureka-provider-another
  2. 补充目录结构、配置文件及启动类
  1. 创建项目 eureka-provider-another

image-20250327182153708

  1. 补充目录结构、配置文件及启动类

pom.xml 文件代码

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!-- 父项目 --><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.7.RELEASE</version><relativePath/></parent><!-- 基本信息 --><groupId>cn.hmck</groupId><artifactId>eureka-provider-another</artifactId><version>1.0-SNAPSHOT</version><!-- 属性 --><properties><!-- jdk版本 --><java.version>1.8</java.version><!-- spring-cloud版本 --><spring-cloud.version>Greenwich.SR2</spring-cloud.version><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></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><version>2.1.7.RELEASE</version><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.1.7.RELEASE</version></dependency></dependencies><!-- spring-cloud依赖管理 --><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><!-- 构建 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
</project>

启动类 EurekaProviderApplication.java 代码

package cn.hmck.eurekaprovider;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication
@EnableEurekaClient
public class EurekaProviderApplication {public static void main(String[] args) {SpringApplication.run(EurekaProviderApplication.class, args);}
}

最终结果展示

image-20250327182746644


4. 改造服务消费者

核心能力:自动故障转移与请求重试

修改项目 eureka-consumer 中的全局配置文件 application.yml。

作为消费者的 eureka-consumer ,我们并没有添加其他的,也没有对其进行修改,代码未作变动。

eureka-consumer 的 application.yml 配置文件内容如下:

server:port: 7002  
spring:application:  name: eureka-consumer	
eureka:client:service-url:defaultZone: http://localhost:7000/eurekainstance:hostname: localhost

5. 启动测试

依次启动两个 Eureka Server、两个服务提供者、一个服务消费者。启动成功后,无论访问哪个 Eureka Server,Eureka Server 的注册实例都是一样的,访问 server1:7000 的页面效果如下图所示。

image-20250327183514510

访问server2:7009的页面效果如下图所示。

image-20250327183538745


Eureka 的常用配置

1. 心跳机制

Eureka 的心跳机制用于客户端(服务提供者)与 Eureka Server 之间的健康状态维护。通过心跳,客户端定期向 Server 发送信号以表明自身存活状态,避免被 Server 自动剔除。

核心配置参数

在服务提供者的 application.yml 中配置以下参数:

eureka:instance:# 心跳间隔时间(默认30秒)lease-renewal-interval-in-seconds: 30# 心跳超时时间(默认90秒)lease-expiration-duration-in-seconds: 90
  • lease-renewal-interval-in-seconds:客户端每隔多少秒向 Eureka Server 发送一次心跳。
  • lease-expiration-duration-in-seconds:如果 Server 在此时间内未收到心跳,则认为实例不可用并剔除注册信息。

工作原理

  1. 客户端启动后向 Server 注册,并开始周期性发送心跳。
  2. Server 接收到心跳后会重置该实例的租约时间。
  3. 若 Server 在 lease-expiration-duration-in-seconds 内未收到心跳,则标记实例为 DOWN 并从注册表中移除。

2. 自我保护机制

Eureka Server 的自我保护机制旨在应对网络分区故障场景。当短时间内丢失大量客户端心跳时,Server 会进入保护模式,保留现有注册信息,避免因网络抖动导致服务被误删。

核心配置参数

在 Eureka Server 的 application.yml 中配置以下参数:

eureka:server:# 启用自我保护机制(默认true)enable-self-preservation: true# 触发保护模式的阈值(默认0.85,即85%心跳丢失)renewal-percent-threshold: 0.85
  • enable-self-preservation:是否启用自我保护机制,生产环境建议保持 true
  • renewal-percent-threshold:触发保护模式的心跳丢失比例阈值(例如 0.85 表示 85% 的心跳未更新时触发)。

工作机制

  1. Server 每分钟统计心跳续约失败的比例。
  2. 若失败比例超过 renewal-percent-threshold,则进入保护模式:
    • 不再剔除任何实例(即使心跳超时)。
    • 在 Eureka 控制台显示警告信息:EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP...
  3. 当心跳恢复正常后,Server 会自动退出保护模式。

配置建议

  • 开发环境:可关闭自我保护机制(enable-self-preservation: false),方便快速发现失效实例。
  • 生产环境:务必启用自我保护机制,避免因网络波动导致服务列表频繁变更。
  • 调试技巧:若发现实例未被剔除,需检查是否因保护模式触发导致,可通过日志或控制台提示确认。

特别说明

本次技术实践文档的整理与验证,部分配置优化方案通过 DeepSeek 的智能辅助工具实现效能提升,在此对技术伙伴的支持表示感谢。

技术无界,协作共生
DeepSeek 智能开发平台


📣 我是鸿·蒙,若有不解之处或发现疏漏,欢迎随时私信交流!
(虽然不一定秒回,但每条消息都会认真看嗷~ (๑•̀ㅂ•́)و✧)

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Redis设计与实现-哨兵

哨兵模式 1、启动并初始化sentinel1.1 初始化服务器1.2 使用Sentinel代码1.3 初始化sentinel状态1.4 初始化sentinel状态的master属性1.5 创建连向主服务器的网络连接 2、获取主服务器信息3、获取从服务器的信息4、向主从服务器发送信息5、接受主从服务器的频道信息6、检测主观…

【大前端系列20】JavaScript核心:项目实战从零构建任务管理系统

JavaScript核心&#xff1a;项目实战从零构建任务管理系统 系列: 「全栈进化&#xff1a;大前端开发完全指南」系列第20篇 核心: 将JavaScript异步编程、事件循环等核心知识应用于实际项目开发 &#x1f4cc; 引言 在前面的文章中&#xff0c;我们深入探讨了JavaScript中的异步…

STM32单片机的桌面宠物机器人(基于HAL库)

效果 基于STM32单片机的桌面宠物机器人 概要 语音模块&#xff1a;ASR PRO&#xff0c;通过天问block软件烧录语音指令 主控芯片&#xff1a;STM32F103C8T6 使用HAL库 屏幕&#xff1a;0.96寸OLED屏&#xff0c;用来显示表情 4个舵机&#xff0c;用来当作四只腿 底部一个面…

计算机视觉初步(环境搭建)

1.anaconda 建议安装在D盘&#xff0c;官网正常安装即可&#xff0c;一般可以安装windows版本 安装成功后&#xff0c;可以在电脑应用里找到&#xff1a; 2.创建虚拟环境 打开anaconda prompt&#xff0c; 可以用conda env list 查看现有的环境&#xff0c;一般打开默认bas…

全局思维与系统思考

最近接到一些需求&#xff0c;1号位希望每个层级的领导者有眼界&#xff0c;胸怀&#xff0c;格局&#xff0c;全局观&#xff0c;这些听起来似乎很抽象&#xff0c;然而它们是每个人、每个团队成长与成功的核心竞争力。那么&#xff0c;如何才能提升这些能力&#xff1f;就像我…

天锐蓝盾终端安全防护——企业终端设备安全管控

从办公室的台式电脑到员工手中的移动终端&#xff0c;这些设备不仅是工作的得力助手&#xff0c;更是企业数据的重要载体。然而&#xff0c;随着终端设备的广泛使用&#xff0c;安全风险也如影随形。硬件设备使用不当、数据随意传输等问题频发&#xff0c;使得企业数据面临着泄…

k8s网络策略

k8s网络策略 k8s网络测试概述查看防火墙策略 k8s网络策略网络访问控制案例&#xff1a;配置k8s网络策略结果验证 k8s网络策略配置示例 k8s网络测试概述 网络策略就是设置防火墙 查看防火墙策略 # 获取当前命名空间下的所有 NetworkPolicy 资源&#xff08;网络策略&#xff0…

leetcode刷题日记——跳跃游戏 II

[ 题目描述 ]&#xff1a; [ 思路 ]&#xff1a; 题目要求在一个一定能达到数组末尾的跳跃数组中(见55题 跳跃游戏)&#xff0c;找出能够跳到末尾的最小次数要求次数最少&#xff0c;那肯定是选取能选步数中最大的数。也就是在当前能够达到的距离中&#xff0c;选择能够达到的…

【Java SE】Java比较器:Comparable、Comparator

目录 1.前言 2.Comaprable接口 2.1 使用细节 2.2 案例演示 3.Comparator接口 3.1 为什么需要Comparator接口 3.2 使用细节 3.3 案例演示 4.Comparable、Comparator对比 1.前言 Java 中的对象&#xff0c;正常情况下&#xff0c;只能进行比较&#xff1a; 或 ! 。不…

(二)创建实例

在这节中&#xff0c; 创建一个实例初始化Vulkan库,指定驱动程序需要使用的应用程序信息 1&#xff0c;要有个实例句柄 VkInstance instance; 2&#xff0c;设置创建Vulkan驱动程序需要的信息&#xff0c; VkInstanceCreateInfo createInfo {}; createInfo.sType VK_STRUCTUR…

高效内存管理:x86-64架构中的分页机制

在 x86-64 架构的世界里&#xff0c;内存分页机制扮演着举足轻重的角色&#xff0c;它就像是一座桥梁&#xff0c;连接着虚拟地址与物理地址。简单来说&#xff0c;内存分页机制就是将线性地址&#xff08;也就是虚拟地址&#xff09;切分成一个个固定大小的页&#xff0c;并把…

23_js面向对象

上次我们讲运动函数&#xff0c;实际开发不会写运动函数。只是讲一下思想。 现在讲一下用原生js去实现轮播图&#xff0c;引入到对象 首先&#xff0c;要明确 面向对象不是语法&#xff0c;是一个思想&#xff0c;是一种编程模式 面向&#xff1a;朝向 面向对象&#xff1a…

torch不能使用cuda的解决方案

遇到了这样的报错&#xff0c;说明 torch不能使用cuda 反思 我频繁地尝试安装不同的 nvdia 驱动&#xff0c;浪费了很多时间。因为我的错误地认为nvidia会自带cuda&#xff0c;其实cuda需要单独安装。 还有我的torch是cpu版本的&#xff0c;即使nvidia cuda安装了&#xff0…

kettle从入门到精通 第九十三课 ETL之kettle kettle 调用web service接口5种方法,一文彻底搞懂

场景&#xff1a;群里有小伙伴向我求助如何调用web service接口&#xff0c;趁着周末时间&#xff0c;给兄弟们搞demo。 1、本次使用的web service服务接口地址是http://ws.webxml.com.cn/WebServices/WeatherWS.asmx?opgetSupportCityDataset&#xff0c; 此接口根据用户输入…

蓝桥杯 14 天 十五届蓝桥杯 数字诗意

static boolean kkk(long x) {if(x1)return true;else {// 初始化xx为1&#xff0c;用于计算2的幂long xx 1;// 循环60次&#xff0c;检查2的幂是否等于xfor (int i 1; i < 60; i) {xx * 2; // 每次将xx乘以2if (xx x) { // 如果xx等于x&#xff0c;说明x是2的幂&#xf…

异常与捕获

1.C 异常概念 异常是一种处理错误的方式&#xff0c;当一个函数发现自己无法处理的错误时就可以抛出异常&#xff0c;让函数的直接或间接的调用者处理这个错误。 throw&#xff1a;当问题出现时&#xff0c;程序会抛出一个异常。这是通过使用 throw 关键字来完成的。catch&am…

Linux进程状态补充(10)

文章目录 前言一、阻塞二、挂起三、运行R四、休眠D五、四个重要概念总结 前言 上篇内容大家看的云里雾里&#xff0c;这实在是正常不过&#xff0c;因为例如 写实拷贝 等一些概念的深层原理我还没有讲解&#xff0c;大家不用紧张&#xff0c;我们继续往下学习就行&#xff01;&…

信息学奥赛一本通 1609:【例 4】Cats Transport | 洛谷 CF311B Cats Transport

【题目链接】 ybt 1609&#xff1a;【例 4】Cats Transport 洛谷 CF311B Cats Transport 【题目考点】 1. 动态规划&#xff1a;斜率优化动规 【解题思路】 解法1&#xff1a;设a点的前缀和 输入的 d d d序列是从 d 2 d_2 d2​到 d n d_n dn​&#xff0c;共n-1个数字。人…

bluecode-20240913_1_数据解码

时间限制&#xff1a;C/C 1000MS&#xff0c;其他语言 2000MS 内存限制&#xff1a;C/C 256MB&#xff0c;其他语言 512MB 难度&#xff1a;困难 数据解码 指定有一段经过编码的二进制数据&#xff0c;数据由0个或多个"编码单元"组成。"编码单元"的编码方式…

接口自动化进阶 —— Pytest全局配置pytest.ini文件详解!

pytest.ini 是 Pytest 的全局配置文件&#xff0c;用于自定义测试运行的行为和规则。通过配置 pytest.ini&#xff0c;可以避免在命令行中重复输入参数&#xff0c;提升测试的效率和一致性。 1. 配置文件的位置和格式 位置&#xff1a;pytest.ini 文件通常放在项目的根目录下。…