> 文档中心 > Ribbon+Hystrix(熔断降级) +@FeignClient 实现跨模块+跨服务远程调用

Ribbon+Hystrix(熔断降级) +@FeignClient 实现跨模块+跨服务远程调用

总目录

  • 一.引入 Ribbon+Hystrix依赖 +feign依赖
  • 二.yml配置Ribbon+Hystrix
  • 三.启动类上添加注解
  • 四.实现跨模块调用
      • 1.client(gd-web模块)代码
      • 2.feign(gd-web远程模块)代码
      • 3.@FeignClient标签的常用属性如下:
      • 4.熔断代码
      • 5.server服务方代码 提供用户信息
  • 五.测试代码
  • 六.跨服务调用

一.引入 Ribbon+Hystrix依赖 +feign依赖

     org.springframework.cloud spring-cloud-starter-netflix-hystrix 2.2.5.RELEASE             org.springframework.cloud spring-cloud-starter-netflix-ribbon 2.2.5.RELEASE             org.springframework.cloud spring-cloud-starter-openfeign 2.2.5.RELEASE    

注意: Ribbon+Hystrix 依赖尽量一致 否则会报异常 自己可以试试嘻嘻!!


二.yml配置Ribbon+Hystrix

# feign远程配置# 这个gd-ae是用户模块 多模块后面打点添加gd-ae:  ribbon:    ## 服务提供者的地址,不是服务注册中心的地址    listOfServers: http://localhost:8088# 开启熔断feign:  #Hystrix超时时间设置 原因 feign第一次调用需要懒加载并且装在bean 所以第一次比较慢   hystrix:     enabled: true   client:     config:      default: connectTimeout: 5000 #连接超时时间2秒 readTimeout: 5000 #读超时时间2秒 hystrix:  command:    default: #也可以针对多个服务      execution: isolation:   thread:     timeoutInMilliseconds: 4000 # 设置hystrix的超时时间为4000ms

注意: 1.一定要设置熔断时间 原因: feign第一次调用需要懒加载并且装在bean 所以第一次比较慢 如果不设置可能会被熔断调

​ 2.也可以设置ribbon重复调用时间 这里没有设置


三.启动类上添加注解

@EnableFeignClients(basePackages = {"com.guodian.api"}) //basePackages = 指定的api远程模块所在包@EnableHystrix

四.实现跨模块调用

请添加图片描述

调用方client 模块gd-web

如下图

请添加图片描述

1.client(gd-web模块)代码

@Api(tags = "调用方模块")@Slf4j@RestController@RequestMapping("/web")public class UserController extends BaseController {    //注入远程服务中转站Ribbon    @Resource    private RemoteUserService remoteUserService;    @GetMapping("/getUser")    public String getUser(Long userId){ return remoteUserService.remoteGetUser(userId).checkAndGt();    }} 

2.feign(gd-web远程模块)代码

/** * @author: wfs * @date: 2022/3/15 15:30 * @version: 1.0 */@FeignClient(contextId = "remoteUserService",value = FeignServiceConstants.GD_AE,fallbackFactory = RemoteUserFactory.class )public interface RemoteUserService {    /**     * 获取用户信息     * @param userId 用户     * @return 客户     */    @GetMapping("/user/login") //这里地址必须要和 serve服务方地址相同 否则找不到 gd-ae用户模块具体的接口地址    R<String> remoteGetUser(@RequestParam("userId") Long userId);    }

3.@FeignClient标签的常用属性如下:

内容 含义
value 当前服务名
name 指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现
url url一般用于调试,可以手动指定@FeignClient调用的地址
decode404: 当发生http 404错误时,如果该字段位true,会调用decoder进行解码,否则抛出FeignException
configuration Feign配置类,可以自定义Feign的Encoder、Decoder、LogLevel、Contract
fallback 定义容错的处理类,当调用远程接口失败或超时时,会调用对应接口的容错逻辑,fallback指定的类必须实现@FeignClient标记的接口
fallbackFactory 工厂类,用于生成fallback类示例,通过这个属性我们可以实现每个接口通用的容错逻辑,减少重复的代码
path 定义当前FeignClient的统一前缀

4.熔断代码

/** * @author: wfs * @date: 2022/3/15 16:22 * @version: 1.0 */public class RemoteUserFactory implements FallbackFactory<RemoteUserService> {    //日志打印    private static final Logger log = LoggerFactory.getLogger(RemoteUserFactory.class);    @Override    public RemoteUserService create(Throwable throwable) { log.info("远程WebSocket服务调用失败!{}", throwable.getMessage());  return new RemoteUserService() {     @Override //熔断报错内容     public R<String> remoteGetUser(Long userId) {  return R.fail("远程调用登录用户失败!!");     } };    }}

注意: 这里一定要指定路径 熔断路径 在resources下 创建 META-INF目录 再创建spring.factories文件 指定熔断类路径 否则会报异常 自己可以试试!!!

如下 api模块架构图及文件目录 可以参考

请添加图片描述

spring.factories 内容

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\com.guodian.api.factory.RemoteUserFactory,\com.guodian.api.factory.RemoteGetUserFactory 

5.server服务方代码 提供用户信息

@Slf4j@Api(tags = "用户模块")@RestController@RequestMapping("/user")public class AeUserController extends BaseController { @GetMapping("/login")    public R<String> user(Long userId){ if (userId.equals(3L)){     return R.ok("获取用户成功!!"); } return R.fail("获取用户失败!!");    }}

五.测试代码

我们调用gd-web模块中 http://*******/web/getUser 接口 传值userId 为3 查看结果

请添加图片描述
OK搞定

六.跨服务调用

这里是我写的 跨服务调用—远程调用接口 点击这里!!
跨服务调用—远程调用接口