【Eureka】搭建Eureka Server，实现服务注册和服务发现

2024-09-02 05:12
文章标签 实现 服务 搭建 发现 server eureka 服务注册

本文主要是介绍【Eureka】搭建Eureka Server，实现服务注册和服务发现，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. Eureka介绍

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

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

Eureka主要分为两部分：

  • Eureka Server: 作为注册中心Server端,向微服务应用程序提供服务注册,发现,健康检查等能力.
  • Eureka Client: 服务提供者,服务启动时,会向Eureka Server 注册自己的信息(IP,端口,服务信息等),Eureka Server 会存储这些信息

2. 什么是注册中心

在最初的架构体系中，集群的概念还不那么流行,且机器数量也比较少,此时直接使用DNS+Nginx就可以满足几乎所有服务的发现.相关的注册信息直接配置在Nginx.但是随着微服务的流行与流量的激增机器规模逐渐变大,并且机器会有频繁的上下线行为,这种时候需要运维手动地去维护这个配置信息是一个很麻烦的操作,所以开发者们开始希望有这么一个东西,它能维护一个服务列表,哪个机器上线了哪个机器宕机了,这些信息都会自动更新到服务列表上,客户端拿到这个列表,直接进行服务调用即可这个就是注册中心.

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

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

他们之间的关系以及工作内容,可以通过两个概念来描述:服务注册:服务提供者在启动时,向 Registry注册自身服务,并向 Registry 定期发送心跳汇报存活状态，

  • 服务发现:服务消费者从注册中心查询服务提供者的地址，并通过该地址调用服务提供者的接口.
  • 服务发现的一个重要作用就是提供给服务消费者一个可用的服务列表.

常见的注册中心：

1. Zookeeper：Zookeeper的官方并没有说它是一个注册中心,但是国内Java体系,大部分的集群环境都是依赖Zookeeper来完成注册中心的功能
2. Eureka：Eureka是Netflix开发的基于REST的服务发现框架,主要用于服务注册,管理，负载均衡和服务故障转移.
官方声明在Eureka2.0版本停止维护,不建议使用.但是Eureka是SpringCloud服务注册/发现的默认实现,所以目前还是有很多公司在使用.
3. Nacos：Nacos是Spring Cloud Alibaba架构中重要的组件,除了服务注册,服务发现功能之外,Nacos还支持配置管理,流量管理,DNS.动态DNS等多种特性

3. 搭建Eureka Server

Eureka-server时一个独立的微服务，我们可以通过创建子项目的方式创建，当然也可以单独创建一个独立的项目，作为Eureka-server.

3.1 创建Eureka-server子模块

3.2 引入Rureka-server依赖

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

3.3 项目构建插件

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

3.4 编写配置文件

# Eureka相关配置
# Eureka 服务
server:port: 8761
spring:application:name: eureka-server
eureka:instance:hostname: localhostclient: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/

3.5完善启动类

给该项⽬编写⼀个启动类,并在启动类上添加 @EnableEurekaServer 注解,开启eureka注册中⼼服务

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);}
}

3.6 启动服务

启动服务，访问注册中心：http://localhost:8761/

4. 服务注册

服务注册也就是服务提供方需要来做的事情，我这里实现准备好了两个子项目分别是order-service和product-service，分别表示订单服务和商品服务。并且这里订单服务有查询订单的接口，商品服务有查询商品的接口，并且order-service通过RestTemplate远程调用product-service，根据订单查询订单信息时, 根据订单⾥产品ID, 获取产品的详细信息.

https://www.cnblogs.com/54chensongxia/p/11414923.htmlicon-default.png?t=N7T8https://www.cnblogs.com/54chensongxia/p/11414923.html -- RestTemplate 详细使⽤可参考

现在我的场景下的是谁需要来进行服务注册？也就是服务提供者-被调用的一方：product-service.

接下来我们吧product-service注册到eureka-service中

4.1 引入Eureka-client依赖

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

4.2 完善配置文件

添加服务名称和eureka地址

4.3 启动服务

刷新注册中⼼: http://127.0.0.1:10010/

5. 服务发现

服务发现就是需要从Eureka中获取到对应的服务，在我们的场景中，order-service从eureka-server拉取product-service的服务信息, 实现服务发现。服务发现就是主动调用的一方。

5.1 引入依赖

这里和前面的服务注册引入的依赖一致，都是引入client

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

5.2 完善配置文件

服务发现也需要知道eureka地址, 因此配置内容依然与服务注册⼀致，都是配置eureka信息 
spring:application:name: order-service#Eureka client
eureka:client:service-url:defaultZone: http://127.0.0.1:8761/eureka/

5.3 远程调用

远程调⽤时, 我们需要从eureka-server中获取product-service的列表(可能存在多个服务), 并选择其中⼀个进⾏调⽤。也就是从众多的服务中，选出我们需要的服务，然后使用。 
import com.guan.order.mapper.OrderMapper;
import com.guan.order.model.OrderInfo;
import com.guan.product.model.ProductInfo;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;import java.util.List;@Service
@Slf4j
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Resourceprivate DiscoveryClient discoveryClient;@Autowiredprivate RestTemplate restTemplate;public OrderInfo selectOrderByID(Integer orderID){OrderInfo orderInfo = orderMapper.selectOrderById(orderID);// String url =  "http://127.0.0.1:9090/product/"+ orderInfo.getProductId();// 从Eureka获取服务列表List<ServiceInstance> instances = discoveryClient.getInstances("product-service");String uri = instances.get(0).getUri().toString();String url =  uri + "/product/"+ orderInfo.getProductId();log.info("远程调用url：{}",url);ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);orderInfo.setProductInfo(productInfo);return orderInfo;}
}

