hystrix熔断、降级使用示例

@SpringCloudApplication
代替
@SpringBootApplication 
@EnableDiscoveryClient  
@EnableCircuitBreaker

/**
 * SpringCloudApplication
 *  提供了springboot 的功能
 *  提供了自动注册到服务中心的功能
 *  开启了断路器
 **/
@SpringCloudApplication
public class UserApplication {
    /**
     * 作为Spring的一个Bean
     **/
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate()
    {
        return new RestTemplate();
    }
    public static void main(String[] args) {    SpringApplication.run(UserApplication.class, args);
    }
 
}

/**
  * @description: 用户服务与活动服务交互
 **/
@Service
public class ActivityService {
 
    @Autowired
    private RestTemplate restTemplate;
 
 
    /**
     *  调用活动服务，完成初次登陆，奖励发放
     *  定义超时时间，让用户服务不再等待活动服务的响应
     *  这样的话，可以及时释放资源。
     *  使用hystrix，设置超时时间超过2s时则不继续等待调用，直接返回
     **/
    @HystrixCommand(commandProperties = {
            @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value = "2000")
    })
    public String firstLoginTimeout(Long userId){
        //使用服务名，实际上Spring会将服务名转为对应ip
        return restTemplate.postForObject("http://xxx/xxxTimeout", userId, String.class);
    }
}

/**
 * 用户服务与活动服务交互
 **/
@Service
public class ActivityService {
 
    @Autowired
    private RestTemplate restTemplate;
 
    /**
     *  需要提供一个备用方案，当活动服务不可用时，执行备用方案,即降级
     **/
    @HystrixCommand(fallbackMethod = "firstLoginFallback0")
    public String firstLoginFallback(Long userId){
        //使用服务名，实际上Spring会将服务名转为对应ip
        return restTemplate.postForObject("http://xxx/xxxError", userId, String.class);
    }
 
    public String firstLoginFallback0(Long userId){
        return "活动备用方案--降级";
    }
}