PGET，一個簡單、易用的並行調用框架

時間 2020-03-16

標籤 pget 一個簡單易用並行調用框架简体版

原文原文鏈接

使用場景

當咱們的服務收到一個請求後，須要大量調用下游服務獲取業務數據，而後對數據進行轉換、計算後，響應給請求方。

若是咱們採用串行獲取下游數據，勢必會增長響應時長，下降接口的qps。若是是並行獲取下游數據，則是不錯的。

最直接想到的並行獲取方法，無非是將一個個獲取數據的方法封裝成一個個task，而後放到線程池裏執行。但這種沒通過設計的使用方式，易用性很低，可複用性也很低。

經本人在實際的業務系統中，屢次思考與設計。終於設計出當前這個框架。

特色：絕對的簡單、絕對的易用。

使用

在spring的xml中配置：

<!-- 初始化框架，並設置用於並行獲取業務數據的線程池配置  -->
    <bean class="com.dyz.pget.core.BizDataManager" init-method="init" destroy-method="destroy">
        <property name="corePoolSize" value="12"/>
        <property name="maximumPoolSize" value="200"/>
        <property name="keepAliveTime" value="0"/>
        <property name="queueSize" value="1000"/>
    </bean>

第一步：自定義BizData對象

自定義的BizData對象需實現IBizData接口。切要提供無參構造方法。java

public class UserInfoBizData implements IBizData{
    private Long userId;
    private String name;
    private Integer age;

    /**
     * 必須提供默認構造參數
     */
    public UserInfoBizData() {
    }

    public UserInfoBizData(Long userId, String name, Integer age) {
        this.userId = userId;
        this.name = name;
        this.age = age;
    }

    /**
     * 若是此數據對象獲取失敗時的默認兜底值。若是不支持兜底，則返回null便可。
     * @return
     */
    @Override
    public IBizData defaultBizData() {
        return null;
    }

    @Override
    public String format2String() {
        return new StringBuilder()
                .append("ID:").append(userId)
                .append(",名字:").append(name)
                .append(",年齡:").append(age)
                .toString();
    }
}
//篇幅問題，此處只貼了一個BizData的代碼

第二步：編寫對應的BizDataProvider

@BizDataProvider
public class TestBizDataProvider {

    /**
     * 異常要拋出，框架會捕獲
     * @param userId
     * @return
     * @throws Exception
     */
    public UserInfoBizData getUserInfoBizData(long userId)throws Exception{
        //調用遠程rpc或者其餘數據源獲得數據，並封裝到UserInfoBizData對象中
        return new UserInfoBizData(userId,"張三",20);
    }

    public ProductInfoBizData getProductInfoBizData(long shopId,long productId)throws Exception{
        //調用遠程rpc或者其餘數據源獲得數據，並封裝到ProductInfoBizData對象中
        return new ProductInfoBizData(productId,shopId,"啤酒");
    }
}

第三步：獲取數據

①Getter模式：

使用案例代碼：

@Test
    public void testGetter() throws BizDataFetchException {
        long userId = 1345L;
        long shopId = 11L;
        long productId = 11011L;
        //並行獲取用戶信息、商品信息、門店信息三個數據。超時時間是100毫秒
        List<IBizData> bizDataList = BizDataGetter.build()
                .get(UserInfoBizData.class,userId)
                .get(ProductInfoBizData.class,shopId,productId)
                .get(ShopInfoBizData.class,shopId)
                .doGet(100L);

        UserInfoBizData userInfoBizData = (UserInfoBizData)bizDataList.get(0);
        ProductInfoBizData productInfoBizData = (ProductInfoBizData)bizDataList.get(1);
        ShopInfoBizData shopInfoBizData = (ShopInfoBizData)bizDataList.get(2);

        System.out.println(userInfoBizData.format2String());
        System.out.println(productInfoBizData.format2String());
        System.out.println(shopInfoBizData.format2String());
    }

Injector模式：

定義一個數據包裹對象，存放所須要的數據對象

public class BizDataWrapper {
    private UserInfoBizData userInfoBizData;
    private ShopInfoBizData shopInfoBizData;
    private ProductInfoBizData productInfoBizData;


    public UserInfoBizData getUserInfoBizData() {
        return userInfoBizData;
    }

    public ShopInfoBizData getShopInfoBizData() {
        return shopInfoBizData;
    }

    public ProductInfoBizData getProductInfoBizData() {
        return productInfoBizData;
    }
}

使用案例代碼：git

@Test
   public void testGetter() throws BizDataFetchException {
        long userId = 1345L;
        long shopId = 11L;
        long productId = 11011L;
        BizDataWrapper bizDataWrapper = new BizDataWrapper();
        //並行獲取用戶信息、商品信息、門店信息三個數據。並注入到bizDataWrapper中，以方便使用。超時時間是100毫秒
        BizDataInjector.build(bizDataWrapper)
                .inject(UserInfoBizData.class,userId)
                .inject(ProductInfoBizData.class,shopId,productId)
                .inject(ShopInfoBizData.class,shopId)
                .doInject(100L);
        
        System.out.println(bizDataWrapper.getUserInfoBizData().format2String());
        System.out.println(bizDataWrapper.getProductInfoBizData().format2String());
        System.out.println(bizDataWrapper.getShopInfoBizData().format2String());
    }