Eureka-注册中心

Eureka简介

官方网址&＃xff1a;

https://spring.io/projects/spring-cloud-netflix

Eureka介绍

Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务注册和发现(请对比Zookeeper)。Zooleeper nacos.

Eureka 采用了 C-S 的设计架构。Eureka Server 作为服务注册功能的服务器&＃xff0c;它是服务注册中心。而系统中的其他微服务&＃xff0c;使用 Eureka 的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。SpringCloud 的一些其他模块&＃xff08;比如Zuul&＃xff09;就可以通过 Eureka Server 来发现系统中的其他微服务&＃xff0c;并执行相关的逻辑。

Eureka包含两个组件&＃xff1a;Eureka Server和Eureka Client

Eureka Server提供服务注册服务

各个节点启动后&＃xff0c;会在EurekaServer中进行注册&＃xff0c;这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息&＃xff0c;服务节点的信息可以在界面中直观的看到EurekaClient是一个Java客户端&＃xff0c;用于简化Eureka Server的交互&＃xff0c;客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后&＃xff0c;将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳&＃xff0c;EurekaServer将会从服务注册表中把这个服务节点移除&＃xff08;默认90秒&＃xff09;

Eureka基本原理

基本原理

上图是来自eureka的官方架构图&＃xff0c;这是基于集群配置的eureka&＃xff1b;

- 处于不同节点的eureka通过Replicate进行数据同步

- Application Service为服务提供者

- Application Client为服务消费者

- Make Remote Call完成一次服务调用

服务启动后向Eureka注册&＃xff0c;Eureka Server会将注册信息向其他Eureka Server进行同步&＃xff0c;当服务消费者要调用服务提供者&＃xff0c;则向服务注册中心获取服务提供者地址&＃xff0c;然后会将服务提供者地址缓存在本地&＃xff0c;下次再调用时&＃xff0c;则直接从本地缓存中取&＃xff0c;完成一次调用。

当服务注册中心Eureka Server检测到服务提供者因为宕机、网络原因不可用时&＃xff0c;则在服务注册中心将服务置为DOWN状态&＃xff0c;并把当前服务提供者状态向订阅者发布&＃xff0c;订阅过的服务消费者更新本地缓存。

服务提供者在启动后&＃xff0c;周期性&＃xff08;默认30秒&＃xff09;向Eureka Server发送心跳&＃xff0c;以证明当前服务是可用状态。Eureka Server在一定的时间&＃xff08;默认90秒&＃xff09;未收到客户端的心跳&＃xff0c;则认为服务宕机&＃xff0c;注销该实例。

eureka搭建

四个子项目作用如下&＃xff1a;

①EurekaService&＃xff1a;Eureka服务中心子项目&＃xff0c;作用是作为Eureka服务程序&＃xff0c;管理其他微服务的状态。其他Eureka客户端子项目运行时需在此模块进行注册。

②ServiceOne&＃xff1a;Eureka客户端-微服务1&＃xff0c;提供了一个业务接口“serviceOne”。

③ServiceTwo&＃xff1a;Eureka客户端-微服务2&＃xff0c;提供了一个业务接口“serviceTwo”。

④ServiceThree&＃xff1a;Eureka客户端-微服务3&＃xff0c;提供了两个业务接口&＃xff1a;

“serviceThree_toOne”&＃xff1a;内部调用ServiceOne的“serviceOne接口”

“serviceThree_toTwo”&＃xff1a;内部调用ServiceTwo的“serviceTwo接口”

新建SpringCloud父项目

1.新建基于Maven的项目

作为SpringCloud其他子模块的父项目&＃xff0c;new->Project&＃xff0c;选择基于Maven的项目&＃xff0c;填入GroupId和AtrifactId&＃xff08;项目名称&＃xff09;然后创建。

2.父项目不需要写源码&＃xff0c;所以删除项目的src文件夹。

3.配置父项目pom.xml中需增加的内容&＃xff1a;


1.82021.0.31.2.47


org.springframework.bootspring-boot-starter-parent2.6.8

org.springframework.cloudspring-cloud-dependencies${spring-cloud.version}pomimportcom.alibabafastjson${fastjson.version}

