Netflix Hystrix @EnableHystrix 注解

前面章节介绍的 Hystrix 实例中均使用 @EnableCircuitBreaker 注解开启断路器功能，但在 IDEA 中 @EnableCircuitBreaker 注解被提示不推荐使用，因为它的源码上面声明了 @Deprecated 注解。本章节将介绍使用 @EnableHystrix 注解替换 @EnableCircuitBreaker 注解。

@EnableHystrix 注解

该注解将方便客户端启用 Hystrix 断路器，该注解的作用也仅仅是打开断路器，并让自动配置找到可用的 Hystrix 类（需要 Hystrix 类库已经在类路径上）。如果你确定您想要的是 Hystrix 断路器，请使用此注解。

@EnableHystrix 注解源码如下：

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@EnableCircuitBreaker
public @interface EnableHystrix {

}

@EnableHystrix 与 @EnableCircuitBreaker 的区别

@EnableHystrix 和 @EnableCircuitBreaker 两个注解的功能都是用来激活 Hystrix 的功能。根据 @EnableHystrix 的源码可以发现，它继承了 @EnableCircuitBreaker，并对它进行了在封装。

如果你需要启动 Hystrix 功能，只需要在服务启动类加入 @EnableHystrix 注解即可，无须增加 @EnableCircuitBreaker 注解，本身 @EnableHystrix 注解已经涵盖了 @EnableCircuitBreaker 的功能。

Hystrix 实例

提供 Eureka Server 和 User 服务

在前面章节介绍了 Eureka Server 和 user 服务的搭建，详细信息参考 “Hystrix入门实例” 章节。

pom.xml

为了使用 Hystrix 组件，需要在 maven 中添加如下依赖：

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

application.yml

在该配置文件中配置 Eureka Server 注册中信息地址，服务端口、名称信息。配置如下：

server:
  port: 8080
spring:
  application:
    name: demo
# 服务地址
eureka:
  instance:
    hostname: localhost
    # 心跳间隔5s，默认30s。每一个服务配置后，心跳间隔和心跳超时时间会被保存在server端，
    # 不同服务的心跳频率可能不同，server 端会根据保存的配置来分别探活
    lease-renewal-interval-in-seconds: 5
    # 心跳超时时间10s，默认90s。从client端最后一次发出心跳后，达到这个时间没有再次发出
    # 心跳，表示服务不可用，将它的实例从注册中心移除
    lease-expiration-duration-in-seconds: 10
  client:
    service-url:
      # 注册中心路径，表示我们向这个注册中心注册服务，如果向多个注册中心注册，用“，”进行分隔
      defaultZone: http://localhost:8077/eureka

RestTemplateConfig.java

使用 @Configuration 配置类配置 RestTemplate，并且在 RestTemplate 上面添加 @LoadBalanced 注解。开启负载均衡功能，配置如下：

package com.hxstrive.springcloud.hystrix;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class RestTemplateConfig {

    // 配置一个 RestTemplate
    @Bean
    // 添加该注解后，可以使得 RestTemplate 拥有负载均衡能力
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

}

DemoService.java

在类中注入 RestTemplate 实例，使用 RestTemplate 实例去调用前面提供的 User 服务。代码如下：

package com.hxstrive.springcloud.hystrix;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

@Component
public class DemoService {

    @Autowired
    private RestTemplate restTemplate;

    public String getInfo() {
        System.out.println("restTemplate=" + restTemplate);
        // 如果你要实现负载均衡，调用地址不能写具体主机地址
        // 需要将主机地址替换成对于服务的服务名，即 spring.application.name 指定的值
        // 你也可以到 Eureka server 中去查看
        String url = "http://USER/info";
        ResponseEntity<String> resp = restTemplate.getForEntity(url, String.class);
        if(resp.getStatusCode().is2xxSuccessful()) {
            return resp.getStatusCode().value() + " :: " + resp.getBody();
        } else {
            return resp.getStatusCode().value() + " :: " + resp.getBody();
        }
    }

}

HystrixDemo3Application.java

客户端代码，使用 @EnableHystrix 注解替换 @EnableCircuitBreaker 注解，开启 Hystrix 功能。代码如下：

package com.hxstrive.springcloud.hystrix;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@SpringBootApplication
// 启用断路器
@EnableHystrix
public class HystrixDemo3Application {

    @Autowired
    private DemoService demoService;

    public static void main(String[] args) {
        SpringApplication.run(HystrixDemo3Application.class, args);
    }

    @GetMapping({"/"})
    @HystrixCommand(fallbackMethod="indexFallback")
    public String index() {
        return demoService.getInfo();
    }

    private String indexFallback() {
        return "很抱歉，网络拥挤！";
    }

}