服务消费者feign与Hystrix断路器容错机制-微服务架构

低调小熊猫

发布于 2020-06-07 10:47:38

6050

发布于 2020-06-07 10:47:38

文章被收录于专栏：低调小熊猫

Feign消费者与Hystrix断路器容错机制-微服务架构

注册中心：https://github.com/java-aodeng/hope/tree/master/micro-service1-eureka-server

服务提供者：https://github.com/java-aodeng/hope/tree/master/micro-service2-eureka-provider

后面都以上面的注册中心，和服务提供者为基础操作后续内容（代码已经开源，使用方式见我上一篇and上上篇文章）

创建Feign与Hystrix

1.添加依赖

<!--feign star-->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>        </dependency>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-openfeign</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <!--feign end-->        <!--添加Hystrix依赖 断路器容错保护 -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>        </dependency>

2.配置yml文件

#配置服务消费者server:  port: 8888spring:  application:    name: eureka-feigneureka:  client:    serviceUrl:      defaultZone: http://localhost:8761/eureka/#开启hystrix 指标feign:  hystrix:    enabled: true

3.启动入口添加注解

@SpringBootApplication@EnableEurekaClient@EnableFeignClients@EnableHystrix//开启断路器功能public class MicroService5FeignApplication {    public static void main(String[] args) {        SpringApplication.run(MicroService5FeignApplication.class, args);    }}

测试

用feign方式消费接口并添加Hystrix断路器

1.创建service层

/** * Feign消费服务接口,定义一个feign接口，通过@ FeignClient（“服务名”），来指定调用哪个服务。比如在代码中调用了eureka-provider服务的“/test”接口 * 注意:服务名大小写无所谓，@FeignClient 会把接口类交给spring所管理,也就是说是可以@Autowired注入的 * @program:hope * @author:aodeng * @blog:低调小熊猫(https://aodeng.cc) * @微信公众号:低调小熊猫 * @create:2019-03-14 13:58 **/@FeignClient(value = "eureka-provider",fallback = TestFeignFallback.class)//关联fallback = TestFeignFallback.class 一旦错误就会调同名称的方法public interface TestFeign {    @RequestMapping("/test")    String testFegin();    @RequestMapping("/testByParam/{from}")    String testByParam(@PathVariable(value = "from") String from);}

2.创建fallback类，出错调用

/** * @program:hope * @ClassName:TestFeignFallback * @author:aodeng * @blog:低调小熊猫(https://aodeng.cc) * @create:2019-03-16 15:33 * @Description: 错误回调类 关联fallback = TestFeignFallback.class 一旦错误就回调同名称的方法 * @Version 1.0 **/@Componentpublic class TestFeignFallback implements TestFeign{    @Override    public String testFegin() {        return "Hystrix断路器容错机制启动";    }    @Override    public String testByParam(String from) {        return "Hystrix断路器容错机制启动";    }}

3.创建controller使用

/** * @program:hope * @ClassName:TestFeignController * @author:aodeng * @blog:低调小熊猫(https://aodeng.cc) * @create:2019-03-14 13:58 * @Description: TODO * @Version 1.0 **/@RestControllerpublic class TestFeignController {    @Autowired(required = false)    private TestFeign testFeign;    @RequestMapping("/testFegin")    public String testFeign(){        return testFeign.testFegin();    }    /**     * @Description: 传参数的接口需要加接收参数的注解，service也要加接收参数的注解，服务提供者provider也要加注解，3个接口必须保持一致    * @Param: [from]    * @return: [from]    * @Author: aodeng    * @Date: 19-3-15    */     @RequestMapping("/testByParam/{from}")    public String testByParam(@PathVariable(value = "from") String from){        return testFeign.testByParam(from);    }}