寫文章

首頁手記 Sentinel+Feign熔斷項目實戰(zhàn)教程

Sentinel+Feign熔斷項目實戰(zhàn)教程

標簽：

Spring Cloud 微服務(wù)

概述

本文将详细介绍如何在Spring Cloud项目中结合使用Sentinel和Feign，实现服务的熔断功能。通过具体案例和配置步骤，读者可以掌握sentinel+Feign熔断项目实战的全过程。我们将从环境搭建、代码示例、项目结构到具体配置一步步深入讲解，帮助您轻松上手。

1. Sentinel与Feign的基本介绍

1.1 什么是Sentinel

Sentinel 是阿里巴巴开源的一款轻量级的、高性能的 Java 熔断降级库，它能够对各种服务的调用关系进行合理的流量控制、实时预警、异常隔离，并提供丰富的适配能力，帮助您优雅地对各种服务进行熔断降级。Sentinel 可以对各个微服务的调用进行熔断，从而保证整个系统在高并发、高流量的情况下依然能够稳定运行。

1.2 什么是Feign

Feign 是一个声明式的 Web 服务客户端，它使得编写 Web 服务客户端变得更加容易。它采用了基于注解的方式进行服务调用，可以与 Spring Cloud 集成，用于声明 HTTP 服务调用接口。Feign 使用了 Netflix 的 Hystrix 库来实现熔断器逻辑，可以对远程调用进行熔断处理，防止服务雪崩。

1.3 Feign与Sentinel的结合点

Feign 本身提供了简单的熔断器（Hystrix），但其配置相对简单，应用场景不丰富。而 Sentinel 则提供了更为丰富和灵活的熔断策略。通过结合使用 Feign 和 Sentinel，可以更好地实现服务的保护和容错，同时保持系统的高可用性。

2. 准备工作

2.1 开发环境搭建

为了搭建开发环境，首先需要安装 Java 开发工具包（JDK），并配置好环境变量。确保 JDK 已经安装并配置好环境变量后，接下来可以安装 Maven 作为构建工具，并配置好 Maven 的环境变量。

2.2 快速入门案例

接下来，我们将通过一个简单的示例来快速入门使用 Sentinel 和 Feign。首先，创建一个基本的 Spring Boot 项目，然后引入 Sentinel 和 Feign 的相关依赖。

2.2.1 创建 Spring Boot 项目

使用 Spring Initializr 创建一个新的 Spring Boot 项目，添加以下依赖：

Spring Web
Spring Cloud Netflix Eureka Client
Spring Cloud Netflix Feign
Sentinel Starter

2.2.2 示例代码

以下是创建 Spring Boot 项目的基本步骤和代码示例：

创建一个 Spring Boot 项目，例如 spring-cloud-sentinel-feign。

在 pom.xml 文件中添加依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-feign</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
    </dependency>
</dependencies>

配置 application.yml 文件，设置 Eureka 服务器地址：

spring:
  application:
    name: service-provider

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

创建一个简单的服务提供者控制器 ProviderController：

package com.example.demo.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProviderController {

    @GetMapping("/echo")
    public String echo(@RequestParam String s) {
        return "Hello, " + s;
    }
}

创建一个服务消费者控制器 ConsumerController，使用 Feign 调用服务提供者：

package com.example.demo.controller;

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(value = "service-provider")
public interface EchoClient {

    @GetMapping("/echo")
    public String echo(@RequestParam String s);
}

在服务消费者控制器中注入并调用 Feign 客户端：

package com.example.demo.controller;

import com.example.demo.controller.EchoClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ConsumerController {

    @Autowired
    private EchoClient echoClient;

    @GetMapping("/call")
    public String call() {
        return echoClient.echo("world");
    }
}

启动并测试项目，确保服务正常运行，并能够通过 Feign 调用服务提供者。

3. 实战项目搭建

3.1 创建项目结构

为了更好地组织代码，可以将项目分为以下几个模块：

service-provider：服务提供者模块
service-consumer：服务消费者模块
common：通用模块（存放公共代码）

3.2 添加依赖包

在 service-provider 和 service-consumer 模块的 pom.xml 文件中添加以下依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-feign</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

4. 配置Sentinel与Feign

4.1 Sentinel的初始化配置

需要在 Spring Boot 启动类中进行 Sentinel 的初始化配置。以下是 service-provider 模块的一个示例：

在 application.yml 文件中配置 Sentinel 服务器地址：

spring:
  application:
    name: service-provider

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

在 Spring Boot 启动类中添加 @EnableDiscoveryClient 和 @EnableFeignClients 注解，并引入 Sentinel 相关配置：

package com.example.serviceprovider;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ServiceProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceProviderApplication.class, args);
    }
}

在 application.yml 文件中配置 Sentinel 的存储模式：
```
sentinel:
  transport:
    dashboard: localhost:8080
```

4.2 Feign的集成与配置

在 service-consumer 模块中，集成 Feign 并进行相关配置。以下是具体的实现步骤：

在 application.yml 文件中配置 Eureka 服务器地址：

spring:
  application:
    name: service-consumer

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

在 Spring Boot 启动类中添加 @EnableDiscoveryClient 和 @EnableFeignClients 注解：

