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

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

   数栈君   发表于 2023-07-17 14:28  180  0

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
-- ----------------------------
DROP TABLE IF EXISTS `tb_order`;
CREATE TABLE `tb_order` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '订单id',
`user_id` bigint(20) NOT NULL COMMENT '用户id',
`name` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '商品名称',
`price` bigint(20) NOT NULL COMMENT '商品价格',
`num` int(10) DEFAULT 0 COMMENT '商品数量',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `username`(`name`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 109 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

-- ----------------------------
-- Records of tb_order
-- ----------------------------
INSERT INTO `tb_order` VALUES (101, 1, 'Apple 苹果 iPhone 12 ', 699900, 1);
INSERT INTO `tb_order` VALUES (102, 2, '雅迪 yadea 新国标电动车', 209900, 1);
INSERT INTO `tb_order` VALUES (103, 3, '骆驼（CAMEL）休闲运动鞋女', 43900, 1);
INSERT INTO `tb_order` VALUES (104, 4, '小米10 双模5G 骁龙865', 359900, 1);
INSERT INTO `tb_order` VALUES (105, 5, 'OPPO Reno3 Pro 双模5G 视频双防抖', 299900, 1);
INSERT INTO `tb_order` VALUES (106, 6, '美的（Midea) 新能效 冷静星II ', 544900, 1);
INSERT INTO `tb_order` VALUES (107, 2, '西昊/SIHOO 人体工学电脑椅子', 79900, 1);
INSERT INTO `tb_order` VALUES (108, 3, '梵班（FAMDBANN）休闲男鞋', 31900, 1);

-- ----------------------------
-- Table structure for tb_user
-- ----------------------------
DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`username` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '收件人',
`address` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '地址',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `username`(`username`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 109 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

-- ----------------------------
-- Records of tb_user
-- ----------------------------
INSERT INTO `tb_user` VALUES (1, '宋祖儿', '北京市朝阳区');
INSERT INTO `tb_user` VALUES (2, '景甜', '陕西省西安市');
INSERT INTO `tb_user` VALUES (3, '李现', '湖北省十堰市');
INSERT INTO `tb_user` VALUES (4, '郭德纲', '天津市');
INSERT INTO `tb_user` VALUES (5, '王思聪', '辽宁省沈阳市');
INSERT INTO `tb_user` VALUES (6, '刘亦菲', '湖北省武汉市');

SET FOREIGN_KEY_CHECKS = 1;

1.1 搭建 user-server




1.1.1 pom
<?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>

<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")
public class User {

@TableId(type = IdType.AUTO)
private Long id;

private String username;

private String address;
}
1
2
3
4
5
6
7
8
9
10
11
@Mapper
public interface UserMapper extends BaseMapper<User> {

}
1
2
3
4
@RestController
@RequestMapping("/user")
public class UserController {

@Resource
private UserMapper userMapper;

@GetMapping("/get/{id}")
public User get(@PathVariable("id") Long id){
return userMapper.selectById(id);
}
}

1.1.3 yml
server:
port: 8081
spring:
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
3
4
5
6
7
8
1.1.4 启动类
@SpringBootApplication
public class UserServerApplication {

public static void main(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"?>
<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>

<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")
public class Order {

@TableId(type = IdType.AUTO)
private Long id;

private Long price;

private String name;

private Integer num;

private Long userId;

@TableField(exist = false)
private User user;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Data
public class User {
private Long id;
private String username;
private String address;
}
1
2
3
4
5
6
@Mapper
public interface OrderMapper extends BaseMapper<Order> {
}
1
2
3
@RestController
@RequestMapping("/order")
public class OrderController {

@Resource
private OrderMapper orderMapper;

@GetMapping("/get/{id}")
public Order get(@PathVariable("id") Long id){
Order order = orderMapper.selectById(id);
return order;
}
}

1.2.3 yml
server:
port: 9091
spring:
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 启动类
@SpringBootApplication
public class OrderServerApplication {

public static void main(String[] args) {
SpringApplication.run(OrderServerApplication.class, args);
}

@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}

}


1.2.5 启动并访问
效果如下：





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

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



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

改造 order 服务的 OrderController：

@RestController
@RequestMapping("/order")
public class OrderController {

@Resource
private OrderMapper orderMapper;

@Resource
private RestTemplate restTemplate;

@GetMapping("/get/{id}")
public Order get(@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"?>
<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>

<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: 10086
spring:
application:
name: eureka-server
eureka:
# 给内置的客户端设置服务端地址
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
register-with-eureka: false # 不注册自己
fetch-registry: false #不拉取服务本eureka服务中的服务信息
1
2
3
4
5
6
7
8
9
10
11
12

2.2.3 启动类
@SpringBootApplication
// 开启Eureka服务端支持
@EnableEurekaServer
public class EurekaApplication {

public static void main(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>
1
2
3
4

修改 user 和 order 的 yml 文件

server:
port: 8081

spring:
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: 9091
spring:
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}")
public Order get(@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 版本！


免责申明：

本文系转载，版权归原作者所有，如若侵权请联系我们进行删除！

《数据治理行业实践白皮书》下载地址：https://fs80.cn/4w2atu

《数栈V6.0产品白皮书》下载地址：https://fs80.cn/cw0iw1

想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：https://www.dtstack.com/?src=bbs

同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：https://github.com/DTStack

0条评论
上一篇：MySQL和Navicat下载、安装及使用详细教程
下一篇：

社区公告

  • 大数据领域最专业的产品&技术交流社区，专注于探讨与分享大数据领域有趣又火热的信息，专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群
热门产品
数雁EasyDigit 数栈DTinsight 数驹DTengine 易知微EasyV
解决方案
政务解决方案 港口解决方案 基金解决方案 制造解决方案 保险解决方案 高校解决方案 证券解决方案 文旅解决方案 银行解决方案 大宗商品解决方案
快速入口
合作与生态 开源社区 Github
联系我们

合作咨询 market@dtstack.com

联系电话 400-002-1024

总部地址 杭州市余杭区余杭塘路2301号海智中心8号楼

袋鼠云官方订阅号
袋鼠云官方订阅号
热门搜索：
数据中台 企业数据中台 金融数据中台 离线数据中台 数据中台公司 一站式数据中台 数据中台开发 一站式数据开发 数据中台解决方案 大数据分析 数据分析平台 新基建 大数据开发 大数据开发平台 数据化转型解决方案 信创 数据可视化 数字孪生 可视化大屏 数字化转型

友情链接： 易知微 云掣

@Copyrights 2016-2023 杭州玳数科技有限公司 浙ICP备15044486号-1 浙公网安备33011002011932号