热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

springbootfeign简单结合hystrix熔断器

SpringCloud在接口调用上,大致会经过如下几个组件配合:Feign——Hystrix——Ribbon——HttpClient(

Spring Cloud 在接口调用上,大致会经过如下几个组件配合:
Feign ——>Hystrix ——>Ribbon ——>Http Client(apache http components 或者 Okhttp) 具体交互流程上,如下图所示:
在这里插入图片描述
(1)接口化请求调用当调用被@FeignClient注解修饰的接口时,在框架内部,将请求转换成Feign的请求实例feign.Request,交由Feign框架处理。
(2)Feign :转化请求Feign是一个http请求调用的轻量级框架,可以以Java接口注解的方式调用Http请求,封装了Http调用流程。
(3)Hystrix:熔断处理机制 Feign的调用关系,会被Hystrix代理拦截,对每一个Feign调用请
求,Hystrix都会将其包装成HystrixCommand,参与Hystrix的流控和熔断规则。如果请求判断需要熔断,则Hystrix直接熔断,抛出异常或者使用FallbackFactory返回熔断Fallback结果;如果通过,则将调用请求传递给Ribbon组件。
(4)Ribbon:服务地址选择 当请求传递到Ribbon之后,Ribbon会根据自身维护的服务列表,根据服务的服务质量,如平均响应时间,Load等,结合特定的规则,从列表中挑选合适的服务实例,选择好机器之后,然后将机器实例的信息请求传递给Http Client客户端,HttpClient客户端来执行真正的Http接口调用;
(5)HttpClient :Http客户端,真正执行Http调用根据上层Ribbon传递过来的请求,已经指定了服务地址,则HttpClient开始执行真正的Http请求

Hystrix概念
Hystrix 是一个供分布式系统使用,提供延迟和容错功能,保证复杂的分布系统在面临不可避免的失败
时,仍能有其弹性。
比如系统中有很多服务,当某些服务不稳定的时候,使用这些服务的用户线程将会阻塞,如果没有隔离机制,系统随时就有可能会挂掉,从而带来很大的风险。SpringCloud使用Hystrix组件提供断路器、资源隔离与自我修复功能。下图表示服务B触发了断路器,阻止了级联失败
在这里插入图片描述
下面简单演示一下springboot结合hystrix
先引入所需要的依赖

<dependency><groupId>org.springframework.cloudgroupId><artifactId>spring-cloud-starter-netflix-hystrixartifactId>dependency>

在配置文件中添加hystrix配置

#开启熔断机制 这个默认是false关闭的
feign.hystrix.enabled&#61;true
#设置hystrix超时时间&#xff0c;默认为1000ms
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds&#61;6000

创建一个实现类实现feign服务发现的接口&#xff0c;当熔断时便可以执行这里面的方法

package com.atguigu.eduservice.client.impl;import com.atguigu.commonutils.R;
import com.atguigu.eduservice.client.VodClient;
import org.springframework.stereotype.Component;import java.util.List;/***

* VodClient实现类&#xff0c;hystrix熔断器熔断将会执行这里面的方法*

** &#64;author Kk* &#64;since 2022/3/6 20:20*/
&#64;Component
public class VodFileDegradeFeignClient implements VodClient { //出错之后将会执行&#64;Overridepublic R deleteAliYunVideo(String videoId) {return R.error().message("删除视频出错啦");}&#64;Overridepublic R deleteBatch(List<String> videoIdList) {return R.error().message("批量删除视频出错啦");}
}

修改feign的接口&#xff0c;在&#64;FeignClient接口上添加fallback属性&#xff0c;属性值为对应的实现类class

package com.atguigu.eduservice.client;import com.atguigu.commonutils.R;
import com.atguigu.eduservice.client.impl.VodFileDegradeFeignClient;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestParam;import java.util.List;/***

* 映射被调用服务端的方法路径*

** &#64;author Kk* &#64;since 2022/3/6 15:31*/
&#64;Component
&#64;FeignClient(name &#61; "service-vod",fallback &#61; VodFileDegradeFeignClient.class) //此注解里面为被调用服务端在nacos注册的服务名
public interface VodClient {/*定义调用的方法路径根据视频id删除阿里云云端视频*/&#64;DeleteMapping("eduvod/video/deleteAliYunVideo/{videoId}")R deleteAliYunVideo(&#64;PathVariable("videoId") String videoId);/*批量删除阿里云端的视频*/&#64;DeleteMapping("eduvod/video/deleteBatch")R deleteBatch(&#64;RequestParam("videoIdList") List<String> videoIdList);
}

这样就简单实现了熔断器的效果


推荐阅读
author-avatar
鬎瀰_418
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有