SpringCloud Hystrix 定义服务降级
壳叔搞笑时间
正文 前言
在微服务架构中，我们将系统拆分成了一个个的服务单元，各单元应用间通过服务注册与订阅的方式互相依赖。由于每个单元都在不同的进程中运行，依赖通过远程调用的方式执行，这样就有可能因为网络原因或是依赖服务自身问题出现调用故障或延迟，而这些问题会直接导致调用方的对外服务也出现延迟，若此时调用方的请求不断增加，最后就会出现因等待出现故障的依赖方响应而形成任务积压，线程资源无法释放，最终导致自身服务的瘫痪，进一步甚至出现故障的蔓延最终导致整个系统的瘫痪。如果这样的架构存在如此严重的隐患，那么相较传统架构就更加的不稳定。为了解决这样的问题，因此产生了断路器等一系列的服务保护机制。
针对上述问题，在 Cloud 中实现了线程隔离、断路器等一系列的服务保护功能。它也是基于的开源框架 实现的，该框架目标在于通过控制那些访问远程系统、服务和第三方库的节点，从而对延迟和故障提供更强大的容错能力。具备了服务降级、服务熔断、线程隔离、请求缓存、请求合并以及服务监控等强大功能。
接下来，我们就从一个简单示例让你了解服务降级
对外提供了一个服务中心地址 :8000// 可用于日常学习使用，请勿用于生产服务
参考项目
懒人命令行专用 git clone
运行项目 运行项目主类
- 服务注册中心 - 服务提供者
创建maven子项目模块 命名为~--- [这个随意就好，反正我是挺随意的，当时没想着展示]
UTF-8 UTF-8 1.8 1.8 1.8 Brixton.RELEASE org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-test test org.springframework.cloud spring-cloud-starter-eureka org.springframework.cloud spring-cloud-starter-ribbon org.springframework.cloud spring-cloud-starter-hystrix org.springframework.cloud spring-cloud-dependencies ${spring-cloud.version} pom import spring-milestones Spring Milestones https://repo.spring.io/libs-milestone false org.springframework.boot spring-boot-maven-plugin #命名
spring.application.name=eureka-consumer-ribbon-hystrix
#运行端口
server.port=9000
#服务中心地址
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/ *** 第三步 在应用主类中使用@或@注解开启的使用
/** * pom.xml的dependencies节点中引入spring-cloud-starter-hystrix依赖 * 在应用主类中使用@EnableCircuitBreaker或@EnableHystrix注解开启Hystrix的使用 */
@EnableCircuitBreaker
@EnableDiscoveryClient
@SpringBootApplication
public class Application { /** * 创建RestTemplate 的springbean实例 * 通过@LoadBalanced 注解开启客户端负载均衡 * @return */ @Bean @LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } //这个就不解释了，这个要是不理解，那我只能说请你回炉重学吧public static void main(String[] args) { SpringApplication.run(Application.class, args); }
}
创建类
在类里创建内部类
接下来看代码~~~
@RestController
public class ConsumerController { @Autowired ConsumerService consumerService; @GetMapping("/consumer") public String consumer() { return consumerService.consumer(); } @Service class ConsumerService { @Autowired RestTemplate restTemplate; /** * 具体执行逻辑的函数上增加@HystrixCommand 注解来指定服务降级方法, * fallbackMethod定义回退方法的名称 * @return */ @HystrixCommand(fallbackMethod = "fallback") public String consumer() { // 如果报异常 则会调用fallbackMethod 指定方法 “fallback” //int error = Integer.parseInt("error"); String result = restTemplate.getForEntity("http://EUREKA-CLIENT/hello", String.class).getBody(); System.out.println(result); return result; } /** * 此处可能是另一个网络请求来获取，所以也可能失败 \* @return */ @HystrixCommand(fallbackMethod = "fallbackSEC") String fallback() { return "Execute raw fallback"; } String fallbackSEC() { return "Execute raw fallback"; } } }第四步则是用注解的方式来实现服务降级，如果将的//int error = .(“error”);如果将注释取消掉，则会立马进入 方法来实现服务降级逻辑。
对于方法的访问修饰符没有特定要求，这个可以放心。
但是需要一点 方法 需要与@ 在同一个类中。
这是我认为 服务容错保护学习过程中，看代码更容易理解的一个阶段~。 关于我们
程序员是个辛苦的职业
请善待你们身边的每一位程序员~
欢迎在评论写下你的程序员趣事，程序员不是一个死板的职业~~
欢迎扫描二维码加入我们的小组织 ，大家都叫我壳叔，很期待你的到来。
黑壳网交流群 Q 群:
