java编程
搜索
分类

SpringCloud Feign实现微服务之间相互请求问题

作者：鳄鱼儿 时间：2022-08-29 08:20:53　

上篇文章说了通过RestTemplate实现微服务之间访问：https://www.jb51.net/article/252981.htm，这篇文章将通过Feign实现微服务之间访问。
代码基于RestTemplate实现微服务之间访问基础上进行修改。

??Feign简介

Github：https://github.com/OpenFeign/feign

Feign是Netflix开发的声明式、模板化的HTTP客户端， Feign可以帮助我们更快捷、优雅地实现微服务之间的调用。
1.Feign可帮助我们更加便捷，优雅的调用HTTP API。
2.在SpringCloud中，使用Feign非常简单——创建一个接口，并在接口上添加一些注解，代码就完成了。
3.Feign支持多种注解，例如Feign自带的注解或者JAX-RS注解等。
4.SpringCloud对Feign进行了增强，使Feign支持了SpringMVC注解，并整合了Ribbon和Eureka，从而让Feign的使用更加方便。

??Spring Cloud 组件依赖版本

官网文档

SpringCloud Feign实现微服务之间相互请求问题

本文参考使用组件依赖如下

SpringCloud Feign实现微服务之间相互请求问题

??Feign实现服务之间访问

创建微服务项目，结构如下图所示

SpringCloud Feign实现微服务之间相互请求问题

root pom.xml

<?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">
   <modelVersion>4.0.0</modelVersion>

<groupId>com.ber</groupId>
   <artifactId>SpringCloud-Feign</artifactId>
   <version>1.0-SNAPSHOT</version>
   <packaging>pom</packaging>

<parent>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-parent</artifactId>
       <version>2.3.12.RELEASE</version>
       <relativePath/>
   </parent>

<properties>
       <maven.compiler.source>8</maven.compiler.source>
       <maven.compiler.target>8</maven.compiler.target>
       <java.version>1.8</java.version>
       <spring-boot.version>2.3.12.RELEASE</spring-boot.version>
       <spring-cloud-alibaba.version>2.2.8.RELEASE</spring-cloud-alibaba.version>
       <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
   </properties>

<dependencies>
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-bootstrap</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-openfeign</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
   </dependencies>

<dependencyManagement>
       <dependencies>
           <dependency>
               <groupId>com.alibaba.cloud</groupId>
               <artifactId>spring-cloud-alibaba-dependencies</artifactId>
               <version>${spring-cloud-alibaba.version}</version>
               <type>pom</type>
               <scope>import</scope>
           </dependency>
           <dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-dependencies</artifactId>
               <version>${spring-cloud.version}</version>
               <type>pom</type>
               <scope>import</scope>
           </dependency>
       </dependencies>
   </dependencyManagement>

<modules>
       <!-- 注册中心 -->
       <module>ber-nacos</module>
   </modules>

</project>

ber-nacos pom.xml

<?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>SpringCloud-Feign</artifactId>
       <groupId>com.ber</groupId>
       <version>1.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>

<artifactId>ber-nacos</artifactId>
   <packaging>pom</packaging>

<modules>
       <module>nacos-consumer</module>
       <module>nacos-provider</module>
       <module>nacos-consumer-feign</module>
   </modules>
</project>

?创建nacos-consumer-feign微服务

nacos-consumer-feign pom.xml

<?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>ber-nacos</artifactId>
       <groupId>com.ber</groupId>
       <version>1.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>

<artifactId>nacos-consumer-feign</artifactId>

<dependencies>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
       <dependency>
           <groupId>com.alibaba.cloud</groupId>
           <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
       </dependency>
       <!-- 负载均衡 -->
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-loadbalancer</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-actuator</artifactId>
       </dependency>
       <!-- feign -->
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-openfeign</artifactId>
       </dependency>
   </dependencies>

</project>

application.properties

spring.application.name=nacos-consumer-feign

spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

server.port=8895

feign.hystrix.enabled=true

启动类，注意添加注解@EnableFeignClients、@EnableDiscoveryClient

package com.ber.nacos.feign;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
* @author: ber
* @date: 2022/6/25 0025 22:43
* -------------------------------
* Github：https://github.com/berbai
* Blog：https://blog.csdn.net/Ber_Bai
*/
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class FeignApplication {
   public static void main(String[] args) {
       SpringApplication.run(FeignApplication.class, args);
   }
}

controller接口，通过/queryMsg/{msgStr}访问provider微服务接口

package com.ber.nacos.feign.controller;

import com.ber.nacos.feign.service.MsgService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

/**
* @author: ber
* @date: 2022/6/25 0025 22:46
* -------------------------------
* Github：https://github.com/berbai
* Blog：https://blog.csdn.net/Ber_Bai
*/
@RestController
public class MsgController {

@Autowired
   MsgService msgService;

/**
    * 获取消息
    *
    * @param msgStr 消息
    * @return
    */
   @GetMapping("/queryMsg/{msgStr}")
   public String getMsg(@PathVariable(value = "msgStr") String msgStr) {
       return msgService.getMsg(msgStr);
   }
}

