devbox
2023面试高手
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springboot整合feign实现RPC调用，并通过Hystrix实现服务降级_springboot rpc

作者：2023面试高手 | 2024-02-26 18:22:02

赞

踩

springboot rpc

feign/openfeign和dubbo是常用的微服务RPC框架，由于feigin内部已经集成ribbon，自带了负载均衡的功能，当有多个同名的服务注册到注册中心时，会根据ribbon默认的负载均衡算法将请求分配到不同的服务。这篇文章就简单介绍一下怎么使用feign来调用远程的服务。

首先，需要有一个微服务注册中心来提供服务注册与发现，本章就使用之前创建的eureka作为注册中心。点击以下文章链接，教你快速搭建一个eureka server

springboot整合eureka、config搭建注册中心和配置中心icon-default.png?t=N7T8https://blog.csdn.net/heyl163_/article/details/131715281

目录

一、服务提供者

二、服务消费者

三、测试效果

四、开启Hystrix实现服务降级

首先，要实现服务间的调用，需要有服务提供者和服务消费者，创建两个项目，分别用于服务提供者和服务消费者。

一、服务提供者

创建一个springboot项目，取名为provider

1、修改maven配置文件pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.  
  6.     <parent>
  7.         <groupId>org.springframework.boot</groupId>
  8.         <artifactId>spring-boot-starter-parent</artifactId>
  9.         <version>2.3.4.RELEASE</version>
  10.         <relativePath/>
  11.     </parent>
  12.  
  13.     <groupId>com.example</groupId>
  14.     <artifactId>provider</artifactId>
  15.     <version>0.0.1-SNAPSHOT</version>
  16.  
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <eureka.version>1.4.4.RELEASE</eureka.version>
  20.     </properties>
  21.  
  22.     <dependencyManagement>
  23.         <dependencies>
  24.             <dependency>
  25.                 <groupId>org.springframework.cloud</groupId>
  26.                 <artifactId>spring-cloud-dependencies</artifactId>
  27.                 <version>Hoxton.SR12</version>
  28.                 <type>pom</type>
  29.                 <scope>import</scope>
  30.             </dependency>
  31.  
  32.             <dependency>
  33.                 <groupId>org.springframework.cloud</groupId>
  34.                 <artifactId>spring-cloud-starter-eureka</artifactId>
  35.                 <version>${eureka.version}</version>
  36.             </dependency>
  37.         </dependencies>
  38.     </dependencyManagement>
  39.  
  40.     <dependencies>
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-starter-web</artifactId>
  44.         </dependency>
  45.  
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.  
  52.         <dependency>
  53.             <groupId>org.springframework.cloud</groupId>
  54.             <artifactId>spring-cloud-starter-eureka</artifactId>
  55.         </dependency>
  56.     </dependencies>
  57.  
  58.     <build>
  59.         <plugins>
  60.             <plugin>
  61.                 <groupId>org.springframework.boot</groupId>
  62.                 <artifactId>spring-boot-maven-plugin</artifactId>
  63.             </plugin>
  64.         </plugins>
  65.     </build>
  66. </project>

2、修改系统配置文件

  1. server:
  2.   port: 8085
  3.  
  4. spring:
  5.   application:
  6.     name: provider
  7.  
  8. eureka:
  9.   instance:
  10.     hostname: localhost
  11.   client:
  12.     service-url:
  13.       defaultZone: http://${eureka.instance.hostname}:8761/eureka

3、创建一个controller

在根目录下创建controller包，然后在controller包下创建一个UserController

  1. package com.example.provider.controller;
  2.  
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RequestMethod;
  5. import org.springframework.web.bind.annotation.RestController;
  6.  
  7. /**
  8.  * @author heyunlin
  9.  * @version 1.0
  10.  */
  11. @RestController
  12. @RequestMapping(path = "/user", produces = "application/json;charset=utf-8")
  13. public class UserController {
  14.  
  15.     @RequestMapping(value = "/name", method = RequestMethod.GET)
  16.     public String name() {
  17.         return "heyunlin";
  18.     }
  19.  
  20. }

4、启动类上添加@EnableDiscoveryClient注解

  1. package com.example.provider;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6.  
  7. @EnableDiscoveryClient
  8. @SpringBootApplication
  9. public class ProviderApplication {
  10.  
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(ProviderApplication.class, args);
  13.     }
  14.  
  15. }

二、服务消费者

1、创建一个springboot项目并命名为consumer

