在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设置
feign:
hystrix:
enabled: true
ribbon:
ReadTimeout: 10000
ConnectTimeout: 10000
|