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

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 看看你的路径是那个。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/640107.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

SSRF服务端请求伪造漏洞原理与修复及靶场实践

SSRF服务端请求伪造漏洞原理与修复及靶场实践 SSRF漏洞原理与检测 SSRF&#xff08;Server-Side Request Forgery&#xff0c;服务器端请求伪造&#xff09;漏洞是一种因为服务端提供了远程访问服务&#xff0c;而并未对请求目标进行限制或限制不严格而引起的安全漏洞&#x…

极空间部署本地最强私有化PDF工具箱『Stirling-PDF』

极空间部署本地最强私有化PDF工具箱『Stirling-PDF』 哈喽小伙伴们好&#xff0c;我是Stark-C~ 关注我的粉丝应该知道&#xff0c;我在前几天教大家怎么在NAS上部署本地最强私有化PDF工具箱『Stirling-PDF』&#xff1a; &#x1f53a;评论区好几位小伙伴都提到了极空间的部署…

【免费Web系列】大家好 ,今天是Web课程的第六天点赞收藏关注,持续更新作品 !

这是Web第一天的课程大家可以传送过去学习 http://t.csdnimg.cn/K547r 后端Web实战(IOCDI) 前言 Web开发的基础知识 &#xff0c;包括 Tomcat、Servlet、HTTP协议等&#xff0c;我们都已经学习完毕了&#xff0c;那接下来&#xff0c;我们就要进入Web开发的实战篇。在实战篇中…

基于自抗扰控制器和线性误差反馈控制律(ADRC-LSEF)的控制系统simulink建模与仿真

目录 1.课题概述 2.系统仿真结果 3.核心程序与模型 4.系统原理简介 4.1 ADRC原理 4.2 线性误差反馈控制律(LSEF) 4.3 ADRC-LSEF融合系统 5.完整工程文件 1.课题概述 基于自抗扰控制器和线性误差反馈控制律(ADRC-LSEF)的控制系统simulink建模与仿真。 2.系统仿真结果 …

[Unity报错] The type or namespace name ‘Newtonsoft‘ could not be found

简介 Unity在跑别人的代码时&#xff0c;控制台报了以下错误 The type or namespace name Newtonsoft could not be found 鉴于这块资料较少&#xff0c;写一下教程帮助后来者。 报错的原因主要是因为缺少Newtonsoft.json这个包&#xff0c;导致Unity在using该库时出现错误。…

【Vue3】封装axios请求(cli和vite)

原文作者&#xff1a;我辈李想 版权声明&#xff1a;文章原创&#xff0c;转载时请务必加上原文超链接、作者信息和本声明。 Vue 【Vue3】env环境变量的配置和使用&#xff08;区分cli和vite&#xff09; 文章目录 Vue前言一、常见用法二、vue3cli封装接口1..env配置2..dev(开…

LuatOS-iRTU

DTU 英文全称为Data Transfer Unit&#xff0c;表示数据传输单元。 是专门用于将串口数据转为IP数据或将I[数据转换为串口数据&#xff0c;通过无线通信网络进行传送的无线终端设备。 业务逻辑包括数据采集上报&#xff1a; 传感器采集数据发送给单片机&#xff0c;单片机由串…

数据库常用命令(1)

DML 1.添加数据&#xff08;insert into&#xff09; insert into 表名 values (值1&#xff0c;值2....); 表示成功运行&#xff1a; 2.修改数据&#xff08;update&#xff09; update 表名 set 字段名1值1&#xff0c;字段名2值2.....【where条件】 3.删除数据&#xff0…

STM32使用旋转编码开关

一、旋转编码开关如何工作 编码器内部有一个开槽圆盘&#xff0c;连接到公共接地引脚 C。它还具有两个接触针 A 和 B&#xff0c;如下所示。 当您转动旋钮时&#xff0c;A 和 B 按照特定顺序与公共接地引脚 C 接触&#xff0c;具体顺序取决于转动旋钮的方向。 当它们与公共地接…

23种设计模式之一————外观模式详细介绍与讲解

