当前位置： 首页 > article >正文

SpringCloud 学习笔记3（OpenFeign）

article 2025/3/20 2:58:56

OpenFeign

微服务之间的通信方式，通常有两种：RPC 和 HTTP。

简言之，RPC 就是像调用本地方法一样调用远程方法。

在 SpringCloud 中，默认是使用 HTTP 来进行微服务的通信，最常用的实现形式有两种：

  • RestTemplate
  • OpenFeigen

什么是 OpenFeign

OpenFeign 是一个声明式的 Web Service 客户端。它让微服务之间的调用变得更简单。

SpringCloud Feign 文档：Spring Cloud OpenFeign

OpenFeign 使用

引入依赖

给调用者添加如下依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

添加注解

给调用者的启动类上添加 @EnableFeignClients

image-20250317203705295

编写客户端

@FeignClient 用来指定访问的是哪个服务，value 值表示要访问的应用名称。

image-20250317205409654

@FeignClient 中的 path = “/product” 表示在这个 ProductApi 接口的所有方法中，都会存在前缀 /product

image-20250317205901774

更改调用代码：

import com.demo.order.api.ProductApi;
import com.demo.order.mapper.OrderMapper;
import com.demo.order.model.OrderInfo;
import com.demo.order.model.ProductInfo;
import lombok.Setter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

/**
 * @author hanzishuai
 * @date 2025/03/07 19:19
 * @Description
 */
@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;
    
    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private ProductApi productApi;

     /**
     * Created by hanzishuai on 2025/3/17
     * @Description: 远程调用 getProductInfo 接口，获取商品信息
     * @param orderId 商品 ID
     * @return: 
     */
    public OrderInfo selectOrderById(Integer orderId) {
        OrderInfo orderInfo = orderMapper.selectOrderById(orderId);

        // 更改之前的调用过程
        // String url = "http://product-service/product/" + orderInfo.getProductId();
        // ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);

        // 更改后的调用过程
        ProductInfo productInfo = productApi.getProductInfo(orderInfo.getProductId());
        
        orderInfo.setProductInfo(productInfo);
        return orderInfo;
    }
}

参数传递

传递单个参数

使用 @RequestParam 来指定参数，@RequestParam 不可省略。

package com.demo.order.api;

import com.demo.order.model.ProductInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;


// @FeignClient 用来指定访问的是哪个服务，value 表示要访问的应用名称。
// path = "/product" 表示在这个 ProductApi 接口的所有方法中，都会存在前缀 /product
@FeignClient(value = "product-service",path = "/product")
public interface ProductApi {

    // @RequestMapping 用来指定要访问哪个 URL
    @RequestMapping("/p1")
    // 使用 @RequestParam 来指定参数，@RequestParam 不可省略。
    String p1(@RequestParam("id") Integer id);
    
}

通过 Controller 调用远程方法：

package com.demo.order.controller;

import com.demo.order.api.ProductApi;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;


@RequestMapping("/feign")
@RestController
public class FeignController {

    @Autowired
    private ProductApi productApi;

    /**
     * Created by hanzishuai on 2025/3/17
     * @Description: 通过远程调用，访问商品服务 p1 方法
     */
    @RequestMapping("/o1")
    public String o1(Integer id) {
        return productApi.p1(id);
    }
}

测试结果：

image-20250317214959882

传递多个参数
package com.demo.order.api;

import com.demo.order.model.ProductInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;


// @FeignClient 用来指定访问的是哪个服务，value 表示要访问的应用名称。
// path = "/product" 表示在这个 ProductApi 接口的所有方法中，都会存在前缀 /product
@FeignClient(value = "product-service", path = "/product")
public interface ProductApi {

    // 使用 @RequestParam 来指定参数，@RequestParam 不可省略。
    @RequestMapping("/p2")
    String p2(@RequestParam("id") Integer id, @RequestParam("name") String name);

}

通过 Controller 调用远程方法同上，就不写了。

传递对象
package com.demo.order.api;

import com.demo.order.model.ProductInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;


// @FeignClient 用来指定访问的是哪个服务，value 表示要访问的应用名称。
// path = "/product" 表示在这个 ProductApi 接口的所有方法中，都会存在前缀 /product
@FeignClient(value = "product-service", path = "/product")
public interface ProductApi {

    // @SpringQueryMap 用来接受对象
    @RequestMapping("/p3")
    String p3(@SpringQueryMap ProductInfo productInfo);

}

通过 Controller 调用远程方法同上，就不写了。

传递 JSON
package com.demo.order.api;

import com.demo.order.model.ProductInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.cloud.openfeign.SpringQueryMap;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;


// @FeignClient 用来指定访问的是哪个服务，value 表示要访问的应用名称。
// path = "/product" 表示在这个 ProductApi 接口的所有方法中，都会存在前缀 /product
@FeignClient(value = "product-service", path = "/product")
public interface ProductApi {

    @RequestMapping("/p4")
    String p4(@RequestBody ProductInfo productInfo);
}

通过 Controller 调用远程方法同上，就不写了。

OpenFeign 最佳实践

继承

我们可以定义好一个接口，服务提供方实现这个接口，服务消费方编写 Feign 接口的时候，直接继承这个接口。

官方介绍：Spring Cloud OpenFeign Features :: Spring Cloud Openfeign

接口可以放在一个公共的 jar 包内，供服务提供方和服务消费方使用。

举个例子：假设 order-service 需要调用 product-service 。

  1. 我们可以新建一个 product-api ，把常用的操作封装到接口里。
package com.demo.product.api;


import com.demo.product.model.ProductInfo;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;


public interface ProductInterface {