org.springframework.bootspring-boot-maven-plugin


新建Eureka服务中心模块

Eureka服务中心子项目&＃xff0c;作用是作为Eureka服务程序&＃xff0c;管理其他微服务的状态。

1.在父项目中&＃xff0c;新建子模块项目&＃xff1a;new->Module依然选择maven项目。

Eureka服务中心项目名称我们命名为EurekaService。

配置文件

1. Eureka的pom.xml中新增对Eureka的依赖包和maven打包插件&＃xff1a;

org.springframework.cloudspring-cloud-starter-netflix-eureka-server
org.springframework.bootspring-boot-starter-web


配置Eureka服务中心的application.yml配置文件

下面是文字版本的&＃xff0c;便于拷贝

server:
port: 8001

eureka:
instance:
hostname: 127.0.0.1
client:
#由于该应用为注册中心&＃xff0c;所以设置为false&＃xff0c;代表不向注册中心注册自己
register-with-eureka: false
#由于注册中心的职责是维护服务器示例&＃xff0c;它不需要去检索服务&＃xff0c;所以设置为false
fetch-registry: false
service-url:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka
spring:
application:
name: service-eureka

主类main方法&＃xff1a;

创建三个微服务子模块并注册为Eureka客户端

创建三个Eureka客户端子项目

我们创建3个Eureka客户端子项目&＃xff0c;命名为ServiceOne、ServiceTwo、ServiceThree。它们的配置都基本一致。

①ServiceOne&＃xff1a;在Eureka中注册为客户端&＃xff0c;提供一个业务接口&＃xff1a;http://127.0.0.1:8001/serviceOne

②ServiceTwo&＃xff1a;在Eureka中注册为客户端&＃xff0c;提供一个业务接口&＃xff1a;http://127.0.0.1:8002/serviceTwo

③ServiceThree&＃xff1a;在Eureka中注册为客户端&＃xff0c;提供两个业务接口&＃xff08;内部调用ServiceOne和ServiceTwo的接口&＃xff09;&＃xff1a;

http://127.0.0.1:8003/serviceThree_toOne

http://127.0.0.1:8003/serviceThree_toTwo

配置Eureka客户端子项目的pom.xml

三个子项目pom.xml的依赖包完全一致&＃xff1a;

org.springframework.cloud
spring-cloud-starter-netflix-eureka-client


org.springframework.boot
spring-boot-starter-web


com.alibaba
fastjson

配置三个子项目的application.yml

三个子项目的application.yml配置文件基本一样&＃xff1a;

1. ServiceOne的application.yml

2. ServiceTwo的application.yml

3. ServiceThree的application.yml

三个子项目的主类main方法

1. ServiceOne的主类&＃xff08;与ServiceTwo基本一致&＃xff09;

