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

news2024/12/25 12:41:50

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: localhost
  client:
    fetch-registry: false # 表示是否从Eureka Server获取注册信息,默认为true.因为这是一个单点的Eureka Server,不需要同步其他的Eureka Server节点的数据,这里设置为false
    register-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 {

    @Autowired
    private OrderMapper orderMapper;

    @Resource
    private DiscoveryClient discoveryClient;

    @Autowired
    private 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 等系统在网络分区时仍然能处理请求，但不同节点可能返回不同的数据（最终一致性）。

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

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

相关文章

指尖疯2024年下半年软考报名快报：赛程过半，你报名成功了吗？

指尖疯2024年下半年软考报名快报：赛程过半，你报名成功了吗？

周一早上好&#xff0c;新的一周&#xff0c;新的9月&#xff01; 特别提醒&#xff1a;青海和上海&#xff0c;这两个“海”今天截止报名&#xff01;已经结束报名的地区已经增长到了13个&#xff0c;目前2024年下半年软考报名已经过半&#xff0c;考虑到还有审核时间以及报名…
阅读更多...
原生冻结进程分析（U）

原生冻结进程分析（U）

一、概要 1.定义&#xff1a; 当应用切换到后台并且没有其他活动时&#xff0c;系统会在一定时间内通过状态判断&#xff0c;将进程 ID 迁移到冻结的 cgroup 节点上&#xff0c;实现冻结 CACHE 应用。这项功能可以减少活跃缓存应用在后台存在时所消耗的 CPU 资源&#xff0c;从…
阅读更多...
Nginx安全性配置

Nginx安全性配置

文章目录 引言I Nginx简单的安全性配置禁止特定的HTTP方法限制URL长度禁止某些用户代理限制请求速率连接限制禁止访问某些文件类型II 常见的安全规则防御CC攻击User-Agent过滤GET-URL过滤GET-参数过滤POST过滤（sql注入、xss攻击 ）引言 Nginx本身并不具备复杂的防火墙规则定制…
阅读更多...
NASA数据集：ASTER全球数字海拔模型（GTEM）V003

NASA数据集：ASTER全球数字海拔模型（GTEM）V003

ASTER Digital Elevation Model V003 简介 ASTER全球数字海拔模型&#xff08;GTEM&#xff09;第3版&#xff08;ASTG TM&#xff09;提供了地球陆地区域的全球数字海拔模型&#xff08;TEM&#xff09;&#xff0c;空间分辨率为1角秒&#xff08;赤道处水平位置约30米&…
阅读更多...
k8s集群环境搭建（一主二从--kubeadm安装）

k8s集群环境搭建（一主二从--kubeadm安装）

前置条件 版本&#xff1a;CentOS Linux release 7.5.1804 (Core) 内存&#xff1a;2G CPU&#xff1a;2 主机名解析 vim /etc/hosts 192.168.109.100 master 192.168.109.101 node1 192.168.109.102 node2时间同步&#xff0c;这里直接使用chronyd服务从网络同步时间syste…
阅读更多...
企业产品推广系统小程序的设计

企业产品推广系统小程序的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;用户管理&#xff0c;活动资讯管理&#xff0c;产品分类管理&#xff0c;产品信息管理&#xff0c;用户分享管理&#xff0c;留言板管理&#xff0c;系统管理 微信端账号功能包括&#xff1a;系统首页…
阅读更多...
C语言 | Leetcode C语言题解之第388题文件的最长绝对路径

C语言 | Leetcode C语言题解之第388题文件的最长绝对路径

题目&#xff1a; 题解&#xff1a; #define MAX(a, b) ((a) > (b) ? (a) : (b))int lengthLongestPath(char * input){int n strlen(input);int pos 0;int ans 0;int * level (int *)malloc(sizeof(int) * (n 1));memset(level, 0, sizeof(int) * (n 1));while (po…
阅读更多...
LabVIEW电机多次调用

LabVIEW电机多次调用

在LabVIEW中&#xff0c;为实现对多个电机的独立控制&#xff0c;工程师可以采用可重入VI、动态VI调用、多任务结构或面向对象编程等方法。每种方法都有其优点和适用场景&#xff0c;选择合适的方法能有效提升系统的性能和可维护性。 在LabVIEW中&#xff0c;如果需要多次调用…
阅读更多...
WPF 手撸插件 六 消息总线

WPF 手撸插件 六 消息总线

虽然暂时不知道该如何将消息总线集成到插件系统中&#xff0c;但是让我先学习起来吧&#xff0c;本文主要来说说我最近学习的Reface.EventBus Reface.EventBus有两个版本&#xff0c;分别支持.Net Framework和 .Net Core。 我们这里先说支持.Net Framework的版本&#xff0c;…
阅读更多...
007.Python爬虫系列_初识爬虫

007.Python爬虫系列_初识爬虫

我 的 个 人 主 页：👉👉 失心疯的个人主页 👈👈 入 门 教 程 推 荐 ：👉👉 Python零基础入门教程合集 👈👈 虚 拟 环 境 搭 建 ：👉👉 Python项目虚拟环境(超详细讲解) 👈👈 PyQt5 系 列 教 程：👉👉 Python GUI(PyQt5)文章合集 👈👈 Oracle数…
阅读更多...
javaSSMmysql宠物领养系统的设计与实现26292-计算机毕业设计项目选题推荐（附源码）

javaSSMmysql宠物领养系统的设计与实现26292-计算机毕业设计项目选题推荐（附源码）

摘 要 如今&#xff0c;随着人们生活水平不断提高&#xff0c;人们的生活在物质满足的基础上&#xff0c;更多的人将生活的重点放在追求精神享受的过程中。于此同时&#xff0c;Internet铺天盖地的普及&#xff0c;使得这样的人纷纷通过Internet的方式去寻找精神的满足。然而领…
阅读更多...
java+Springboot+mysql小区维修管理平台41866-计算机毕业设计项目选题推荐（免费领源码）

java+Springboot+mysql小区维修管理平台41866-计算机毕业设计项目选题推荐（免费领源码）

摘 要 随着计算机技术的飞速发展&#xff0c;计算机在小区维修管理中应用的普及&#xff0c;利用计算机在实现小区维修的管理势在必行。当今社会正快速向信息化社会前进&#xff0c;信息自动化的作用也越来越大。从而使我们从繁杂的事务中解放出来,提高了我们的工作效率。目前…
阅读更多...
Web入门-06.HTTP协议-协议解析

Web入门-06.HTTP协议-协议解析

浏览器发起HTTP协议请求&#xff0c;服务端通过ServerSocket接收并交给一个Socket对象&#xff08;管道&#xff09;&#xff0c;然后解析浏览器的请求&#xff0c;并通过Socket管道向浏览器响应。 代码如下&#xff1a; package com.gjw;import java.io.*; import java.net…
阅读更多...
学习之git的常用命令

学习之git的常用命令

git常用命令 设置用户签名 基本语法&#xff1a; 1.1 git config --global user.name 用户名 1.2 git config – global user.email 邮箱 1.3 cat ~/.gitconfig 1.4 git init 初始化本地库 在D盘新建一个文件夹—进入文件夹–右键–点击&#xff08;open git base here) …
阅读更多...
低代码技术新趋势——逆向工程

低代码技术新趋势——逆向工程

低代码的下一个趋势&#xff0c;应该是“逆向工程”&#xff0c;用户可以通过 可视化界面&#xff0c;逆向输出全栈工程代码。而标准的工程代码同样可以编译为支持可视化分析、编辑、调整的“无代码”程序。前一个是解释性语言向编译性语言的逆向工程。后者则是一个理论实践应用…
阅读更多...
华为OD机试真题 - 跳马 - 广度优先搜索BFS（Python/JS/C/C++ 2024 D卷 200分）

华为OD机试真题 - 跳马 - 广度优先搜索BFS（Python/JS/C/C++ 2024 D卷 200分）

华为OD机试 2024E卷题库疯狂收录中，刷题点这里 专栏导读 本专栏收录于《华为OD机试真题（Python/JS/C/C++）》。 刷的越多，抽中的概率越大，私信哪吒，备注华为OD，加入华为OD刷题交流群，每一题都有详细的答题思路、详细的代码注释、3个测试用例、为什么这道题采用XX算法、…
阅读更多...
Java SpringBoot Vue开发的公司单位考勤管理系统，一键导出考勤数据，智能分析员工出勤，提高管理效率

Java SpringBoot Vue开发的公司单位考勤管理系统，一键导出考勤数据，智能分析员工出勤，提高管理效率

&#x1f34a;作者&#xff1a;计算机毕设匠心工作室 &#x1f34a;简介&#xff1a;毕业后就一直专业从事计算机软件程序开发&#xff0c;至今也有8年工作经验。擅长Java、Python、微信小程序、安卓、大数据、PHP、.NET|C#、Golang等。 擅长&#xff1a;按照需求定制化开发项目…
阅读更多...
IEEE PDF eXpress 报错解决 Error in converting file + font not embedded

IEEE PDF eXpress 报错解决 Error in converting file + font not embedded

IEEE PDF eXpress 报错解决方法 1. Error in converting file解决方法&#xff08;1&#xff09;直接使用 Manual Request&#xff08;2&#xff09;查看报错信息并修改 2. 报错信息为&#xff1a;font xxx not embedded解决方法&#xff1a;在pdf中嵌入字体 1. Error in conve…
阅读更多...
codeforce一半空白？怎么解决

codeforce一半空白？怎么解决

codeforces界面问题&#xff0c;有一半是空白 如图&#xff1a; 下拉到底&#xff0c;点击desktop version即可 这样就好了
阅读更多...
鸿蒙界面开发（12）：选项卡布局(Tabs)

鸿蒙界面开发（12）：选项卡布局(Tabs)

选项卡布局(Tabs) 当页面信息较多时&#xff0c;为了让用户能够聚焦于当前显示的内容&#xff0c;需要对页面内容进行分类&#xff0c;提高页面空间利用率。Tabs组件可以在一个页面内快速实现视图内容的切换。 基本布局 Tabs组件的页面组成包含两个部分&#xff0c;分别是Ta…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023