创建feign client

FeignClient 默认集成了 Ribbon，使用@FeignClient注解将MsgService 接口作为 FeignClient ，其属性名称与服务名称nacos-provider对应

package com.ber.nacos.feign.service;

import com.ber.nacos.feign.service.fallback.MsgServiceFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
* @author: ber
* @date: 2022/6/25 0025 22:54
* -------------------------------
* Github：https://github.com/berbai
* Blog：https://blog.csdn.net/Ber_Bai
*/
@Component
@FeignClient(name = "nacos-provider", fallback = MsgServiceFallback.class)
public interface MsgService {

@GetMapping("/getMsg/{msgStr}")
   String getMsg(@PathVariable("msgStr") String msgStr);
}

Feign的Fallback机制，在网络请求时，可能会出现异常请求，如果还想再异常情况下使系统可用，那么就需要容错处理，执行设置的容错业务代码。
当接口请求不成功时，就会调用MsgServiceFallback类这里的实现

package com.ber.nacos.feign.service.fallback;

import com.ber.nacos.feign.service.MsgService;
import org.springframework.stereotype.Component;

/**
* @author: ber
* @date: 2022/6/25 0025 22:58
* -------------------------------
* Github：https://github.com/berbai
* Blog：https://blog.csdn.net/Ber_Bai
*/
@Component
public class MsgServiceFallback implements MsgService {
   @Override
   public String getMsg(String msgStr) {
       return "请求失败";
   }
}

?nacos-provider微服务

代码参考上篇文章《RestTemplate实现微服务之间访问》

SpringCloud Feign实现微服务之间相互请求问题

??Feign微服务之间访问测试

启动nacos-consumer-feign和nacos-provider，访问http://localhost:8848/nacos，使用 nacos/nacos 登陆后，可以发现服务列表中，两个微服务已经注册，如下图所示。

SpringCloud Feign实现微服务之间相互请求问题

访问http://localhost:8895/queryMsg/hello，即consumer-feign的接口，可以得到如下图所示的界面

SpringCloud Feign实现微服务之间相互请求问题

?Feign容错机制

修改feign client代码如下所示
改为@GetMapping("/getMsg-error/{msgStr}")，即原本的queryMsg会被请求到getMsg-error，而provider并没有提供getMsg-error，此时feign会进入容错机制。

package com.ber.nacos.feign.service;

import com.ber.nacos.feign.service.fallback.MsgServiceFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
* @author: ber
* @date: 2022/6/25 0025 22:54
* -------------------------------
* Github：https://github.com/berbai
* Blog：https://blog.csdn.net/Ber_Bai
*/
@Component
@FeignClient(name = "nacos-provider", fallback = MsgServiceFallback.class)
public interface MsgService {

@GetMapping("/getMsg-error/{msgStr}")
   String getMsg(@PathVariable("msgStr") String msgStr);
}

再次访问http://localhost:8895/queryMsg/hello，即consumer-feign的接口，可以得到如下图所示的界面

SpringCloud Feign实现微服务之间相互请求问题

来源：https://blog.csdn.net/Ber_Bai/article/details/125445607

标签：SpringCloud,Feign,微服务,请求
0
投稿

猜你喜欢

  • java编程之AC自动机工作原理与实现代码

    2023-04-04 19:11:23

  • Java中Future和FutureTask的示例详解及使用

    2023-01-29 11:48:42

  • Flutter runApp到渲染上屏分析详解

    2023-06-27 12:09:45

  • 浅谈java中对集合对象list的几种循环访问

    2022-02-11 02:32:33

  • 利用java实现中奖概率详情

    2021-08-10 06:56:58

  • java中对象调用成员变量与成员实例方法

    2023-08-04 11:42:49

  • 那些年,我还在学习C# 学习笔记

    2021-11-09 07:08:35

  • 浅谈JSON的数据交换、缓存问题和同步问题

    2021-08-08 09:31:25

  • Java Map接口概述和常用方法详解

    2022-07-29 14:19:06

  • SpringBoot整合WebSocket实现后端向前端发送消息的实例代码

    2021-10-30 19:24:56

  • Android之复选框对话框用法实例分析

    2023-10-03 05:07:03

  • Android隐藏标题栏及解决启动闪过标题的实例详解

    2023-10-10 12:18:12

  • Java NIO：浅析IO模型_动力节点Java学院整理

    2022-01-17 17:07:38

  • 详解Mybatis中的PooledDataSource

    2022-10-24 18:08:11

  • C#向word文档插入新段落及隐藏段落的方法

    2022-04-11 16:29:10

  • Compose状态保存rememberSaveable原理解析

    2021-12-26 10:07:56

  • java 对象的克隆（浅克隆和深克隆）

    2021-06-27 20:43:20

  • C# 汉字与拼音互转的实现示例

    2022-03-06 06:50:20

  • 解决eclipse启动tomcat时不能加载web项目的问题

    2023-11-15 14:45:01

  • SpringBoot集成Redisson实现分布式锁的方法示例

    2021-10-30 16:59:38
    • asp之家 软件编程 m.aspxhome.com