2、修改pom.xml配置文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.  
  6.     <parent>
  7.         <groupId>org.springframework.boot</groupId>
  8.         <artifactId>spring-boot-starter-parent</artifactId>
  9.         <version>2.3.4.RELEASE</version>
  10.         <relativePath/>
  11.     </parent>
  12.  
  13.     <groupId>com.example</groupId>
  14.     <artifactId>consumer</artifactId>
  15.     <version>0.0.1-SNAPSHOT</version>
  16.  
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <eureka.version>1.4.4.RELEASE</eureka.version>
  20.     </properties>
  21.  
  22.     <dependencyManagement>
  23.         <dependencies>
  24.             <dependency>
  25.                 <groupId>org.springframework.cloud</groupId>
  26.                 <artifactId>spring-cloud-dependencies</artifactId>
  27.                 <version>Hoxton.SR12</version>
  28.                 <type>pom</type>
  29.                 <scope>import</scope>
  30.             </dependency>
  31.  
  32.             <dependency>
  33.                 <groupId>org.springframework.cloud</groupId>
  34.                 <artifactId>spring-cloud-starter-eureka</artifactId>
  35.                 <version>${eureka.version}</version>
  36.             </dependency>
  37.         </dependencies>
  38.     </dependencyManagement>
  39.  
  40.     <dependencies>
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-starter-web</artifactId>
  44.         </dependency>
  45.  
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.  
  52.         <dependency>
  53.             <groupId>org.springframework.cloud</groupId>
  54.             <artifactId>spring-cloud-starter-eureka</artifactId>
  55.         </dependency>
  56.  
  57.         <dependency>
  58.             <groupId>org.springframework.cloud</groupId>
  59.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  60.         </dependency>
  61.     </dependencies>
  62. </project>

3、修改配置文件，注册到eureka

  1. server:
  2.   port: 8086
  3.  
  4. spring:
  5.   application:
  6.     name: consumer
  7.  
  8. eureka:
  9.   instance:
  10.     hostname: localhost
  11.   client:
  12.     service-url:
  13.       defaultZone: http://${eureka.instance.hostname}:8761/eureka

4、通过feign调用远程的方法

根目录下创建feign包，在feign包下创建一个接口FeignService（类名不重要）

@FeignClient("provider")指定注册到eurka的服务名

@RequestMapping的路径写provider服务的控制器接口路径

  1. package com.example.consumer.feign;
  2.  
  3. import org.springframework.cloud.openfeign.FeignClient;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RequestMethod;
  6.  
  7. /**
  8.  * @author heyunlin
  9.  * @version 1.0
  10.  */
  11. @FeignClient("provider")
  12. public interface FeignService {
  13.  
  14.     @RequestMapping(value = "/user/name", method = RequestMethod.GET)
  15.     String name();
  16.  
  17. }

5、最后，创建一个控制器类，类名随便取

  1. package com.example.consumer.controller;
  2.  
  3. import com.example.consumer.feign.FeignService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.web.bind.annotation.RequestMapping;
  6. import org.springframework.web.bind.annotation.RequestMethod;
  7. import org.springframework.web.bind.annotation.RestController;
  8.  
  9. /**
  10.  * @author heyunlin
  11.  * @version 1.0
  12.  */
  13. @RestController
  14. @RequestMapping("/user")
  15. public class UserController {
  16.  
  17.     @Autowired
  18.     FeignService feignService;
  19.  
  20.     @RequestMapping(value = "/name", method = RequestMethod.GET)
  21.     public String name() {
  22.         return feignService.name();
  23.     }
  24.  
  25. }

这时候@Autowired会报错，找不到FeignService的bean，因为没有在启动类上面添加@EnableFeignClients注解

  1. package com.example.consumer;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.openfeign.EnableFeignClients;
  6.  
  7. @EnableFeignClients
  8. @SpringBootApplication
  9. public class ConsumerApplication {
  10.  
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(ConsumerApplication.class, args);
  13.     }
  14.  
  15. }

 

三、测试效果

完成以上操作之后，依次启动euraka-server，provider和consumer

浏览器上访问consumer的控制器地址http://localhost:8086/user/name，发现成功返回了字符串。

四、开启Hystrix实现服务降级

首先需要开启hystrix

在pom.xml文件中添加配置

  1. feign:
  2.   hystrix:
  3.     enabled: true

然后创建一个FeignService的实现类，交给spring管理

  1. package com.example.consumer.feign;
  2.  
  3. import org.springframework.stereotype.Component;
  4.  
  5. /**
  6.  * @author heyunlin
  7.  * @version 1.0
  8.  */
  9. @Component
  10. public class FeignServiceImpl implements FeignService {
  11.  
  12.     @Override
  13.     public String name() {
  14.         return "error";
  15.     }
  16.  
  17. }

 最后，在FeiginService接口的的@FeiginCilent注解上指定fallback=FeignServiceImpl.class

@FeignClient(value = "provider", fallback = FeignServiceImpl.class)

完成以上配置之后，重启consumer，访问http://localhost:8086/user/name时正确调用了provider的控制器方法，得到了正确的结果。

接着把关掉provider项目，再访问，发现调用失败，成功执行了配置的降级方法，直接返回了error

好了，springboot整合feign的介绍到这里就完了，代码已开源，按需获取~

注册中心

eurekaicon-default.png?t=N7T8https://gitee.com/he-yunlin/eureka.git服务提供者

providericon-default.png?t=N7T8https://gitee.com/he-yunlin/provider.git服务消费者

consumericon-default.png?t=N7T8https://gitee.com/he-yunlin/consumer.git

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/145798
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号