這一組方法接受一個(gè)Function作為參數(shù)，這個(gè)Function的輸入是當(dāng)前的CompletableFuture的計(jì)算值，返回結(jié)果將是一個(gè)新的CompletableFuture，這個(gè)新的CompletableFuture會(huì)組合原來(lái)的CompletableFuture和函數(shù)返回的CompletableFuture。

現(xiàn)在就能看出CompletableFuture的強(qiáng)大了，它解決了自定義ResponseFuture的許多問(wèn)題，該類(lèi)有幾十個(gè)方法，感興趣的可以去一一嘗試。

可以看到以前的版本只能在RpcContext中進(jìn)行獲取。而經(jīng)過(guò)改良后，首先RpcContext一樣能過(guò)獲取，其次在過(guò)濾器鏈返回的Result中也能獲取，可以從最新的代碼中看到，原先的RpcResult類(lèi)已經(jīng)被去除，而在AsyncRpcResult也繼承了CompletableFuture類(lèi)，也就是說(shuō)有AsyncRpcResult的地方，就有CompletableFuture。并且在后續(xù)的dubbo3.0中，AsyncRpcResult將會(huì)內(nèi)置CompletableFuture類(lèi)型的變量，CompletableFuture的獲取方式也會(huì)大大增加。

接下來(lái)我就來(lái)講解一下AsyncRpcResult類(lèi)。

/**
 * 當(dāng)相同的線(xiàn)程用于執(zhí)行另一個(gè)RPC調(diào)用時(shí)，并且回調(diào)發(fā)生時(shí)，原來(lái)的RpcContext可能已經(jīng)被更改。
 * 所以我們應(yīng)該保留當(dāng)前RpcContext實(shí)例的引用，并在執(zhí)行回調(diào)之前恢復(fù)它。
 * 存儲(chǔ)當(dāng)前的RpcContext
 */
private RpcContext storedContext;
/**
 * 存儲(chǔ)當(dāng)前的ServerContext
 */
private RpcContext storedServerContext;

/**
 * 會(huì)話(huà)域
 */
private Invocation invocation;

public AsyncRpcResult(Invocation invocation) {
    // 設(shè)置會(huì)話(huà)域
    this.invocation = invocation;
    // 獲得當(dāng)前線(xiàn)程內(nèi)代表消費(fèi)者端的Context
    this.storedContext = RpcContext.getContext();
    // 獲得當(dāng)前線(xiàn)程內(nèi)代表服務(wù)端的Context
    this.storedServerContext = RpcContext.getServerContext();
}

/**
 * 轉(zhuǎn)換成新的AsyncRpcResult
 * @param asyncRpcResult
 */
public AsyncRpcResult(AsyncRpcResult asyncRpcResult) {
    this.invocation = asyncRpcResult.getInvocation();
    this.storedContext = asyncRpcResult.getStoredContext();
    this.storedServerContext = asyncRpcResult.getStoredServerContext();
}

上面的是AsyncRpcResult核心的變量以及構(gòu)造函數(shù)，storedContext和storedServerContext存儲(chǔ)了相關(guān)的RpcContext實(shí)例的引用，為的就是防止在回調(diào)的時(shí)候由于相同的線(xiàn)程用于執(zhí)行另一個(gè)RPC調(diào)用導(dǎo)致原來(lái)的RpcContext可能已經(jīng)被更改。所以存儲(chǔ)下來(lái)后，我們需要在執(zhí)行回調(diào)之前恢復(fù)它。具體的可以看下面的thenApplyWithContext方法。

@Override
public Object getValue() {
    // 獲得計(jì)算的結(jié)果
    return getAppResponse().getValue();
}

@Override
public void setValue(Object value) {
    // 創(chuàng)建一個(gè)AppResponse實(shí)例
    AppResponse appResponse = new AppResponse();
    // 把結(jié)果放入AppResponse
    appResponse.setValue(value);
    // 標(biāo)志該future完成，并且把攜帶結(jié)果的appResponse設(shè)置為該future的結(jié)果
    this.complete(appResponse);
}

@Override
public Throwable getException() {
    // 獲得拋出的異常信息
    return getAppResponse().getException();
}

@Override
public void setException(Throwable t) {
    // 創(chuàng)建一個(gè)AppResponse實(shí)例
    AppResponse appResponse = new AppResponse();
    // 把異常放入appResponse
    appResponse.setException(t);
    // 標(biāo)志該future完成，并且把攜帶異常的appResponse設(shè)置為該future的結(jié)果
    this.complete(appResponse);
}

@Override
public boolean hasException() {
    // 設(shè)置是否有拋出異常
    return getAppResponse().hasException();
}

public Result getAppResponse() {
    // 如果該結(jié)果計(jì)算完成，則直接調(diào)用get方法獲得結(jié)果
    try {
        if (this.isDone()) {
            return this.get();
        }
    } catch (Exception e) {
        // This should never happen;
        logger.error("Got exception when trying to fetch the underlying result from AsyncRpcResult.", e);
    }
    // 創(chuàng)建AppResponse
    return new AppResponse();
}

這些實(shí)現(xiàn)了Result接口的方法，可以發(fā)現(xiàn)其中都是調(diào)用了AppResponse的方法，AppResponse跟AsyncRpcResult一樣也繼承了AbstractResult，不過(guò)它是作為回調(diào)的數(shù)據(jù)結(jié)構(gòu)。AppResponse我會(huì)在異步化過(guò)濾器鏈回調(diào)中講述。

@Override
public Object recreate() throws Throwable {
    // 強(qiáng)制類(lèi)型轉(zhuǎn)化
    RpcInvocation rpcInvocation = (RpcInvocation) invocation;
    // 如果返回的是future類(lèi)型
    if (InvokeMode.FUTURE == rpcInvocation.getInvokeMode()) {
        // 創(chuàng)建AppResponse實(shí)例
        AppResponse appResponse = new AppResponse();
        // 創(chuàng)建future
        CompletableFuture