详解Spring Cloud 跨服务数据聚合框架
AG-Merge
SpringCloud跨服务数据聚合框架
解决问题
解决SpringCloud服务拆分后分页数据的属性或单个对象的属性拆分之痛,支持对静态数据属性(数据字典)、动态主键数据进行自动注入和转化,其中聚合的静态数据会进行一级混存(guava).
举个栗子:
两个服务,A服务的某张表用到了B服务的某张表的值,我们在对A服务那张表查询的时候,把B服务某张表的值聚合在A服务的那次查询过程中
示例
具体示例代码可以看ace-merge-demo模块
|-------ace-eureka注册中心 |-------ace-data-merge-demo查询数据,此处聚合示例 |-------ace-data-provider数据提供者
Maven添加依赖
com.github.wxiaoqi ace-merge-core 2.0-SNAPSHOT
推荐仓库配置
oss oss https://oss.sonatype.org/content/groups/public
启动类加注解
@EnableAceMerge
application.yml配置
#跨服务数据合并 merge: enabled:true guavaCacheNumMaxSize:1000 guavaCacheRefreshWriteTime:10#min guavaCacheRefreshThreadPoolSize:10 aop:#启动注解的方式,自动聚合 enabled:true
代码示例(@MergeField标志对象的数据需要聚合)
@Retention(RetentionPolicy.RUNTIME) @Target(value={ElementType.METHOD,ElementType.TYPE,ElementType.FIELD}) public@interfaceMergeField{ /** *查询值 *@return */ Stringkey()default""; /** *目标类 *@return */ Classfeign()defaultObject.class; /** *调用方法 *@return */ Stringmethod()default""; /** *是否以属性值合并作为查询值 *@return */ booleanisValueNeedMerge()defaultfalse; }
聚合对象
publicclassUser{ privateStringname; //需要聚合的属性 @MergeField(key="test",feign=IService2.class,method="writeLog") privateStringsex; //需要聚合的属性 @MergeField(feign=IService2.class,method="getCitys",isValueNeedMerge=true) privateStringcity; publicUser(Stringname,Stringsex,Stringcity){ this.name=name; this.sex=sex; this.city=city; } publicStringgetCity(){ returncity; } publicvoidsetCity(Stringcity){ this.city=city; } publicUser(Stringname){ this.name=name; } publicUser(Stringname,Stringsex){ this.name=name; this.sex=sex; } publicStringgetName(){ returnname; } publicvoidsetName(Stringname){ this.name=name; } publicStringgetSex(){ returnsex; } publicvoidsetSex(Stringsex){ this.sex=sex; } }
聚合数据来源方法(示例为通过FeignClient,也可以是本地的springbean对象)
特别要求:入参必须为一个String,返回值必须为Map
@FeignClient("test") publicinterfaceIService2{ @RequestMapping("car/do") publicMapwriteLog(Stringtest); @RequestMapping("car/city") publicMap getCitys(Stringids); }
对应的远程服务接口
/** *@authorace *@create2017/11/20. */ @RestController @RequestMapping("car") publicclassService2Rest{ privateLoggerlogger=LoggerFactory.getLogger(Service2Rest.class); @RequestMapping("do") publicMapwriteLog(Stringtest){ logger.info("service2iswritinglog!"); Map map=newHashMap (); map.put("man","男"); map.put("woman","女"); returnmap; } @RequestMapping("city") publicMap getCity(Stringids){ logger.info("service2iswritinglog!"+ids); Map map=newHashMap (); map.put("1","广州"); map.put("2","武汉"); returnmap; } }
聚合对象的Biz类(下面的方式是采用aop扫描注解的方式)
@Service @Slf4j publicclassUserBiz{ @Autowired privateMergeCoremergeCore; /** *aop注解的聚合方式 *其中聚合的方法返回值必须为list, *如果为复杂对象,则需要自定义自己的聚合解析器(实现接口IMergeResultParser) */ @MergeResult(resultParser=TestMergeResultParser.class) publicListgetAopUser(){ ArrayList users=newArrayList (); for(inti=1000;i>0;i--){ users.add(newUser("zhangsan"+i,"man","1")); users.add(newUser("lisi"+i,"woman","2")); users.add(newUser("wangwu"+i,"unkonwn","2")); } returnusers; } /** *手动聚合方式 *@return */ publicList getUser(){ ArrayList users=newArrayList (); for(inti=1000;i>0;i--){ users.add(newUser("zhangsan"+i,"man","1")); users.add(newUser("lisi"+i,"woman","2")); users.add(newUser("wangwu"+i,"unkonwn","2")); } try{ //list聚合 mergeCore.mergeResult(User.class,users); //单个对象聚合 //mergeCore.mergeOne(User.class,users.get(0)); }catch(Exceptione){ log.error("数据聚合失败",e); }finally{ returnusers; } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。