实用篇-Eureka注册中心

news/2025/3/6 2:05:40/

一、提供者与消费者

服务提供者：一次业务中，被其他微服务调用的服务。(提供接口给其他微服务)

服务消费者：一次业务中，调用其他微服务的服务。(调用其他微服务提供的接口)

例如前面的案例中，order-service微服务是服务提供者，user-service微服务是服务消费者

思考：

如果服务A调用服务B，服务B调用服务C，那么服务B是什么角色 ?

一个服务既可以是提供者，也可以是消费者。所以服务B相对于服务A而言，服务B是提供者。服务B相对于服务C而言，服务B是消费者

二、Eureka原理分析

以上面的案例为例，order-service微服务和user-service微服务之间，服务调用出现的问题如下:

  • order-service去向user-service发送请求，使用的是硬编码，也就是 "http://localhost:8081/user/"+order.getUserId();
  • 硬编码每次修改需要重新打包
  • 如果user-service微服务(提供者)部署成了多实例，形成集群来应对并发，那么order-service微服务(消费者)硬编码到底是写哪个实例的地址
  • 即使你知道这些实例的地址，那么如何挑选其中一台实例来使用呢

Eureka原理

  • Eureka架构中，微服务角色有两类，一个是EurekaServer叫做服务端(注册中心)。作用是记录服务信息，心跳监控；一个是EurekaClient叫做客户端，也就是服务的提供者/消费者
  • 可以把注册中心理解为Key，我们的微服务项目理解为Value，Eureka理解为字典
  • 当微服务项目(例如user-service)启动时，会主动把自己(user-service微服务)的信息注册给注册中心
  • 注册到注册中心的微服务会每隔30秒，向注册中心发起心跳，证明自己还在健康运行
  • 多个微服务的话，注册中心就会有多个Value，一个Value就是一个微服务的信息，这些Value会放到一个列表里面
  • 当其它微服务(例如order-service)要使用某个微服务(例如user-service)时，这个微服务(order-service就会向注册中心去拉取对应微服务(user-service)的信息
  • 当注册中心有多个提供者(微服务)，那么消费者是通过负载均衡算法，在注册中心的服务列表中挑选一个

三、搭建Eureka

步骤有三步：

1、搭建注册中心(EurekaServer)。搭建EurekaServer注册中心，也就是创建一个项目(在cloud-demo项目内部创建eureka-server项目)，把这个项目做成注册中心

2、服务注册。将user-service(前面导入的服务拆分Demo)、order-service(前面导入的服务拆分Demo)都注册到eureka

3、服务发现。在order-service中完成服务拉取，然后通过负载均衡挑选一个服务，实现远程调用

1. 搭建EurekaServer注册中心

第一步: 创建一个新的项目，作为独立的微服务，用于搭建Eureka，也就是在cloud-demo工程里面新建eureka-server微服务项目

第二步: 在eureka-server微服务的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"><parent><artifactId>cloud-demo</artifactId><groupId>cn.itcast.demo</groupId><version>1.0</version></parent><modelVersion>4.0.0</modelVersion><artifactId>eureka-server</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target></properties><!--添加注册中心的依赖坐标--><dependencies>
<!--        eureka服务端--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency></dependencies></project>

第三步: 在eureka-server微服务的src/main/java目录新建cn.itcast.eureka.EurekaApplication类，写入如下，注意加上@EnableEurekaServer注解，启动Eureka

package cn.itcast.eureka;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {public static void main(String[] args) {SpringApplication.run(EurekaApplication.class,args);}
}

第四步: 在eureka-server微服务的src/main/resources目录新建File，名字为application.yml，写入如下

server:# 服务端口port: 8686spring:application:# eureka的服务名称，因为eureka自己也是一个服务，也需要注册服务name: eurekaservereureka:client:service-url:# eureka的服务地址。如果有多个的话，逗号隔开defaultZone: http://localhost:8686/eureka

第五步: 启动eureka-server微服务。也就是运行EurekaApplication类，浏览器访问 http://localhost:8686 

2. 服务注册

这里我们实现把user-service和order-service注册到Eureka，只演示user-service

第一步：在user-service项目引入spring-cloud-start-netfix-eureka-client依赖，表示客户端

<!--引入Eureka客户端依赖-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

 第二步: 在user-service微服务的application.yml添加如下

spring:# Eureka相关配置application:# user的服务名称。也就是这个user-service注册到Eureka之后，这个user-service会叫什么名字name: userserviceeureka:client:service-url:# eureka的服务地址。如果有多个的话，逗号隔开。也就是把当前这个user-service微服务注册给哪个EurekadefaultZone: http://localhost:8686/eureka

 添加完后，user-service的application.yml文件如下，注意application是spring下的配置，要写在spring的下面

server:port: 8081
spring:datasource:url: jdbc:mysql://localhost:3306/cloud_user?useSSL=falseusername: rootpassword:driver-class-name: com.mysql.jdbc.Driver# Eureka相关配置application:# user的服务名称。也就是这个user-service注册到Eureka之后，这个user-service会叫什么名字name: UserService
mybatis:type-aliases-package: cn.itcast.user.pojoconfiguration:map-underscore-to-camel-case: true
logging:level:cn.itcast: debugpattern:dateformat: MM-dd HH:mm:ss:SSSeureka:client:service-url:# eureka的服务地址。如果有多个的话，逗号隔开。也就是把当前这个user-service微服务注册给哪个EurekadefaultZone: http://localhost:8686/eureka

同理，order-service也做相同操作，只是服务名修改一下 

第三步:

启动user-service。也就是运行UserApplication类，浏览器访问 http://localhost:8686，就可以看到user-service已经添加到Eureka里面

启动order-service。也就是运行OrderApplication类，浏览器访问 http://localhost:8686，就可以看到order-service已经添加到Eureka里面

当运行程序出现找不到或无法加载主类，可以尝试install一下maven工程，实在不行就全部删掉重新写一遍

IDEA复制服务实例 

上面我们启动了一个UserService服务实例，那么我们想再启动一个UserService实例，向Eureka注册多个服务，实现如下

第一步：右键服务然后点击复制配置 

第二步：设置服务名称和端口

 第三步：启动服务

第四步：打开Eureka注册中心，看到UserService的服务列表中增加了一个

也就是说，UserService的服务实例可以注册多个，当消费者想要获取服务时，可以通过负载均衡策略向服务实例发起请求 

3. 服务发现

服务发现也叫服务拉取，我们需要在order-service完成服务拉取。服务拉取是基于服务名称获取服务列表，然后再对服务列表做负载均衡

首先回想一下，前面的远程调用，我们实现了在订单项目(也就是现在的order-service微服务)去查询用户项目(也就是现在的user-service微服务)的案例需求

当时是在order-service里面使用url请求ip地址的方式，去请求user-service，从而获取user-service的用户信息

那么，学习了上面的Eureka之后，并且我们已经把order-service和user-service注册到注册中心(eureka-server)了，所以就可以在order-service里面，通过 '服务发现' 去获取user-service里面的用户信息

具体操作也非常简单，也是使用url请求的方式，但请求的路径不是ip，而是服务名称

代码实现

第一步: 在order-server微服务中的src/main/java/cn.itcast.order/service/OrderService类，修改访问的url路径，用服务名代替ip、端口。修改为如下

package cn.itcast.order.service;import cn.itcast.order.mapper.OrderMapper;
import cn.itcast.order.pojo.Order;
import cn.itcast.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;import java.sql.PreparedStatement;@Service
public class OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate RestTemplate restTemplate;public Order queryOrderById(Long orderId) {// 1.查询订单Order order = orderMapper.findById(orderId);//2.利用RestTemplate发起http请求，查询用户//2.1 url路径String url = "http://UserService:8081/user/" + order.getUserId();//这个方法第一个参数是访问路径，第二个参数是把响应得到的Json数据封装成实体类对象User user = restTemplate.getForObject(url, User.class);//3.封装user到Orderorder.setUser(user);// 4.返回return order;}
}

第二步: 负载均衡。在order-server微服务中的OrderApplication引导类修改为如下，主要是给RestTemplate加上@LoadBalanced注解

package cn.itcast.order;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}/*** 创建RestTemplate并注入Spring容器* @return*/@Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}}

