Spring Cloud(Dalston.SR5)--Feign 与 Hystrix 断路器整合

  • 创建项目

    要使 Feign 与 Hystrix 进行整合,我们需要增加 Feign 和 Hystrix 的依赖,修改 POM.xml 中增加以下依赖项如下:

    <?xmlversion="1.0"encoding="UTF-8"?>

    <projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    ?
    ?

    <groupId>org.lixue</groupId>

    <artifactId>spring-cloud-hystrix-client</artifactId>

    <version>0.0.1-SNAPSHOT</version>

    <packaging>jar</packaging>

    ?
    ?

    <name>spring-cloud-hystrix-client</name>

    <description>DemoprojectforSpringBoot</description>

    ?
    ?

    <parent>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-parent</artifactId>

    <version>1.5.4.RELEASE</version>

    <relativePath/><!--lookupparentfromrepository-->

    </parent>

    ?
    ?

    <properties>

    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

    <java.version>1.8</java.version>

    <spring-cloud.version>Dalston.SR5</spring-cloud.version>

    </properties>

    ?
    ?

    <dependencies>

    <dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-web</artifactId>

    </dependency>

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-eureka</artifactId>

    </dependency>

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-feign</artifactId>

    </dependency>

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-ribbon</artifactId>

    </dependency>

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-hystrix</artifactId>

    </dependency>

    <dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-test</artifactId>

    <scope>test</scope>

    </dependency>

    </dependencies>

    ?
    ?

    <dependencyManagement>

    <dependencies>

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-dependencies</artifactId>

    <version>${spring-cloud.version}</version>

    <type>pom</type>

    <scope>import</scope>

    </dependency>

    </dependencies>

    </dependencyManagement>

    ?
    ?

    <build>

    <plugins>

    <plugin>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-maven-plugin</artifactId>

    </plugin>

    </plugins>

    </build>

    </project>

?
?

  • 增加配置

    还需要在 src/main/resources/application.yml 中,开启 Feign 的配置,如下:

    #配置应用名称

    spring:

    application:

    name:spring-cloud-hystrix-client

    #服务端口

    server:

    port:8077

    #启用feign的hystrix支持

    feign:

    hystrix:

    enabled:true

    #设置eureka服务注册中心的地址,如果多个以逗号分割

    eureka:

    client:

    service-url:

    defaultZone:http://eurekaserver01:9000/eureka/,http://eurekaserver02:9000/eureka/

    ?
    ?

  • 创建 Feign 客户端

    创建 Feign 客户端接口,增加回退的类实现,在 @FeignClient 注解中,设置 fallback 属性,如下:

    package org.lixue;

    ?
    ?

    import org.springframework.cloud.netflix.feign.FeignClient;

    import org.springframework.stereotype.Component;

    import org.springframework.web.bind.annotation.RequestMapping;

    import org.springframework.web.bind.annotation.RequestMethod;

    import org.springframework.web.bind.annotation.RequestParam;

    ?
    ?

    @FeignClient(name="HELLOWORLD-PROVIDER",fallback=HelloWorldFeignClient.HelloWorldFallback.class)

    public interface HelloWorldFeignClient{

    ?
    ?

    @RequestMapping(path="/speaks",method=RequestMethod.GET)

    String speak(@RequestParam(name="names")Stringname);

    ?
    ?

    @Component

    class HelloWorldFallback implements HelloWorldFeignClient{

    ?
    ?

    @Override

    public String speak(String name){

    return"speakfallbackisname="+name;

    }

    }

    }

?
?

  • 创建调用类

    只需要使用 @Autowired 注解标注 HelloWorldFeignClient 实例进行自动注入,然后调用 HelloWorldFeignClient 实例的方法即完成调用,如下:

    package org.lixue;

    ?
    ?

    import org.springframework.beans.factory.annotation.Autowired;

    import org.springframework.web.bind.annotation.RequestMapping;

    import org.springframework.web.bind.annotation.RequestMethod;

    import org.springframework.web.bind.annotation.RequestParam;

    import org.springframework.web.bind.annotation.RestController;

    ?
    ?

    import java.util.List;

    import java.util.Map;

    import java.util.concurrent.ExecutionException;

    import java.util.concurrent.Future;

    ?
    ?

    @RestController

    public class InvokerController{

    ?
    ?

    @Autowired

    private HelloWorldFeignClient helloWorldFeignClient;

    ?
    ?

    @RequestMapping(method=RequestMethod.GET,path="/speakFeign")

    public String speakFeign(@RequestParam("name")String name){

    return helloWorldFeignClient.speak(name);

    }

    }

?
?

?
?

  • 启动类

    增加 @EnableCircuitBreaker 和 @EnableFeignClients 注解,启用 Feign 和 Hystrix 功能,如下:

    package org.lixue;

    ?
    ?

    import org.springframework.boot.SpringApplication;

    import org.springframework.boot.autoconfigure.SpringBootApplication;

    import org.springframework.boot.web.servlet.ServletComponentScan;

    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;

    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

    import org.springframework.cloud.netflix.feign.EnableFeignClients;

    ?
    ?

    @SpringBootApplication

    @EnableDiscoveryClient

    @EnableCircuitBreaker

    @EnableFeignClients

    @ServletComponentScan

    public class SpringCloudHystrixClientApplication{

    ?
    ?

    public static void main(String[]args){

    SpringApplication.run(SpringCloudHystrixClientApplication.class,args);

    }

    }

    ?
    ?

  • 测试验证

    由于我们使用了 Ribbon 因此首先启动 eureka-server 和 service-provider 服务,然后启动该项目,访问 http://localhost:8077/speak?name=abc 可以看到能正常返回信息,如下:

    Hello World abc Port=8080

    此时,关闭 service-provider 服务,然后在访问地址 http://localhost:8077/speak?name=abc 可以看到,由于服务已经不可用,因此执行了该方法的回退返回,返回如下:

    speak fallback is name=abc

    ?
    ?

  • 配置说明

    Feign 与 Hystrix 整合使用时,会自动帮我们生成 CommandKey,格式为:Feign 客户端接口名称#方法名() ,生成的 GroupKey 为 @FeignClient 注解的 name 属性,例如,上面示例生成的 CommandKey 为 HelloWorldFeignClient#speak() ,Groupkey 为 HELLOWORLD-PROVIDER,如果需要针对该 Feign 客户端设置 Hystrix 的配置属性,在 application.yml 中增加配置如下:

    #设置Hystrix的属性

    hystrix:

    command:

    HelloWorldFeignClient#speak():

    execution:

    isolation:

    thread:

    timeoutInMilliseconds:200

    如果需要设置默认全局属性,则修改 application.yml 配置如下:

    #设置Hystrix的属性

    hystrix:

    command:

    default:

    execution:

    isolation:

    thread:

    timeoutInMilliseconds:200

    ?
    ?

原文地址:https://www.cnblogs.com/li3807/p/8916830.html

时间: 2024-10-09 05:46:11

Spring Cloud(Dalston.SR5)--Feign 与 Hystrix 断路器整合的相关文章

Spring Cloud(Dalston.SR5)--Zuul 网关-Hystrix 回退

当我们对网关进行配置让其调用集群的服务时,将会执行 Ribbon 路由过滤器,该过滤器在进行转发时会封装为一个 Hystrix 命令予以执行,Hystrix 命令具有容错的功能,如果"源服务"出现问题(例如超时),那边所执行的 Hystrix 命令将会触发回退,我们需要实现 org.springframework.cloud.netflix.zuul.filters.route.ZuulFallbackProvider 接口,该接口主要需要实现 getRoute 方法 .fallbac

Spring Cloud(Dalston.SR5)--Config 集群配置中心

Spring Cloud Config 是一个全新的项目,用来为分布式系统中的基础设施和微服务应用提供集中化的外部配置支持,他分为服务端和客户端两个部分.服务端也称为分布式配置中心,是一个独立的微服务应用,用来连接配置仓库并为客户端提供获取配置信息.加密.解密信息等访问接口:而客户端则是为微服务架构中的各个微服务应用,通过指定的配置中心来管理应用资源与业务相关的配置内容,并在启动的时候从配置中心获取和加载配置信息.服务端与客户端的结构图如下: ? ? ? ? Spring Cloud 程序在进行