2. ServiceTwo的主类(与ServiceOne基本一致&＃xff09;

3. ServiceThree的主类&＃xff0c;略有不同&＃xff0c;需配置RestTemplate的Bean

三个子项目的Controller控制器

1. ServiceOne的控制器&＃xff08;与ServiceTwo基本一致&＃xff09;

2. ServiceTwo的控制器(与ServiceOne基本一致&＃xff09;

3. ServiceThree的控制器

与前两个略有不同&＃xff0c;需注入主类配置的RestTemplate&＃xff0c;通过它内部调用微服务ServiceOne和ServiceTwo的业务接口

package com.tjetc.controller;import com.alibaba.fastjson.JSONObject;
import com.netflix.discovery.converters.Auto;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;&＃64;RestControllerpublic class ServiceThreeController {&＃64;Autowiredprivate RestTemplate restTemplate;/*** http请求serviceOne的url并接收返回值* &＃64;return*/&＃64;RequestMapping("serviceThree_toOne")public JSONObject serviceThreeToOne() {//restTemplate发出get请求String result &＃61; restTemplate.getForObject("http:127.0.0.1:8001/serviceOne", String.class);JSONObject jsonObject &＃61; new JSONObject();jsonObject.put("code", "200");jsonObject.put("msg", "service three to one, return msg");jsonObject.put("data", result);return jsonObject;}&＃64;RequestMapping("serviceThree_toTwo")public JSONObject serviceThreeToTwo() {String result &＃61; restTemplate.getForObject("http:127.0.0.1:8002/serviceTwo", String.class);JSONObject jsonObject &＃61; new JSONObject();jsonObject.put("code", "200");jsonObject.put("msg", "service three to two, return msg");jsonObject.put("data", result);return jsonObject;}&＃64;RequestMapping("serviceThree")public JSONObject serviceThree() {JSONObject jsonObject &＃61; new JSONObject();jsonObject.put("code", "200");jsonObject.put("msg", "service three, return msg");return jsonObject;}
}

结果验证

1.按顺序启动各个子项目

先启动EurekaService子项目&＃xff0c;它是Eureka服务器&＃xff0c;其他子模块都需作为Eureka客户端在它上面进行注册&＃xff01;

再启动ServiceOne、ServiceTwo和ServiceThree&＃xff0c;启动后如下图&＃xff1a;

2.进入Eureka服务状态页面&＃xff0c;查看服务注册情况

在谷歌浏览器中输入&＃xff1a;http://127.0.0.1:8000/&＃xff0c;进入Eureka服务页面&＃xff0c;我们主要查看当前注册情况&＃xff1a;

如上图所示&＃xff0c;三个Eureka客户端子项目都注册成功。

3.验证ServiceOne的接口

在浏览器地址栏或者PostMan中请求ServiceOne的接口地址http://127.0.0.1:8001/serviceOne&＃xff0c;验证请求结果&＃xff1a;

5.验证ServiceThree包装的接口

在浏览器地址栏或者PostMan中请求ServiceThree的两个接口地址。

①http://127.0.0.1:8003/serviceThree_toOne&＃xff0c;验证请求结果&＃xff1a;

如上图所示&＃xff0c;其内部成功的调用了ServiceOne提供的接口。

②http://127.0.0.1:8003/serviceThree_toTwo&＃xff0c;验证请求结果&＃xff1a;

如上图所示&＃xff0c;其内部成功的调用了ServiceTwo提供的接口。

Ribbon-负载均衡

Ribbon简介

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。

简单的说&＃xff0c;Ribbon是Netflix发布的开源项目&＃xff0c;主要功能是提供客户端的软件负载均衡算法&＃xff0c;将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时&＃xff0c;重试等。简单的说&＃xff0c;就是在配置文件中列出Load Balancer&＃xff08;简称LB&＃xff09;后面所有的机器&＃xff0c;Ribbon会自动的帮助你基于某种规则&＃xff08;如简单轮询&＃xff0c;随机连接等&＃xff09;去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

LB&＃xff0c;即负载均衡(Load Balance)&＃xff0c;在微服务或分布式集群中经常用的一种应用。

负载均衡简单的说就是将用户的请求平摊的分配到多个服务上&＃xff0c;从而达到系统的HA。

常见的负载均衡有软件Nginx&＃xff0c;LVS&＃xff0c;硬件 F5等。

相应的在中间件&＃xff0c;例如&＃xff1a;dubbo和SpringCloud中均给我们提供了负载均衡&＃xff0c;SpringCloud的负载均衡算法可以自定义。

Ribbon在工作时分成两步&＃xff1a;

第一步先选择 EurekaServer ,它优先选择在同一个区域内负载较少的server.

第二步再根据用户指定的策略&＃xff0c;在从server取到的服务注册列表中选择一个地址。

其中Ribbon提供了多种策略&＃xff1a;比如轮询、随机和根据响应时间加权。

Ribbon代码编写

模仿ServiceOne子项目“复制”出ServiceOneCopy子项目

在上面eureka项目中&＃xff0c;把service1的项目复制一下&＃xff0c;取名ServiceOneCopy.ServiceOneCopy的作用是对ServiceOne提供的业务进行分流&＃xff0c;因此我们把ServiceOne中的所有内容全部复制到新项目中一份&＃xff0c;包括&＃xff1a;pom.xml、application.yml、SpringBoot应用主类“ServiceOneApplication”和业务控制器“ServiceOneController”&＃xff1a;然后再做接下来的修改。

修改application.yml

ServiceOne中也作了说明&＃xff1a;由于在ServiceThree中开启了ribbon负载均衡后&＃xff0c;需要通过ServiceOne的“应用名称”而不是IP&＃43;端口号访问业务接口&＃xff0c;因此我们要把需要负载均衡的业务模块&＃xff0c;其应用名称保持一致&＃xff01;

注意&＃xff0c;改下端口&＃xff0c;改成8004

修改SpringBoot应用主类名称

在idea中直接运行项目时&＃xff0c;会按主类的名称作为SpringBoot启动栏目的名称&＃xff0c;因此我们需要把主类名称修改一下&＃xff0c;我们修改为&＃xff1a;“ServiceOneCopyApplication”。

修改业务接口的响应结果

我们要分流ServiceOne的业务方法“serviceOne”&＃xff0c;因此方法本身不能做改变&＃xff08;方法名、参数、返回结果格式&＃xff09;&＃xff0c;但为了验证分流的结果&＃xff0c;我们在返回的响应结果中增加了“copy”字样文字&＃xff1a;

http://127.0.0.1:8004/serviceOne

http://127.0.0.1:8000/

修改ServiceThree子项目

我们需要在ServiceThree中开启ribbon的负载均衡功能&＃xff0c;由于ribbon依赖包已被Eureka引用&＃xff0c;因此我们无需引入任何新依赖包&＃xff0c;所以不需要修改pom.xml文件。

application.yml文件也不做任何修改。

下面对需要修改的两处进行说明&＃xff1a;

1. 修改SpringBoot应用主类&＃xff0c;提供负载均衡能力

我们在“ServiceThreeApplication”主类中&＃xff0c;给RestTemplate的Bean方法上添加&＃64;LoadBalanced注解&＃xff0c;给RestTemplate对象开启ribbon负载均衡能力。

之后RestTemplate发送请求时&＃xff0c;就会自动进行请求的分流。

2. 修改请求其他内部业务接口的调用方式

由于需要对某一业务接口“负载均衡”&＃xff0c;那么我们就不能再使用原先的IP&＃43;端口号的方式调用了&＃xff0c;否则还是会把请求指定到一个部署的服务中。

ribbon的负载均衡是通过使用“应用程序名”来代替IP&＃43;端口号&＃xff0c;来调用业务接口的。

因此我们需要在控制器中修改调用ServieOne的业务接口方式&＃xff1a;

从&＃xff1a;http://127.0.0.1:8001/serviceOne

修改为&＃xff1a;http://service-one/serviceOne

结果验证

1. 按顺序启动各个子项目

先启动EurekaService子项目&＃xff0c;它是Eureka服务器&＃xff0c;其他子模块都需作为Eureka客户端在它上面进行注册&＃xff01;

再启动ServiceOne、ServiceOneCopy、ServiceTwo和ServiceThree&＃xff0c;启动后如下图&＃xff1a;

2. 进入Eureka服务状态页面&＃xff0c;查看服务注册情况

在谷歌浏览器中输入&＃xff1a;http://127.0.0.1:8000/&＃xff0c;进入Eureka服务页面&＃xff0c;我们主要查看当前注册情况&＃xff1a;

如上图所示&＃xff0c;名为“service-one”的微服务&＃xff0c;在Eureka中注册数量为2&＃xff0c;一个是ServiceOne启动的实例、另一个是ServiceOneCopy启动的实例。

3. 验证ServiceThree的接口&＃xff0c;验证负载均衡情况

在浏览器地址栏或者PostMan中重复请求ServiceThree的接口地址&＃xff1a;

http://127.0.0.1:8003/serviceThree_toOne

第一次调用&＃xff1a;

第二次调用&＃xff1a;

如上图所示&＃xff0c;其内部成功的调用了ServiceOne提供的接口&＃xff0c;并负载均衡分流至了两个模块&＃xff01;

参考文章&＃xff1a;

https://blog.csdn.net/weixin_45701868/article/details/125738876