AI 助理
备案控制台
开发者社区 微服务 文章 正文

sentinel整合ribbon+fallback（5）

2022-09-23 65
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 前期准备：启动nacos和sentinel

前期准备：

启动nacos和sentinel

提供者9003/9004 （以9003为样本）


新建cloudalibaba-provider-payment9003/9004


pom文件


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>mscloud03</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>cloudalibaba-provider-payment9003</artifactId>
    <dependencies>
        <!--SpringCloud ailibaba nacos -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>



yml文件


server:
  port: 9003
spring:
  application:
    name: nacos-payment-provider
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #配置Nacos地址
management:
  endpoints:
    web:
      exposure:
        include: '*'

配置9004的时候记得修改端口


主启动类


@SpringBootApplication
@EnableDiscoveryClient
public class PaymentMain9003
{
    public static void main(String[] args) {
            SpringApplication.run(PaymentMain9003.class, args);
    }
}


业务类


@RestController
public class PaymentController
{
    @Value("${server.port}")
    private String serverPort;
    public static HashMap<Long,Payment> hashMap = new HashMap<>();
    static
    {
        hashMap.put(1L,new Payment(1L,"28a8c1e3bc2742d8848569891fb42181"));
        hashMap.put(2L,new Payment(2L,"bba8c1e3bc2742d8848569891ac32182"));
        hashMap.put(3L,new Payment(3L,"6ua8c1e3bc2742d8848569891xt92183"));
    }
    @GetMapping(value = "/paymentSQL/{id}")
    public CommonResult<Payment> paymentSQL(@PathVariable("id") Long id)
    {
        Payment payment = hashMap.get(id);
        CommonResult<Payment> result = new CommonResult(200,"from mysql,serverPort:  "+serverPort,payment);
        return result;
    }
}


测试1


启动9003访问localhost:9003/paymentSQL/1


521ad0ddb7014feba155940983546261.png


消费者84


新建cloudalibaba-consumer-nacos-order84


pom文件


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>mscloud03</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>cloudalibaba-consumer-nacos-order84</artifactId>
    <dependencies>
        <!--SpringCloud ailibaba nacos -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!--SpringCloud ailibaba sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>


yml文件


server:
  port: 84
spring:
  application:
    name: nacos-order-consumer
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
    sentinel:
      transport:
        #配置Sentinel dashboard地址
        dashboard: localhost:8080
        #默认8719端口，假如被占用会自动从8719开始依次+1扫描,直至找到未被占用的端口
        port: 8719
#消费者将要去访问的微服务名称(注册成功进nacos的微服务提供者)
service-url:
  nacos-user-service: http://nacos-payment-provider


主启动


@EnableDiscoveryClient
@SpringBootApplication
public class OrderNacosMain84
{
    public static void main(String[] args) {
            SpringApplication.run(OrderNacosMain84.class, args);
    }
}


配置类 


@Configuration
public class ApplicationContextConfig
{
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate()
    {
        return new RestTemplate();
    }
}


业务类1


@RestController
@Slf4j
public class CircleBreakerController
{
    public static final String SERVICE_URL = "http://nacos-payment-provider";
    @Resource
    private RestTemplate restTemplate;
    @RequestMapping("/consumer/fallback/{id}")
    @SentinelResource(value = "fallback") 
     public CommonResult<Payment> fallback(@PathVariable Long id)
    {
        CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
        if (id == 4) {
            throw new IllegalArgumentException ("IllegalArgumentException,非法参数异常....");
        }else if (result.getData() == null) {
            throw new NullPointerException ("NullPointerException,该ID没有对应记录,空指针异常");
        }
        return result;
    }
}


测试2


启动9003 9004 84

访问http://localhost:84/consumer/fallback/1


4faea41af63c4e26ab7b0f2eca993f7a.png



再访问http://localhost:84/consumer/fallback/1


66348297e09645df92e0060216d01e51.png

可以发现第一次是9004端口，第二次是9003端口，这里面的话，就可以就知道意见实现了ribbon中的轮训


测试3


访问http://localhost:84/consumer/fallback/4


14e5686cb6ca4e34ad9187fd08103b90.png

http://localhost:84/consumer/fallback/4

给客户error页面，不友好


修改业务类（只配置fallback）


@RestController
@Slf4j
public class CircleBreakerController
{
    public static final String SERVICE_URL = "http://nacos-payment-provider";
    @Resource
    private RestTemplate restTemplate;
    @RequestMapping("/consumer/fallback/{id}")
    @SentinelResource(value = "fallback",fallback = "handlerFallback") //fallback负责业务异常
    public CommonResult<Payment> fallback(@PathVariable Long id)
    {
        CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
        if (id == 4) {
            throw new IllegalArgumentException ("IllegalArgumentException,非法参数异常....");
        }else if (result.getData() == null) {
            throw new NullPointerException ("NullPointerException,该ID没有对应记录,空指针异常");
        }
        return result;
    }
    public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(444,"兜底异常handlerFallback,exception内容  "+e.getMessage(),payment);
    }
}

