java版spring cloud+spring boot+redis社交电子商务平台：服务容错保护（Hystrix服务降级）...

╰半夏微凉° 2022-10-01 11:41 111阅读 0赞

## 动手试一试 ##

电子商务社交平台源码请加企鹅求求：三五三六二四七二五九。在开始使用Spring Cloud Hystrix实现断路器之前，我们先拿之前实现的一些内容作为基础，其中包括：

*  `eureka-server`工程：服务注册中心，端口：1001
 *  `eureka-client`工程：服务提供者，两个实例启动端口分别为2001

下面我们可以复制一下之前实现的一个服务消费者：`eureka-consumer-ribbon`，命名为`eureka-consumer-ribbon-hystrix`。下面我们开始对其进行改在：

第一步：`pom.xml`的dependencies节点中引入`spring-cloud-starter-hystrix`依赖：

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
    </dependency>复制代码

第二步：在应用主类中使用`@EnableCircuitBreaker`或`@EnableHystrix`注解开启Hystrix的使用：

@EnableCircuitBreaker
    @EnableDiscoveryClient
    @SpringBootApplication
    public class Application {
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String[] args) {
            new SpringApplicationBuilder(Application.class).web(true).run(args);
        }
    
    }复制代码

**注意：这里我们还可以使用Spring Cloud应用中的`@SpringCloudApplication`注解来修饰应用主类，该注解的具体定义如下所示。我们可以看到该注解中包含了上我们所引用的三个注解，这也意味着一个Spring Cloud标准应用应包含服务发现以及断路器。**

@Target({ElementType.TYPE})
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    @Inherited
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableCircuitBreaker
    public @interface SpringCloudApplication {
    }复制代码

第三步：改造服务消费方式，新增`ConsumerService`类，然后将在`Controller`中的逻辑迁移过去。最后，在为具体执行逻辑的函数上增加`@HystrixCommand`注解来指定服务降级方法，比如：

@RestController
    public class DcController {
    
        @Autowired
        ConsumerService consumerService;
    
        @GetMapping("/consumer")
        public String dc() {
            return consumerService.consumer();
        }
    
        class ConsumerService {
    
            @Autowired
            RestTemplate restTemplate;
    
            @HystrixCommand(fallbackMethod = "fallback")
            public String consumer() {
                return restTemplate.getForObject("http://eureka-client/dc", String.class);
            }
    
            public String fallback() {
                return "fallback";
            }
    
        }
    
    }复制代码

下面我们来验证一下上面Hystrix带来的一些基础功能。我们先把涉及的服务都启动起来，然后访问`localhost:2101/consumer`，此时可以获取正常的返回，比如：`Services: [eureka-consumer-ribbon-hystrix, eureka-client]`。

为了触发服务降级逻辑，我们可以将服务提供者`eureka-client`的逻辑加一些延迟，比如：

@GetMapping("/dc")
    public String dc() throws InterruptedException {
        Thread.sleep(5000L);
        String services = "Services: " + discoveryClient.getServices();
        System.out.println(services);
        return services;
    }复制代码

重启`eureka-client`之后，再尝试访问`localhost:2101/consumer`，此时我们将获得的返回结果为：`fallback`。我们从`eureka-client`的控制台中，可以看到服务提供方输出了原本要返回的结果，但是由于返回前延迟了5秒，而服务消费方触发了服务请求超时异常，服务消费者就通过HystrixCommand注解中指定的降级逻辑进行执行，因此该请求的结果返回了`fallback`。这样的机制，对自身服务起到了基础的保护，同时还为异常情况提供了自动的服务降级切换机制。

电子商务社交平台源码请加企鹅求求：三五三六二四七二五九

转载于:https://juejin.im/post/5cfe1ce6e51d457778117367