詳解Spring Cloud 跨服務(wù)數(shù)據(jù)聚合框架

更新時間：2018年03月05日 11:03:57 作者：老A / AG-Merge

這篇文章主要介紹了詳解Spring Cloud 跨服務(wù)數(shù)據(jù)聚合框架，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

AG-Merge

Spring Cloud 跨服務(wù)數(shù)據(jù)聚合框架

解決問題

解決Spring Cloud服務(wù)拆分后分頁數(shù)據(jù)的屬性或單個對象的屬性拆分之痛, 支持對靜態(tài)數(shù)據(jù)屬性(數(shù)據(jù)字典)、動態(tài)主鍵數(shù)據(jù)進行自動注入和轉(zhuǎn)化, 其中聚合的靜態(tài)數(shù)據(jù)會進行一級混存 (guava).

舉個栗子：

兩個服務(wù)，A服務(wù)的某張表用到了B服務(wù)的某張表的值，我們在對A服務(wù)那張表查詢的時候，把B服務(wù)某張表的值聚合在A服務(wù)的那次查詢過程中

示例

具體示例代碼可以看 ace-merge-demo 模塊

|------- ace-eureka 注冊中心
|------- ace-data-merge-demo 查詢數(shù)據(jù),此處聚合示例
|------- ace-data-provider 數(shù)據(jù)提供者

Maven添加依賴

<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

application.yml配置

# 跨服務(wù)數(shù)據(jù)合并
merge:
 enabled: true
 guavaCacheNumMaxSize: 1000
 guavaCacheRefreshWriteTime: 10 # min
 guavaCacheRefreshThreadPoolSize: 10
 aop: # 啟動注解的方式,自動聚合
  enabled: true

代碼示例( @MergeField 標志對象的數(shù)據(jù)需要聚合)

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

  /**
   * 調(diào)用方法
   * @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;
  }
}

聚合數(shù)據(jù)來源方法(示例為通過FeignClient,也可以是本地的spring bean對象)

特別要求:入?yún)⒈仨殲橐粋€String,返回值必須為Map<String,String>. 其中返回值的構(gòu)成,就是聚合對象屬性的key和對應(yīng)的value.

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

對應(yīng)的遠程服務(wù)接口

/**
 * @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;
  }
}

聚合對象的Biz類(下面的方式是采用aop掃描注解的方式)

@Service
@Slf4j
public class UserBiz {
  @Autowired
  private MergeCore mergeCore;
  /**
   *   aop注解的聚合方式
   *   其中聚合的方法返回值必須為list,
   *   如果為復(fù)雜對象,則需要自定義自己的聚合解析器(實現(xiàn)接口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("數(shù)據(jù)聚合失敗",e);
    }finally {
      return users;
    }
  }
}

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: