0
点赞
收藏
分享

微信扫一扫

【微服务】OpenFeign+Sentinel集中处理远程调用异常

是归人不是过客 03-31 15:30 阅读 1
微服务sentinel架构OpenFeign

文章目录

1.微服务基本环境调整

1.对10004模块的application.yml调整

image-20240330095841583

2.启动nacos以及一个消费者两个提供者

目前的消费者是Ribbon+restTemplate形式进行远程调用的

image-20240330100101156

image-20240330100754503

3.测试
1.输入http://localhost:8848/nacos/index.html 来查看注册情况

image-20240330101232507

2.浏览器访问 http://localhost:81/member/nacos/consumer/get/1
3.结果

image-20240330101116525

2.使用OpenFeign实现微服务模块间的远程调用

1.消费者的pom.xml，引入OpenFeign和Nacos的服务发现
<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/maven-v4_0_0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.example</groupId>
        <artifactId>e-commerce-center</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <artifactId>member-service-nacos-consumer-81</artifactId>
    <name>Archetype - member-service-nacos-consumer-81</name>
    <url>http://maven.apache.org</url>

    <dependencies>
        <!-- 引入openfeign -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--引入nacos的服务发现-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- springboot web starter 用来监听端口-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <!-- 如果在子工程/模块指定了 version，则以指定为准 -->
        </dependency>
        <!--
        1. starter-actuator 是 springboot 程序的监控系统，可以实现健康检查，info 信息
        等
        2. 访问 http://localhost:10000/actuator 可以看到相关链接, 还可以做相关设置. -->
        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <!-- lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <!-- test -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- 公共模块的jar包 -->
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>e_commerce_center-common-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

    </dependencies>
</project>
2.消费者的application.yml（配置nacos服务注册）
server:
  port: 81
spring:
  application:
    name: member-service-nacos-consumer-81
# 配置nacos的服务注册
  cloud:
      nacos:
        discovery:
          server-addr: localhost:8848 # 配置要注册到的nacos地址，根据实际情况填写
3.消费者的启动类（开启nacos的服务发现，以及启动OpenFeign）
package com.sun.springcloud;

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

/**
 * @author 孙显圣
 * @version 1.0
 */
@SpringBootApplication // springboot启动类
@EnableDiscoveryClient // 开启nacos服务发现
@EnableFeignClients // 开启feign远程调用
public class MemberNacosCostomerApplication81 {
    public static void main(String[] args) {
        SpringApplication.run(MemberNacosCostomerApplication81.class, args);
    }
}
4.com/sun/springcloud/service/MemberOpenfeignService.java 编写与远程调用的方法匹配的接口
1.将要远程调用的方法整个复制到这个接口，然后去掉方法体
package com.sun.springcloud.service;

import com.sun.springcloud.util.Result;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/3/30 10:39
 * @Version 1.0
 */
public interface MemberOpenfeignService {
    /**
     * 根据id来获取某个会员的信息
     *
     * @param id 使用路径参数的形式传入参数
     * @return 返回json格式的数据
     */
    @GetMapping("/memberget/{id}") // 这里使用的路径参数
    public Result getMemberById(@PathVariable("id") Long id);
}
2.在接口上添加@FeignClient注解，指定远程调用的服务在nacos中的名字
  • 这样这个接口中就具备了所有远程调用微服务的信息
  • 后面在注入的时候就会注入针对这个接口的代理对象，远程调用方法的时候通过@FeignClient注解中的信息进行服务发现ip + 端口 + 上下文路径，并在前面加上http://，最后再拼接上这个@GetMapping注解中的资源路径，完成远程调用
  • 简单来说，这个接口需要包含要远程调用的服务发现和资源路径的信息，这样才能够进行远程调用
package com.sun.springcloud.service;

import com.sun.springcloud.util.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/3/30 10:39
 * @Version 1.0
 */
@FeignClient("member-service-nacos-provider") // 会进行服务的发现，发现服务的ip+端口+上下文路径
public interface MemberOpenfeignService {
    /**
     * 根据id来获取某个会员的信息
     *
     * @param id 使用路径参数的形式传入参数
     * @return 返回json格式的数据
     */
    @GetMapping("/member/get/{id}") // 这里使用的路径参数
    public Result getMemberById(@PathVariable("id") Long id);
}
5.编写一个controller进行远程调用
1.创建一个MemberOpenFeignController的controller并将要远程调用的controller上面的注解复制过来（不能改）
package com.sun.springcloud.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RestController;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/3/30 10:53
 * @Version 1.0
 */
// 这两个注解是要远程调用的controller的注解
@RestController
@Slf4j
public class MemberOpenFeignController {
}
2.依赖注入刚才编写的远程调用的接口的动态代理对象
package com.sun.springcloud.controller;

import com.sun.springcloud.service.MemberOpenfeignService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/3/30 10:53
 * @Version 1.0
 */
