手写Openfeign实现原理——极简版

文章目录

  • 前言
  • Openfeign实现思路
  • 前期准备
    • 基本依赖项
  • 开始实现
    • 自定义注解
    • 自定义代理类
    • 定义创建代理对象的工厂
    • InstantiationAwareBeanPostProcessor实现bean的注入
      • OpenInstantiationAwareBeanPostProcessor 自定义
    • feign接口
    • 启动类
    • 小结
  • 踩坑记录
    • @Import
    • @Component和@Configuration区别是什么
  • 总结

前言

最近开发cloud项目，里面涉及到服务间调用，最后使用的openfeign解决的，于是对于openfeign的底层原理有些兴趣了，提前透露一下底层无非就是使用一些http调用的工具帮助我们实现了请求调用

Openfeign实现思路

在这里插入图片描述

前期准备

基本依赖项

  • 首先创建一个springboot项目
  • 有一个发送请求的工具这里使用的ribbon
        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId><version>2.2.9.RELEASE</version><scope>compile</scope><optional>true</optional></dependency>

开始实现

自定义注解

创建两个自定义注解，分别用于在启动类和接口上添加

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Configuration
@Import(OpenInstantiationAwareBeanPostProcessor.class)//这个类重点注意
public @interface EnableRemoteClient {
}@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Component
public @interface CustomProxy {String servie();String address();
}

自定义代理类

代理类中有一个RestTemplate 用于发送请求

public class CustomProxyHandler implements InvocationHandler {RestTemplate restTemplate=new RestTemplate();@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {//首先获取对象Class<?> declaringClass = method.getDeclaringClass();//判断当前的被代理对象是否使用了自定的注解if(declaringClass.isAnnotationPresent(CustomProxy.class)){CustomProxy annotation = declaringClass.getAnnotation(CustomProxy.class);String servie = annotation.servie();String address = annotation.address();String url=address+servie;RequestMapping annotation1 = method.getAnnotation(RequestMapping.class);url=url+annotation1.value()[0];//判断请求方法是否入参if(args!=null&&args.length!=0){return restTemplate.getForObject(url,method.getReturnType(),args);}else {return restTemplate.getForObject(url,method.getReturnType());}}else{return null;}}
}

定义创建代理对象的工厂

用于创建代理对象使用，

public class ProxyFactory {/*** @description: 创建具体的代理对象* @author: * @date: 2023/9/1 17:30* @param: [targetInterface]* @return: T**/public static  <T> T createProxy(Class<T> targetInterface) {return (T) Proxy.newProxyInstance(targetInterface.getClassLoader(),new Class[]{targetInterface},new CustomProxyHandler());}
}

InstantiationAwareBeanPostProcessor实现bean的注入

InstantiationAwareBeanPostProcessor 是 Spring 框架提供的一个扩展接口，它在 Spring 容器实例化 bean 之前和之后对 bean 进行处理。其主要功能如下：

  1. 实例化前置处理（Before Instantiation）：在 Spring 容器实例化 bean 之前，可以通过这个接口来自定义 bean 的实例化方式。可以在此处进行一些特殊的准备工作，比如使用自定义的实例化逻辑或者切入点的选择。

  2. 实例化后置处理（After Instantiation）：在 Spring 容器实例化 bean 之后，可以通过这个接口对实例化后的 bean 进行处理。可以在此处做一些初始化的操作，比如对属性进行赋值、调用初始化方法等。

  3. 属性设置前置处理（Before Property Set）：在 Spring 容器对 bean 的属性进行设置之前，可以通过这个接口来自定义属性的设置方式。可以在此处对属性进行修改或者校验操作。

  4. 属性设置后置处理（After Property Set）：在 Spring 容器对 bean 的属性进行设置之后，可以通过这个接口对属性设置后的 bean 进行处理。可以在此处做一些属性设置后的额外操作。

  5. 初始化前置处理（Before Initialization）：在 Spring 容器对 bean 进行初始化之前，可以通过这个接口来自定义初始化的方式。可以在此处添加一些额外的初始化逻辑。

