优雅实现远程调用-OpenFeign

2024-08-28 14:44

本文主要是介绍优雅实现远程调用-OpenFeign,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 

目录

OpenFeign介绍

OpenFeign最佳实践

我再来遇到个问题,我创建的com.xx.xxx包,放到一起了,不是那种一个在一个下面的那种

Nacos,只要看见这种什么网络报错啥的,java.net.SocketException: Network is unreachable


虽然RestTemple对于HTTP封装后,已经比直接使用HTTPClient简单多,但还是存在问题

1.需要拼接URL,灵活度高,但是封装囊肿,URL复杂时,容易出错

2.代码可读性差,风格不统一。

微服务之间通信方式:RPC和HTTP

RestTemplate

OpenFeign

RPC:是一种远程过程调用,是一种通过网络从远程计算机上请求服务,而不需要了解底层网络通信细节,RPC可以使用多种网络协议进行通信,如HTTP,TCP,UDP等,并且在TCP/IP网络四层模型中跨越了传输层和应用层,总之,RPC可以像调用本地方法一样调用远程方法

OpenFeign介绍

OpenFeign是一个声明式的Web Service客户端,他让微服务之间调用变得更加简单,类似Controller调用Service,只需要创建一个接口,添加注解即可使用OpenFeign

Netflix Feign是OpenFeign的祖先,或者说OpenFeign是Netflix的升级版,网络大多使用的Feign都是OpenFeign

Spring Cloud Feign是Spring对Feign的封装,将Feign项目集成到SpringCloud生态环境中

Spring Cloud Feign也有两个starter

spring-cloud-starter-feign

spring-cloud-starter-openfeign(用)

1.引入依赖

2.通过开启,开启Feign的功能

3.编写客户端

4.修改远程调用

5.测试

OpenFeign的参数传递

1.传递单个参数

2.传递多个参数

3.传递对象

4.传递JSON

客户端调用服务端

订单系统调用商品系统

2.传递多个参数

服务端需要提供相应的接口

1.传递单个参数

2.传递多个参数

3.传递对象

4.传递JSON

package com.bite.order.controller;import com.bite.order.Service.ProductService;
import com.bite.order.model.ProductInfo;
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.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
//根据商品ID,获取商品信息
@RequestMapping("/product")
@RestController
@Slf4j
public class ProductController {@Autowiredprivate ProductService productService;//只是一个声明,接口和实现之间的关系绑定,哪个服务,url@RequestMapping("/{productId}")public ProductInfo getProductById(@PathVariable("productId") Integer productId){log.info("接收到参数:productId"+productId);return productService.selectProductById(productId);}@RequestMapping("/p1")public String p1(Integer id){return "product-service 接收到参数,id:"+id;}@RequestMapping("/p2")public String p2(Integer id,String name){return "product-service接收到参数,id:"+id+",name:"+name;}@RequestMapping("/p3")public String p3(ProductInfo productInfo){return "product-service 接收到参数:productInfo"+productInfo.toString();}@RequestMapping("/p4")public String p4(@RequestBody ProductInfo productInfo){return "profuct-service 接收到参数: productInfo"+productInfo.toString();}
}
package com.bite.order.api;import com.bite.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;//假如后面加上path,那么说明下面的所有前面都有一个product
@FeignClient(value = "product-service",path ="/product")
public interface ProductApi {@RequestMapping("/{productId}")ProductInfo getProductInfo(@PathVariable("productId") Integer productId);//Feign的客户端@RequestMapping("/p1")//这个Param不可以省略.String p1(@RequestParam("id")Integer id);@RequestMapping("/p2")//做了一个参数的绑定public  String p2(@RequestParam("id") Integer id,  @RequestParam("name") String name);@RequestMapping("/p3")public String p3(@SpringQueryMap  ProductInfo productInfo); //SpringQueryMap需要把对象绑定给Feign@RequestMapping("/p4")public  String p4(@RequestBody ProductInfo productInfo);}
package com.bite.order;import com.bite.order.api.ProductApi;
import com.bite.order.model.ProductInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/feign")
public class FeignController {@Autowiredprivate ProductApi productApi;//通过远程调用,o1访问商品服务p1方法@RequestMapping("/o1")public String o1(Integer id){return productApi.p1(id);}@RequestMapping("/o2")public String o2(Integer id,String name){return productApi.p2(id,name);}@RequestMapping("/o3")public String o3(){ProductInfo productInfo=new ProductInfo();productInfo.setId(23);productInfo.setProductName("乔丹");return productApi.p3(productInfo);}@RequestMapping("/o4")public String o4(){ProductInfo productInfo=new ProductInfo();productInfo.setId(24);productInfo.setProductName("科比");return productApi.p4(productInfo);}
}

OpenFeign最佳实践

我们的一些业务代码不方便给使用者展示,以外一些代码冗余,客户端代码和服务提供者代码十分相似,有没有一种办法可以把公共的代码提出来呢?

 点击install把当前工程打成jar包,放到Maven本地仓库。

但是我发现会一个没有主类的错误

我再来遇到个问题,我创建的com.xx.xxx包,放到一起了,不是那种一个在一个下面的那种

这种情况是因为idea选择了空文件夹,会自动折叠。点击项目的设置

把我光标指的地方取消勾即可

OpenFeign的最佳实验

1.继承的方式,把公共的放到一个接口里面,

Nacos,只要看见这种什么网络报错啥的,java.net.SocketException: Network is unreachable

不是端口没开,就是 protocol/ 没删除,它是你运行一会他会再次生成,所以,一旦出现问题,就去把这个鬼东西删除,浪费我两小时,真恶心。

2.抽取的方式

企业开发中,更多是把Feigm接口抽取成为一个独立的模块(做法和继承类似,但是理念不同)             

1.抽取方式,完成抽取,

2.打包install,

3.启动服务端。    

4.服务调用方,引入抽取过来的模块

 (抽取的模块通常由服务提供方来写),抽取的时候提供的API可以只写其中四五个,因为这样整个这个对外提供的服务通常由服务提供方,然后调用方来引入

服务部署

1.确认配置

2.打包,上传包

3.启动服务

4.测试

我们那个抽取的模块,无法进行打包,因为打包都是从Maven下载的,

方法

1.:上传到Maven中央仓库(麻烦)

2.搭建Maven私服(企业)

3.从本地读取jar包(推荐,个人学习)

这篇关于优雅实现远程调用-OpenFeign的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1115056

相关文章

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts?二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步:安装必要的依赖库第二步:获取并构建 BoringSSL第三步:获取 Nginx

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码(Binary-Coded Decima

SpringBoot全局域名替换的实现

《SpringBoot全局域名替换的实现》本文主要介绍了SpringBoot全局域名替换的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录 项目结构⚙️ 配置文件application.yml️ 配置类AppProperties.Ja