Eureka 服务注册和服务发现的使用

news2025/1/31 15:22:41

1. 父子工程的搭建

首先创建一个 Maven 项目，删除 src ，只保留 pom.xml

然后来进行 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>

  <groupId>org.example</groupId>
  <artifactId>spring-cloud-demo</artifactId>
  <version>1.0-SNAPSHOT</version>
  <packaging>pom</packaging>
  <modules>
    <module>order-service</module>
    <module>product-service</module>
  </modules>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>3.1.6</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <properties>
    <maven.compiler.source>17</maven.compiler.source>
    <maven.compiler.target>17</maven.compiler.target>
    <java.version>17</java.version>
    <mybatis.version>3.0.3</mybatis.version>
    <mysql.version>8.0.33</mysql.version>
    <spring-cloud.version>2022.0.3</spring-cloud.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
  </dependencies>

  <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>
      <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>${mybatis.version}</version>
      </dependency>
      <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
        <version>${mysql.version}</version>
      </dependency>
      <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter-test</artifactId>
        <version>${mybatis.version}</version>
        <scope>test</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
</project>

在上面的配置中，使用 properties 来进行版本号的统一管理，使用 dependencyManagement 来管理依赖，并通过<packaging>pom</packaging>来生命父工程的打包方式为 pom

dependencyManagement 和 dependencies

  1. dependencies：将依赖的 jar 包添加到父项目的 dependencies 部分时，这些依赖会被父项目及其子项目继承，子项目无需额外操作即可自动包含这些依赖。
  2. dependencyManagement： 仅用于声明依赖，不会将 jar 包引入到父项目或子项目中。当子项目需要使用在父项目 dependencyManagement 中声明的依赖时，需在子项目中显式声明该依赖。子项目不指定版本号时，会从父项目的 dependencyManagement 部分读取相应依赖的版本号；如果子项目指定了版本号，就使用子项目中指定的版本号，不使用父项目声明的版本。

关于打包方式：父项目的打包方式通常应为 pom，而不是 jar 或 war，因为父项目主要起依赖管理和项目聚合的作用，不包含需要部署或运行的代码。

2. 子工程的搭建

在父工程右键选择新建一个 Module，

创建时 Parent 默认为父工程

接着配置子工程的项目依赖，由于父工程已经对版本号进行了统一管理，直接进行以下配置即可

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
  </dependency>
  <!--mybatis-->
  <dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
  </dependency>
</dependencies>

