当前位置：首页 > news >正文

湖北三丰建设集团股份网站如何写软文推广产品

news 2025/8/9 0:26:01

湖北三丰建设集团股份网站,如何写软文推广产品,东营信息港,网站快速备案多少钱简介 Hystrix 是springcloud官方推出的分布式系统容错处理的一个组件那么这个组件有哪些作用呢,官方文档是这样说的 : 通过客户端库对延迟和故障进行保护和控制在一个复杂的分布式系统中停止级联故障快速失败和迅速恢复在合理的情况下回退和优雅的降级开启近实时监控报警和…

简介

Hystrix 是springcloud官方推出的分布式系统容错处理的一个组件

那么这个组件有哪些作用呢,官方文档是这样说的 :

通过客户端库对延迟和故障进行保护和控制
在一个复杂的分布式系统中停止级联故障
快速失败和迅速恢复
在合理的情况下回退和优雅的降级
开启近实时监控报警和操作控制

这里举一个很简单的例子来概括一下 Hystrix 的作用

比如你的分布式系统中服务A 因为某种原因调不通了 , 导致依赖服务A 的服务B 也挂在那里 , 从而造成级联故障 , 这也是大家常说的分布式系统中服务雪崩的一种体现 ,
关于服务雪崩 , 通常的解决办法就是限流 , 熔断 , 隔离,这里就不展开讲了

这里通过一个小的demo来看一下 Hystrix 的熔断功能

实战案例

创建 client-service 工程

引入相关依赖

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

并在启动类上添加注解开启 Hystrix 模式

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

增加@HystrixCommand 和降级 fallback


/***@Description*@author apdoer*@CreateDate 2019/6/15-13:20*@Version 1.0*===============================
**/
@RestController
public class DemoController {@HystrixCommand(fallbackMethod = "fallbackMethod")@GetMapping("/getUser")public String getUser(String username) throws Exception {if ("apdoer".equals(username)){return "username====="+username;}else {throw new Exception();}}/*** 通过 @HystrixCommand 注解指定的方法如果出错,则调用关联的方法*      比如getUser方法如果出错,就会调用 指定的 fallbackMethod方法* @param username* @return*/public String fallbackMethod(String username){return username + "does not exists";}
}

我们来看下效果,分别访问

localhost:8080/getUser?username=apdoer
localhost:8080/getUser?username=Hystrix

可以看到结果和我们预想的是一样的:

当 username=apdoer 时返回 username=====apdoer
当username != apdoer 时返回 username does not exists

Feign中使用断路器

上面我们在一个单体工程中使用了 Hystrix 的熔断功能 , 接下来我们在在 Feign 中使用 Hystrix

在Feign中实默认自带 Hystrix 功能的,但是在新版本是默认关闭的,需要通过配置文件打开

创建consumer 工程 , 定义接口

使用 @FeignClient 定义接口

@FeignClient(name = "client-service",fallback = UserServiceFallback.class)
public interface UserService {@GetMapping("/getUser")String getUser(@RequestParam("username") String username);
}

配置降级类

@Component
public class UserServiceFallback implements UserService {/*** 出错则调用该方法返回友好提示* @param username* @return*/public String getUser(String username){return username + "does not exists";}
}

配置文件

server:port: 8081
spring:application:name: service-consumer
eureka:client:service-url:defaultZone: http://localhost:8761/eureka/
feign:hystrix:enabled: true

controller里的接口就不在这里贴了,很简单

结果:

当不启动client-service 工程,并且不开启 Feign 中的Hystrix时,访问localhost:8081/getUser?username=apdoer,报错500
打开Feign 的Hystrix再次访问,发现 Hystrix已经起作用了

feign:hystrix:enabled: true

这里虽然没有贴出具体访问的效果图,但是我把整个过程梳理一下, 大家可以自己试

consumer中定义了 FeignClient接口,调用了service-client 中的getUser接口
service-client 中的 getUser有一个熔断方法,当你传入的值不是apdoer时,会调用这里的熔断方法
而service-client 没有启动或者 consumer 中的开启 Hystrix没有配置时,会导致Feign调不通或者 Feign调用 Hystrix没有生效,所以会报500
而service-client没有启动但是 consumer 中的开启了 Hystrix配置时,会调用consumer中的熔断方法
当service-client 启动,并且Feign 应用Hystrix 配置开启了,此时能调通就调的是service-client中的方法

Hystrix 的异常处理机制

Hystrix 的异常处理中 , 有 5 种出错的情况会进入熔断的逻辑中,从而触发fallback

FAILURE : 执行失败 , 抛出异常
TIMEOUT : 执行超时
SHORT_CIRCUITED : 断路器打开
THREAD_POOL_REJECTED : 线程池拒绝
SEMAPHORE_REJECTED : 信号量拒接

那么,就会有一种我们很常见的异常不会触发 fallback 从而进入熔断逻辑 ,他就是 BAD_REQUEST,
会抛出HystrixBadRequestException,一般都是参数不和法,或者Feign 调用的时候没有按照规范来
对于这类异常 , 可以根据响应创建对应的异常进行异常封装或者直接处理,