  6. 初始化后置处理（After Initialization）：在 Spring 容器对 bean 进行初始化之后，可以通过这个接口对初始化后的 bean 进行处理。可以在此处做一些初始化后的额外操作。

通过实现 InstantiationAwareBeanPostProcessor 接口，并重写其中的方法，可以在 Spring 容器实例化和初始化 bean 的各个阶段进行自定义处理，从而灵活地对 bean 进行定制化的操作。

OpenInstantiationAwareBeanPostProcessor 自定义

public class OpenInstantiationAwareBeanPostProcessor implements InstantiationAwareBeanPostProcessor, ApplicationContextAware {private ApplicationContext applicationContext;/*** 实例化前，后面的方法可以不用看了* @param beanClass* @param beanName* @return* @throws BeansException*/@Overridepublic Object postProcessBeforeInstantiation(Class<?> beanClass, String beanName) throws BeansException {log.info("正在为：{}生成代理对象,被代理的类为：{}",beanName,beanClass.getName());if(!beanClass.isAnnotationPresent(CustomProxy.class)){return null;}//动态代理里面需要实现的方法，本文采用的是jdk动态代理//返回代理对象Object object = ProxyFactory.createProxy(beanClass);return object;}/*** 实例化后* @param bean* @param beanName* @return* @throws BeansException*/@Overridepublic boolean postProcessAfterInstantiation(Object bean, String beanName) throws BeansException {return true;}@Overridepublic PropertyValues postProcessProperties(PropertyValues pvs, Object bean, String beanName) throws BeansException {return pvs;}/*** 初始化钱* @param bean* @param beanName* @return* @throws BeansException*/@Overridepublic Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {return bean;}/*** 初始化后* @param bean* @param beanName* @return* @throws BeansException*/@Overridepublic Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {return bean;}@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext=applicationContext;}
}

feign接口

这里的servie没有参数是因为我的另一个服务中没有配置context-path，如果你们自己的被调用的那个demo中有配置一定要加上哦

@CustomProxy(servie = "",address = "http://localhost:8082/")
public interface MyService {@RequestMapping(value = "/QuerySubselect",method = RequestMethod.GET)String  test();
}

启动类

@SpringBootApplication
@EnableRemoteClient
@Import({MyService.class})//接口注册，注意接口上面加@Se
public class OpenfeignDemoApplication {public static void main(String[] args) {SpringApplication.run(OpenfeignDemoApplication.class, args);}}

小结

这个版本的实现目前spring还不能识别我添加了注解的这个接口，需要在启动类中使用@Import注解手动配置，所以还不完善，不过后期会继续完善的，目前博主也在学习这个，这个思路就是基于我们正常的发送请求，然后有一个人帮助我们去发送请求这个思路。

踩坑记录

@Import

将接口 MyService 标识为 @Import 的目的是为了在启动类中将该接口的实现类（动态代理对象）注册到 Spring 容器中。

当你使用 @Import({MyService.class}) 注解时，Spring 在启动时会扫描被注解的类，并根据其类型进行相应的处理。在这种情况下，MyService 类型是一个接口，而不是一个具体的类。

由于接口无法直接实例化，因此你需要在某处提供对 MyService 接口的实现类的创建逻辑。通常情况下，使用动态代理是一种常见的方式。

动态代理是一种在运行时生成代理类的机制，可以在不修改原始接口源代码的情况下，通过代理类来增强接口的功能。你可以编写一个动态代理类，实现 MyService 接口，并在动态代理类中实现你所需的增强逻辑。

然后，在启动类上使用 @Import 注解，并传入该动态代理类的类型，告诉 Spring 在启动时需要将该动态代理类注册到容器中。

这样，当其他组件需要使用 MyService 接口时，Spring 容器会从容器中获取该接口的实例，而实际上获得的是动态代理对象，该代理对象会在实际调用接口方法时根据你的增强逻辑进行处理。

  • 因为openfeign的标注的接口没有实现类所以需要这个@Import注解帮助我们告诉spring容器可以去容器中去这个类型的代理对象，目前还没有想到其他的方式不用使用@Import注解声明的。后续再想想办法

@Component和@Configuration区别是什么

@Configuration 注解不能直接添加到接口上，因为 @Configuration 注解是用于标识一个类为配置类的注解，它主要用于定义和配置 Bean 对象以及其他的配置信息。
在这里插入图片描述
一开始使用这个注解导致使用了自定义注解的接口一直扫描不到，后来修改为@Component注解后就可以了。
@Component 是 Spring Framework 中的一个核心注解之一，用于将一个普通的 Java 类标识为一个可以被 Spring 自动扫描并管理的组件。

具体来说，@Component 注解可以应用于以下场景：

  1. Bean 的自动扫描和注册：通过在类上添加 @Component 注解，Spring 容器会自动扫描并将该类作为 Bean 进行注册，使得我们可以通过依赖注入等方式方便地使用该类的实例。

  2. 类型指定的自动装配：当需要进行自动装配时，Spring 容器会检测所有被 @Component 注解标记的类，并根据类型进行自动装配。

@Component 注解是一个通用的注解，如果对应的类有更具体的角色或作用，还可以使用其他派生注解，例如：