外观模式详细讲解 一、概念二、 外观模式结构核心思想及解释模式的UML类图模式角色应用场景模式优点模式缺点 三、实例演示图示代码展示运行结果 一、概念 外观模式&#xff08;Facade Pattern&#xff09;是一种结构型设计模式&#xff0c;它提供了一个统一的接口&#xff0c…

详细分析Vue按钮间距的优化方式(附Demo)

目录 前言1. 按钮间距2. 垂直间距 前言 正常间距如下&#xff1a; 其Demo如下&#xff1a; <el-table-column label"操作" align"center"><template #default"scope"><el-buttonlinktype"primary"click"openFor…

XSS漏洞:pikachu靶场中的XSS通关

目录 1、反射型XSS&#xff08;get&#xff09; 2、反射性XSS&#xff08;POST&#xff09; 3、存储型XSS 4、DOM型XSS 5、DOM型XSS-X 6、XSS之盲打 7、XSS之过滤 8、XSS之htmlspecialchars 9、XSS之href输出 10、XSS之js输出 最近在学习XSS漏洞&#xff0c;这里使用…

苹果CMS:怎么重新安装

当我们安装好苹果CMS之后苹果cms&#xff1a;介绍及安装&#xff0c;但是最好我们在安装的时候配置好对应配置后&#xff0c;备份一份&#xff0c;如果不记得哪里配置出了问题&#xff0c;出现一些不可预料的问题&#xff0c;那我们可以简单暴力的直接重新安装&#xff0c;我们…

Netty学习02----使用多线程优化Selector

背景前置 在单线程环境下&#xff0c;使用一个线程同时绑定多个事件&#xff1a;连接事件、读事件、写事件。不能充分发挥多核CPU的优势&#xff0c;考虑使用多个线程&#xff0c;每个线程专门负责处理不同的事件&#xff0c;如下图所示&#xff1a;一个线程专门负责连接&#…

【Spring Security系列】权限之旅:SpringSecurity小程序登录深度探索

作者&#xff1a;后端小肥肠 创作不易&#xff0c;未经允许严禁转载。 姊妹篇&#xff1a; 【Spring Security系列】Spring SecurityJWTRedis实现用户认证登录及登出_spring security jwt 退出登录-CSDN博客 1. 前言 欢迎来到【Spring Security系列】&#xff01;在当今数字化…

后端之路第二站(正片)——SprintBoot之:分层解耦

很抽象&#xff0c;我自己也不好理解&#xff0c;仅作为一个前端转后端的个人理解 一、先解释一个案例&#xff0c;以这个案例来分析“三层架构” 这里我先解释一下黑马程序员里的这个案例&#xff0c;兄弟们看视频的可以跳过这节课&#xff1a;Day05-08. 请求响应-响应-案例_…

OpenStack配置 之 不同cpu迁移虚拟机

介绍 OpenStack是一个开源的云计算管理平台项目&#xff0c;是一系列软件开源项目的组合。 OpenStack由NASA&#xff08;美国国家航空航天局&#xff09;和Rackspace合作研发并发起&#xff0c;以Apache许可证&#xff08;Apache软件基金会发布的一个自由软件许可证&#xff…

亚洲知名度最高的杰出代表人物颜廷利:人生的意义和生命的价值,只有‘四部曲’

在童年的田野里&#xff0c;玩耍是孩子们最纯粹的语言&#xff0c;他们通过释放天性探索世界的奥秘。如同小溪自由地流淌&#xff0c;孩童们在游戏中学会交流、合作&#xff0c;激发无限想象。这时期&#xff0c;他们如同种子一般&#xff0c;需要充足的阳光和水分&#xff0c;…

构建智能化的语言培训教育技术架构:挑战与机遇

随着全球化的发展和人们对语言学习需求的增长&#xff0c;语言培训教育行业正面临着越来越多的挑战和机遇。在这个背景下&#xff0c;构建智能化的语言培训教育技术架构成为提升服务质量和效率的重要手段。本文将探讨语言培训教育行业的技术架构设计与实践。 一、智能化教学平台…

电脑版网易云音乐听歌识曲

文章目录 流程 流程 电脑网易云音乐的搜索框旁边就是听歌识曲功能