【愚公系列】2023年12月 Java教学课程 219-微服务保护（Sentinel的隔离和降级）

愚公搬代码

发布于 2025-06-02 16:36:37

12500

代码可运行

文章被收录于专栏：历史专栏历史专栏

运行总次数：0

代码可运行

🚀前言

微服务保护是指在微服务架构中为了确保服务的稳定性和安全性而采取的一系列保护措施。这些保护措施包括：

限流：通过设置并发请求、QPS（每秒请求数）等限制，防止服务因过多请求导致崩溃或响应缓慢。
熔断：在服务出现异常或超时的情况下，自动切换到备用服务或返回默认值，防止服务雪崩。
降级：当服务出现异常或超时时，自动降级，返回较为简单或者不完整的结果，保证服务的可用性。
容错：对于服务的异常情况，进行处理，尽量避免对其他服务或系统产生影响，确保整个系统的稳定性。
安全保护：对服务进行身份认证、授权、加密解密等安全措施，防止恶意攻击或者非法访问。

以上措施可以提升微服务架构的可用性、稳定性和安全性，同时也能够减少应用程序出现故障的概率，保障业务的正常运行。

🚀一、Sentinel的隔离和降级

线程隔离和熔断降级是常见的应对高并发和系统异常情况的策略，具体实现方式和目的略有不同。

线程隔离：

线程隔离是将不同的请求或任务分配到不同的线程中执行，以避免线程间的资源争用和影响。例如，在Web应用中，可以通过线程池来管理请求的处理线程，将每个请求放到一个独立的线程中执行，从而避免线程间的干扰和影响。

线程隔离的目的是提高系统的并发性和稳定性，防止线程间的竞争和阻塞，在高并发的情况下，可以更好地利用服务器资源，提高系统的处理能力和响应速度。

熔断降级：

熔断降级是在系统出现异常或过载情况下，通过关闭或降低某些服务或功能，保证系统的可用性和稳定性。例如，在微服务架构中，当服务出现故障或响应时间过长时，可以快速返回错误结果，避免出现更严重的故障或延迟。

熔断降级的目的是在系统异常或过载时，保证系统的可用性和稳定性，避免出现更严重的故障或延迟。通过熔断降级，可以保证部分服务或功能的正常运行，为用户提供有限的服务，避免系统全面崩溃。

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

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

🔎1.FeignClient整合Sentinel

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

🦋1.1 修改配置，开启sentinel功能

修改OrderService的application.yml文件，开启Feign的Sentinel功能：

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

🦋1.2 编写失败降级逻辑

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

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

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

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

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

步骤一：在feign-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> {
    @Override
    public UserClient create(Throwable throwable) {
        return new UserClient() {
            @Override
            public User findById(Long id) {
                log.error("查询用户异常", throwable);
                return new User();
            }
        };
    }
}

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

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

步骤三：在feign-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控制台，可以看到新的簇点链路：