前言

本篇是SpringCloud原理系列的 OpenFeign 模块的第一篇。主要内容是搭建一个极简的Spring Cloud OpenFeign 调用链路。

项目代码仓库地址：https://gitee.com/fengsoshuai/springcloud-openfeign-demo

正文

本次项目使用java 17，spring cloud 4.0.4，springboot 3.1.4。
maven 环境编译，idea开发。

一、项目结构

本次项目分为3个模块。

二、服务调用链路说明

1. 使用IDEA/Postman/Apifox等工具进行触发client服务的接口
2. client内部通过feign调用server接口
3. server执行业务逻辑
4. server返回执行结果到client
5. client返回调用结果到触发方

三、Rpc调用链路说明

两个服务之间，使用远程调用。
基本都是需要URL，请求头，请求报文，请求方式（Get\Post 等）等基本信息的。
下图简单说明rpc调用时的链路。

其中，调用方，相当于发起远程调用的一方，对比本项目的话，相当于使用postman等工具触发后，client模块的操作。

只是特殊的一点在于，调用方中的红色虚线框内的部分，被openFeign 封装了，不再是我们手动去处理他们。而这也正是本系列研究的重点。

中间部分，就是形如 RestTemplate，WebClient的功能，只是发出请求，接受响应。

服务方，就是一个提供rest接口的普通应用。

四、项目代码

本文全部代码托管在gitte仓库中，地址已经在文章开头给出。
这里只粘贴出比较重要的几个文件。

4.1 client 模块中的feign接口

package org.feng.feigns;import org.feng.common.dto.HelloRequest;
import org.feng.common.dto.HelloResponse;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;/*** hello-feign客户端接口** @version v1.0* @author: fengjinsong* @date: 2023年11月20日 21时25分*/
@FeignClient(name = "helloFeignClient", url = "http://localhost:10080")
public interface HelloFeignClient {@PostMapping("/hello/post")HelloResponse postHello(@RequestBody HelloRequest helloRequest);
}

4.2 client 中的rest接口

package org.feng.controller;import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletRequest;
import lombok.extern.slf4j.Slf4j;
import org.feng.common.dto.HelloRequest;
import org.feng.common.dto.HelloResponse;
import org.feng.feigns.HelloFeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;import java.time.LocalDateTime;
import java.util.Objects;/*** HelloFeignClientController** @version v1.0* @author: fengjinsong* @date: 2023年11月20日 21时45分*/
@Slf4j
@RestController
@RequestMapping("/helloclient")
public class HelloFeignClientController {@Resourceprivate HelloFeignClient helloFeignClient;@PostMapping("/postHello")public HelloResponse postHello(@RequestBody HelloRequest helloRequest) {if(Objects.isNull(helloRequest.getLocalDateTime())){helloRequest.setLocalDateTime(LocalDateTime.now());}ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = requestAttributes.getRequest();String localAddr = request.getLocalAddr();int serverPort = request.getServerPort();helloRequest.setHost(localAddr);helloRequest.setPort(serverPort);log.info("helloRequest  {}", helloRequest);return helloFeignClient.postHello(helloRequest);}
}

4.3 client 中的启动类

指定扫描包为 org.feng.feigns。

package org.feng;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;@EnableFeignClients(basePackages = "org.feng.feigns")
@SpringBootApplication
public class ClientApplication {public static void main(String[] args) {SpringApplication.run(ClientApplication.class, args);}}

4.4 server中的rest接口

package org.feng.controller;import lombok.extern.slf4j.Slf4j;
import org.feng.common.dto.HelloRequest;
import org.feng.common.dto.HelloResponse;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** openfeign 控制器** @author feng*/
@Slf4j
@RequestMapping("/hello")
@RestController
public class HelloOpenFeignController {@PostMapping("/post")public HelloResponse postHello(@RequestBody HelloRequest helloRequest) {log.info("request：{}", helloRequest);HelloResponse response = new HelloResponse();response.setTitle(helloRequest.getTitle());response.setLocalDateTime(helloRequest.getLocalDateTime());response.setFromHost(helloRequest.getHost());response.setFromPort(helloRequest.getPort());log.info("response: {}", response);return response;}
}

4.5 server中的配置文件

spring.application.name=openserver
server.port=10080

五、调试

启动server 和 client 服务。
在idea中触发client 的服务：

POST http://localhost:8080/helloclient/postHello
Content-Type: application/json{"title": "托尔斯泰"
}

响应报文如下：

{"fromHost": "127.0.0.1","fromPort": 8080,"title": "托尔斯泰","localDateTime": "2023-11-21T14:07:18.537384"
}

server中的服务，打印出来的日志如下：

以上就是通过onepfeign 进行rpc 调用的完整示例了。

可以看到，我们只在client中定义了接口，并没有实现。但是在调用时，没有报错，同时也调用到了server服务。而这，就是spring cloud 中的 openfeign 封装了远程调用，帮我们处理的部分，也是我们后续研究其原理的核心部分。

附录

附1：本系列文章链接

SpringCloud原理-OpenFeign篇（一、Hello OpenFeign项目示例）
SpringCloud原理-OpenFeign篇（二、OpenFeign包扫描和FeignClient的注册原理）
SpringCloud原理-OpenFeign篇（三、FeignClient的动态代理原理）