0
0

【SpringCloud】Eureka 案例上手稍微带点原理

文章目录

在这里插入图片描述

1. 前置工作

先准备两个能独立跑起来的微服务（user-server 和 order-server）

将 所需 SQL 导入

/*
 Navicat Premium Data Transfer

 Source Server         : CentOS7
 Source Server Type    : MySQL
 Source Schema         : cloud
 Target Server Type    : MySQL

 Date: 28/05/2023 10:19:17
*/SET NAMES utf8mb4;SET FOREIGN_KEY_CHECKS =0;-- ------------------------------ Table structure for tb_order-- ----------------------------DROPTABLEIFEXISTS`tb_order`;CREATETABLE`tb_order`(`id`bigint(20)NOTNULLAUTO_INCREMENTCOMMENT'订单id',`user_id`bigint(20)NOTNULLCOMMENT'用户id',`name`varchar(100)CHARACTERSET utf8 COLLATE utf8_general_ci DEFAULTNULLCOMMENT'商品名称',`price`bigint(20)NOTNULLCOMMENT'商品价格',`num`int(10)DEFAULT0COMMENT'商品数量',PRIMARYKEY(`id`)USINGBTREE,UNIQUEINDEX`username`(`name`)USINGBTREE)ENGINE=InnoDBAUTO_INCREMENT=109CHARACTERSET= utf8 COLLATE= utf8_general_ci ROW_FORMAT = Compact;-- ------------------------------ Records of tb_order-- ----------------------------INSERTINTO`tb_order`VALUES(101,1,'Apple 苹果 iPhone 12 ',699900,1);INSERTINTO`tb_order`VALUES(102,2,'雅迪 yadea 新国标电动车',209900,1);INSERTINTO`tb_order`VALUES(103,3,'骆驼（CAMEL）休闲运动鞋女',43900,1);INSERTINTO`tb_order`VALUES(104,4,'小米10 双模5G 骁龙865',359900,1);INSERTINTO`tb_order`VALUES(105,5,'OPPO Reno3 Pro 双模5G 视频双防抖',299900,1);INSERTINTO`tb_order`VALUES(106,6,'美的（Midea) 新能效 冷静星II ',544900,1);INSERTINTO`tb_order`VALUES(107,2,'西昊/SIHOO 人体工学电脑椅子',79900,1);INSERTINTO`tb_order`VALUES(108,3,'梵班（FAMDBANN）休闲男鞋',31900,1);-- ------------------------------ Table structure for tb_user-- ----------------------------DROPTABLEIFEXISTS`tb_user`;CREATETABLE`tb_user`(`id`bigint(20)NOTNULLAUTO_INCREMENT,`username`varchar(100)CHARACTERSET utf8 COLLATE utf8_general_ci DEFAULTNULLCOMMENT'收件人',`address`varchar(255)CHARACTERSET utf8 COLLATE utf8_general_ci DEFAULTNULLCOMMENT'地址',PRIMARYKEY(`id`)USINGBTREE,UNIQUEINDEX`username`(`username`)USINGBTREE)ENGINE=InnoDBAUTO_INCREMENT=109CHARACTERSET= utf8 COLLATE= utf8_general_ci ROW_FORMAT = Compact;-- ------------------------------ Records of tb_user-- ----------------------------INSERTINTO`tb_user`VALUES(1,'宋祖儿','北京市朝阳区');INSERTINTO`tb_user`VALUES(2,'景甜','陕西省西安市');INSERTINTO`tb_user`VALUES(3,'李现','湖北省十堰市');INSERTINTO`tb_user`VALUES(4,'郭德纲','天津市');INSERTINTO`tb_user`VALUES(5,'王思聪','辽宁省沈阳市');INSERTINTO`tb_user`VALUES(6,'刘亦菲','湖北省武汉市');SET FOREIGN_KEY_CHECKS =1;

1.1 搭建 user-server

在这里插入图片描述

