springcloud 之 Ribbon Hystrix Feign bus 动态修改配置

🕗 发布于 2024-05-25 10:26 spring cloud ribbon hystrix

Ribbon 是微服务架构图中负责负载均衡的组件。

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

测试如下：

    //微服务方式 Ribbon方式
    @GetMapping("ribbon/{name}")
    public String RibbonTest(@PathVariable String name) {
//        ip和域名 更换成 微服务名称
        String url = "http://user-service/hello?name="+name;
        String forObject = restTemplate.getForObject(url, String.class);
        return forObject;
    }

Hystrix 熔断：

1、熔断器：当某个服务的失败率达到一定阈值时，Hystrix会打开熔断器，停止对该服务的调用，从而防止故障进一步扩散。熔断器开启后，Hystrix会快速失败并返回备选结果或降级数据，以提高系统的响应速度。
2、资源隔离：Hystrix可以对调用远程服务的线程池进行资源隔离，限制调用分布式服务的资源使用。这样，即使某个服务出现故障，也不会影响其他服务的调用。
3、服务降级：当服务调用失败或资源不足时，Hystrix可以进行降级处理。降级后可以配合降级接口返回托底数据，以保证系统的正常运行。
4、缓存：Hystrix提供了请求缓存和请求合并的实现。通过缓存请求的结果，可以减少对后端服务的调用，提高系统的性能。同时，通过将多个相同类型的请求合并为一个批量请求，可以减少网络开销。
5、监控和告警：Hystrix可以监控服务的调用情况，如调用次数、成功率、响应时间等，并提供告警功能。这样，开发人员可以及时发现并处理潜在的问题。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

在application中加入 @EnableCircuitBreaker注解

@EnableDiscoveryClient 
@SpringBootApplication
@EnableCircuitBreaker //开启熔断 hytrix
public class ClientServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ClientServiceApplication.class, args);
    }

使用方式如下：
方案一：方法级别的指定

    @GetMapping("ribbon/{name}")
    @HystrixCommand(fallbackMethod = "ribbonTestFail")
    public String RibbonTest(@PathVariable String name) {
//        ip和域名 更换成 微服务名称
        String url = "http://user-service/hello?name="+name;
        String forObject = restTemplate.getForObject(url, String.class);
        return forObject;
    }
//    服务降级处理 配合使用    @HystrixCommand(fallbackMethod = "ribbonTestFail") 入参出入要一和对应方法一直
    public String ribbonTestFail(String name){
        return "请求失败";
    }

方案二类级别方案的指定：

@RestController
@RequestMapping("client")
@DefaultProperties(defaultFallback = "TestControllerRequestFail") //指定访问失败时的方法
public class TestController {

    //微服务方式 Ribbon方式
    @GetMapping("ribbon/{name}")
    @HystrixCommand
    public String RibbonTest(@PathVariable String name) {
//        ip和域名 更换成 微服务名称
        String url = "http://user-service/hello?name="+name;
        String forObject = restTemplate.getForObject(url, String.class);
        return forObject;
    }

//统一处理，配合 @DefaultProperties(defaultFallback = "TestControllerRequestFail") 来使用
    public String TestControllerRequestFail(){
        return "Controller 请求失败";
    }

yml 配置：

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 1000
      circuitBreaker:
        errorThresholdPercentage: 50 #触发熔断错误比例阈值，默认值50号
        sleepWindowInMilliseconds: 10000 #熔断后休眠时长，默认值5秒
        requestVolumeThreshold: 10 #熔断触发最小请求次数，默认值是20

Feign

是一个声明式的 HTTP 客户端，它使得编写 HTTP 客户端变得更简单，通过注解和接口的方式定义和调用远程服务。
pom 加入依赖：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

最佳实践：

创建一个 xxx-api模块。（Feign 模块由被调用端编写）