第三步: 重新启动在order-server微服务的OrderApplication引导类，浏览器输入

http://localhost:8080/order/101，并向user-service微服务发送多次请求

总结：服务发现，就是将请求url中的ip地址替换成服务名称，然后根据负载均衡策略去调用服务


http://www.ppmy.cn/news/1184738.html

相关文章

Vue--》简易资金管理系统后台项目实战（前端）

Vue--》简易资金管理系统后台项目实战（前端）

今天开始使用 vue3 + ts + node 搭建一个简易资金管理系统的前后端分离项目，因为前后端分离所以会分两个专栏分别讲解前端与后端的实现，后端项目文章讲解可参考：后端链接，我会在前后端的两类专栏的最后一篇文章中会将项目代码开源到我的github上，大家可以自行去进行下载运…
阅读更多...
冥想第九百五十九天

冥想第九百五十九天

1.上午上了一上午日语课&#xff0c; 2.下去去西三环的拙艺园附近拉计时器。 3.之后送到黄河湿地公园&#xff0c;里边的人沟通协调不好&#xff0c;等到10点才回家&#xff0c;中间自己还借了铁丝&#xff0c;就近借。 4.回家后吃一碗泡面&#xff0c;大晚上的能量炸弹。 5.感…
阅读更多...
超市便利店小程序商城该是怎样的