92f51a0f716a4d8cb144d9f9c6400505.png


本例sentinel无配置


测试4

访问http://localhost:84/consumer/fallback/4

4ac71fef8ec64a9a9299a47f831234f2.png

这里可以发现没有出现error界面，而是我们自己配置的兜底的处理方案


修改业务类（只配置blockHandler ）


@RestController
@Slf4j
public class CircleBreakerController
{
    public static final String SERVICE_URL = "http://nacos-payment-provider";
    @Resource
    private RestTemplate restTemplate;
    @RequestMapping("/consumer/fallback/{id}")
     @SentinelResource(value = "fallback",blockHandler = "blockHandler") //blockHandler负责在sentinel里面配置的降级限流
    public CommonResult<Payment> fallback(@PathVariable Long id)
    {
        CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
        if (id == 4) {
            throw new IllegalArgumentException ("非法参数异常....");
        }else if (result.getData() == null) {
            throw new NullPointerException ("NullPointerException,该ID没有对应记录");
        }
        return result;
    }
    public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    }
    public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    }
}

5ba425975eb64ebf960b248b7b6013b4.png


配置sentinel


5042119acd94498980dfd6de37be7f21.png


测试5


访问2次以后http://localhost:84/consumer/fallback/4

f505625405a341cdb6bf21c46c3d3fef.png


 修改业务类（fallback和blockHandler都配置）


@RestController
@Slf4j
public class CircleBreakerController
{
    public static final String SERVICE_URL = "http://nacos-payment-provider";
    @Resource
    private RestTemplate restTemplate;
    @RequestMapping("/consumer/fallback/{id}")
     @SentinelResource(value = "fallback",fallback = "handlerFallback",blockHandler = "blockHandler")
    public CommonResult<Payment> fallback(@PathVariable Long id)
    {
        CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
        if (id == 4) {
            throw new IllegalArgumentException ("非法参数异常....");
        }else if (result.getData() == null) {
            throw new NullPointerException ("NullPointerException,该ID没有对应记录");
        }
        return result;
    }
    public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    }
    public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    }
}

d95ed620f0494933a9ae7a3ec85fe685.png92a71244ecb44665a8b3337530e4ccef.png


测试 6


访问http://localhost:84/consumer/fallback/4


0304a6a4a3ae416c94e2a210c97c0a54.png

再访问的时候，那就意味着这个时候会被限流处理


235ed0bbb1334e9eb19b7b713170732b.png


若 blockHandler 和 fallback 都进行了配置，则被限流降级而抛出 BlockException 时只会进入 blockHandler 处理逻辑。

 修改业务类（忽略属性.......） 

@RestController
@Slf4j
public class CircleBreakerController
{
    public static final String SERVICE_URL = "http://nacos-payment-provider";
    @Resource
    private RestTemplate restTemplate;
    @RequestMapping("/consumer/fallback/{id}")
    @SentinelResource(value = "fallback", fallback = "handlerFallback", blockHandler = "blockHandler",
            exceptionsToIgnore = {IllegalArgumentException.class})
    public CommonResult<Payment> fallback(@PathVariable Long id)
    {
        CommonResult<Payment> result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
        if (id == 4) {
            throw new IllegalArgumentException ("非法参数异常....");
        }else if (result.getData() == null) {
            throw new NullPointerException ("NullPointerException,该ID没有对应记录");
        }
        return result;
    }
    public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    }
    public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
        Payment payment = new Payment(id,"null");
        return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    }
}


c5e7779e5b8d4e54bc857e2b9f8d0ad2.png


测试7


访问http://localhost:84/consumer/fallback/4


0dacfdde8136489c8232edf07705ea5b.png