     <groupId>com.zll</groupId>
    <artifactId>user-api</artifactId>
    <version>0.0.1-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>3.1.5</version>
        </dependency>
    </dependencies>
</project>

用于单独存放，Feign 接口，以及出入参对象。

@Data
public class User {
    private String name;
    private Integer age;
}

@FeignClient("user-service")
public interface UserControllerApi {
    @GetMapping("/hello")
    public String hello(@RequestParam(name = "name", defaultValue = "unknown user") String name);
    @PostMapping("/save_user")
    public String saveUser(User u);
}

被调用端：
user-service:
加入pom

        <dependency>
    <groupId>com.zll</groupId>
    <artifactId>user-api</artifactId>
    <version>0.0.1-SNAPSHOT</version>
        </dependency>

使用API中的入参出参

@Controller
public class UserController {

    @GetMapping("/hello")
    @ResponseBody
    public String hello(@RequestParam(name = "name", defaultValue = "unknown user") String name) {
        return "Hello " + name;
    }

    @PostMapping("/save_user")
    @ResponseBody
    public String saveUser(User u) {
        return "user will save: name=" + u.getName() + ", age=" + u.getAge();
    }

调用端：
第一步：加入pom

        <dependency>
            <groupId>com.zll</groupId>
            <artifactId>user-api</artifactId>
        </dependency>

第二步：开启feign 扫描

@EnableFeignClients(basePackages={"com.zll.api"}) //开启feign功能 并且加入xxx-api的扫描包路径
@SpringBootApplication(basePackages={"com.zll.client"，"com.zll.api"})
public class ClientServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ClientServiceApplication.class, args);
    }

第三步：

public class ClientUserController {
//引入xxx-api的接口对象
    @Resource
    UserControllerApi userControllerApi;

    @GetMapping("/hello")
    public String hello(@RequestParam(name = "name", defaultValue = "unknown user") String name){
    //像调用方法一下，调用请求接口
        String hello = userControllerApi.hello(name);
        return hello;
    }

    @PostMapping("/save_user")
    public String saveUser(User u){
        //像调用方法一下，调用请求接口
        String s = userControllerApi.saveUser(u);
        return s;
    }

注意，使用该种模式，就不支持服务降级处理。

Gateway

创建一个新Module
在这里插入图片描述
GateWayApplication

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

pom 部分代码

    <parent>
        <groupId>com.zll</groupId>
        <artifactId>zll-springcloud-demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>

