【SpringCloud】注册中心 && 服务注册 && 服务发现 && Eureka

【SpringCloud】注册中心 && 服务注册 && 服务发现 && Eureka

文章目录

在这里插入图片描述

Ⅰ. 背景

一、问题描述

上个章节的例子中可以看到,远程调用时,我们的 URL 是写死的:

String url ="http://127.0.0.1:9090/product/"+ orderInfo.getProductId();

当更换机器,或者新增机器时,这个 URL 就需要跟着变更,就需要去通知所有的相关服务去修改。随之而来的就是各个项目的配置文件反复更新,各个项目的频繁部署。这种没有具体意义,但又不得不做的工作,会让人非常痛苦。

二、注册中心

注册中心(Service Registry / Service Discovery Center)是微服务架构中一个核心组件,用来管理和维护服务实例的“地址簿”。它的核心作用是让服务能够动态发现其他服务的位置,而不依赖固定的 IP 或端口

注册中心主要有三种角色:

  • 服务提供者(Server):一次业务中,被其它微服务调用的服务。也就是提供接口给其它微服务。
  • 服务消费者(Client):一次业务中,调用其它微服务的服务。也就是调用其它微服务提供的接口。
  • 服务注册中心(Registry):用于保存 Server 的注册信息,当 Server 节点发生变更时,Registry 会同步变更。服务与注册中心使用一定机制通信,如果注册中心与某服务长时间无法通信,就会注销该实例。

注册中心主要负责两件事:

  1. 服务注册(Service Registration)
    1. 当一个服务实例启动时,它会把自己的信息(服务名、IP、端口、健康状态等)注册到注册中心。
    2. 示例:服务 A 启动 → 向注册中心注册自己为 A:IP:PORT
  2. 服务发现(Service Discovery)
    1. 当一个服务需要调用另一个服务时,它不再去找固定 IP,而是向注册中心查询目标服务的可用实例列表。
    2. 示例:服务 B 需要调用服务 A → 查询注册中心 → 获取 A 的可用实例 → 调用。
  3. 健康检查(Health Check,可选)
    • 注册中心通常会定期检查服务实例的状态,发现异常则剔除,保证服务调用可靠性。
在这里插入图片描述

三、CAP理论

CAP 理论是分布式系统设计中最基础,也是最为关键的理论。

在这里插入图片描述
  • 一致性(Consistency):CAP 理论中的一致性,指的是强一致性,即所有节点在同一时间具有相同的数据。
  • 可用性(Availability):保证每个请求都有响应,但是响应结果可能是旧的。
  • 分区容错性(Partition Tolerance):当出现网络分区后,系统仍然能够对外提供服务。

一个分布式系统不可能同时满足数据一致性,服务可用性和分区容错性这三个基本需求,最多只能同时满足其中的两个。

在分布式系统中,系统间的网络不能 100% 保证健康,服务又必须对外保证服务,因此 Partition Tolerance 不可避免,那就只能在 Consistency 和 Availability 中选择一个,也就是 CP 或者 AP 架构。

  • CP架构: 为了保证分布式系统对外的数据一致性,可能选择不返回任何数据
  • AP架构: 为了保证分布式系统的可用性,即使这个数据不正确

更多参考:https://cloud.tencent.com/developer/article/1860632

四、常见的注册中心

① Zookeeper

Zookeeper 的官方并没有说它是一个注册中心,但是国内 Java 体系大部分的集群环境都是依赖 Zookeeper 来完成注册中心的功能。

② Eureka

Eureka 是 Netflix 开发的基于 REST 的服务发现框架,主要用于服务注册、管理、负载均衡和服务故障转移。

官方声明在 Eureka2.0 版本停止维护,不建议使用。但是 Eureka 是 SpringCloud 服务注册/发现的默认实现,所以目前还是有很多公司在使用。

③ Nacos

Nacos 是 SpringCloudAlibaba 架构中重要的组件,除了服务注册,服务发现功能之外,Nacos 还支持配置管理、流量管理、DNS、动态DNS等多种特性。

CAP对比

ZookeeperEurekaNacos
CAP理论CPAPCP或AP (默认AP)

在分布式环境中,即使拿到一个错误的数据,也胜过无法提供实例信息而造成请求失败要好,比如淘宝双十一、京东618都是谨遵AP原则。

Ⅱ. Eureka介绍

Eureka 是 NetflixOSS 套件中关于服务注册和发现的解决方案。SpringCloud 对 Eureka 进行了集成,并作为优先推荐方案进行宣传,虽然目前 Eureka2.0 已经停止维护,新的微服务架构设计中,也不再建议使用,但是目前依然有大量公司的微服务系统使用 Eureka 作为注册中心。