超市便利店小程序商城该是怎样的

超市便利店的数量非常多&#xff0c;在人流聚集处和小区周边&#xff0c;线下店主要以周边客户为主&#xff0c;一般来说不会缺生意&#xff0c;但也不会有大的增长&#xff0c;线上电商冲击下&#xff0c;尤其是中大型超市或连锁&#xff0c;需要商家线上发展获得生意。 而除…
阅读更多...
多模态领域的先进模型

多模态领域的先进模型

多模态学习领域涌现了许多先进的模型&#xff0c;这些模型能够处理来自不同感官模态的信息并实现多模态任务。以下是一些先进的多模态学习模型&#xff1a; CLIP (Contrastive Language-Image Pretraining)&#xff1a;由OpenAI开发的CLIP是一种多模态预训练模型&#xff0c;能…
阅读更多...
JDK项目分析的经验分享

JDK项目分析的经验分享

基本类型的包装类（Character放在最后） String、StringBuffer、StringBuilder、StringJoiner、StringTokenizer（补充正则表达式的知识） CharacterIterator、StringCharacterIterator、CharsetProvider、CharsetEncoder、CharsetDecoder（较难） java.util.function下的函数表…
阅读更多...
C#__简单了解XML文档

C#__简单了解XML文档

/* XML(可扩展标记语言)&#xff1a;用于传输和存储数据 XML文档&#xff1a;树结构&#xff1b;包含根元素 XML元素&#xff1a;从开始标签到结束标签的部分 XML语法规则&#xff1a; 1、所有XML元素都必须有结束标签 …
阅读更多...
多进程间通信学习之有名管道

多进程间通信学习之有名管道

有名管道&#xff1a;区别于无名管道&#xff0c;其可以用于任意进程间的通信&#xff1b;同无名管道一样&#xff0c;也是半双工的通信方式&#xff1b;有名管道的大小也是64KB&#xff1b;也是不能使用lseek函数&#xff1b;其本质上&#xff0c;是在内存上&#xff0c;在文件…
阅读更多...
【2023年NCST C语言新生培训】| 五次培训总结 | C到C++内容补充 | 排位赛详细题解 |《万字长文》

【2023年NCST C语言新生培训】| 五次培训总结 | C到C++内容补充 | 排位赛详细题解 |《万字长文》

文章目录 一&#xff0c;四次培训总结1&#xff0c;第一次培训&#xff08; 培训介绍 Onilne Judge&#xff0c;编译语言&#xff0c;编译器的选择 )2&#xff0c;第二次培训1&#xff0c;本次培训安排2&#xff0c;基本的运算式结构 3&#xff0c;第三次培训1&#xff0c;选择…
阅读更多...
最新文章

Copyright @ 2022~2023