Spring Cloud(Dalston.SR5)--Zuul 网关-微服务集群

通过 url 映射的方式来实现 zuul 的转发有局限性,比如每增加一个服务就需要配置一条内容,另外后端的服务如果是动态来提供,就不能采用这种方案来配置了.实际上在实现微服务架构时,服务名与服务实例地址的关系在 eureka server 中已经存在了,所以只需要将Zuul注册到 eureka server上去发现其他服务,就可以实现对 serviceId 的映射,并且启用了 eureka server 同时也会启用 ribbon 对服务进行负载均衡调用,加入 Zuul 到微服务集群架构图如下:

Spring Cloud(Dalston.SR5)--Hystrix 断路器

Spring Cloud 对 Hystrix 进行了封装,使用 Hystrix 是通过 @HystrixCommand 注解来使用的,被 @HystrixCommand 注解标注的方法,会使用 AspectJ 对其进行代理,Spring 会将相关的类转换为 Bean 放到容器中,在 @HystrixCommand 注解中,还可以通过 commandProperties.threadPoolProperties 属性来设置命令的配置. Hystrix 示例如下: 创建项目 创建名称为 spring

Spring Cloud(Dalston.SR5)--Config 集群配置中心-刷新配置

远程 SVN 服务器上面的配置修改后,需要通知客户端来改变配置,需要增加 spring-boot-starter-actuator 依赖并将 management.security.enabled 设置为 false,然后访问客户端的 /refresh 端点进行刷新,访问改端点要使用 HTTP 的 POST 方法,客户端的 refresh 在接收到请求后,会重新到配置服务器获取最新的配置,然后用新的配置和旧配置进行对比,最终把有修改的配置 Key 返回给调用者. 在实际应用中,往往不仅是刷新一个

Spring Cloud构建微服务架构—Hystrix断路器

断路器模式源于Martin Fowler的Circuit Breaker一文."断路器"本身是一种开关装置,用于在电路上保护线路过载,当线路中有电器发生短路时,"断路器"能够及时的切断故障电路,防止发生过载.发热.甚至起火等严重后果. 在分布式架构中,断路器模式的作用也是类似的,当某个服务单元发生故障(类似用电器发生短路)之后,通过断路器的故障监控(类似熔断保险丝),直接切断原来的主逻辑调用.但是,在Hystrix中的断路器除了切断主逻辑的功能之外,还有更复杂的逻辑

Spring Cloud(Dalston.SR5)--Zuul 网关-路由配置

Spring Cloud 在 Zuul 的 routing 阶段实现了几个过滤器,这些过滤器决定如何进行路由工作. 简单路由(SimpleHostRoutingFilter) 该过滤器运行后,会将 HTTP 请求全部转发到"源服务器",简单路由的配置如下: #zuul路由配置 zuul: routes: #表示http://localhost:9100/person/speaks地址,路由到http://localhost:8080/speaks person: path:/perso

08 在Spring Cloud中使用Feign

Spring Cloud对Feign进行了封装,本例将演示如何在Spring Cloud中使用Feign. 1.准备SpringCloud的测试项目 测试项目主要有三个, a.spring-feign-server: Eureka的服务器项目,端口为8761: b.spring-feign-provider: 服务提供者,该项目通过在控制台输入对应的端口号启动两个实例,分别是8080和8081端口的实例,这两个实例提供如下服务 第一个地址为person/{personId}的服务,请求后返回Pe

Spring Cloud下使用Feign Form实现微服务之间的文件上传

背景 ? Spring Cloud现在已经被越来越多的公司采用了,微服务架构比传统意义上的单服务架构从复杂度上多了很多,出现了很多复杂的场景.比如,我们的产品是个app,支持第三方登录功能,在手机端调用第三方授权接口之后,返回了用户的相关信息,比如open_id,性别,头像等.这些信息我们需要保存在我们服务器上,当时针对头像是应该保存图片的url还是图片本身发生了歧义,在一番讨论之后,得出的结果是,我们需要通过url将图片下载到我们本地,然后调用我们自己的文件微服务中上传功能保存起来. 工具 I