  <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>

yml

server:
  port: 9000
spring:
  application:
    name: api-gateway
  cloud:
    gateway:
      routes:
        - id: user-service-route  #路由id 随意编写
          uri: http://127.0.0.1:9092  #代理服务器地址
          predicates:   #路由断言： 可以匹配映射路径
            - Path=/client/**
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8000/eureka
#========================选配内容 更具需要来定===================
  instance:
#    服务续约时间 默认30秒
    lease-renewal-interval-in-seconds: 5
#    服务时效时间 默认90秒
    lease-expiration-duration-in-seconds: 5
#    优先使用ip
    prefer-ip-address: true
#============================================================

gateway网关的规则：

添加路径
所有路径加前缀：

spring:
  application:
    name: api-gateway
  cloud:
    gateway:
      routes:
        - id: user-service-route  #路由id 随意编写
          uri: lb://client-service  #微服务服务注册名称。lb 表示loadBalancer
          predicates:
            - Path=/**
          filters:
            - PrefixPath=/client #在路径前面添加  /client

实际下过如下：例如：
访问路径： localhost:9000/hello
实际路径：localhost:9000/client/hello

删除路径

    gateway:
      routes:
        - id: user-service-route  #路由id 随意编写
          uri: lb://client-service #微服务服务注册名称。lb 表示loadBalancer
          predicates:
            - Path=/api/client/**
          filters:
            - StripPrefix=1 #1表示删除一个路径  2表示两个路径
#            - PrefixPath=/client #在路径前面添加  /client

示范入戏
访问路径：http://localhost:9000/api/client/hello
实际路径：http://localhost:9000/client/hello

gateway自定义局部拦截器：

第一步在：yml添加拦截器名称和要拦截的参数拦截器名称为 MyParam 拦截参数 name
在这里插入图片描述
第二步：创建 MyParam拦截器：MyParam + GatewayFilterFactory = MyParamGatewayFilterFactory 前缀 MyParam +固定命名方式，否则会报错Unable to find GatewayFilterFactory with name MyParam

第三步：


/**
 * 局部拦截，需要在yml 的fiter 配置
 * spring:
 *   cloud:
 *     gateway:
 *       routes:
 *           uri: lb://client-service #微服务服务注册名称。lb 表示loadBalancer
 *           predicates:
 *             - Path=/client/**
 *           filters:
 *             - MyParam=name
 */
@Component
public class MyParamGatewayFilterFactory extends AbstractGatewayFilterFactory<MyParamGatewayFilterFactory.Config> {
    public MyParamGatewayFilterFactory() {
        super(Config.class);
    }
    public List<String> shortcutFieldOrder() {
        return Arrays.asList("param");
    }
    public static class Config{
        private String param;
        public String getParam() {
            return param;
        }
        public void setParam(String param) {
            this.param = param;
        }
    }
    @Override
    public GatewayFilter apply(Config config) {
        return ((exchange, chain) ->{
            ServerHttpRequest request = exchange.getRequest();
            if(request.getQueryParams().containsKey(config.param)){
                request.getQueryParams().get(config.param).forEach(item-> System.out.printf("%s==%s",config.param,item));
            }
            return chain.filter(exchange);
        });
    }
}

好了，局部拦截器完成。

gateway全局拦截器：

@Component
public class MyGlobalFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        System.out.println("======================MyGlobalFilter====================");
//        String token = exchange.getRequest().getQueryParams().getFirst("name");
        String token = exchange.getRequest().getHeaders().getFirst("Token");
        if(StringUtils.isBlank(token)){
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        //值越小，执行优先级越高。
        return 100;
    }
}

gateway跨域解决：

在这里插入图片描述
微服务内部，使用feign 外部调用gateway 就用nginx

配置中心

pom

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>

第二步：
在git 创建一个仓库，任意分支创建一个 user-dev.yml 文件，这里以 master 分支为例
user-dev.yml 中随便写你想要的配置
在这里插入图片描述

例如：

server:
  port: 9091
spring:
  application:
    name: user-server
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8000/eureka

回到项目的yml中：
配置git 地址

server:
  port: 10000
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/leonzhang2013/configuration-center.git  #这里写你自己的git 地址
          default-label: master #不写默认值，config会报NoSuchLabelException: No such label: main。
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8000/eureka

项目中开启配置功能：
在这里插入图片描述
最后启动项目：
访问你编写的git 文件，例如：

其他项目读取配置：
添加配置pom

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
            <version>2.1.1.RELEASE</version>
        </dependency>

如果报错：
在这里插入图片描述
就再加入下面的包：（新版本这个包被排除了，需要添加这包）

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>

更换启动文件：
applicaton.yml ⇒ bootstrap.yml

spring:
  cloud:
    config:
      name: user  # 要与仓库中配置的profile保持一致  例如 user-dev.yml
      profile: dev # 要与仓库中配置的profile保持一致  例如 user-dev.yml
      label: master #分支名称
      discovery:
        enabled: true
        service-id: config-server #配置中心的名称

eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8000/eureka

启动配置中心和注册中心服务，最后启动项目，就可以完美读到配置了。项目运行正常
user-server 读到配置，端口为配置的9091
在这里插入图片描述

实时动态同步配置（无需重启服务）：spring cloud bus
第一步：安装RabbitMQ
需要配合 RabbitMQ服务使用 ( RabbitMQ for Window 安装指南)

第二步：Config-server服务添加 actuator 和 rabbit库

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

第三步：Config-server 配置完成
添加 rabbit 配置和actutor 的 management 的路径解封。不然访问不到

server:
  port: 10000

spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/leonzhang2013/configuration-center.git
          default-label: master
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8000/eureka

  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

management:
  endpoints:
    web:
      exposure:
        include: "*"

配置使用端 user-server
第一步：添加 pom

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-bus</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
        </dependency>

