OpenFeign+hystrix服务降级简单实现

在SpringCloud中,使用OpenFeign实现微服务模块之间的方法调用。假设业务有:微服务A调用微服务B中的某一个接口,并对接口返回的数据作为输出。
问题:由于某些原因这个调用过程不太顺利,比如:连接超时;或者一些其他的原因导致调用失败。对于调用失败的情况,需要一个兜底的解决方案。

微服务B的接口:

@GetMapping("/getTestInfo")
public R<?> queryTestInfo(String username,String password){
...
}

微服务A【名称:module-A】对微服务B【名称:module-B】接口调用:
①在微服务A启动类添加注解:@EnableFeignClients

@EnableFeignClients
@SpringBootApplication(scanBasePackages = {"xxx", "xxx"})
public class XXXApplication{...}

②创建service接口类:
创建一个专门的service接口类,该类的接口格式与将要调用的微服务B的接口格式类似。
在接口类添加注解@Component将其配置为组件,@FeignClient表明为服务调用端。

@Component
@FeignClient(contextId = "remoteTestService", value = "module-B", path = "/xxx", fallbackFactory = RemoteTestFallbackFactory.class,
        url = "http://XXXX")
public interface TestService{
	@GetMapping("/getTestInfo")
	public R<?> queryTestInfo(@RequestParam String username,@RequestParan String password);
}

其中配置项:
value:指定被调用服务模块名称,与微服务B在服务注册中心的名称对应。
path:定义当前FeignClient的统一前缀,一般是在网关路由中配置的匹配路径。
url:指定被调用服务模块所部署的ip地址。一般用于本地调试,配置该项后,从指定ip获取服务,而非服务注册中心获取。

③创建一个FallbackFacory的实现类

public class RemoteTestFallbackFactory implements FallbackFactory<TestService> {

    @Override
    public TestService create(Throwable throwable) {
        log.error("Call remote test service error[{}]", throwable.getMessage());
        return new TestService() {
            @Override
            public R<?> queryTestInfo(String username, String password) {
   				return R.fail("获取测试信息失败:"+throwable.getMessage());
            }
        };
    }
}

问题:
在调用时,可能存在超时情况:
在application.yml设置

#开启hystrix熔断机制
feign:
  hystrix:
    enabled: true
#设置openfeign超时时间,由于OpenFeign封装了Ribbon依赖,实质是设置Ribbon超时时间。
ribbon:
  ReadTimeout: 10000  #建立连接后从服务器读取到可用资源所用的时间
  ConnectTimeout: 10000

版权声明:本文为weixin_44318522原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。