当前位置: 首页 > news >正文

微服务保护--Feign整合Sentinel

        限流是一种预防措施,虽然限流可以尽量避免因高并发而引起的服务故障,但服务还会因为其它原因而故障。而要将这些故障控制在一定范围,避免雪崩,就要靠线程隔离(舱壁模式)和熔断降级手段了。

        线程隔离之前讲到过:调用者在调用服务提供者时,给每个调用的请求分配独立线程池,出现故障时,最多消耗这个线程池内资源,避免把调用者的所有资源耗尽。

熔断降级:是在调用方这边加入断路器,统计对服务提供者的调用,如果调用的失败比例过高,则熔断该业务,不允许访问该服务的提供者了。

        可以看到,不管是线程隔离还是熔断降级,都是对客户端(调用方)的保护。需要在调用方 发起远程调用时做线程隔离、或者服务熔断。

        而我们的微服务远程调用都是基于Feign来完成的,因此我们需要将Feign与Sentinel整合,在Feign里面实现线程隔离和服务熔断。

1.FeignClient整合Sentinel

        SpringCloud中,微服务调用都是通过Feign来实现的,因此做客户端保护必须整合Feign和Sentinel。

2.修改配置,开启sentinel功能

        修改OrderService的application.yml文件,开启Feign的Sentinel功能:

feign:sentinel:enabled: true # 开启feign对sentinel的支持

3.编写失败降级逻辑

        业务失败后,不能直接报错,而应该返回用户一个友好提示或者默认结果,这个就是失败降级逻辑。

给FeignClient编写失败后的降级逻辑

①方式一:FallbackClass,无法对远程调用的异常做处理

②方式二:FallbackFactory,可以对远程调用的异常做处理,我们选择这种

这里我们演示方式二的失败降级处理。

步骤一:在feing-api项目中定义类,实现FallbackFactory:

代码:

package cn.itcast.feign.clients.fallback;import cn.itcast.feign.clients.UserClient;
import cn.itcast.feign.pojo.User;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;@Slf4j
public class UserClientFallbackFactory implements FallbackFactory<UserClient> {@Overridepublic UserClient create(Throwable throwable) {return new UserClient() {@Overridepublic User findById(Long id) {log.error("查询用户异常", throwable);return new User();}};}
}

步骤二:在feing-api项目中的DefaultFeignConfiguration类中将UserClientFallbackFactory注册为一个Bean:

@Bean
public UserClientFallbackFactory userClientFallbackFactory(){return new UserClientFallbackFactory();
}

步骤三:在feing-api项目中的UserClient接口中使用UserClientFallbackFactory:

import cn.itcast.feign.clients.fallback.UserClientFallbackFactory;
import cn.itcast.feign.pojo.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;@FeignClient(value = "userservice", fallbackFactory = UserClientFallbackFactory.class)
public interface UserClient {@GetMapping("/user/{id}")User findById(@PathVariable("id") Long id);
}

重启后,访问一次订单查询业务,然后查看sentinel控制台,可以看到新的簇点链路:

喜欢的话点个关注吧!

http://www.lryc.cn/news/260722.html

相关文章:

  • 二进制to十六进制
  • Logistic 回归算法
  • ubuntu安装详细步骤
  • 力扣5. 最长回文子串
  • 肆[4],函数VectorToHomMat2d/AffineTransPoint2d
  • 下载文件 后端返回给前端 response header 响应头
  • lvs负载均集群
  • luttuce(RedisTempate)实现hash expire lua脚本
  • 【Xamarin】WebView连接局域网自动跳转外部浏览器问题的解决
  • 【Unity动画】实现不同的肢体动作自由搭配播放Layer+Avatar Mask
  • 将0x06(16进制)转换为二进制
  • 考PRINCE2有用么?有PMP证书了还需要考PRINCE2吗?
  • 06进程间关系-学习笔记
  • Vue的动画方式有几种
  • PyTorch: 基于【VGG16】处理MNIST数据集的图像分类任务【准确率98.9%+】
  • 【lombok】从easyExcel read不到值到cglib @Accessors(chain = true)隐藏的大坑
  • 1-SaaS通识
  • Spring Boot实现接口幂等
  • ShopsN commentUpload 文件上传漏洞复现
  • 【Qt5】ui文件最后会变成头文件
  • 数组笔试题解析(下)
  • PPT插件-好用的插件-图形缩放-大珩助手
  • 五:爬虫-数据解析之xpath解析
  • 什么是Laravel?它有哪些特性?
  • [足式机器人]Part2 Dr. CAN学习笔记-自动控制原理Ch1-3燃烧卡路里-系统分析实例
  • 安恒明御安全网关 aaa_local_web_preview文件上传漏洞复现
  • 基于ssm企业人事管理系统的设计与实现论文
  • 你知道为什么要加 final 关键字了吗?
  • 找不到mfc100u.dll,程序无法继续执行?三步即可搞定
  • postman接口测试之Postman配置环境变量和全局变量