第二步：添加rabbit 配置 applition.yml 中：
在这里插入图片描述
第三步：添加@RefreshScope 属性注解，表示该类，中的属性需要动态刷新（test.name）

测试：
启动注册中心，config-server ,user-server 三个服务。
1、修改git 上的配置：例如 test.name =lisi 修改为 zhangsan
2、访问 user-servier 服务中的测试链接 localhost:9091 查看数据，此时数据应该是 lisi
3、通过postman 访问 config-server 的刷新配置路径 http://localhost:10000/actuator/busrefresh
4、再次访问 localhost:9091 查看数据，此时数据应该是 zhangsan 测试结束。

关于第三步，老版本的是 bus-refresh 新版是 busrefresh
具体是那个可以访问：http://localhost:10000/actuator/mappings 去搜索一下 refresh 看看你的路径是那个。

原文地址：https://blog.csdn.net/zhanglinlang/article/details/138891536

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：华为数通 HCIP-Datacom（H12-821）题库
下一篇：HTTPS证书——网站如何实现HTTPS访问？

百度搜索AI探索版多线程批量生成TXT原创文章软件-可生成3种类型文章
8、有8种标题模式可自由设置：1、关键词 2、百度搜索AI原创标题(以原创标题写文章) 3、关键词 + 百度搜索AI原创标题 4、关键词 + 下拉副标题 5、关键词 + 下拉副标题
阅读更多2024-11-16
批量更改表格数据不更新、不实时渲染、或则watch监听不到表格修改数据
第一种方法是监听的watch中添加deep:true，但是这种方法对我来说不管用，我需要监听某一列的数据，在批量更改后，统计数量，这时候，手动更改数据，他的监听并不能实时抓捕到。我这里的功能是，批量更
阅读更多2024-11-16
【大语言模型】ACL2024论文-10 CSCD-IME: 纠正拼音输入法产生的拼写错误
本文研究了中文拼写校正（CSC）任务，特别是针对拼音输入法（IME）产生的错误。作者首先介绍了一个包含40,000个标注句子的中文拼写校正数据集（CSCD-IME），这些句子来自新浪微博上的官方媒体帖
阅读更多2024-11-16
react 中 memo 模块作用
memo`是一个用于优化组件性能的高阶组件。
阅读更多2024-11-16
随笔content1
如果组件的具体类型无法获得，或者你并不关心组件的具体类型，那么可以使用 ComponentPublicInstance。当你将一个响应式对象的属性赋值或解构到一个本地变量时，访问或赋值该变量是非响应式
阅读更多2024-11-16
Java多线程底层设计思路
Java 的多线程设计比较全面和灵活，提供了多种方式来定义任务和管理线程，特别是通过Runnable和Callable接口，可以实现任务和线程的解耦，适应不同的应用场景。与 Python 和 C# 相
阅读更多2024-11-16
第七章利用CSS和多媒体美化页面
当设置为show时，就意味着当表格中某个单元格没有内容时，依然会显示该单元格的边框，这样可以保持表格的完整性和视觉上的连贯性，让用户在浏览表格时，能清晰地看到每个单元格的范围。而当参数为hide时，则
阅读更多2024-11-16
Cyberchef配合Wireshark提取并解析TCP/FTP流量数据包中的文件
通过cyberchef还原pcap数据包中TCP上层的文件内容，提升wireshark分析数据包的效率
阅读更多2024-11-16
redis
Redis 本质上是一个 Key-Value 类型的内存数据库，整个数据库加载在内存当中进行操作，定期通过异步操作把数据库数据 flush 到硬盘上进行保存。因为是纯内存操作， Redis 的性能
阅读更多2024-11-16
C++学习笔记之string容器、vector容器
vector可以动态扩展，动态扩展并不是在原空间之后续接新空间，而是找更大的内存空间，然后将原数据拷贝新空间，释放原空间。我们读过的书，说过的话，见过的山水，见到的人和事，最终都会变成我们脚下的的路。
阅读更多2024-11-16