目录
一、Springcloud
1.1 springcloud简介
二、Eureka
2.1 Eureka简介
2.1.1 Eureka介绍
2.1.2 Eureka基本原理
2.1.3 Eureka 官方文档地址
2.2Eureka代码编写
2.2.1 总体说明
2.2.2 新建SpringCloud父项目
2.2.3 新建Eureka服务中心模块
2.2.4 创建三个微服务子模块并注册为Eureka客户端
2.2.5 结果验证
三、Ribbon
3.1 Ribbon简介
3.2 Ribbon代码编写
3.2.1总体说明
3.2.2新建ServiceOneCopy子项目
3.2.3修改ServiceThree子项目
3.2.4结果验证
一、Springcloud
1.1 springcloud简介
SpringCloud（Spring Cloud），基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控，服务网关，负载均衡，熔断器等组件，除了基于NetFlix的开源组件做高度抽象封装之外，还有一些选型中立的开源组件。
SpringCloud利用SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发，SpringCloud为开发人员提供了快速构建分布式系统的一些工具，包括配置管理、服务发现、断路器、路由、微代理、事件总线、全局锁、决策竞选、分布式会话等等,它们都可以用SpringBoot的开发风格做到一键启动和部署。
SpringCloud并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过SpringBoot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。
二、Eureka
2.1 Eureka简介
2.1.1 Eureka介绍
2.1.1 Eureka介绍
Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务注册和发现(请对比Zookeeper)。Zooleeper nacos.
Eureka 采用了 C-S 的设计架构。Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka 的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。SpringCloud 的一些其他模块（比如Zuul）就可以通过 Eureka Server 来发现系统中的其他微服务，并执行相关的逻辑。
Eureka包含两个组件：Eureka Server和Eureka Client
Eureka Server提供服务注册服务
各个节点启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到EurekaClient是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）
2.1.2 Eureka基本原理
基本原理
上图是来自eureka的官方架构图，这是基于集群配置的eureka；
- 处于不同节点的eureka通过Replicate进行数据同步
- Application Service为服务提供者
- Application Client为服务消费者
- Make Remote Call完成一次服务调用
服务启动后向Eureka注册，Eureka Server会将注册信息向其他Eureka Server进行同步，当服务消费者要调用服务提供者，则向服务注册中心获取服务提供者地址，然后会将服务提供者地址缓存在本地，下次再调用时，则直接从本地缓存中取，完成一次调用。
当服务注册中心Eureka Server检测到服务提供者因为宕机、网络原因不可用时，则在服务注册中心将服务置为DOWN状态，并把当前服务提供者状态向订阅者发布，订阅过的服务消费者更新本地缓存。
服务提供者在启动后，周期性（默认30秒）向Eureka Server发送心跳，以证明当前服务是可用状态。Eureka Server在一定的时间（默认90秒）未收到客户端的心跳，则认为服务宕机，注销该实例。
2.1.3 Eureka 官方文档地址
https://spring.io/projects/spring-cloud-netflix
2.2Eureka代码编写
2.2.1 总体说明
本项目总体上为一个分步骤编写完成SpringCloud微服务开发项目的示例程序，使用了Eureka服务注册（第一步）、Ribbon请求负载均衡（第二步）和SpringCloud Gateway微服务网关（第三步）、Feign完成统一服务接口调用（第四步）。
本案例说明为第一步：搭建SpringCloud项目，完成Eureka服务器、客户端子项目注册并提供各自的服务。
本案例在idea中创建了一个父项目和四个子项目，父项目为微服务项目的总体管理模块，在其中统一引入SpringBoot、SpringCloud所需要的依赖包，并统一设置打包插件。
四个子项目作用如下：
①EurekaService：Eureka服务中心子项目，作用是作为Eureka服务程序，管理其他微服务的状态。其他Eureka客户端子项目运行时需在此模块进行注册。
②ServiceOne：Eureka客户端-微服务1，提供了一个业务接口“serviceOne”。
③ServiceTwo：Eureka客户端-微服务2，提供了一个业务接口“serviceTwo”。
④ServiceThree：Eureka客户端-微服务3，提供了两个业务接口：
“serviceThree_toOne”：内部调用ServiceOne的“serviceOne接口”
“serviceThree_toTwo”：内部调用ServiceTwo的“serviceTwo接口”
2.2.2 新建SpringCloud父项目
1.新建基于Maven的项目
作为SpringCloud其他子模块的父项目，new->Project，选择基于Maven的项目，填入GroupId和AtrifactId（项目名称）然后创建。
2.父项目不需要写源码，所以删除项目的src文件夹。
3.配置父项目pom.xml中需增加的内容：
1.8 2021.0.3 1.2.47 org.springframework.boot spring-boot-starter-parent2.6.8 org.springframework.cloud spring-cloud-dependencies${spring-cloud.version} pom import com.alibaba fastjson${fastjson.version} org.springframework.boot spring-boot-maven-plugin
2.2.3 新建Eureka服务中心模块
Eureka服务中心子项目，作用是作为Eureka服务程序，管理其他微服务的状态。
1.在父项目中，新建子模块项目：new->Module依然选择maven项目。
Eureka服务中心项目名称我们命名为EurekaService。
2.Eureka的pom.xml中新增对Eureka的依赖包和maven打包插件：
org.springframework.cloud spring-cloud-starter-netflix-eureka-serverorg.springframework.boot spring-boot-starter-web
3.配置Eureka服务中心的application.yml配置文件
4.主类main方法：
2.2.4 创建三个微服务子模块并注册为Eureka客户端
1.创建三个Eureka客户端子项目
我们创建3个Eureka客户端子项目，命名为ServiceOne、ServiceTwo、ServiceThree。它们的配置都基本一致。
①ServiceOne：在Eureka中注册为客户端，提供一个业务接口：http://127.0.0.1:8001/serviceOne
②ServiceTwo：在Eureka中注册为客户端，提供一个业务接口：http://127.0.0.1:8002/serviceTwo
③ServiceThree：在Eureka中注册为客户端，提供两个业务接口（内部调用ServiceOne和ServiceTwo的接口）：
http://127.0.0.1:8003/serviceThree_toOne
http://127.0.0.1:8003/serviceThree_toTwo
2.配置Eureka客户端子项目的pom.xml
三个子项目pom.xml的依赖包完全一致：
org.springframework.cloud spring-cloud-starter-netflix-eureka-clientorg.springframework.boot spring-boot-starter-webcom.alibaba fastjson
3.配置三个子项目的application.yml
三个子项目的application.yml配置文件基本一样：
1)ServiceOne的application.yml
2)ServiceTwo的application.yml
3)ServiceThree的application.yml
4.三个子项目的主类main方法
1)ServiceOne的主类（与ServiceTwo基本一致）
2)ServiceTwo的主类(与ServiceOne基本一致）
3)ServiceThree的主类，略有不同，需配置RestTemplate的Bean
5.三个子项目的Controller控制器
1)ServiceOne的控制器（与ServiceTwo基本一致）
2)ServiceTwo的控制器(与ServiceOne基本一致）
3)ServiceThree的控制器
与前两个略有不同，需注入主类配置的RestTemplate，通过它内部调用微服务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;
@RestController
public class ServiceThreeController {
@Autowired
private RestTemplate restTemplate;
@RequestMapping("serviceThree_toOne")
public JSONObject serviceThreeToOne() {
//restTemplate发出get请求
String result = restTemplate.getForObject("http:127.0.0.1:8001/serviceOne", String.class);
JSONObject jsonObject = new JSONObject();
jsonObject.put("code", "200");
jsonObject.put("msg", "service three to one, return msg");
jsonObject.put("data", result);
return jsonObject;
}
@RequestMapping("serviceThree_toTwo")
public JSONObject serviceThreeToTwo() {
String result = restTemplate.getForObject("http:127.0.0.1:8002/serviceTwo", String.class);
JSONObject jsonObject = new JSONObject();
jsonObject.put("code", "200");
jsonObject.put("msg", "service three to two, return msg");
jsonObject.put("data", result);
return jsonObject;
}
@RequestMapping("serviceThree")
public JSONObject serviceThree() {
JSONObject jsonObject = new JSONObject();
jsonObject.put("code", "200");
jsonObject.put("msg", "service three, return msg");
return jsonObject;
}
}
2.2.5 结果验证
1.按顺序启动各个子项目
先启动EurekaService子项目，它是Eureka服务器，其他子模块都需作为Eureka客户端在它上面进行注册！
再启动ServiceOne、ServiceTwo和ServiceThree，启动后如下图：
2.进入Eureka服务状态页面，查看服务注册情况
在谷歌浏览器中输入：http://127.0.0.1:8000/，进入Eureka服务页面，我们主要查看当前注册情况：
如上图所示，三个Eureka客户端子项目都注册成功。
3.验证ServiceOne的接口
在浏览器地址栏或者PostMan中请求ServiceOne的接口地址http://127.0.0.1:8001/serviceOne，验证请求结果：
4.验证ServiceTwo的接口
在浏览器地址栏或者PostMan中请求ServiceTwo的接口地址http://127.0.0.1:8002/serviceTwo，验证请求结果：
5.验证ServiceThree包装的接口
在浏览器地址栏或者PostMan中请求ServiceThree的两个接口地址。
①http://127.0.0.1:8003/serviceThree_toOne，验证请求结果：
如上图所示，其内部成功的调用了ServiceOne提供的接口。
②http://127.0.0.1:8003/serviceThree_toTwo，验证请求结果：
如上图所示，其内部成功的调用了ServiceTwo提供的接口。
三、Ribbon
3.1 Ribbon简介
Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。
简单的说，Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。
LB，即负载均衡(Load Balance)，在微服务或分布式集群中经常用的一种应用。
负载均衡简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA。
常见的负载均衡有软件Nginx，LVS，硬件 F5等。
相应的在中间件，例如：dubbo和SpringCloud中均给我们提供了负载均衡，SpringCloud的负载均衡算法可以自定义。
Ribbon在工作时分成两步：
第一步先选择 EurekaServer ,它优先选择在同一个区域内负载较少的server.
第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。
其中Ribbon提供了多种策略：比如轮询、随机和根据响应时间加权。
3.2 Ribbon代码编写
3.2.1总体说明
本项目总体上为一个分步骤编写完成SpringCloud微服务开发项目的示例程序，使用了Eureka服务注册（第一步）、Ribbon请求负载均衡（第二步）和SpringCloud Gateway微服务网关（第三步）、Feign完成统一服务接口调用（第四步）。
本案例说明为第二步：在第一步完成的基础上，使用ribbon的负载均衡功能，调用ServiceOne的serviceOne接口时，会被“分流”。
本案例在第一步案例基础上，修改了部分配置文件和代码，并新建了用于承担负载分流的接口请求的微服务。我们“复制”了原有的ServiceOne微服务子项目，创建出ServiceOneCopy微服务子项目，有变化的内容如图：
注意：由于Eureka的包已经引用了ribbon依赖包，因此本例无需新增依赖项！
3.2.2新建ServiceOneCopy子项目
我们为了验证ribbon的负载均衡功能，需要新建一个用于“业务分流”的子模块，因此我们在此新建一个ServiceOne的分流程序。
1.在父项目中，新建子模块项目：new->Module依然选择maven项目。
本项目名称我们命名为ServiceOneCopy。
2.模仿ServiceOne子项目“复制”出ServiceOneCopy子项目
ServiceOneCopy的作用是对ServiceOne提供的业务进行分流，因此我们把ServiceOne中的所有内容全部复制到新项目中一份，包括：pom.xml、application.yml、SpringBoot应用主类“ServiceOneApplication”和业务控制器“ServiceOneController”：然后再做接下来的修改。
3.修改application.yml
ServiceOne中也作了说明：由于在ServiceThree中开启了ribbon负载均衡后，需要通过ServiceOne的“应用名称”而不是IP+端口号访问业务接口，因此我们要把需要负载均衡的业务模块，其应用名称保持一致！
4.修改SpringBoot应用主类名称
在idea中直接运行项目时，会按主类的名称作为SpringBoot启动栏目的名称，因此我们需要把主类名称修改一下，我们修改为：“ServiceOneCopyApplication”。
5.修改业务接口的响应结果
我们要分流ServiceOne的业务方法“serviceOne”，因此方法本身不能做改变（方法名、参数、返回结果格式），但为了验证分流的结果，我们在返回的响应结果中增加了“copy”字样文字：
3.2.3修改ServiceThree子项目
我们需要在ServiceThree中开启ribbon的负载均衡功能，由于ribbon依赖包已被Eureka引用，因此我们无需引入任何新依赖包，所以不需要修改pom.xml文件。
application.yml文件也不做任何修改。
下面对需要修改的两处进行说明：
1.修改SpringBoot应用主类，提供负载均衡能力
我们在“ServiceThreeApplication”主类中，给RestTemplate的Bean方法上添加@LoadBalanced注解，给RestTemplate对象开启ribbon负载均衡能力。
之后RestTemplate发送请求时，就会自动进行请求的分流。
2.修改请求其他内部业务接口的调用方式
由于需要对某一业务接口“负载均衡”，那么我们就不能再使用原先的IP+端口号的方式调用了，否则还是会把请求指定到一个部署的服务中。
ribbon的负载均衡是通过使用“应用程序名”来代替IP+端口号，来调用业务接口的。
因此我们需要在控制器中修改调用ServieOne的业务接口方式：
从：http://127.0.0.1:8001/serviceOne
修改为：http://service-one/serviceOne
3.2.4结果验证
1.按顺序启动各个子项目
先启动EurekaService子项目，它是Eureka服务器，其他子模块都需作为Eureka客户端在它上面进行注册！
再启动ServiceOne、ServiceOneCopy、ServiceTwo和ServiceThree，启动后如下图：
2.进入Eureka服务状态页面，查看服务注册情况
在谷歌浏览器中输入：http://127.0.0.1:8000/，进入Eureka服务页面，我们主要查看当前注册情况：
如上图所示，名为“service-one”的微服务，在Eureka中注册数量为2，一个是ServiceOne启动的实例、另一个是ServiceOneCopy启动的实例。
3.验证ServiceThree的接口，验证负载均衡情况
在浏览器地址栏或者PostMan中重复请求ServiceThree的接口地址：
http://127.0.0.1:8003/serviceThree_toOne
第一次调用：
第二次调用：
如上图所示，其内部成功的调用了ServiceOne提供的接口，并负载均衡分流至了两个模块！
