这篇文章，主要介绍微服务组件之Hystrix和OpenFeign结合使用。

目录

一、Hystrix和OpenFeign结合使用

1.1、引入依赖

1.2、openfeign启用hystrix

1.3、编写FeignClient接口

1.4、编写FeignClient实现类

1.5、编写Controller控制器

1.6、启动类启动OpenFeign

1.7、运行测试

1.8、捕获异常信息

一、Hystrix和OpenFeign结合使用

在实际开发中，Hystrix都是和OpenFeign组件一起结合使用的，OpenFeign组件中已经包含了Hystrix，但是默认情况下，OpenFeign是没有开启Hystrix的功能，我们需要在application.yml配置文件中手动的开启Hystrix的功能。

1.1、引入依赖

• 引入openfeign组件中已经引入了hystrix的依赖，所以这里只需要引入openfeign依赖即可。

<!-- 引入 OpenFeign 依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

• 需要注意的是，OpenFeign虽然集成了Hystrix，但是如果你要使用Hystrix中的 @HystrixCommand等注解，那还是需要引入下面的依赖。
• 注意：hystrix的依赖根据需要自行引入，如果你项目中要使用hystrix的注解，那就引入这个依赖。

<!-- 引入 hystrix 依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

1.2、openfeign启用hystrix

在application.yml配置文件中，添加如下配置：

# openfeign 开启 hystrix 的支持
feign:hystrix:enabled: true

1.3、编写FeignClient接口

• 在@FeignClient注解中，使用 fallback 属性指定服务降级之后的处理类。

package com.gitcode.hystrix.service;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;import java.util.Map;/* @version 1.0.0* @Date: 2023/4/13 11:14* @Copyright (C) ZhuYouBin* @Description: openfeign 和 hystrix 结合使用*/
@FeignClient(name = "hystrix-provider", fallback = HystrixFallback.class)
public interface HystrixFeignClient {@GetMapping("/hystrix/provider/getById")Map<String, String> getUserInfoById(@RequestParam("id") String id);}

1.4、编写FeignClient实现类

• 需要注意的是：这个实现类必须注入到IOC容器里面。

package com.gitcode.hystrix.service;import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;/* @version 1.0.0* @Date: 2023/4/13 11:16* @Copyright (C) ZhuYouBin* @Description: 用于 hystrix 实现服务降级的类*/
// 将当前类注入到 IOC 容器里面
@Component
public class HystrixFallback implements HystrixFeignClient {@Overridepublic Map<String, String> getUserInfoById(String id) {System.out.println("服务降级，请稍后重试！");Map<String, String> map = new HashMap<>();map.put("uname", "服务降级");map.put("pass", "000");map.put("age", "0");return map;}}

1.5、编写Controller控制器

package com.gitcode.hystrix.controller;import com.gitcode.hystrix.service.HystrixFeignClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.Map;/* @version 1.0.0* @Date: 2023/4/13 11:27* @Copyright (C) ZhuYouBin* @Description:*/
@RestController
@RequestMapping("/api/openfeign")
public class HystrixOpenFeignController {@Autowiredprivate HystrixFeignClient hystrixFeignClient;@GetMapping("/hystrix")public Map<String, String> hystrix(String id) {return hystrixFeignClient.getUserInfoById(id);}
}

1.6、启动类启动OpenFeign

package com.gitcode.hystrix;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;/* @version 1.0.0* @Date: 2023/4/13 11:11* @Copyright (C) ZhuYouBin* @Description:*/
// 启动类启动 OpenFeign 扫描
@EnableFeignClients
@EnableEurekaClient
@SpringBootApplication
public class FeignHystrixApp {public static void main(String[] args) {SpringApplication.run(FeignHystrixApp.class, args);}
}

1.7、运行测试

到这里，Hystrix和OpenFeign就基本上可以一起使用啦，启动工程，访问接口，当访问超时或者出现异常时候，就会调用服务降级之后的方法。

1.8、捕获异常信息

采用上面那种方式，当接口调用出现异常的时候，控制台是不会抛出异常的，所以为了能够获取到异常信息，OpenFeign中的@FeignClient注解提供了一个fallbackFactory属性。fallbackFactory属性需要指定一个服务降级工厂类，自定义的工厂类需要实现【FallbackFactory】接口，并且重写其中的【create()】方法，这个方法中会有一个Throwable类型的参数，这个参数就是运行过程中出现的一些异常信息。

package com.gitcode.hystrix.service;import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;import java.util.HashMap;
import java.util.Map;/* @version 1.0.0* @Date: 2023/4/13 11:35* @Copyright (C) ZhuYouBin* @Description: 自定义的服务降级工厂类*/
@Component
public class HystrixFallbackFactory implements FallbackFactory<HystrixFeignClient> {@Overridepublic HystrixFeignClient create(Throwable ex) {return new HystrixFeignClient() {@Overridepublic Map<String, String> getUserInfoById(String id) {System.out.println("[HystrixFallbackFactory]服务降级，请稍后重试！出现的异常是: " + ex.getMessage());Map<String, String> map = new HashMap<>();map.put("uname", "服务降级");map.put("pass", "000");map.put("age", "0");return map;}};}}

在对应的Feign接口中，使用fallbackFactory属性。

@FeignClient(name = "hystrix-provider", fallbackFactory = HystrixFallbackFactory.class)

到此，Hystrix和OpenFeign结合使用就介绍完啦。

综上，这篇文章结束了，主要介绍微服务组件之Hystrix和OpenFeign结合使用。

大学生论坛