用通俗易懂的语言，揭示Sentinel服务降级与熔断技术精华

后端

2024-01-22 07:39:30

前言

在分布式微服务架构中，服务之间通过调用实现交互，服务调用方为服务消费者，服务被调用方为服务提供者。在微服务架构下，服务之间调用具有很强的并发性，当某个服务出现异常或故障时，很容易对整个微服务集群的稳定性产生影响。

为此，服务降级与熔断技术应运而生。服务降级是指在某些特定情况下，将非核心业务服务的请求临时拒绝，以保护核心业务服务的稳定性。服务熔断是指当服务调用失败次数达到一定阀值时，直接中断服务调用，避免服务之间的雪崩效应。

Sentinel + OpenFeign实现服务降级与熔断

在微服务架构中，Sentinel是一个功能强大的流控服务框架，它可以实现服务降级、熔断、限流等功能。Sentinel是Nacos Service Mesh产品的功能子集，用于在Nacos Service Mesh微服务治理中实现流控功能。

OpenFeign是一个Java开源客户端库，它使得Java应用能够以简便的方式调用HTTP服务。

Nacos是一个基于Spring Cloud Alibaba体系的服务发现、配置管理和服务治理的平台。Nacos注册中心为服务提供者和服务消费者提供服务发现机制，以帮助它们相互通信。

通过Nacos注册中心，结合OpenFeign整合Sentinel，可以轻松实现服务降级与熔断功能。接下来，我们将以具体代码示例进行说明。

配置Nacos服务注册中心

import com.alibaba.nacos.api.annotation.NacosProperties;
import com.alibaba.nacos.api.naming.NamingFactory;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.client.naming.NacosNamingService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.List;

@Configuration
public class NacosConfiguration {

    @Autowired
    private NacosProperties nacosProperties;

    @Value("${spring.application.name}")
    private String serviceName;

    @Bean
    public NamingService namingService() throws Exception {
        return NamingFactory.createNamingService(nacosProperties.getServerAddr());
    }

    @Bean
    public List<Instance> serviceInstances() throws Exception {
        return namingService().getAllInstances(serviceName);
    }

    @Bean
    public NacosNamingService nacosNamingService() throws Exception {
        return new NacosNamingService(nacosProperties.getServerAddr(), nacosProperties.getNamespace());
    }
}

配置OpenFeign客户端

import feign.Feign;
import feign.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class OpenFeignConfiguration {

    @Autowired
    private List<Instance> serviceInstances;

    @Bean
    public Feign.Builder feignBuilder() {
        return Feign.builder()
                .client(new NacosFeignClient(serviceInstances))
                .logger(Logger.Level.FULL);
    }
}

配置Sentinel服务降级与熔断

import com.alibaba.cloud.sentinel.annotation.SentinelResource;
import com.alibaba.cloud.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SentinelController {

    @SentinelResource(value = "hello", fallback = "helloFallback")
    @GetMapping("/hello")
    public String hello() {
        return "Hello World!";
    }

    public String helloFallback(BlockException ex) {
        return "Service is unavailable, please try again later.";
    }
}