Spring Cloud Eureka & Spring Cloud Feign
发布日期:2021-06-29 11:14:41 浏览次数:2 分类:技术文章

本文共 5599 字,大约阅读时间需要 18 分钟。

什么是Spring Cloud

Spring Cloud 是一系列框架的有序集合。Spring Cloud 并没有重复制造轮子,它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来,通过 Spring Boot 风格进行再封装屏蔽掉了复杂的配置和实现原理,最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。

Spring Cloud 和 Spring Boot 的关系

Spring Boot 是 Spring 的一套快速配置脚手架,可以基于 Spring Boot 快速开发单个微服务,Spring Cloud 是一个基于Spring Boot 实现的云应用开发工具。Spring Boot 专注于快速、方便集成的单个微服务个体,Spring Cloud 关注全局的服务治理框架。

Spring Boot 使用了默认大于配置的理念,很多集成方案已经帮你选择好了,能不配置就不配置,Spring Cloud 很大的一部分是基于 Spring Boot 来实现,可以不基于 Spring Boot 吗?不可以。
Spring Boot 可以离开 Spring Cloud 独立使用开发项目,但是 Spring Cloud 离不开 Spring Boot,属于依赖的关系。

Spring Cloud 中的主要框架

  • 服务发现(Netflix Eureka)
  • 服务调用(Netflix Feign)
  • 熔断器(Netflix Hystrix):假如三个服务器,A->B->C,但是突然 B->C 调不通了, 如果不加以措施控制的话,整个服务将雪崩,而熔断器的作用就是,虽然 B->C 调不通了,但是可以保证 B 服务器可以正常给 A 返回,比如“B服务器暂时不可用”,而不至于报错
  • 服务网关(Netflix Zuul):因为每一个微服务的端口都不相同,服务网关的作用就是可以保证前端调用后台的时候,走统一的IP地址和端口,然后再分发到各微服务
  • 分布式配置(Spring Cloud Config):把各微服务的配置文件放到一个统一的地方,方便修改。每次修改配置文件里的内容的时候,不用将程序重新打包。
  • 消息总线 (Spring Cloud Bus):在分布式配置的基础上,修改了配置文件的内容,不需要重启服务器。

Spring Cloud 和 Dubbo 的对比

或许很多人会说 Spring Cloud 和 Dubbo 的对比有点不公平,Dubbo 只是实现了服务治理,而Spring Cloud 下面有17个子项目(可能还会新增)分别覆盖了微服务架构下的方方面面,服务治理只是其中的一个方面,一定程度来说,Dubbo 只是 Spring Cloud Netflix 中的一个子集。

在这里插入图片描述

Spring Cloud 和 Spring Boot 对应的版本

在这里插入图片描述

如果版本不对应,程序就无法运行

Spring Cloud Eureka

介绍

  Eureka 是 Netflix 开发的服务发现框架,Spring Cloud 将它集成在自己的子项目 spring-cloud-netflix 中,实现 Spring Cloud 的服务发现功能。Eureka 包含两个组件:Eureka Server 和 Eureka Client。

  Eureka Server 提供服务注册服务,各个节点启动后,会在 Eureka Server 中进行注册,这样Eureka Server 中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。
  Eureka Client 是一个 java 客户端,用于简化与 Eureka Server 的交互,客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后,将会向 Eureka Server 发送心跳,默认周期为 30 秒,如果 Eureka Server 在多个心跳周期内没有接收到某个节点的心跳,Eureka Server 将会从服务注册表中把这个服务节点移除(默认90秒,3个周期)。
  Eureka Server 之间通过复制的方式完成数据的同步,Eureka 还提供了客户端缓存机制,即使所有的 Eureka Server 都挂掉,客户端依然可以利用缓存中的信息消费其他服务的 API。综上,Eureka 通过心跳检查、客户端缓存等机制,确保了系统的高可用性、灵活性和可伸缩性。

Eureka 服务端

1)在父工程中锁定 Spring Cloud 的版本

org.springframework.cloud
spring-cloud-dependencies
Finchley.M9
pom
import

2)在 Eureka 服务端的 pom 文件中导入坐标

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

3)添加 application.yml

