Sentinel整合OpenFeign对远程调用限流并降级

微服务提供者demo-pay 第一步：创建模块demo-pay添加依赖：

    org.springframework.boot
    spring-boot-starter-web


    org.springframework.boot
    spring-boot-starter-actuator



    org.springframework.boot
    spring-boot-devtools



    org.springframework.boot
    spring-boot-starter-test
    test


    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-discovery

第二步：修改application.yml：

server:
  port: 8801
  servlet:
    context-path: /pay
spring:
  application:
    name: nacos-pay
  cloud:
    nacos:
      discovery:
        server-addr: http://localhost:8848  # 配置Nacos地址
management:
  endpoints:
    web:
      exposure:
        include: '*' # 对外暴露出所有的端点

第三步：项目主启动类添加注解

@EnableDiscoveryClient

第四步：提供控制器PayController：

@RestController
public class PayController {

    @GetMapping("/fun/{id}")
    public String fun(@PathVariable("id") Long id) {
        System.out.println("1111111111111111");
        return "支付 id: " + id;
    }
}

微服务消费者demo-sentinel-openfeign 第一步：创建模块demo-sentinel-openfeign并添加依赖：

    org.springframework.boot
    spring-boot-starter-web


    org.springframework.boot
    spring-boot-starter-actuator



    org.springframework.boot
    spring-boot-devtools



    org.springframework.boot
    spring-boot-starter-test
    test



    com.alibaba.cloud
    spring-cloud-starter-alibaba-sentinel



    com.alibaba.cloud
    spring-cloud-starter-alibaba-nacos-discovery



    com.alibaba.csp
    sentinel-datasource-nacos





    com.github.ben-manes.caffeine
    caffeine
    3.1.1



    org.springframework.cloud
    spring-cloud-starter-loadbalancer
    3.0.1



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

第二步：修改application.yml

server:
  port: 6601
  servlet:
    context-path: /sentinelfeign

spring:
  application:
    name: sentinel-feign
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 # 配置nacos地址
    sentinel:
      transport:
        # 配置sentinel dashboard地址
        dashboard: localhost:8080
        # 默认端口8719，假如被占用会自动从8719开始依次+1扫描，直至找到未被占用的端口
        port: 8719

management:
  endpoints:
    web:
      exposure:
        include: '*' #暴露出所有的端点
# 激活Sentinel对Feign的支持
feign:
  sentinel:
    enabled: true

第三步：在项目主启动类上添加注解：

@EnableFeignClients
@EnableDiscoveryClient

第四步：创建Feign接口：

@Service
//name：指定调用Rest接口所对应的服务名
//path：指定要调用的Rest接口所在的Controller指定的RequestMapping，如果Rest接口所在的Controller没有指定RequestMapping，则不用指定
@FeignClient(name = "nacos-pay", path = "/pay", fallback = PayFeignServiceFallback.class)
public interface PayFeignService {
    @GetMapping("/fun/{id}")
    public String fun(@PathVariable("id") Long id);
}

第五步：创建兜底类：

@Component
public class PayFeignServiceFallback implements PayFeignService {
    @Override
    public String fun(Long id) {
        return "兜底 服务降级： " + id;
    }
}

第六步：创建测试Controller

@RestController
public class DemoCtroller {
    @Resource
    private PayFeignService payFeignService;

    @GetMapping("/fun1")
    public String fun1(Long a) {
        String res = payFeignService.fun(a);
        return "fun1 "+res;
    }
}

测试： 第一步：依次启动软件Nacos和Sentinel，然后再分别启动项目demo-pay和demo-sentinel-openfeign。

第二步：结果：

添加流控规则：

请求消费者中的示例控制器中的api接口： 低频访问：

高频访问：