详解Spring Cloud 跨服务数据聚合框架

AG-Merge

Spring Cloud 跨服务数据聚合框架

解决问题

解决Spring Cloud服务拆分后分页数据的属性或单个对象的属性拆分之痛, 支持对静态数据属性(数据字典)、动态主键数据进行自动注入和转化, 其中聚合的静态数据会进行 一级混存 (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 @interface MergeField {
  
  String key() default "";

  
  Class feign() default Object.class;

  
  String method() default "";

  
  boolean isValueNeedMerge() default false;
}

聚合对象

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.

@FeignClient("test")
public interface IService2 {
  @RequestMapping("car/do")
  public Map writeLog(String test);

  @RequestMapping("car/city")
  public Map getCitys(String ids);
}

对应的远程服务接口

@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扫描注解的方式)

@Service
@Slf4j
public class UserBiz {
  @Autowired
  private MergeCore mergeCore;
  
  @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;
  }

  
  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;
    }
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。