  • @Controller：标识一个类是控制器（Controller）组件，用于接收和处理用户请求。
  • @Service：标识一个类是服务（Service）组件，用于封装业务逻辑。
  • @Repository：标识一个类是数据访问仓库（Repository）组件，用于访问持久化数据。

这些派生注解都是基于 @Component 注解的，继承了 @Component 的功能，并且更明确地表示了对应类的角色和用途。

总结

对于这次去实现这么一个框架的小demo自己思考了一天，不能说很长时间吧，主要是因为对于spring中提供的一些扩展机制还不是很了解，但是我相信它一定提供了能够解决我上面问题的一些api的，只是我还没有发现而已。对于这些技术的应用底层原理还是很简单的，可以发现无非就是没让你做的事情有人帮你做了这么一个过程，只不过这个过程被人封装起来以后就是一个技术或者一个框架了。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/94777.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vscode远程调试php

vscode远程调试php

使用vscode远程调试php的方法 1.安装remote ssh插件 2.连接服务器 可以点击左下角的绿色按钮&#xff0c;或者ctrlshiftp打开命令框输入remote ssh应该也有。 3.在服务器端vscode安装php debug插件 4.安装xdebug xdebug是用来调试php的软件&#xff0c;原本和vscode没什么关…
阅读更多...
数据库-DQL

数据库-DQL

DQL&#xff1a;用来查询数据库表中的记录 关键字&#xff1a;SELECT 语法&#xff1a; select&#xff1a;字段列表 from&#xff1a;表名列表 where&#xff1a;条件列表 group by&#xff1a;分组列表 having&#xff1a;分组后条件列表 order by&#xff1a;排序字段列表…
阅读更多...
软件外包开发人员分类

软件外包开发人员分类

在软件开发中&#xff0c;通常会分为前端开发和后端开发&#xff0c;下面和大家分享软件开发中的前端开发和后端开发分类和各自的职责&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合作。 1. 前端开发&…
阅读更多...
企业如何充分借助大数据下精准营销？

企业如何充分借助大数据下精准营销？

技术的发展和智能终端的普及移动互联网用户的大规模增长使移动互联网快速发展&#xff0c;使中国移动互联网软件进入移动互联网时代越来越多地涉及到改变生活大家习惯。移动互联网时代的到来也意味着大数据时代的到来。精准营销数据方法&#xff0c;移动互联网和大数据的兴起不…
阅读更多...
Excel：通过Lookup函数提取指定文本关键词

Excel：通过Lookup函数提取指定文本关键词

函数公式&#xff1a;LOOKUP(9^9,FIND($G 2 : 2: 2:G 6 , C 2 ) , 6,C2), 6,C2),G 2 : 2: 2:G$6) 公式解释&#xff1a; lookup第一参数为9^9&#xff1a;代表的是一个极大值的数据&#xff0c;查询位置里面最接近这一个值的数据&#xff1b;lookup第二参数用find函数代替&am…
阅读更多...
Kubernetes入门 十、HPA 自动扩/缩容

Kubernetes入门 十、HPA 自动扩/缩容

目录 概述安装metrics-server使用HPA 概述 我们已经可以通过手动执行 kubectl scale 命令实现Pod的扩缩容&#xff0c;但是这显然不符合 Kubernetes 的定位目标–自动化和智能化。Kubernetes 期望可以通过监测Pod的使用情况&#xff0c;实现 Pod 数量的自动调整&#xff0c;于…
阅读更多...
JDBC编程

JDBC编程

文章目录 一、概述二、使用 一、概述 1.概念 JDBC&#xff08;Java Database Connectivity java数据库连接&#xff09;指的是通过Java代码&#xff0c;来操作数据库&#xff0c;是一种用于执行SQL语句的Java API&#xff0c;是Java中的数据库连接规范。这个API由 java.sql.,…
阅读更多...
SpringBoot介绍与搭建

SpringBoot介绍与搭建

SpringBoot Spring Boot 是由 Pivotal 团队提供的在 spring 框架基础之上开发的框架&#xff0c; 其设计目的是用来简化应用的初始搭建以及开发过程。对spring搭建过程中的繁琐模板配置以及版本依赖问题进行解决(优化)不使用xml进行配置&#xff0c;提供其他的方式进行配置,使…
阅读更多...
pytorch异常——RuntimeError:Given groups=1, weight of size..., expected of...

pytorch异常——RuntimeError:Given groups=1, weight of size..., expected of...

文章目录 省流异常报错异常截图异常代码原因解释修正代码执行结果 省流 nn.Conv2d 需要的输入张量格式为 (batch_size, channels, height, width)&#xff0c;但您的示例输入张量 x 是 (batch_size, height, width, channels)。因此&#xff0c;需要对输入张量进行转置。 注意…
阅读更多...
第 112 场 LeetCode 双周赛题解

第 112 场 LeetCode 双周赛题解

A 判断通过操作能否让字符串相等 I s 1 s1 s1和 s 2 s2 s2第 1 1 1、 2 2 2位若同位置不等&#xff0c;则 s 1 s1 s1交换对应的 i i i和 j j j位置&#xff0c;之后判断 s 1 s1 s1和 s 2 s2 s2是否相当 class Solution { public:bool canBeEqual(string s1, string s2) {for (i…
阅读更多...
全脑建模：过去、现在和未来

全脑建模：过去、现在和未来

什么是全脑建模&#xff1f; 全脑建模(WBM)是计算神经科学的子领域&#xff0c;涉及近似全脑神经活动的计算和理论模型。该方法的目标是研究神经活动的宏观时空模式如何由解剖连接结构、内在神经动力学和外部扰动(感觉、认知、药理、电磁等)的相互作用产生。这种宏观现象及其模…
阅读更多...
CSS3D+动画

CSS3D+动画

CSS3D 1.css3D 给父元素设置 perspective:景深:近大远小的效果900-1200px这个范围内 transform-style:是否设置3D环境 flat 2D环境 默认值 perserve-3D环境 3D功能函数 1.位移: translateZ()translate3D(x,y,z) <!DOCTYPE html> <html lang"en"><h…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023