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

|------- ace-eureka 注册中心|------- ace-data-merge-demo 查询数据,此处聚合示例|------- ace-data-provider 数据提供者

<dependency>  <groupId>com.github.wxiaoqi</groupId>  <artifactId>ace-merge-core</artifactId>  <version>2.0-SNAPSHOT</version></dependency>

<repositories>    <repository>      <id>oss</id>      <name>oss</name>      <url>https://oss.sonatype.org/content/groups/public</url>    </repository>  </repositories>

@EnableAceMerge

# 跨服务数据合并merge: enabled: true guavaCacheNumMaxSize: 1000 guavaCacheRefreshWriteTime: 10 # min guavaCacheRefreshThreadPoolSize: 10 aop: # 启动注解的方式,自动聚合  enabled: true

@Retention(RetentionPolicy.RUNTIME)@Target(value={ElementType.METHOD,ElementType.TYPE,ElementType.FIELD})public @interface MergeField {  /**   * 查询值   * @return   */  String key() default "";  /**   * 目标类   * @return   */  Class<? extends Object> feign() default Object.class;  /**   * 调用方法   * @return   */  String method() default "";  /**   * 是否以属性值合并作为查询值   * @return   */  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("test")public interface IService2 {  @RequestMapping("car/do")  public Map<String, String> writeLog(String test);  @RequestMapping("car/city")  public Map<String, String> getCitys(String ids);}

/** * @author ace * @create 2017/11/20. */@RestController@RequestMapping("car")public class Service2Rest {  private Logger logger = LoggerFactory.getLogger(Service2Rest.class);  @RequestMapping("do")  public Map<String,String> writeLog(String test){    logger.info("service 2 is writing log!");    Map<String,String> map = new HashMap<String, String>();    map.put("man","男");    map.put("woman","女");    return map;  }  @RequestMapping("city")  public Map<String,String> getCity(String ids){    logger.info("service 2 is writing log!"+ids);    Map<String,String> map = new HashMap<String, String>();    map.put("1","广州");    map.put("2","武汉");    return map;  }}

@Service@Slf4jpublic class UserBiz {  @Autowired  private MergeCore mergeCore;  /**   *   aop注解的聚合方式   *   其中聚合的方法返回值必须为list,   *   如果为复杂对象,则需要自定义自己的聚合解析器(实现接口IMergeResultParser)   */  @MergeResult(resultParser = TestMergeResultParser.class)  public List<User> getAopUser() {    ArrayList<User> users = new ArrayList<User>();    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<User> getUser(){    ArrayList<User> users = new ArrayList<User>();    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;    }  }}