package com.example.serviceconsumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ServiceConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceConsumerApplication.class, args);
    }
}

在 ServiceConsumerApplication 类中添加 Sentinel 配置：

package com.example.serviceconsumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ServiceConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceConsumerApplication.class, args);
    }
}

4.3 Feign与Sentinel的熔断策略配置

为了实现 Feign 与 Sentinel 的熔断策略结合，可以在 application.yml 文件中配置 Sentinel 相关策略：

在 application.yml 文件中配置熔断策略：

sentinel:
  flow:
    controlBehavior: fast
    blockHandler: sentinelFallback
    fallbackHandler: sentinelFallback
  circuitbreaker:
    slowRatioThreshold: 0.05
    statisticWindowInSecs: 10
  metric:
    statisticWindowInSecs: 10

实现熔断处理逻辑：

package com.example.demo.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(value = "service-provider")
public interface EchoClient {

    @GetMapping("/echo")
    @SentinelResource(value = "echo", blockHandler = "handleBlock")
    public String echo(@RequestParam String s);
}

package com.example.demo.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/consumer")
public class ConsumerController {

    @Autowired
    private EchoClient echoClient;

    @GetMapping("/call")
    @SentinelResource(value = "callEcho", blockHandler = "handleBlock")
    public String call() {
        return echoClient.echo("world");
    }

    public String sentinelFallback(@RequestParam String s, BlockException ex) {
        return "Sentinel fallback: " + s;
    }

    public String sentinelFallback(Throwable ex) {
        return "Sentinel fallback: " + ex.getMessage();
    }
}

5. 功能实现与测试

5.1 模拟服务调用

在 service-provider 模块中，创建一个简单的服务提供者控制器 ProviderController，并在 service-consumer 模块中创建一个服务消费者控制器 ConsumerController，使用 Feign 调用服务提供者。

5.2 操作Sentinel控制台

启动 Sentinel 控制台，可以通过访问 http://localhost:8080 访问控制台，查看熔断器状态和监控数据。

访问控制台，登录后可以看到 Sentinel 的监控面板，包括机器列表、服务列表以及各个服务的详细监控信息。
在控制台上可以查看调用链路、实时流量控制、熔断降级的状态。

5.3 测试熔断功能

为了验证熔断功能是否生效，可以进行以下步骤：

访问服务消费者，查看服务提供者的调用情况。
通过控制台修改资源配置，例如调整 QPS 限制。
触发异常调用，查看熔断器是否生效。

6. 常见问题与解决方案

6.1 常见错误排查

服务调用失败：请检查服务提供者和消费者之间的网络连接是否正常，确保服务提供者的地址和端口配置正确。
熔断器未生效：请检查 @SentinelResource 注解是否正确配置，确保熔断器策略已配置且生效。
控制台无法访问：请确保 Sentinel 控制台已启动，并且配置的地址和端口正确。

6.2 优化建议

合理设置资源名称：通过 @SentinelResource 注解配置资源名称，确保资源名称唯一且易于理解。
优化配置参数：根据实际业务需求，合理设置熔断器的触发条件和恢复条件。
增强监控：集成更全面的监控工具，实时监控服务调用情况，及时发现并解决异常问题。
服务降级：在服务调用出现异常时，及时触发服务降级机制，确保系统稳定性。

以上是 Sentinel 和 Feign 的实战教程，通过以上步骤和示例代码，您可以更好地理解和使用这两个强大的库，并在实际项目中实现服务的熔断和容错保护。

點擊查看更多內(nèi)容

為 TA 點贊

若覺得本文不錯，就分享一下吧！

評論

評論

共同學習，寫下你的評論

評論加載中...

展開查看更多評論

作者其他優(yōu)質(zhì)文章

正在加載中

回首憶惘然

手記
篇

粉絲

76

獲贊與收藏

417

關(guān)注作者，訂閱最新文章

閱讀免費教程

Spring Cloud Hystrix

15個小節(jié) 6338 124

后端通用面試教程

41個小節(jié) 32028 357

網(wǎng)絡(luò)編程入門教程

20個小節(jié) 13125 247

推薦

評論

收藏

共同學習，寫下你的評論



感謝您的支持，我會繼續(xù)努力的～

掃碼打賞，你說多少就多少

贊賞金額會直接到老師賬戶

支付方式

打開微信掃一掃，即可進行掃碼打賞哦

今天注冊有機會得

100積分直接送

付費專欄免費學

大額優(yōu)惠券免費領(lǐng)

立即參與放棄機會

點擊
抽獎

慕課手記新用戶專享福利

恭喜你，你的運氣太好了，居然抽中了 100個積分！

恭喜你，抽中了價值元的專欄！

太棒了，直接落到你賬戶里！

積分商城里的羅技鼠標、機械鍵盤、
Kindle 閱讀器、小米平衡車
Apple iPad （10.2英寸）、大額優(yōu)惠券
在等著你去兌換了噢

作者：

免費贈送

兌換碼：1111222211 復(fù)制

優(yōu)惠券可用于購買實戰(zhàn)課、體系課
無門檻使用

先去看看，有什么好東西馬上兌換我愛學習，選課去


第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

熱搜

最近搜索清空