// 这两个注解是要远程调用的controller的注解
@RestController
@Slf4j
public class MemberOpenFeignController {
    @Resource
    private MemberOpenfeignService memberOpenFeignService; // 注入远程调用的接口
}
3.将要远程调用的接口再复制过来，按Tab，使用copilot来自动补全远程调用的代码
  • 这里的url，方法名，参数，都是可以修改的
  • 传入getMemberById的参数必须符合这个controller的要求
  • getMemberById的返回类型也要匹配，比如这里就必须使用@RestController
  • 牢记接口三要素 url 参数 返回值
  • 建议：如果只是想要远程调用一下的话，就没必要修改了，直接粘贴过来远程调用即可
package com.sun.springcloud.controller;

import com.sun.springcloud.service.MemberOpenfeignService;
import com.sun.springcloud.util.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/3/30 10:53
 * @Version 1.0
 */
// 这两个注解是要远程调用的controller的注解
@RestController
@Slf4j
public class MemberOpenFeignController {
    @Resource
    private MemberOpenfeignService memberOpenFeignService; // 注入远程调用的接口

    /**
     * 根据id来获取某个会员的信息
     *
     * @param id 使用路径参数的形式传入参数
     * @return 返回json格式的数据
     */
    @GetMapping("/member/openfeign/get/{id}") // 1.这里的url是可以改的
    public Result getMemberById(@PathVariable("id") Long id) { // 2.这里的参数和方法名是可以改的
        // 远程调用member-service-nacos-provider的getMemberById方法
        return memberOpenFeignService.getMemberById(id); // 这里的参数和返回值是要远程调用的接口的参数和返回值
    }
}
6.测试
1.启动nacos，81模块，10004，10006模块

image-20240330112344035

image-20240330112330720

2.访问nacos查看注册情况

image-20240330112448718

3.浏览器输入 http://localhost:81/member/openfeign/get/1 （必须加上http:// ）

image-20240330112747460

7.切换负载均衡算法
1.编写配置类，注入一个负载均衡算法的bean
package com.sun.springcloud.config;

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/** 配置类，用于配置Ribbon的负载均衡策略
 * @author 孙显圣
 * @version 1.0
 */
@Configuration
public class RibbonRule {
    @Bean
    public IRule ribbonRule() {
        // 随机策略
        return new RandomRule();
    }
}
2.重新启动，报错，bean已经被定义了，说明之前可能定义了同样id的负载均衡算法的bean

image-20240330131715496

3.换一个id即可，然后重新启动

image-20240330131826535

image-20240330131949790

4.测试，浏览器访问几次，有时会出现超时的情况（OpenFeign默认超时时间为1s）

image-20240330132533574

5.设置超时时间 application.yml
1.全局配置
feign:
  client:
    config:
      default:
        connectTimeout: 5000
        readTimeout: 10000
2.单个Feign客户端配置
feign:
  client:
    config:
      客户端的application-name:
        connectTimeout: 5000
        readTimeout: 10000
6.又检查了一下，远程调用的方法，之前设置了休眠时间，删除即可。。。

image-20240330132831360

3.服务消费者整合Sentinel进行服务保护

1.pom.xml引入Sentinel
        <!-- 引入Sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
2.application.yml 配置Sentinel的客户端和服务端

image-20240330133818630

      sentinel:
        transport:
          dashboard: localhost:8080 # 配置sentinel服务端的地址，根据实际情况填写  
          port: 8719 # 配置sentinel客户端的端口，根据实际情况填写，如果冲突，会自动+1，直到找到可用的端口
3.测试
1.启动nacos，sentinel

image-20240330134115568

image-20240330134103411

2.启动81，10004，10006模块

image-20240330134142463

3.浏览器输入http://localhost:8080/ 进入Sentinel的服务端

image-20240330134321907

4.浏览器输入http://192.168.137.1:8848/nacos/index.html进入nacos查看注册情况

image-20240330134523803

5.浏览器访问 http://localhost:81/member/openfeign/get/1 然后查看Sentinel控制台

image-20240330135602866

4.需求分析

image-20240330140249918

5.开始配置之前进行测试
当10004和10006都down掉时，不断请求会发生什么？
1.首先关闭10004和10006微服务

image-20240330141042709

2.浏览器发送请求 http://localhost:81/member/openfeign/get/1，发现是超时
  • 原因是OpenFeign会根据接口的信息来通过服务发现和资源路径，找到要远程调用的接口，并缓存在本地，所以只要缓存还在，就不会是服务不可用

image-20240330132533574

3.浏览器发送请求 http://localhost:81/member/openfeign/get/1， 可以发现服务不可用
  • 此时的缓存已经不在，OpenFeign重新从nacos获取服务信息，但是获取不到所以会出现服务不可用的错误

image-20240330141137054

6. 81模块配置如果远程调用的服务出现异常，则立即返回结果

image-20240330144105150

1.MemberFeignFallbackService.java 实现 MemberOpenfeignService.java 并注入容器
package com.sun.springcloud.service;