1.1.1 pom

<?xml version="1.0" encoding="UTF-8"?><projectxmlns="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.3.9.RELEASE</version><relativePath/></parent><groupId>com.snow</groupId><artifactId>cloud_user</artifactId><version>1.0-SNAPSHOT</version><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><servlet.version>3.1.0</servlet.version><druid.version>1.1.20</druid.version><mybatisplus.version>3.4.1</mybatisplus.version><mysql.version>5.1.6</mysql.version><commons.lang.version>3.7</commons.lang.version><commons.codec.version>1.10</commons.codec.version><fastjson.version>1.2.45</fastjson.version><lombok.version>1.18.4</lombok.version><!-- SpringCloud版本号 --><spring-cloud.version>Hoxton.SR10</spring-cloud.version></properties><!-- 版本锁定: 并不是jar包导入 --><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><!-- 打包方式为pom: 说明我们导入的是一个父工程 --><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- mysql驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!-- druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>${druid.version}</version></dependency><!-- mybatis-plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>${mybatisplus.version}</version><exclusions><exclusion><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId></exclusion></exclusions></dependency><!-- lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version></dependency><!-- 阿里JSON解析器 --><dependency><groupId>com.alibaba.fastjson2</groupId><artifactId>fastjson2</artifactId><version>2.0.16</version></dependency></dependencies></project>

1.1.2 po，mapper，controller

@Data@TableName("tb_user")publicclassUser{@TableId(type =IdType.AUTO)privateLong id;privateString username;privateString address;}

@MapperpublicinterfaceUserMapperextendsBaseMapper<User>{}

@RestController@RequestMapping("/user")publicclassUserController{@ResourceprivateUserMapper userMapper;@GetMapping("/get/{id}")publicUserget(@PathVariable("id")Long id){return userMapper.selectById(id);}}

1.1.3 yml

server:port:8081spring:datasource:url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver

1.1.4 启动类

@SpringBootApplicationpublicclassUserServerApplication{publicstaticvoidmain(String[] args){SpringApplication.run(UserServerApplication.class, args);}}

1.1.5 启动并访问

效果如下：

在这里插入图片描述

1.2 搭建 order-server

1.2.1 pom

<?xml version="1.0" encoding="UTF-8"?><projectxmlns="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.3.9.RELEASE</version><relativePath/></parent><groupId>com.snow</groupId><artifactId>cloud_order</artifactId><version>1.0-SNAPSHOT</version><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><servlet.version>3.1.0</servlet.version><druid.version>1.1.20</druid.version><mybatisplus.version>3.4.1</mybatisplus.version><mysql.version>5.1.6</mysql.version><commons.lang.version>3.7</commons.lang.version><commons.codec.version>1.10</commons.codec.version><fastjson.version>1.2.45</fastjson.version><lombok.version>1.18.4</lombok.version><!-- SpringCloud版本号 --><spring-cloud.version>Hoxton.SR10</spring-cloud.version></properties><!-- 版本锁定: 并不是jar包导入 --><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><!-- 打包方式为pom: 说明我们导入的是一个父工程 --><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- mysql驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!-- druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>${druid.version}</version></dependency><!-- mybatis-plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>${mybatisplus.version}</version><exclusions><exclusion><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId></exclusion></exclusions></dependency><!-- lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version></dependency><!-- 阿里JSON解析器 --><dependency><groupId>com.alibaba.fastjson2</groupId><artifactId>fastjson2</artifactId><version>2.0.16</version></dependency></dependencies></project>

1.2.2 po mapper controller

@Data@TableName("tb_order")publicclassOrder{@TableId(type =IdType.AUTO)privateLong id;privateLong price;privateString name;privateInteger num;privateLong userId;@TableField(exist =false)privateUser user;}

@DatapublicclassUser{privateLong id;privateString username;privateString address;}

@MapperpublicinterfaceOrderMapperextendsBaseMapper<Order>{}

