Ribbon使用Hystrix

org.springframework.cloudspring-cloud-starter-hystrix

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;&＃64;SpringBootApplication
&＃64;EnableDiscoveryClient
//开启Ribbon
&＃64;RibbonClient(name&＃61;"cloud-producer")
//启动断路器支持(Hystrix)
&＃64;EnableCircuitBreaker
public class RibbonConsumerApplication {&＃64;Bean&＃64;LoadBalanced //负载均衡public RestTemplate restTemplate() {return new RestTemplate();}public static void main(String[] args) {SpringApplication.run(RibbonConsumerApplication.class, args);}}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import org.springframework.web.client.RestTemplate;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;&＃64;Repository
public class TestService {&＃64;Autowiredprivate RestTemplate restTemplate;//设置断路器,当此方法无法应答时(把mima-cloud-producer服务停掉),调用getError方法&＃64;HystrixCommand(fallbackMethod&＃61;"getError")public String get(String id) {System.out.println(Thread.currentThread().getName()&＃43;".get before...");String result &＃61; restTemplate.getForObject("http://cloud-producer/get/"&＃43;id, String.class);System.out.println(Thread.currentThread().getName()&＃43;".get end...result&＃61;"&＃43;result);return result;}public String getError(String id) {System.out.println(Thread.currentThread().getName()&＃43;"断路器启动");return "断路器fallback返回error";}
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;import com.mimaxueyuan.consumer.robbin.service.TestService;&＃64;RestController
public class TestController {&＃64;Autowiredprivate TestService testService;&＃64;GetMapping("/ribbon/get/{id}")public String get(&＃64;PathVariable String id) {return testService.get(id);}
}