import com.sun.springcloud.util.Result;
import org.springframework.stereotype.Component;

/**
 * Description: 会员服务的降级处理， 当服务不可用时，立即返回一个默认的结果
 *
 * @Author sun
 * @Create 2024/3/30 14:32
 * @Version 1.0
 */
@Component // 注入到spring容器中
public class MemberFeignFallbackService implements MemberOpenfeignService{
    @Override
    public Result getMemberById(Long id) {
        return Result.error("503", "服务降级返回, 服务不可用");
    }
}
2.在application.yml配置启用openfeign和sentinel的整合

image-20240330144151786

# 配置openfeign和sentinel的整合          
feign:
  sentinel:
    enabled: true
3.MemberOpenfeignService 添加fallback属性，指定出现异常要处理的类

image-20240330145014987

4.重新启动81模块，浏览器输入 http://localhost:81/member/openfeign/get/1测试

image-20240330144529901

5.关闭10004和10006，再次进行测试，成功处理异常！

image-20240330145207537

4.消费者使用OpenFeign整合Sentinel进行服务保护小结

1.服务消费者OpenFeign远程调用流程
1.配置Nacos的服务发现和服务注册功能
  • 服务发现：配置pom.xml，和启动类开启服务发现的注解
  • 服务注册：配置application.yml
2.配置OpenFeign远程调用
1.pom.xml引入OpenFeign依赖
2.编写service接口存放服务发现和资源路径的信息
  • 将要远程调用的方法整个复制到这个接口，然后去掉方法体
  • 在接口上添加@FeignClient注解，指定远程调用的服务在nacos中的名字
3.编写controller进行远程调用
  • 将要远程调用的controller上面的注解复制过来（不能改）
  • 依赖注入刚才编写的远程调用的接口的动态代理对象
  • 将要远程调用的接口再复制过来去掉方法体，按Tab，使用copilot来自动补全远程调用的代码
2.整合Sentinel进行服务保护流程
1.配置Sentinel监控服务
  • pom.xml引入Sentinel依赖
  • application.yml 配置Sentinel的客户端和服务端
2.配置OpenFeign整合Sentinel，使得远程调用出现异常集中处理
  • 编写一个类实现存放服务发现和资源路径的信息的service，并实现其方法，然后注入容器
  • 在application.yml配置启用openfeign和sentinel的整合
  • 在service中的@FeignClient注解，添加fallback属性，指定出现处理异常的类
3.服务消费者OpenFeign远程调用整合Sentinel进行服务保护原理

image-20240330153347387

4.Sentinel仍然可以对这个controller进行流量控制，熔断降级，热点限流
设置QPS为1

image-20240330150307503

5.规则持久化

1.规则持久化方案

image-20240330160104138

2.规则持久化原理
  • 简单来说就是在Nacos配置Sentinel的规则
  • 然后在通过Sentinel监控的微服务通过底层通信，同步到Sentinel上

image-20240330160929985

3.需求分析

image-20240330161414714

4.具体配置
1.在Nacos配置中心增加Sentinel的流控规则

image-20240330164518209

2.pom.xml引入nacos和sentinel持久化的依赖
        <!-- 引入nacos和sentinel持久化的依赖 -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>
3.application.yml 拉取Nacos的配置信息并同步到Sentinel

image-20240330165648937

        datasource:
          ds1: # 从Nacos中读取sentinel的规则配置
            nacos:
              server-addr: localhost:8848 # 配置要注册到的nacos地址，根据实际情况填写
              dataId: member-service-nacos-consumer-81 # 配置要读取的配置的dataId
              groupId: DEFAULT_GROUP # 配置要读取的配置的groupId
              data-type: json # 配置要读取的配置的类型
              rule-type: flow # 配置要读取的配置的规则类型为流控规则
4.测试
1.启动Nacos、Sentinel、81、10004、10006
2.查看Nacos注册情况

image-20240330165957732

3.浏览器快速请求 http://localhost:81/member/openfeign/get/1， 流控规则生效！

image-20240330170121418

4.查看同步到Sentinel的流控规则

image-20240330170241130

5.其他规则配置

官方文档

举报

相关推荐

微服务远程调用openFeign整合

udp网络tcp/ip

微服务-OpenFeign服务接口调用

微服务javaspring cloud

Sentinel 服务熔断 OpenFeign

springidexml云平台云计算

feign 远程调用异常处理

java开发语言解析器springide系统/运维

openfeign整合sentinel出现异常

物联网学习python人工智能嵌入式硬件

微服务介绍、使用 Nacos 实现远程调用以及 OpenFeign 的使用

微服务架构云原生

微服务结构及微服务远程调用

微服务java架构spring cloud服务器云平台云计算

微服务远程调用Feign

chatgpt人工智能

【微服务-OpenFeign】OpenFeign最佳实践

springjava服务提供者架构后端开发yyds干货盘点

服务拆分和远程调用（微服务）

微服务javaspring cloudspring
0 条评论