文章标签：
Nacos
Sentinel
关键词：
Ribbon fallback
一个风轻云淡
目录
相关文章
玉面大蛟龙
|
SpringCloudAlibaba 负载均衡 Java
SpringCloud Alibaba学习（十）：Sentinel的服务熔断功能（Sentinel整合Ribbon+OpenFeign+fallback）
SpringCloud Alibaba学习（十）：Sentinel的服务熔断功能（Sentinel整合Ribbon+OpenFeign+fallback）
玉面大蛟龙
302 0
SpringCloud Alibaba学习（十）：Sentinel的服务熔断功能（Sentinel整合Ribbon+OpenFeign+fallback）
wei_shuo
|
4月前
|
JSON 负载均衡 Java
Spring Cloud Ribbon：负载均衡的服务调用
Spring Cloud Ribbon：负载均衡的服务调用
wei_shuo
90 0
蓝易云
|
17天前
|
负载均衡 算法 Java
SpringCloud之Ribbon使用
通过 Ribbon，可以非常便捷的在微服务架构中实现请求负载均衡，提升系统的高可用性和伸缩性。在实际使用中，需要根据实际场景选择合适的负载均衡策略，并对其进行适当配置，以达到更佳的负载均衡效果。
蓝易云
25 13
不会编程的小孩子
|
3月前
|
负载均衡 算法 Java
Spring Cloud Netflix 之 Ribbon
Spring Cloud Netflix Ribbon是客户端负载均衡器，用于在微服务架构中分发请求。它与RestTemplate结合，自动在服务发现（如Eureka）注册的服务之间进行调用。配置包括在pom.xml中添加依赖，设置application.yml以连接Eureka服务器，并在配置类中创建@LoadBalanced的RestTemplate。通过这种方式，当调用如`/user/userInfoList`的接口时，Ribbon会自动处理到多个可用服务实例的负载均衡。
不会编程的小孩子
30 1
长梦
|
3月前
|
缓存 负载均衡 Java
Java一分钟之-Spring Cloud Netflix Ribbon：客户端负载均衡
【6月更文挑战第9天】Spring Cloud Netflix Ribbon是客户端负载均衡器，用于服务间的智能路由。本文介绍了Ribbon的基本概念、快速入门步骤，包括添加依赖、配置服务调用和使用RestTemplate。此外，还讨论了常见问题，如服务实例选择不均、超时和重试设置不当、服务列表更新不及时，并提供了相应的解决策略。最后，展示了如何自定义负载均衡策略。理解并正确使用Ribbon能提升微服务架构的稳定性和效率。
长梦
122 3
叶落闲庭
|
4月前
|
负载均衡
【SpringCloud】Ribbon负载均衡原理、负载均衡策略、饥饿加载
【SpringCloud】Ribbon负载均衡原理、负载均衡策略、饥饿加载
叶落闲庭
55 0
请回答1024
|
4月前
|
负载均衡 算法
SpringCloud&Ribbon负载均衡原理与实践
SpringCloud&Ribbon负载均衡原理与实践
请回答1024
55 3
请回答1024
|
4月前
|
负载均衡 算法 Java
第五章 Spring Cloud Netflix 之 Ribbon
第五章 Spring Cloud Netflix 之 Ribbon
请回答1024
38 0
hhzz
|
4月前
|
负载均衡 算法 Java
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（四）Ribbon的使用
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（四）Ribbon的使用
hhzz
73 0
小z1
|
4月前
|
负载均衡
【二十】搭建SpringCloud项目四（Ribbon）
【二十】搭建SpringCloud项目四（Ribbon）
小z1
56 0

热门文章

最新文章

  • 1
    [Spring cloud 一步步实现广告系统] 10. Ribbon 服务调用
  • 2
    负载均衡---ribbon
  • 3
    基于Windows 7中的 Ribbon开发技术应用
  • 4
    Spring Cloud源码分析（二）Ribbon
  • 5
    【CF 189A Cut Ribbon】dp
  • 6
    最适合新手入门的SpringCloud教程 6—Ribbon负载均衡「F版本」
  • 7
    SharePoint 2013 添加Ribbon菜单
  • 8
    SharePoint 2013 隐藏部分Ribbon菜单
  • 9
    自定义ribbon负载均衡策略
  • 10
    SharePoint 2013 初始化Ribbon选中Tab
  • 1
    Ribbon负载均衡策略
    42
  • 2
    Ribbon、Feign和OpenFeign的区别来了
    129
  • 3
    SpringCloud&Ribbon负载均衡原理与实践
    55
  • 4
    Ribbon的负载均衡策略
    68
  • 5
    Springcloud-ribbon和hystrix配置
    34
  • 6
    【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（四）Ribbon的使用
    73
  • 7
    ribbon的7种负载均衡算法和替换方法
    83
  • 8
    【二十】搭建SpringCloud项目四（Ribbon）
    56
  • 9
    【Spring底层原理高级进阶】微服务 Spring Cloud 的注册发现机制：Eureka 的架构设计、服务注册与发现的实现原理，深入掌握 Ribbon 和 Feign 的用法 ️
    144
  • 10
    SpringCloud负载均衡源码解析 | 带你从表层一步步剖析Ribbon组件如何实现负载均衡功能
    96

    • 相关课程

    更多
  • 微服务实战-服务熔断 - Sentinel
  • 微服务实战-服务注册与发现 - Nacos Discovery

    • 相关电子书

    更多
  • 阿里云容器 AHAS Sentinel 网关流控揭秘
  • Sentinel-Sentinel :保障微服务高可用的利器
  • 流量太大容易挂？接入Sentinel让N个9成为可能

    • 相关实验场景

    更多
  • 快速玩转Dubbo生态之限流降级篇（Sentinel）
    • 下一篇
    对象存储 OSS 如何创建 bucket|学习笔记