<build>
  <plugins>
    <plugin>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-maven-plugin</artifactId>
    </plugin>
  </plugins>
  <resources>
    <resource>
      <directory>src/main/resources</directory>
      <filtering>true</filtering>
      <includes>
        <include>**/**</include>
      </includes>
    </resource>
  </resources>
</build>

在一个父项目中搭建两个子工程

然后在这两个子工程中分别写一个查询接口

@RequestMapping("/{orderId}")
public OrderInfo getOrderById(@PathVariable("orderId") Integer orderId){
    return orderService.selectOrderById(orderId);
}
@RequestMapping("/{productId}")
public ProductInfo selectProductById(@PathVariable("productId") Integer productId) {
    return productService.selectProductById(productId);
}

3. 远程调用

如果此时需要实现一个查询订单的功能，查询结果中需要包含商品信息，由于上面的两个子工程现在是分开的，并不是像之前一样写在一个工程中，那么现在就不能直接调用查询的结果了

可以联想一下前端调用后端获取资源的方式，就是通过发送一个 http 请求来获取的，那么后端之间调用也可以使用这种方式，order-service 服务向 product-service 服务发送一个 http 请求，把得到的返回结果和订单结果合并在一起返回给调用方，有许多方式可以构造一个 http 请求，这里采用 Spring 提供的 RestTemplate 来实现一下：

RestTemplate 是 Spring 提供的，封装 http 调用，并强制使用 RESTful 风格，它会处理 http 连接和关闭，只需要提供资源的地址和参数即可

首先定义一下 RestTemplate

@Configuration
public class BeanConfig {
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

之后就可以在 service 中注入 RestTemplate 对象，然后就可以构造 http 请求了，把获取到的资源再通过指定的 ProductInfo 类型进行返回

@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private RestTemplate restTemplate;

    public OrderInfo selectOrderById(Integer orderId){
        OrderInfo orderInfo = orderMapper.selectOrderById(orderId);
        //构建URL
        String url = "http://127.0.0.1:9090/product/" + orderInfo.getProductId();
        //通过get方式发起请求获取资源
        ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);
        orderInfo.setProductInfo(productInfo);
        return orderInfo;
    }
}

通过这种方式就实现了远程调用

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

不过上面的方式存在一些弊端，根据 get，post，put 等来区分对资源的操作类型并不能直观地看出来，通过抓包才能看出具体是哪种类型，不如直接把动作放在 URL 上直观

此外，还存在下面的一些问题：

  1. 由于 IP 地址是固定写的，如果 IP 地址发生了变化就需要修改代码
  2. 如果是多机部署如何处理？
  3. 返回结果怎么共用？
  4. URL 也的书写也容易出现错误
  5. 接口是对外开放的，存在一定风险

4. 注册中心的引入

针对 IP 地址改变的问题，可以通过下面的流程来解决

  1. 服务提供者（Server）：一次业务中被其它微服务调用的服务，也就是提供接口给其它微服务
  2. 服务消费者（Client）：一次业务中，调用其它微服务的服务，也就是调用其它微服务提供的接口
  3. 服务注册中心（Registry）：用于保存 Server 的注册信息，当 Server 节点发生变更时，Registry 会同步变更，服务与注册中心使用一定机制通信，如果注册中心与某服务长时间无法通信，就会注销该实例
  4. 服务注册：服务提供者在启动时，向 Registry 注册自身服务，并向 Registry 定期发送心跳汇报存活状态。
  5. 服务发现：服务消费者从注册中心查询服务提供者的地址，并通过该地址调用服务提供者的接口。服务发现的一个重要作用就是提供给服务消费者一个可用的服务列表。

在上面的流程中，通过一个注册中心来存储应用和 IP 之间的关系，服务消费者以此来获取应用的 IP 地址，然后再去远程调用

5. CAP 理论

C：一致性（强一致性），所有节点在同一时间具有相同的数据

当客户端向数据库集群发送了一个数据修改的请求之后，数据库集群需要向客户端进行响应，此时就会有两种情况：

  1. 主数据库接收到请求并处理成功，不过数据还没有同步到从数据库，随着时间的推移会同步到从数据库
  2. 主数据库接收到请求，所有的从数据库数据同步成功时

弱一致性就是第一种情况，强一致性就是第二种情况，不论何时，主库和从库对外提供的服务都是一致的

A：可用性，保证每个请求都有响应，不过响应结果可能不对

P：分区容错性，当出现网络分区后，系统仍然能够对外提供服务

这三种特性是不能同时兼顾的，比如，在主数据库和从数据库同步数据的过程中网络出现了问题，那么这个过程就会被拉长，如果保证可用性，那么用户此时获取到的信息就不是强一致性的数据，在微服务架构中， P 是必须要保证的，所以 C 和 A 只能兼顾一个，也就是 CP 架构和 AP 架构

6. Eureka

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

6.1. 搭建 Eureka Server

首先再创建一个 eureka-server 的子模块

然后引入 eureka-server 的依赖和项目构建的插件

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  </dependency>
</dependencies>
<build>
  <plugins>
    <plugin>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-maven-plugin</artifactId>
    </plugin>
  </plugins>
</build>

接着还需要编写配置文件

server:
  port: 10010  
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/

然后编写启动类进行启动，和之前的启动类不同的是，这里还需要加上@EnableEurekaServer注解

@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class,args);
    }
}

启动之后访问服务就可以看到注册中心的界面了：

6.2. 服务注册

把 product-service 注册到 eureka-server 中需要在 product-service 中添加客户端的依赖

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

然后配置文件也需要完善一下，把要注册的服务的名称和 eureka 的地址配置一下：

在 product-service 的 yml 文件中添加一下配置，端口号也是之前配置的 eureka 的端口号，

#Eureka Client
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10010/eureka/

然后配置服务名称

spring:
  application:
    name: product-service

接下来先启动 eureka 服务，再启动 product 服务就能够看到已经注册成功了

然后以相同的方式把 order-service 也添加到注册列表中

6.3. 服务发现

之后再进行远程调用的时候就可以从注册中心来获取要调用服务的 IP 和端口号了，需要在原来获取的方式上进行一些修改

接下来就能成功的获取到 product-service 的信息了

Eureka 和 Zookeeper 的区别：

Eureka 和 Zookeeper 都是用于服务注册和发现的工具，区别有以下几点：

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

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

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

相关文章

白嫖DeepSeek：一分钟完成本地部署AI

白嫖DeepSeek：一分钟完成本地部署AI

1. 必备软件 LM-Studio 大模型客户端DeepSeek-R1 模型文件 LM-Studio 是一个支持众多流行模型的AI客户端&#xff0c;DeepSeek是最新流行的堪比GPT-o1的开源AI大模型。 2. 下载软件和模型文件 2.1 下载LM-Studio 官方网址&#xff1a;https://lmstudio.ai 打开官网&#x…
阅读更多...
《Origin画百图》之同心环图

《Origin画百图》之同心环图

《Origin画百图》第四集——同心环图 入门操作可查看合集中的《30秒&#xff0c;带你入门Origin》 具体操作&#xff1a; 1.数据准备&#xff1a;需要X和Y两列数据 2. 选择菜单 绘图 > 条形图&#xff0c;饼图&#xff0c;面积图: 同心圆弧图 3. 这是绘制的基础图形&…
阅读更多...
蓝牙技术在物联网中的应用有哪些

蓝牙技术在物联网中的应用有哪些

蓝牙技术凭借低功耗、低成本和易于部署的特性&#xff0c;在物联网领域广泛应用&#xff0c;推动了智能家居、工业、医疗、农业等多领域发展。 智能家居&#xff1a;在智能家居系统里&#xff0c;蓝牙技术连接各类设备&#xff0c;像智能门锁、智能灯泡、智能插座、智能窗帘等。…
阅读更多...
简易计算器（c++ 实现)

简易计算器（c++ 实现)

前言 本文将用 c 实现一个终端计算器&#xff1a; 能进行加减乘除、取余乘方运算读取命令行输入&#xff0c;输出计算结果当输入表达式存在语法错误时&#xff0c;报告错误&#xff0c;但程序应能继续运行当输出 ‘q’ 时&#xff0c;退出计算器 【简单演示】 【源码位置】…
阅读更多...
自动化运维的未来：从脚本到AIOps的演进

自动化运维的未来：从脚本到AIOps的演进

点击进入IT管理资料库 一、自动化运维的起源&#xff1a;脚本时代 &#xff08;一&#xff09;脚本在运维中的应用场景 在自动化运维的发展历程中&#xff0c;脚本扮演着至关重要的角色&#xff0c;它作为最初的操作入口&#xff0c;广泛应用于诸多日常运维工作场景里。 在系统…
阅读更多...
线程池以及在QT中的接口使用

线程池以及在QT中的接口使用

文章目录 前言线程池架构组成**一、任务队列&#xff08;Task Queue&#xff09;****二、工作线程组&#xff08;Worker Threads&#xff09;****三、管理者线程&#xff08;Manager Thread&#xff09;** 系统协作流程图解 一、QRunnable二、QThreadPool三、线程池的应用场景W…
阅读更多...
联想拯救者R720笔记本外接显示屏方法，显示屏是2K屏27英寸

联想拯救者R720笔记本外接显示屏方法，显示屏是2K屏27英寸

晚上23点10分前下单&#xff0c;第二天上午显示屏送到&#xff0c;检查外包装没拆封过。这个屏幕左下方有几个按键&#xff0c;按一按就开屏幕、按一按就关闭屏幕&#xff0c;按一按方便节省时间&#xff0c;也支持阅读等模式。 显示屏是 &#xff1a;AOC 27英寸 2K高清 100Hz…
阅读更多...
C++ deque（1）

C++ deque（1）

1.deque介绍 deque的扩容不像vector那样麻烦 直接新开一个buffer 不用重新开空间再把数据全部移过去 deque本质上是一个指针数组和vector<vector>不一样&#xff0c;vector<vector>本质上是一个vector对象数组&#xff01;并且vector<vector>的buffer是不一…
阅读更多...
Brightness Controller-源码记录

Brightness Controller-源码记录

Brightness Controller 亮度控制 一、概述二、ddcutil 与 xrandr1. ddcutil2. xrandr 三、部分代码解析1. icons2. ui3. utilinit.py 一、概述 项目&#xff1a;https://github.com/SunStorm2018/Brightness.git 原理&#xff1a;Brightness Controlle 是我在 Ubuntu 发现上调…
阅读更多...
Java8_StreamAPI

Java8_StreamAPI

Stream 1.创建流 1.1 集合创建流 List<String> list List.of("a", "b", "c"); Stream<String> stream list.stream(); stream.forEach(System.out::println);1.2 数组创建流 String[] array {"a","b",&qu…
阅读更多...
【架构面试】二、消息队列和MySQL和Redis

【架构面试】二、消息队列和MySQL和Redis

MQ MQ消息中间件 问题引出与MQ作用 常见面试问题&#xff1a;面试官常针对项目中使用MQ技术的候选人提问&#xff0c;如如何确保消息不丢失&#xff0c;该问题可考察候选人技术能力。MQ应用场景及作用&#xff1a;以京东系统下单扣减京豆为例&#xff0c;MQ用于交易服和京豆服…
阅读更多...
OpenEuler学习笔记（十六）：搭建postgresql高可用数据库环境

OpenEuler学习笔记（十六）：搭建postgresql高可用数据库环境

以下是在OpenEuler系统上搭建PostgreSQL高可用数据环境的一般步骤&#xff0c;通常可以使用流复制&#xff08;Streaming Replication&#xff09;或基于Patroni等工具来实现高可用&#xff0c;以下以流复制为例&#xff1a; 安装PostgreSQL 配置软件源&#xff1a;可以使用O…
阅读更多...
论文阅读(十一)：基因-表型关联贝叶斯网络模型的评分、搜索和评估

论文阅读(十一)：基因-表型关联贝叶斯网络模型的评分、搜索和评估

1.论文链接&#xff1a;Scoring, Searching and Evaluating Bayesian Network Models of Gene-phenotype Association 摘要&#xff1a; 全基因组关联研究&#xff08;GWAS&#xff09;的到来为识别常见疾病的遗传变异&#xff08;单核苷酸多态性&#xff08;SNP&#xff09;&…
阅读更多...
企业微信远程一直显示正在加载

企业微信远程一直显示正在加载

企业微信远程一直显示正在加载 1.问题描述2.问题解决 系统&#xff1a;Win10 1.问题描述 某天使用企业微信给同事进行远程协助的时候&#xff0c;发现一直卡在正在加载的页面&#xff0c;如下图所示 2.问题解决 经过一番查找资料后&#xff0c;我发现可能是2个地方出了问题…
阅读更多...
人工智能 - 1

人工智能 - 1

深度强化学习&#xff08;Deep Reinforcement Learning&#xff09; 图神经网络&#xff08;Graph Neural Networks, GNNs&#xff09; Transformer 一种深度学习模型 大语言模型&#xff08;Large Language Models, LLMs&#xff09; 人工智能 • Marvin Minsky 将其定义…
阅读更多...
Linux_线程同步生产者消费者模型

Linux_线程同步生产者消费者模型

同步的相关概念 同步&#xff1a;在保证数据安全的前提下&#xff0c;让线程能够按照某种特定的顺序访问临界资源&#xff0c;从而有效避免饥饿问题&#xff0c;叫做同步竞态条件&#xff1a;因为时序问题&#xff0c;而导致程序异常&#xff0c;我们称之为竞态条件。 同步的…
阅读更多...
Github 2025-01-30 Go开源项目日报 Top10

Github 2025-01-30 Go开源项目日报 Top10

根据Github Trendings的统计，今日(2025-01-30统计)共有10个项目上榜。根据开发语言中项目的数量，汇总情况如下： 开发语言项目数量Go项目10Ollama: 本地大型语言模型设置与运行 创建周期：248 天开发语言：Go协议类型：MIT LicenseStar数量：42421 个Fork数量：2724 次关注人…
阅读更多...
【Rust自学】17.2. 使用trait对象来存储不同值的类型

【Rust自学】17.2. 使用trait对象来存储不同值的类型

喜欢的话别忘了点赞、收藏加关注哦&#xff08;加关注即可阅读全文&#xff09;&#xff0c;对接下来的教程有兴趣的可以关注专栏。谢谢喵&#xff01;(&#xff65;ω&#xff65;) 17.2.1. 需求 这篇文章以一个例子来介绍如何在Rust中使用trait对象来存储不同值的类型。 …
阅读更多...
VLLM性能调优

VLLM性能调优

1. 抢占 显存不够的时候&#xff0c;某些request会被抢占。其KV cache被清除&#xff0c;腾退给其他request&#xff0c;下次调度到它&#xff0c;重新计算KV cache。 报这条消息&#xff0c;说明已被抢占&#xff1a; WARNING 05-09 00:49:33 scheduler.py:1057 Sequence gr…
阅读更多...
Java线程认识和Object的一些方法

Java线程认识和Object的一些方法

本文目标&#xff1a; 要对Java线程有整体了解&#xff0c;深入认识到里面的一些方法和Object对象方法的区别。认识到Java对象的ObjectMonitor&#xff0c;这有助于后面的Synchronized和锁的认识。利用Synchronized wait/notify 完成一道经典的多线程题目&#xff1a;实现ABC…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023