基于Spring实现策略模式

　　背景：
　　看多很多策略模式，总结下来实现原理大体都差不多，在这里主要是讲解下自己基于Spring更优雅的实现方案；这个方案主要是看了一些开源rpc和Spring相关源码后的一些思路，所以在此进行总结首先看下比较常见的策略模式写法一个接口或者抽象类，里面两个方法（一个方法匹配类型，一个可替换的逻辑实现方法）不同策略的差异化实现（就是说，不同策略的实现类）使用策略模式1。3。1一个接口，两个方法publicinterfaceIFileStrategy｛属于哪种文件解析类型FileTypeResolveEnumgainFileType（）；封装的公用算法（具体的解析方法）voidresolve（Objectobjectparam）；｝
　　1。3。2不同策略的差异化实现
　　A类型策略具体实现ComponentpublicclassAFileResolveimplementsIFileStrategy｛OverridepublicFileTypeResolveEnumgainFileType（）｛returnFileTypeResolveEnum。FileARESOLVE；｝Overridepublicvoidresolve（Objectobjectparam）｛logger。info（A类型解析文件，参数：｛｝，objectparam）；A类型解析具体逻辑｝｝
　　B类型策略具体实现ComponentpublicclassBFileResolveimplementsIFileStrategy｛OverridepublicFileTypeResolveEnumgainFileType（）｛returnFileTypeResolveEnum。FileBRESOLVE；｝Overridepublicvoidresolve（Objectobjectparam）｛logger。info（B类型解析文件，参数：｛｝，objectparam）；B类型解析具体逻辑｝｝
　　默认类型策略具体实现ComponentpublicclassDefaultFileResolveimplementsIFileStrategy｛OverridepublicFileTypeResolveEnumgainFileType（）｛returnFileTypeResolveEnum。FileDEFAULTRESOLVE；｝Overridepublicvoidresolve（Objectobjectparam）｛logger。info（默认类型解析文件，参数：｛｝，objectparam）；默认类型解析具体逻辑｝｝
　　1。3。3使用策略模式
　　如何使用呢？我们借助spring的生命周期，使用ApplicationContextAware接口，把对用的策略，初始化到map里面。然后对外提供resolveFile方法即可。ComponentpublicclassStrategyUseServiceimplementsApplicationContextAware｛privateMapFileTypeResolveEnum，IFileStrategyiFileStrategyMapnewConcurrentHashMap（）；publicvoidresolveFile（FileTypeResolveEnumfileTypeResolveEnum，ObjectobjectParam）｛IFileStrategyiFileStrategyiFileStrategyMap。get（fileTypeResolveEnum）；if（iFileStrategy！null）｛iFileStrategy。resolve（objectParam）；｝｝把不同策略放到mapOverridepublicvoidsetApplicationContext（ApplicationContextapplicationContext）throwsBeansException｛MapString，IFileStrategytmepMapapplicationContext。getBeansOfType（IFileStrategy。class）；tmepMap。values（）。forEach（strategyServiceiFileStrategyMap。put（strategyService。gainFileType（），strategyService））；｝｝
　　基于Spring服务策略实现
　　稍微了解过Spring源码都知道，在Spring里面我们定义好的bean被Autowired修饰后，实际这个bean是被Spring进行了统一管理，当需要调用的时候实际是从Spring工厂里拿到这个bean；所以大致思路就是在如何拿到bean之前注入一个代理类，让代理类根据元数据的一些自定义规则后去组装成一个能从Spring里拿到实际的bean元素；基于以上的思路进行编码如下
　　注解定义自定义一个RouteBizService注解（作用可以理解为Autowired）Target（｛ElementType。CONSTRUCTOR，ElementType。METHOD，ElementType。PARAMETER，ElementType。FIELD，ElementType。ANNOTATIONTYPE｝）Retention（RetentionPolicy。RUNTIME）publicinterfaceRouteBizService｛StringserviceName（）；｝
　　自定义一个RouteBizParam参数注解，用于给代理类组装实际beanNameTarget（ElementType。PARAMETER）Retention（RetentionPolicy。RUNTIME）publicinterfaceRouteBizParam｛｝
　　定义一个代理类：RouteServiceProxypackagecom。gitee。adapter。proxy；importorg。springframework。context。ApplicationContext；importjava。lang。annotation。Annotation；importjava。lang。reflect。InvocationHandler；importjava。lang。reflect。Method；publicclassRouteServiceProxyTimplementsInvocationHandler｛privateStringserviceName；privateApplicationContextcontext；publicRouteServiceProxy（StringserviceName，ApplicationContextcontext）｛this。serviceNameserviceName；this。contextcontext；｝OverridepublicObjectinvoke（Objectproxy，Methodmethod，Object〔〕args）throwsThrowable｛StringrouteCodenull；Annotation〔参数个数索引〕〔注解个数索引〕paramsAnnomethod。getParameterAnnotations（）；if（paramsAnno！null）｛for（inti0；iparamsAnno。length；i）｛if（paramsAnno〔i〕。length0）｛routeCode（String）args〔i〕；获取到路由的参数值break；｝｝｝returnmethod。invoke（context。getBean（genBeanName（routeCode，serviceName）），args）；｝paramsellerCode用于区分是哪个Service编码paraminterfaceSimpleName服务接口returnprivateStringgenBeanName（StringsellerCode，StringinterfaceSimpleName）｛returnnewStringBuilder（sellerCode。toLowerCase（））。append（interfaceSimpleName）。toString（）；｝｝
　　ViewCode
　　基于BeanFactoryPostProcessor定义一个用于扫描RouteBizService修饰的实现类，该类的作用是为了注入代理类packagecom。gitee。adapter。spring；importcom。gitee。adapter。annation。RouteBizService；importcom。gitee。adapter。proxy。RouteServiceProxy；importorg。springframework。beans。BeansException；importorg。springframework。beans。factory。config。BeanDefinition；importorg。springframework。beans。factory。config。BeanFactoryPostProcessor；importorg。springframework。beans。factory。config。ConfigurableListableBeanFactory；importorg。springframework。context。ApplicationContext；importorg。springframework。context。ApplicationContextAware；importorg。springframework。core。annotation。AnnotationUtils；importorg。springframework。util。ClassUtils；importorg。springframework。util。ReflectionUtils；importjava。lang。reflect。Proxy；ClassnameBizRouteServiceProcessorDescriptionbean后置处理器获取所有bean判断bean字段是否被｛linkcom。gitee。adapter。annation。RouteBizService｝注解修饰publicclassBizRouteServiceProcessorimplementsBeanFactoryPostProcessor，ApplicationContextAware｛privateApplicationContextapplicationContext；OverridepublicvoidpostProcessBeanFactory（ConfigurableListableBeanFactorybeanFactory）throwsBeansException｛for（StringbeanDefinitionName：beanFactory。getBeanDefinitionNames（））｛BeanDefinitionbeanDefinitionbeanFactory。getBeanDefinition（beanDefinitionName）；StringbeanClassNamebeanDefinition。getBeanClassName（）；if（beanClassName！null）｛Classlt；？clazzClassUtils。resolveClassName（beanClassName，this。getClass（）。getClassLoader（））；ReflectionUtils。doWithFields（clazz，field｛RouteBizServicerouteBizServiceAnnotationUtils。getAnnotation（field，RouteBizService。class）；if（routeBizService！null）｛ObjectbeanapplicationContext。getBean（clazz）；field。setAccessible（true）；修改为代理对象ReflectionUtils。setField（field，bean，Proxy。newProxyInstance（field。getType（）。getClassLoader（），newClass〔〕｛field。getType（）｝，newRouteServiceProxy（routeBizService。serviceName（），this。applicationContext）））；｝｝）；｝｝｝OverridepublicvoidsetApplicationContext（ApplicationContextapplicationContext）throwsBeansException｛this。applicationContextapplicationContext；｝｝
　　ViewCode
　　测试
　　环境搭建操作系统：Windows集成开发工具：IntelliJIDEA2021项目技术栈：SpringBoot2。2。11JDK1。8项目依赖管理工具：Maven4。0。0
　　小伙伴们有兴趣想了解内容和更多相关学习资料的请点赞收藏评论转发关注我，后面会有很多干货。
　　我有一些面试题、架构、设计类资料可以说是程序员面试必备！所有资料都整理到网盘了，需要的话欢迎下载！私信我回复【07】即可免费获取
　　原文出处：www。shaoqun。coma1437729。html