转载

[Spring cloud 一步步实现广告系统] 11. 使用Feign实现微服务调用

上一节我们使用了Ribbon(基于 Http/Tcp )进行微服务的调用，Ribbon的调用比较简单，通过Ribbon组件对请求的服务进行拦截，通过 Eureka Server 获取到服务实例的 IP:Port ,然后再去调用API。本节课我们使用更简单的方式来实现，使用声明式的 Web 服务客户端 Feign ，我们只需要使用Feign来声明接口，利用 注解 来进行配置就可以使用了，是不是很简单？实际工作中，我们也只会用到Feign来进行服务之间的调用（大多数）。接下来，我们来实例操作一把。

为了代码的重用性，我们来创建一个新的project mscx-ad-feign-sdk 作为Feign的服务调用工具。

mscx-ad-feign-sdk

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>mscx-ad</artifactId>
        <groupId>com.sxzhongf</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <packaging>jar</packaging>
    <name>mscx-ad-feign-sdk</name>
    <description>只定义微服务Feign调用用到的请求对象和响应对象，而不涉及具体的实现类。</description>

    <groupId>com.sxzhongf</groupId>
    <artifactId>mscx-ad-feign-sdk</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 引入服务调用的组件 feign 依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>com.sxzhongf</groupId>
            <artifactId>mscx-ad-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!-- 引入系统容错hystrix 的依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.2.7.RELEASE</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

三部曲之Step 2(加注解 @EnableFeignClients ,添加在具体的微服务中，使用我们自定义的FeignClient)

/**
 * ISponsorFeignClient for service using
 *
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初</a>
 */
@FeignClient(value = "mscx-ad-sponsor", fallback = SponsorClientHystrix.class)
public interface ISponsorFeignClient {
    @RequestMapping(value = "/ad-sponsor/plan/get", method = RequestMethod.POST)
    CommonResponse<List<AdPlanVO>> getAdPlansUseFeign(@RequestBody AdPlanGetRequestVO requestVO);

    @RequestMapping(value = "/ad-sponsor/user/get", method = RequestMethod.GET)
    /**
     * Feign 埋坑之 如果是Get请求，必须在所有参数前添加{@link RequestParam},不能使用{@link Param}
     * 会被自动转发为POST请求。
     */
    CommonResponse getUsers(@RequestParam(value = "username") String username);
}


---
@RestController
@Slf4j
@RequestMapping(path = "/search-feign")
public class SearchFeignController {
   /**
   * 注入我们自定义的FeignClient
   */
    private final ISponsorFeignClient sponsorFeignClient;
    @Autowired
    public SearchFeignController(ISponsorFeignClient sponsorFeignClient) {
        this.sponsorFeignClient = sponsorFeignClient;
    }

    @GetMapping(path = "/user/get")
    public CommonResponse getUsers(@Param(value = "username") String username) {
        log.info("ad-search::getUsersFeign -> {}", JSON.toJSONString(username));
        CommonResponse commonResponse = sponsorFeignClient.getUsers(username);
        return commonResponse;
    }
}

三部曲之Step 3(加配置，工具类库不需要，添加在具体的微服务中)

我们上面的实例中有一个问题，如果说我们的广告提供服务出现了问题，那么我们通过使用FeignClient 调用的API sponsorFeignClient.getUsers(username); 就会报错，如果长时间报错，会引起大规模的服务错误问题，也就有是我们常说的服务雪崩效应，我们要怎样避免一个服务出错而拖垮整个系统的问题呢？这里我们需要引入一个组件 Hystrix 来处理服务错误。

三部曲之Step1(加依赖)

[Spring cloud 一步步实现广告系统] 11. 使用Feign实现微服务调用

从上图我们可以看到，我们引入Feign依赖的时候，它本身已经依赖了Hystrix，根据Maven依赖的传递性，我们可以知道我们自己的服务已经包含了Hystrix的依赖支持，我们可以直接使用了～

@EnableHystrix // 开启hystrix 断路器

feign:
  hystrix:
    enabled: true

使用Hystrix来配置Feign实现调用容错

@Component
public class SponsorClientHystrix implements ISponsorFeignClient {
    @Override
    public CommonResponse<List<AdPlanVO>> getAdPlansUseFeign(AdPlanGetRequestVO requestVO) {
        return new CommonResponse<>(-1, "mscx-ad-sponsor feign & hystrix get plan error.");
    }

    @Override
    public CommonResponse getUsers(String username) {
        return new CommonResponse<>(-1, "mscx-ad-sponsor feign & hystrix get user error.");
    }
}

在 ISponsorFeignClient 类中，添加出错处理类（fallback）

@FeignClient(value = "mscx-ad-sponsor", fallback = SponsorClientHystrix.class)
public interface ISponsorFeignClient {
...

在 SponsorClientHystrix 中，我们要特别注意2点

@Component
ISponsorFeignClient

通过上面的实现，我们的服务在调用过程中，如果发生错误，就会进行服务降级，调用到出错应该调用的默认处理类中的方法，也就实现了我们想要做的短路处理来保护我们的当前服务。

原文 https://segmentfault.com/a/1190000019969360

正文到此结束

所属分类：编程技术软件架构

本文标签： maven description 代码 list build id web tar API value schema IO IDE XML plugin apache js UI json final Service 微服务 spring https 配置实例 dependencies ACE Feign ip map App 参数 http ribbon mail cat TCP REST src Spring cloud pom 广告时间 Eureka client Hystrix
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[Spring cloud 一步步实现广告系统] 11. 使用Feign实现微服务调用

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流