官方文档:https://github.com/Netflix/eureka/wiki

Eureka主要分为两个部分:

  • EurekaServer 作为注册中心 Server 端,向微服务应用程序提供服务注册、服务发现、健康检查等功能。
  • EurekaClient 服务提供者,服务启动时,会向 EurekaServer 注册自己的信息(IP、端口、服务信息等信息),然后 EurekaServer 会存储这些信息。

通常Eureka-server作为一个独立的微服务!

Ⅲ. 搭建EurekaServer

一、创建Eureka-server子模块

在这里插入图片描述

二、引入eureka-server依赖

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

三、添加maven项目构建插件

<build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

四、完善启动类

给该项目编写一个启动类,并在启动类上添加 @EnableEurekaServer 注解,开启 eureka 注册中心服务。

importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;@EnableEurekaServer@SpringBootApplicationpublicclassEurekaServerApplication{publicstaticvoidmain(String[] args){SpringApplication.run(EurekaServerApplication.class, args);}}

五、编写配置文件

server:port:10010spring:application:name: eureka-server eureka:instance:hostname: localhost client:fetch-registry:false# 表示是否从Eureka Server获取注册信息,默认为true.因为这是一个单点的Eureka Server,不需要同步其他的Eureka Server节点的数据,这里设置为falseregister-with-eureka:false# 表示是否将自己注册到Eureka Server,默认为true.由于当前应用就是Eureka Server,故而设置为false.service-url:# 设置与Eureka Server的地址,查询服务和注册服务都需要依赖这个地址.defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 

六、启动服务

启动服务,访问注册中心:http://127.0.0.1:10010/,可以看到 eureka-server 已经启动成功了。

在这里插入图片描述

Ⅳ. 服务注册

接下来将之前的 product-service 注册到 eureka-server 中。

一、引入eureka-client依赖

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

二、完善配置文件

添加服务名称和 eureka 的地址:

spring:application:name: product-service eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka 

三、启动服务

刷新注册中心:http://127.0.0.1:10010/,可以看到 product-service 已经注册到 eureka 上了:

在这里插入图片描述

Ⅴ. 服务发现

接下来修改 order-service,在远程调用时,从 eureka-server 拉取 product-service 的服务信息,实现服务发现。

一、引入依赖

服务注册和服务发现都封装在 eureka-client 依赖中,所以服务发现时,也是引入 eureka-client 依赖。

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

二、完善配置文件

服务发现也需要知道 eureka 地址,因此配置内容依然与服务注册一致,都是配置 eureka 信息。

spring:application:name: order-service eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka 

三、远程调用

远程调用时,我们需要从 eureka-server 中获取 product-service 的列表(可能存在多个服务),并选择其中一个进行调用。

所有微服务要从注册中心(如 Eureka、Consul、Nacos)拉取服务实例信息,靠的就是DiscoveryClient