server:  port: 6868eureka:  client:    register-with-eureka: false #是否将自己注册到 Eureka 服务中,因为本身就是服务端,所以无需注册    fetch-registry: false       #是否从 Eureka 中获取注册信息    service-url:      defaultZone: http://127.0.0.1:${
server.port}/eureka/ #Eureka客户端与服务端进行交互的地址

4)编写启动类

@SpringBootApplication@EnableEurekaServerpublic class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class); }}

5)启动运行启动类,然后在浏览器地址栏输入 运行效果如下:

在这里插入图片描述
主界面中:system status为系统信息 、General Info为一般信息、 Instances currently registered with Eureka为注册到的所有微服务列表

Eureka Server 的保护模式

如果在Eureka Server的首页看到以下这段提示,则说明Eureka已经进入了保护模式:

在这里插入图片描述
Eureka Server在运行期间,会统计心跳失败的比例在15分钟之内是否低于85%,如果出现低于的情况(在单机调试的时候很容易满足,实际在生产环境上通常是由于网络不稳定导致),Eureka Server会将当前的实例注册信息保护起来,同时提示这个警告。保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。一旦进入保护模式,Eureka Server将会尝试保护其服务注册表中的信息,不再删除服务注册表中的数据(也就是不会注销任何微服务)。

Eureka 客户端

1)在 pom 文件中引入坐标

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

2)修改 application.yml

eureka:  client:    service-url:      defaultZone: http://127.0.0.1:6868/eureka/  instance:    prefer-ip-address: true #使用IP注册微服务,而不是主机名,便于微服务之间跨域访问

3)启动类添加注解

@SpringBootApplication@EnableEurekaClientpublic class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class, args); }}

4)启动后,就会在 eureka 的注册列表看见这些微服务

Spring Cloud Feign

作用:用于微服务之间的调用

1)在 pom 文件中引入坐标(谁调用谁引入)

org.springframework.cloud
spring-cloud-starter-openfeign

2)修改启动类,再加 2 个注解

@SpringBootApplication@EnableEurekaClient// 新添加的 2 个注解@EnableDiscoveryClient@EnableFeignClientspublic class FriendApplication {
public static void main(String[] args) {
SpringApplication.run(FriendApplication.class); }}

3)在调用者服务下创建一个包,包中创建接口。将被调用的微服务的 controller 中的方法复制过来,无需方法体。

@FeignClient(value = "tensquare-user")public interface UserClient {
/** * 添加粉丝数和关注数 * @param userId * @param friendId * @param count */ @RequestMapping(value = "/user/{userId}/{friendId}/{count}",method = RequestMethod.PUT) public void addFanscountAndFollowcount(@PathVariable("userId") String userId, @PathVariable("friendId") String friendId, @PathVariable("count") String count);}

@FeignClient 注解用于指定从哪个服务中调用功能 ,注意:里面的名称与被调用的服务名保持一致,并且不能包含下划线_

@RequestMapping 注解用于对被调用的微服务进行地址映射。
注意:@PathVariable 注解一定要指定参数名称,否则出错
4)修改调用微服务的 controller,自动注入刚刚创建的接口,就可以调用接口中的方法了。

@RestController@RequestMapping(value = "/friend")public class FriendController {
@Autowired private UserClient userClient; /** * 删除好友关系 * @param friendid * @return */ @RequestMapping(value = "/{friendid}",method = RequestMethod.DELETE) public Result deleteFriend(@PathVariable String friendid){
// 验证用户是否登录 Claims claims = (Claims) request.getAttribute("claims_user"); if (claims == null){
return new Result(false, StatusCode.ERROR,"权限不够"); } String userId = claims.getId(); friendService.deleteFriend(userId,friendid); userClient.addFanscountAndFollowcount(userId,friendid,"-1"); return new Result(true,StatusCode.OK,"删除好友成功"); }}

Spring Cloud Feign 自动内置了负载均衡策略,如果同一微服务同时开启多个,则它们之间就会轮流调用

转载地址:https://blog.csdn.net/zwj_jyzl/article/details/104089106 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:Spring Cloud Hystrix
下一篇:微服务鉴权之JWT

发表评论

最新留言

做的很好,不错不错
[***.243.131.199]2024年04月23日 19时23分50秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

推荐文章