@RestController@RequestMapping("/order")publicclassOrderController{@ResourceprivateOrderMapper orderMapper;@GetMapping("/get/{id}")publicOrderget(@PathVariable("id")Long id){Order order = orderMapper.selectById(id);return order;}}

1.2.3 yml

server:port:9091spring:datasource:url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver

1.2.4 启动类

@SpringBootApplicationpublicclassOrderServerApplication{publicstaticvoidmain(String[] args){SpringApplication.run(OrderServerApplication.class, args);}@Bean@LoadBalancedpublicRestTemplaterestTemplate(){returnnewRestTemplate();}}

1.2.5 启动并访问

效果如下：

在这里插入图片描述

至此 两个独立的微服务就顺利的跑起来了。

1.3 两个服务通信

上面的两个独立服务已经跑起来了，因为上来看呢， 可以看到我们的 order服务是需要调用 user 服务的。如下图

在这里插入图片描述
可以看到我们的 order信息里的 user 是为null，因为我们还没有去调用 user 服务。
下来我们在 order服务里调用 user 服务。

改造 order 服务的 OrderController：

@RestController@RequestMapping("/order")publicclassOrderController{@ResourceprivateOrderMapper orderMapper;@ResourceprivateRestTemplate restTemplate;@GetMapping("/get/{id}")publicOrderget(@PathVariable("id")Long id){String url ="http://localhost:8081/user/get/";Order order = orderMapper.selectById(id);User user = restTemplate.getForObject(url + order.getUserId(),User.class);
        order.setUser(user);return order;}}

启动，访问

在这里插入图片描述

可以看到 order 里有 user 的数据了 ！OK!

2. Eureka

2.1 Eureka 概述

Eureka 是 Netflix 提供的基于 REST 的服务发现组件，用于帮助开发者管理微服务架构中的服务实例。它提供了一个可伸缩的注册中心，可以让每个微服务都能够找到其他微服务的位置和元数据信息，并对其进行负载均衡、自动故障转移等操作。

通过将 Eureka Server 部署在中心服务器上，然后将各个微服务节点（即Eureka Client）注册到该中心服务器上，便可以实现微服务间的快速查找和调用。

在这里插入图片描述

使用Eureka能够方便地扩展和部署大规模微服务应用程序，并让你更容易地维护和监控整个系统。

同时，由于Eureka本身是基于REST接口设计的，因此它能够与多种编程语言和框架无缝集成，可以让开发者像使用本地服务一样轻松地编写分布式应用程序。

2.2 搭建 Eureka

2.2.1 pom

<?xml version="1.0" encoding="UTF-8"?><projectxmlns="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.3.9.RELEASE</version></parent><artifactId>eureka-service</artifactId><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><!-- SpringCloud版本号 --><spring-cloud.version>Hoxton.SR10</spring-cloud.version></properties><!-- 版本锁定: 并不是jar包导入 --><dependencyManagement><dependencies><!-- todo:2.导入springCloud父工程 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><!-- 打包方式为pom: 说明我们导入的是一个父工程 --><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies><build><finalName>app</finalName><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

2.2.2 yml

server:port:10086spring:application:name: eureka-server
eureka:# 给内置的客户端设置服务端地址client:service-url:defaultZone: http://127.0.0.1:10086/eureka
    register-with-eureka:false# 不注册自己fetch-registry:false#不拉取服务本eureka服务中的服务信息

2.2.3 启动类

@SpringBootApplication// 开启Eureka服务端支持@EnableEurekaServerpublicclassEurekaApplication{publicstaticvoidmain(String[] args){SpringApplication.run(EurekaApplication.class, args);}}

2.2.4 启动访问

在这里插入图片描述

2.3 将服务注册进 Eureka

给user服务和order服务分别引入依赖：

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

修改 user 和 order 的 yml 文件

server:port:8081spring:datasource:url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
  application:name: USER-SERVER

eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka
  instance:# 在Eureka中显示服务的ip地址ip-address: 127.0.0.1 # 配置服务器ip地址prefer-ip-address:true# 更倾向于使用ip,而不是host名instance-id: ${eureka.instance.ip-address}:${server.port}# 自定义实例的id

server:port:9091spring:datasource:url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
  application:name: ORDER-SERVER

eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

重启服务。

在这里插入图片描述

服务就已注册进来了。

2.4 通过Eureka调用服务

回看我们之前 order 调用 user 时候的方式是直接通过 RestTemplate 调用的，这样耦合是有些大的，比如我们的 user 服务换了部署地址，就得去动 order 的源代码。实在不妥。
在这里插入图片描述

下来我们通过 Eureka 提供的注册发现服务去调用。

改造OrderController

@GetMapping("/get/{id}")publicOrderget(@PathVariable("id")Long id){String user_server_name ="USER-SERVER";String url ="http://"+ user_server_name +"/user/get/";Order order = orderMapper.selectById(id);User user = restTemplate.getForObject(url + order.getUserId(),User.class);

        order.setUser(user);return order;}

启动访问：

在这里插入图片描述

3. Eureka 原理

Eureka 采用了客户端-服务端的设计架构，分为 Eureka Server 和 Eureka Client 两部分。

在这里插入图片描述

Eureka Server 是一个基于 RESTful 的服务，用于管理和维护客户端节点的信息。每个 Eureka Client 向 Eureka Server 注册自己提供的服务，并定时通过心跳机制告知 Eureka Server 自己仍然存活。同时，Eureka Server 也会定期对注册在自己那里的每个 Eureka Client 进行监控，以确保它们正常运行。

Eureka Client 则是一个轻量级的 Java 客户端，用于将自己注册到 Eureka Server 并获取所依赖服务的信息。他们使用轮询来访问 Eureka Server 来达到负载均衡的目的。 另外，它还会缓存 Eureka Server 中的服务列表信息，当服务端不能访问时可以快速切换到本地缓存服务列表模式，尽可能降低系统的开销。
在这里插入图片描述

具体流程如下

Eureka Client 启动后，会向 Eureka Server 发送一个注册请求，包含了该客户端所提供的服务实例、IP 地址、端口号等元数据。
Eureka Server 接收到注册请求后，会将该客户端所提供的服务实例信息记录到自身的内存中，同时将变更信息广播给其他的 Eureka Server 节点，以实现服务注册中心的高可用和服务同步。

Eureka Client 通过 “心跳” 机制定期向 Eureka Server 发送请求，以更新服务健康状态、刷新缓存等操作。如果在一定时间内 Eureka Server 没有接收到“心跳”消息，则会将该客户端实例从注册列表中摘除。
Eureka Client 还可以通过发送 RESTful API 请求来查询可用的服务节点信息，以实现负载均衡等功能。

Eureka 的核心对象是服务实例，每个服务实例都可以作为提供者向 Eureka Server 注册自己，同时也可以作为消费者从 Eureka Server 中获取所需服务的信息，从而实现服务发现和调用。

4. 注意

Eurek 已经停止维护 2.x 版本！

在这里插入图片描述

标签： spring cloud eureka spring
本文转载自: https://blog.csdn.net/m0_60915009/article/details/130909841
版权归原作者 我有一颗五叶草 所有， 如有侵权，请联系我们删除。
登录后发布评论

“【SpringCloud】Eureka 案例上手稍微带点原理”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

机器人技术在安全领域的重要作用

安全学习记录——网络篇（一）

图腾柱PFC：HP1010为您的电动两轮车之旅提供绿色，高效，安全的动力

单元测试数据库回滚问题

这才是单元测试，之前我们都错了

【C语言基础】：字符函数和字符串函数

ChatGPT-Next-Web SSRF漏洞+XSS漏洞复现(CVE-2023-49785)

文章导航