    // @RequestMapping 用来指定要访问哪个 URL
    @RequestMapping("/{productId}")
    ProductInfo getProductById(@PathVariable("productId") Integer productId);
    
}
  1. 把当前 jar 包放到本地的 maven 仓库：

image-20250318145322359

  1. 让 order-service、product-service 引入 刚刚打好的 jar 包。

image-20250318145934539

  1. 继承 product-api 的接口：
package com.demo.product.controller;


import com.demo.product.api.ProductInterface;
import com.demo.product.model.ProductInfo;
import com.demo.product.service.ProductService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;


@Slf4j
@RequestMapping("/product")
@RestController
public class ProductController implements ProductInterface {

    @Autowired
    private ProductService productService;

    @RequestMapping("/{productId}")
    public ProductInfo getProductById(@PathVariable Integer productId) {
        log.info("接收参数，productId：" + productId);
        return productService.selectProductById(productId);
    }

}
抽取

将 Feign 的 Client 抽取为一个独立的模块，并把涉及到的实体类等都放在这个模块中，打成一个 jar。服务消费方只需要依赖该 jar 包即可。jar 包通常由服务提供方来实现。

举个例子：假设 order-service 需要调用 product-service 。

  1. 我们可以新建一个 product-api ，把常用的操作封装到接口里。
package com.demo.product.api;

import com.demo.product.model.ProductInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;

@FeignClient(value = "product-service",path = "/product")
public interface ProductApi {
    
    @RequestMapping("/{productId}")
    ProductInfo getProductById(@PathVariable("productId") Integer productId);
    
}
  1. 把当前 jar 包放到本地的 maven 仓库：

image-20250318145322359

  1. 让 order-service、product-service 引入 刚刚打好的 jar 包。

image-20250318145934539

  1. 由于 Spring 只会扫描启动类下面的目录，而我们要使用的 api 不在启动类下面。所以需要使用@EnableFeignClients(clients = {ProductApi.class}) 来让 Spring 帮我们管理。

    package com.demo.order;

import com.demo.product.api.ProductApi;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author hanzishuai
 * @date 2025/03/07 17:30
 */
@EnableFeignClients(clients = {ProductApi.class})
@SpringBootApplication
public class OrderServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServiceApplication.class, args);
    }
}

  2. 服务调用方引入抽取出来的模块

package com.demo.product.controller;


import com.demo.product.model.ProductInfo;
import com.demo.product.service.ProductService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;


@Slf4j
@RequestMapping("/product")
@RestController
public class ProductController{

    @Autowired
    private ProductService productService;

    @RequestMapping("/{productId}")
    public ProductInfo getProductById(@PathVariable Integer productId) {
        log.info("接收参数，productId：" + productId);
        return productService.selectProductById(productId);
    }

}

服务部署

maven 打包默认是从远程仓库下载的，但是由于我们之前把 jar 包放到了本地的 maven 仓库，所以程序会启动失败。解决方案如下：

  1. 上传到 maven 仓库，如何发布Jar包到Maven中央仓库 - 简书。
  2. 搭建 maven 私服，上传 jar 包到私服。
  3. 从本地读取 jar 包。

在这里选择第三种方法。

  1. 把 jar 包放到本地的 maven 仓库

image-20250318162508525

  1. 更改消费者服务的配置文件

           <dependency>
            <groupId>org.example</groupId>
            <artifactId>product-api</artifactId>
            <version>1.0-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>

    把 compile 改为system，并添加 systemPath

            <dependency>
            <groupId>org.example</groupId>
            <artifactId>product-api</artifactId>
            <version>1.0-SNAPSHOT</version>
            <scope>system</scope>
            <systemPath>C:/Users/awa/.m2/repository/org/example/product-api/1.0-SNAPSHOT/product-api-1.0-SNAPSHOT.jar</systemPath>

        </dependency>

    systemPath的位置在：

    image-20250318162958681

    更改 spring-boot-maven-plugin 添加configuration并将includeSystemScope设置为 true

            <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <includeSystemScope>true</includeSystemScope>
                </configuration>
            </plugin>
        </plugins>

    刷新 maven

剩下的参考 博客系统笔记总结 2（ Linux 相关） 中的部署 Web 项目到 Linux。

本文到这里就结束啦~

在这里插入图片描述


http://www.kler.cn/a/591998.html

相关文章：

  • OSG简介
  • 电信大带宽服务器的应用场景都有哪些？
  • vue中js简单创建一个事件中心/中间件/eventBus
  • Zabbix安装（保姆级教程）
  • 学习Python如何高效处理CSV文件的技巧！
  • Docker 和 Docker Compose 的关系
  • 可视化图解算法：链表中倒数（最后）k个结点
  • 使用py-ffmpeg批量合成视频的脚本
  • CentOS7 安装 jdk8（Java安装）
  • Next.js 的渲染体系架构
  • Spring Boot 核心知识点深度详解：自动化配置 (Auto-configuration) - 解锁 Spring Boot 的 “魔法”
  • 【从零开始学习计算机科学】软件工程（三）需求工程
  • 《算法笔记》9.2小节——数据结构专题(2)-＞二叉树的遍历 问题 B: 二叉树
  • 批量清空 Excel 文档主题、标记、作者、保存时间、总编辑时间元数据
  • 23年蓝桥杯 ———— 阶乘求和
  • rk3588 linux的rootfs.img挂载后通过chroot切换根目录安装应用提示空间不足
  • 一、Redis简介篇
  • 一文梳理清楚Vsync/Choreographer/SurfaceFlinger/Surface/SurfaceHolder/硬件刷新频率关系
  • Springboot是怎么保证WebSocket的链接对象是唯一的
  • 孜然SEO静态页面生成系统V1.0