@Slf4j@ServicepublicclassOrderService{@AutowiredprivateOrderMapper orderMapper;@ResourceprivateDiscoveryClient discoveryClient;@AutowiredprivateRestTemplate restTemplate;publicOrderInfoselectOrderById(Integer orderId){OrderInfo orderInfo = orderMapper.selectOrderById(orderId);//String url = "http://127.0.0.1:9090/product/"+ orderInfo.getProductId();// 根据应用名称获取服务列表List<ServiceInstance> instances = discoveryClient.getInstances("product-service");// 服务可能有多个, 获取第一个EurekaServiceInstance instance =(EurekaServiceInstance) instances.get(0); log.info(instance.getInstanceId());// 拼接urlString url = instance.getUri()+"/product/"+ orderInfo.getProductId();ProductInfo productInfo = restTemplate.getForObject(url,ProductInfo.class); orderInfo.setProductInfo(productInfo);return orderInfo;}}

四、启动服务

刷新注册中心:http://127.0.0.1:10010/,可以看到 order-service 已经注册到 eureka 上了。

在这里插入图片描述

访问接口:http://127.0.0.1:8080/order/1,可以看到,远程调用也成功了。

Ⅵ. Eureka和Zookeeper区别

Eureka 和 Zookeeper 都是用于服务注册和发现的工具,区别如下:

  1. Eureka 是 Netflix 开源的项目,而 Zookeeper 是 Apache 开源的项目。
  2. Eureka 基于 AP 原则,保证高可用,而 Zookeeper 基于 CP 原则,保证数据一致性。
  3. Eureka 每个节点都是均等的,而 Zookeeper 的节点区分 Leader 和 Follower/Observer,也正因为这个原因,如果 Zookeeper 的 Leader 发生故障时,需要重新选举,选举过程集群会有短暂时间的不可用。
在这里插入图片描述

Read more

【重学MySQL】一文搞懂行级锁 无废话版

👨‍💻程序员三明治:个人主页 🔥 个人专栏: 《设计模式精解》《重学数据结构》 🤞先做到 再看见! 目录 * 行级锁 * Record Lock * Gap Lock * Next-Key Lock * select ... for update有啥用?我不加for update不行吗? * MySQL 是怎么加行级锁的? * 唯一索引(主键索引)等值查询 * 唯一索引(主键索引)范围查询 * 实验一:针对「大于」的范围查询的情况。 * 实验二:针对「大于等于」的范围查询的情况。 * 实验三:针对「小于」的范围查询时,查询条件值的记录「不存在」表中的情况。 * 实验四:针对「小于等于」的范围查询时,查询条件值的记录「存在」表中的情况。

By Ne0inhk
Python ORM神器:SQLAlchemy完全指南

Python ORM神器:SQLAlchemy完全指南

在Python开发中,数据库操作是不可避免的重要环节。直接使用原生SQL虽然灵活,但容易出错且维护困难。SQLAlchemy作为Python中最流行的ORM(对象关系映射)框架,为我们提供了优雅的数据库操作方式。 一、什么是SQLAlchemy? SQLAlchemy是一个功能强大的Python SQL工具包和ORM框架。它提供了完整的数据库抽象层,让我们可以用面向对象的方式操作数据库,而不需要直接编写复杂的SQL语句。 主要特点: * 数据库无关性:支持多种数据库(MySQL、PostgreSQL、SQLite等) * 灵活性:既支持高层ORM,也支持底层SQL表达式 * 高性能:优化的查询执行和连接池管理 * 丰富的功能:事务管理、连接池、迁移等 二、安装SQLAlchemy pip install sqlalchemy 三、核心概念 1. Engine(引擎) Engine是SQLAlchemy与数据库通信的核心组件,负责连接数据库和执行SQL语句。 from sqlalchemy import create_engine # 创建引擎 eng

By Ne0inhk

Rust 全栈开发最好的框架是哪一个?深度对比 Leptos、Yew、Axum 与 Tauri

作者:张大鹏|全栈工程师 / 技术博主 关键词:Rust、全栈开发、Leptos、Yew、Axum、Tauri、WebAssembly 一、前言:Rust 全栈时代已经到来 过去十年,Rust 从系统语言一步步成长为现代开发生态的重要力量。 而现在,Rust 已不再局限于“写系统底层”或“高性能后端”。 它正在成为一种全栈语言—— 既能写后端服务、命令行工具,也能编译成 WebAssembly(WASM) 运行在前端, 甚至能构建跨平台桌面应用。 于是一个问题越来越多地被问到: “Rust 做全栈,哪个框架最好?” 本文将从四大主流框架:Axum、Yew、Leptos、Tauri 出发, 对比它们在性能、生态、易用性、全栈整合能力等方面的表现,帮你找出最值得投入学习的框架。 二、Rust

By Ne0inhk
【感恩支持】一票一星皆厚意,一行一履总关情——Java与PostgreSQL正在Commit这份支持,永不Rollback

【感恩支持】一票一星皆厚意,一行一履总关情——Java与PostgreSQL正在Commit这份支持,永不Rollback

目录 前言 1、回味硝烟 2、感恩助力 3、铭记助力 一、该怎么存储呢 1、PG数据库的设计与实现 2、JAVA后台设计与实现 二、JAVA数据存储实践 1、持久化所有助力 2、助力数据查询 三、助力可视化 1、助力名单展示 2、时空引力分析 四、总结 前言 1、回味硝烟         当时间拨回2026年1月24日零点,2025ZEEKLOG博客之星评选网络投票的硝烟终于在零点投票通道关闭的那一刻缓缓散去。回望这场持续了7天的技术圈"全民公投",恍若一场漫长而激烈的数据库高并发事务——每一位参赛者的票数曲线在屏幕上疯狂跳动,每一次刷新都可能意味着排名的重新排序。这是一场没有硝烟的战争,却充满了计算与决策的张力:有人选择在高并发的高峰期持续拉票,如同优化SQL查询般精准投放;有人在最后时刻发起"秒杀式"冲刺,像极了处理分布式事务时的最后提交。

By Ne0inhk