java 聚合服务_java相关：详解Spring Cloud 跨服务数据聚合框架

爱被打了一巴掌 2022-11-08 14:15 256阅读 0赞

java相关：详解Spring Cloud 跨服务数据聚合框架

发布于 2020-5-29|

复制链接

摘记: AG-MergeSpring Cloud 跨服务数据聚合框架解决问题解决Spring Cloud服务拆分后分页数据的属性或单个对象的属性拆分之痛, 支持对静态数据属性(数据字典)、动态主键数据进行自动注入和转化, 其中聚合的静态数据会进行 一级 ..

AG-MergeSpring Cloud 跨服务数据聚合框架解决问题解决Spring Cloud服务拆分后分页数据的属性或单个对象的属性拆分之痛, 支持对静态数据属性(数据字典)、动态主键数据进行自动注入和转化, 其中聚合的静态数据会进行 一级混存 (guava).举个栗子：两个服务，A服务的某张表用到了B服务的某张表的值，我们在对A服务那张表查询的时候，把B服务某张表的值聚合在A服务的那次查询过程中示例具体示例代码可以看 ace-merge-demo 模块

\`\`\`plain

|------- ace-eureka 注册中心

|------- ace-data-merge-demo 查询数据,此处聚合示例

|------- ace-data-provider 数据提供者

\`\`\`

Maven添加依赖

\`\`\`xml

com.github.wxiaoqi

ace-merge-core

2.0-SNAPSHOT

\`\`\`

推荐仓库配置

\`\`\`xml

oss

https://oss.sonatype.org/content/groups/public

\`\`\`

启动类加注解

\`\`\`java

@EnableAceMerge

\`\`\`

application.yml配置

\`\`\`plain

\# 跨服务数据合并

merge:

enabled: true

guavaCacheNumMaxSize: 1000

guavaCacheRefreshWriteTime: 10 \# min

guavaCacheRefreshThreadPoolSize: 10

aop: \# 启动注解的方式,自动聚合

enabled: true

\`\`\`

代码示例( @MergeField 标志对象的数据需要聚合)

\`\`\`java

@Retention(RetentionPolicy.RUNTIME)

@Target(value=\{ElementType.METHOD,ElementType.TYPE,ElementType.FIELD\})

public @interface MergeField \{

/\*\*

\* 查询值

\* @return

\*/

String key() default "";

/\*\*

\* 目标类

\* @return

\*/

Class feign() default Object.class;

/\*\*

\* 调用方法

\* @return

\*/

String method() default "";

/\*\*

\* 是否以属性值合并作为查询值

\* @return

\*/

boolean isValueNeedMerge() default false;

\`\`\`

聚合对象

\`\`\`java

public class User \{

private String name;

// 需要聚合的属性

@MergeField(key="test", feign = IService2.class,method = "writeLog")

private String sex;

// 需要聚合的属性

@MergeField(feign = IService2.class,method = "getCitys",isValueNeedMerge = true)

private String city;

public User(String name, String sex, String city) \{

this.name = name;

this.sex = sex;

this.city = city;

public String getCity() \{

return city;

public void setCity(String city) \{

this.city = city;

public User(String name) \{

this.name = name;

public User(String name, String sex) \{

this.name = name;

this.sex = sex;

public String getName() \{

return name;

public void setName(String name) \{

this.name = name;

public String getSex() \{

return sex;

public void setSex(String sex) \{

this.sex = sex;

\`\`\`

聚合数据来源方法(示例为通过FeignClient,也可以是本地的spring bean对象)

特别要求:入参必须为一个String,返回值必须为Map. 其中返回值的构成,就是聚合对象属性的key和对应的value.

\`\`\`java

@FeignClient("test")

public interface IService2 \{

@RequestMapping("car/do")

public Map writeLog(String test);

@RequestMapping("car/city")

public Map getCitys(String ids);

\`\`\`

对应的远程服务接口

\`\`\`java

/\*\*

\* @author ace

\* @create 2017/11/20.

\*/

@RestController

@RequestMapping("car")

public class Service2Rest \{

private Logger logger = LoggerFactory.getLogger(Service2Rest.class);

@RequestMapping("do")

public Map writeLog(String test)\{

logger.info("service 2 is writing log!");

Map map = new HashMap();

map.put("man","男");

map.put("woman","女");

return map;

@RequestMapping("city")

public Map getCity(String ids)\{

logger.info("service 2 is writing log!"+ids);

Map map = new HashMap();

map.put("1","广州");

map.put("2","武汉");

return map;

\`\`\`

聚合对象的Biz类(下面的方式是采用aop扫描注解的方式)

\`\`\`java

@Service

@Slf4j

public class UserBiz \{

@Autowired

private MergeCore mergeCore;

/\*\*

\* aop注解的聚合方式

\* 其中聚合的方法返回值必须为list,

\* 如果为复杂对象,则需要自定义自己的聚合解析器(实现接口IMergeResultParser)

\*/

@MergeResult(resultParser = TestMergeResultParser.class)

public List getAopUser() \{

ArrayList users = new ArrayList();

for (int i = 1000; i > 0; i--) \{

users.add(new User("zhangsan" + i, "man", "1"));

users.add(new User("lisi" + i, "woman", "2"));

users.add(new User("wangwu" + i, "unkonwn", "2"));

return users;

/\*\*

\* 手动聚合方式

\* @return

\*/

public List getUser()\{

ArrayList users = new ArrayList();

for (int i = 1000; i > 0; i--) \{

users.add(new User("zhangsan" + i, "man", "1"));

users.add(new User("lisi" + i, "woman", "2"));

users.add(new User("wangwu" + i, "unkonwn", "2"));

try \{

// list 聚合

mergeCore.mergeResult(User.class,users);

// 单个对象聚合

// mergeCore.mergeOne(User.class,users.get(0));

\} catch (Exception e) \{

log.error("数据聚合失败",e);

\}finally \{

return users;

\`\`\`

java 聚合服务_java相关：详解Spring Cloud 跨服务数据聚合框架

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关微服务--数据聚合

相关 Spring Cloud Gateway②聚合Swagger

相关 java 聚合服务_java相关：详解Spring Cloud 跨服务数据聚合框架

相关 Spring Cloud构建微服务架构：Hystrix监控数据聚合【Dalston版】

相关 Spring Cloud-Turbine 聚合监控

相关 spring cloud gateway聚合swagger

相关 Spring Cloud Turbine聚合Hystrix

相关微服务spring cloud-使用Turbine聚合监控数据

相关 Spring Cloud构建微服务架构：Hystrix监控数据聚合【Dalston版】

相关 Spring Cloud Gateway -- 聚合swagger