需要注意这里使用的是，springframework.cloud.client.discovery包下面的DiscoveryClient。

5.4 启动服务

刷新注册中心：http://localhost:8761/

可以看到order-service已经注册到 eureka上了, 访问接⼝: http://127.0.0.1:8080/order/1
可以看到, 远程调⽤也成功了

6. Eureka和Zookeeper区别

Eureka和Zookeeper都是⽤于服务注册和发现的⼯具,区别如下:
  • Eureka是Netflix开源的项目,而Zookeeper是Apache开源的项目；
  • Eureka基于AP原则,保证高可用,Zookeeper基于CP原则,保证数据一致性
  • Eureka每个节点 都是均等的,Zookeeper的节点区分Leader和Follower 或 Observer,也正因为这个原因,如果Zookeeper的Leader发生故障时,需要重新选举,选举过程集群会有短暂时间的不可用

注：

CAP 三个核心概念：

  1. 一致性 (Consistency)：

    • 所有节点在同一时间看到的数据是一致的。
    • 每次读取都可以读取到最近写入的数据（或写入操作发生的错误）。
    • 换句话说，在所有成功的写操作之后，所有节点都应立即反映出相同的数据。

  2. 可用性 (Availability)：

    • 每个请求都能接收到非错误的响应——尽管它不保证返回最新写入的数据。
    • 系统始终处于运行状态，并且能够响应请求。
    • 换句话说，即使部分节点发生故障，系统仍然能够正常工作。

  3. 分区容错性 (Partition Tolerance)：

    • 系统能够在网络分区（即网络通信中断，节点无法相互通信）的情况下继续运行。
    • 分布式系统中存在网络分区时，仍然能够继续提供一致性和可用性（需要在一致性和可用性之间做权衡）。
    • 系统必须能够处理任意数量的消息丢失或延迟，并保证系统的正常运行。

CAP 定理的核心结论：

在一个分布式系统中，同时满足一致性、可用性和分区容错性这三者是不可能的，只能最多满足其中的两项：

  • CA（一致性 + 可用性）： 系统在网络没有分区的情况下保证一致性和可用性。

    • 例子：传统的关系型数据库（如 MySQL 在单节点配置下），在网络分区出现时，系统无法继续正常工作。

  • CP（一致性 + 分区容错性）： 系统在网络分区的情况下选择一致性，但牺牲了一定的可用性。

    • 例子：Zookeeper、HBase 等系统在网络分区发生时，会拒绝部分请求来维持一致性。

  • AP（可用性 + 分区容错性）： 系统在网络分区的情况下选择可用性，但可能牺牲一致性。

    • 例子：Cassandra、DynamoDB 等系统在网络分区时仍然能处理请求，但不同节点可能返回不同的数据（最终一致性）。

这篇关于【Eureka】搭建Eureka Server，实现服务注册和服务发现的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1129082。

相关文章

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

利用康拓展开将一个排列映射成一个自然数，然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯，先赞后看哦~🎈🎈 🏆 作者简介：景天科技苑 🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。 🏆《博客》：Python全栈，前后端开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi
阅读更多...
让树莓派智能语音助手实现定时提醒功能

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现，因为rasa本身是带有remindschedule模块的。不过经过一番折腾后，忽然发现，chatbot上实现的定时，语音助手不一定会有响应。因为，我目前语音助手的代码设置了长时间无应答会结束对话，这样一来，chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢？ 我最后选择的方法是用threading.Time
阅读更多...
Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸： 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  （注意不能是bmp格式） 替换默认锁屏壁纸： 将图片资源放入vendo
阅读更多...
C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

哈喽，你好啊，我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记，这是第6篇； 接下来实现实时显示当前选中红球数量，蓝球数量； 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时，在对应的位置显示实时已选择的红球、蓝球的数量； 02 标签名称 分别设置Label标签名称为：lblRedCount、lblBlueCount
阅读更多...
【区块链 + 人才服务】可信教育区块链治理系统 | FISCO BCOS应用案例

【区块链 + 人才服务】可信教育区块链治理系统 | FISCO BCOS应用案例

伴随着区块链技术的不断完善，其在教育信息化中的应用也在持续发展。利用区块链数据共识、不可篡改的特性， 将与教育相关的数据要素在区块链上进行存证确权，在确保数据可信的前提下，促进教育的公平、透明、开放，为教育教学质量提升赋能，实现教育数据的安全共享、高等教育体系的智慧治理。 可信教育区块链治理系统的顶层治理架构由教育部、高校、企业、学生等多方角色共同参与建设、维护，支撑教育资源共享、教学质量评估、
阅读更多...
搭建Kafka+zookeeper集群调度

搭建Kafka+zookeeper集群调度

前言 硬件环境 172.18.0.5        kafkazk1        Kafka+zookeeper                Kafka Broker集群 172.18.0.6        kafkazk2        Kafka+zookeeper                Kafka Broker集群 172.18.0.7        kafkazk3
阅读更多...
Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注，收藏不迷路💖 Kubernetes的PodSecurityPolicy（PSP）是一个关键的安全特性，它在Pod创建之前实施安全策略，确保P
阅读更多...
【IPV6从入门到起飞】5-1 IPV6+Home Assistant(搭建基本环境)

【IPV6从入门到起飞】5-1 IPV6+Home Assistant(搭建基本环境)

【IPV6从入门到起飞】5-1 IPV6+Home Assistant #搭建基本环境 1 背景2 docker下载 hass3 创建容器4 浏览器访问 hass5 手机APP远程访问hass6 更多玩法 1 背景 既然电脑可以IPV6入站，手机流量可以访问IPV6网络的服务，为什么不在电脑搭建Home Assistant（hass），来控制你的设备呢？@智能家居 @万物互联
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2