日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
Dubbo同步調(diào)用太慢，也許你可以試試異步處理

 本文轉(zhuǎn)載自微信公眾號(hào)「小黑十一點(diǎn)半」，作者樓下小黑哥 。轉(zhuǎn)載本文請(qǐng)聯(lián)系小黑十一點(diǎn)半公眾號(hào)。

創(chuàng)新互聯(lián)專(zhuān)注為客戶(hù)提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于做網(wǎng)站、網(wǎng)站建設(shè)、巨鹿網(wǎng)絡(luò)推廣、重慶小程序開(kāi)發(fā)公司、巨鹿網(wǎng)絡(luò)營(yíng)銷(xiāo)、巨鹿企業(yè)策劃、巨鹿品牌公關(guān)、搜索引擎seo、人物專(zhuān)訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等，從售前售中售后，我們都將竭誠(chéng)為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供巨鹿建站搭建服務(wù)，24小時(shí)服務(wù)熱線：18982081108，官方網(wǎng)址：www.cdcxhl.com

Hello，大家好，我是樓下小黑哥~

今天原本是想解析一道朋友在大廠面試的時(shí)候碰到問(wèn)題：

「Dubbo 異步調(diào)用的底層原理是什么?」

之前其實(shí)聽(tīng)說(shuō)過(guò) Dubbo 異步調(diào)用，但是沒(méi)有在實(shí)際業(yè)務(wù)中使用過(guò)，所以使用方法比較陌生。

再加上 Dubbo 2.7 版本對(duì)于異步調(diào)用進(jìn)行了一些修改，網(wǎng)上找到的一些資料也比較老，所以今天先寫(xiě)一篇介紹一下 Dubbo 2.7 版本之后的異步調(diào)用使用方式。

后續(xù)我們從源碼出發(fā)再介紹一下 Dubbo 底層原理。

異步調(diào)用

我們平常大部分都是使用 Dubbo 的同步調(diào)用，即調(diào)用 Dubbo 請(qǐng)求之后，調(diào)用線程將會(huì)阻塞，直到服務(wù)提供者返回結(jié)果。

那相反，Dubbo 異步調(diào)用就不會(huì)阻塞調(diào)用線程，那么在服務(wù)提供者返回結(jié)果這段時(shí)間，我們就可以執(zhí)行其他業(yè)務(wù)邏輯。

下面我們從代碼示例，來(lái)學(xué)習(xí)一下如何使用 Dubbo 異步調(diào)用。

PS：下面例子 Dubbo 版本為 2.7。

第一種方式

Dubbo 異步調(diào)用是針對(duì)方法級(jí)別，所以我們需要對(duì)引用接口中指定方法做一些專(zhuān)門(mén)的配置。

異步調(diào)用配置其實(shí)與普通 xml服務(wù)引用配置類(lèi)似，只不過(guò)我們還需要增加一個(gè) dubbo:method將指定方法配置成異步調(diào)用。

示例 xml 配置如下：

 
 
 
    
  
  
  
  1.  
    2. 
  
  
  
  2.        
    3. 
  
  
  
  3.  
    4.

服務(wù)引用配置完成之后，此時(shí)如果直接調(diào)用這個(gè)方法，將會(huì)立即返回 null，內(nèi)部將會(huì)異步執(zhí)行服務(wù)端調(diào)用邏輯。

 
 
 
    
  
  
  
  1. // 此調(diào)用會(huì)立即返回null 
    2. 
  
  
  
  2. String world = asyncService.sayHello("world"); 
    3.

// 畫(huà)個(gè)時(shí)序圖

如果我們需要獲取服務(wù)提供者返回的結(jié)果，那么此時(shí)需要借助 RpcContext。這個(gè)類(lèi)是 Dubbo 中專(zhuān)門(mén)用于保存 「RPC」 調(diào)用過(guò)程中一些關(guān)鍵信息。

因此我們可以借助這個(gè)類(lèi)可以獲取到 「RPC」 很多信息，這次我們主要使用下面的方法獲取 CompletableFuture。

 
 
 
    
  
  
  
  1. RpcContext.getContext().getCompletableFuture() 
    2.

CompletableFuture 是 JDK1.8 之后提供的異步任務(wù)增強(qiáng)類(lèi)，我們可以直接調(diào)用其 get 方法直接獲取返回結(jié)果。

 
 
 
    
  
  
  
  1. // 此調(diào)用會(huì)立即返回null 
    2. 
  
  
  
  2. String world = asyncService.sayHello("world"); 
    3. 
  
  
  
  3. // 拿到調(diào)用的Future引用，當(dāng)結(jié)果返回后，會(huì)被通知和設(shè)置到此Future 
    4. 
  
  
  
  4. CompletableFuture helloFuture = RpcContext.getContext().getCompletableFuture(); 
    5. 
  
  
  
  5. helloFuture.get(); 
    6.

這里需要注意一點(diǎn)。調(diào)用get 方法之后，線程就會(huì)被阻塞，「直到服務(wù)端返回結(jié)果或者服務(wù)調(diào)用超時(shí)」。

另外如果不想線程被阻塞，我們可以使用 whenComplete，添加回調(diào)方法，然后異步處理返回結(jié)果。

 
 
 
    
  
  
  
  1. // 此調(diào)用會(huì)立即返回null 
    2. 
  
  
  
  2. String world = asyncService.sayHello("world"); 
    3. 
  
  
  
  3. // 拿到調(diào)用的Future引用，當(dāng)結(jié)果返回后，會(huì)被通知和設(shè)置到此Future 
    4. 
  
  
  
  4. CompletableFuture helloFuture = RpcContext.getContext().getCompletableFuture(); 
    5. 
  
  
  
  5. // 為Future添加回調(diào) 
    6. 
  
  
  
  6. helloFuture.whenComplete((retValue, exception) -> { 
    7. 
  
  
  
  7.     if (exception == null) { 
    8. 
  
  
  
  8.         System.out.println("return value: " + retValue); 
    9. 
  
  
  
  9.     } else { 
    10. 
  
  
  
  10.         exception.printStackTrace(); 
    11. 
  
  
  
  11.     } 
    12. 
  
  
  
  12. }); 
    13.

從上面的例子我們可以看到， Dubbo 消費(fèi)端異步調(diào)用借助了JDK 提供的 CompletableFuture，這個(gè)類(lèi)非常強(qiáng)大，提供的方法也非常多。

小黑哥之前寫(xiě)過(guò)一篇文章，比較完整的介紹了 CompletableFuture的用法，感興趣可以深入學(xué)習(xí)一下。

// TODO 文章

上面的方式我們使用 xml引用服務(wù)，不過(guò)現(xiàn)在很多同學(xué)應(yīng)該直接使用 Dubbo 注解引用服務(wù)。

如果想直接使用注解方式，其實(shí)也非常簡(jiǎn)單，只要使用 @Method注解即可。

配置方法如下：

 
 
 
    
  
  
  
  1. @Reference(interfaceClass = AsyncService.class, 
    2. 
  
  
  
  2.         timeout = 1000, 
    3. 
  
  
  
  3.         methods = {@Method(name = "sayHello", async = true)}) 
    4. 
  
  
  
  4. private AsyncService asyncService; 
    5.

第二種方式

第一種方式我們還需要額外修改 Dubbo 相關(guān)配置，相對(duì)來(lái)說(shuō)比較繁瑣。那第二種方式就不需要做額外配置了，它只要使用 RpcContext#asyncCall就可以直接完成異步調(diào)用。

示例代碼如下：

 
 
 
    
  
  
  
  1. // 使用  asyncCall 異步調(diào)用 
    2. 
  
  
  
  2. CompletableFuture f = RpcContext.getContext().asyncCall(() -> asyncService.sayHello("async call request")); 
    3. 
  
  
  
  3. // get 將會(huì)一直阻塞到服務(wù)端返回，或者直到服務(wù)調(diào)用超時(shí) 
    4. 
  
  
  
  4. System.out.println("async call returned: " + f.get()); 
    5. 
  
  
  
  5.  
    6. 
  
  
  
  6. // 異步調(diào)用，不關(guān)心服務(wù)端返回 
    7. 
  
  
  
  7. RpcContext.getContext().asyncCall(() -> { 
    8. 
  
  
  
  8.     asyncService.sayHello("one way call request1"); 
    9. 
  
  
  
  9. }); 
    10.

這種方式返回依然是 CompletableFuture對(duì)象，操作方式就如同第一種方式。

第三種方式

終于到了最后一種方式了，這種方式與上面兩種方式都不太一樣，其完全不需要借助RpcContext就可以完成，開(kāi)發(fā)流程與普通 Dubbo 服務(wù)一樣。

首先需要服務(wù)提供者事先定義 CompletableFuture 簽名的服務(wù)：

 
 
 
    
  
  
  
  1. public interface AsyncService { 
    2. 
  
  
  
  2.     CompletableFuture sayHello(String name); 
    3. 
  
  
  
  3. } 
    4.

「注意接口的返回類(lèi)型是 CompletableFuture ?！?/p>

服務(wù)端接口實(shí)現(xiàn)邏輯如下：

 
 
 
    
  
  
  
  1. public class AsyncServiceImpl implements AsyncService { 
    2. 
  
  
  
  2.     private static Logger logger = LoggerFactory.getLogger(AsyncServiceImpl.class); 
    3. 
  
  
  
  3.  
    4. 
  
  
  
  4.     @Override 
    5. 
  
  
  
  5.     public CompletableFuture sayHello(String name) { 
    6. 
  
  
  
  6.         return CompletableFuture.supplyAsync(() -> { 
    7. 
  
  
  
  7.             try { 
    8. 
  
  
  
  8.                 Thread.sleep(10000); 
    9. 
  
  
  
  9.             } catch (InterruptedException e) { 
    10. 
  
  
  
  10.                 e.printStackTrace(); 
    11. 
  
  
  
  11.             } 
    12. 
  
  
  
  12.             return "async response from provider."; 
    13. 
  
  
  
  13.         }); 
    14. 
  
  
  
  14.     } 
    15. 
  
  
  
  15.  
    16. 
  
  
  
  16. } 
    17.

服務(wù)端需要使用 CompletableFuture 完成業(yè)務(wù)邏輯。

消費(fèi)端這時(shí)就不需要借助了 RpcContext，可以直接調(diào)用服務(wù)提供者。

 
 
 
    
  
  
  
  1. // 調(diào)用直接返回CompletableFuture 
    2. 
  
  
  
  2. CompletableFuture future = asyncService.sayHello("async call request"); 
    3. 
  
  
  
  3. // 增加回調(diào) 
    4. 
  
  
  
  4. future.whenComplete((v, t) -> { 
    5. 
  
  
  
  5.     if (t != null) { 
    6. 
  
  
  
  6.         t.printStackTrace(); 
    7. 
  
  
  
  7.     } else { 
    8. 
  
  
  
  8.         System.out.println("Response: " + v); 
    9. 
  
  
  
  9.     } 
    10. 
  
  
  
  10. }); 
    11. 
  
  
  
  11. // 早于結(jié)果輸出 
    12. 
  
  
  
  12. System.out.println("Executed before response return.") 
    13.

這種方式對(duì)于調(diào)用者來(lái)就比較方便，無(wú)需引入其他對(duì)象，可以像使用同步的方式使用異步調(diào)用。

其他參數(shù)

上面介紹了三種的 Dubbo 異步調(diào)用的使用方式，下面主要介紹一下異步調(diào)用涉及其他參數(shù)。

sent

我們可以在 dubbo:method 設(shè)置：

 
 
 
    
  
  
  
  1.  
    2.

也可以在注解中設(shè)置：

 
 
 
    
  
  
  
  1. @Reference(interfaceClass = XXX.class, 
    2. 
  
  
  
  2.         version = AnnotationConstants.VERSION, 
    3. 
  
  
  
  3.         timeout = 1000, 
    4. 
  
  
  
  4.         methods = {@Method(name = "greeting", timeout = 3000, retries = 1, sent = false)}) 
    5.

默認(rèn)情況下sent=false， Dubbo 將會(huì)把消息放入 IO 隊(duì)列，然后立刻返回。那這時(shí)如果宕機(jī)，消息就有可能沒(méi)有發(fā)送給服務(wù)端。

那如果我們將其設(shè)置成 sent=true,Dubbo 將會(huì)等待消息發(fā)送發(fā)出才會(huì)返回，否則將會(huì)拋出異常。

return

Dubbo 異步調(diào)用默認(rèn)將會(huì)創(chuàng)建 Future 對(duì)象，然后設(shè)置到 RpcContext 中。那我們?nèi)绻魂P(guān)心返回值，只想單純的異步執(zhí)行，那我們可以配置 return="false"，以此減少 Future 對(duì)象的創(chuàng)建和管理成本。

 
 
 
    
  
  
  
  1.  
    2.

總結(jié)

今天的文章介紹三種 Dubbo 異步調(diào)用的使用方式：

第一種需要修改 Dubbo xml 配置文件或者注解，然后再通過(guò) RpcContext獲取異步 Future對(duì)象。

第二種無(wú)需修改任何配置文件，我們可以直接通過(guò)RpcContext#asyncCall異步完成方法調(diào)用，然后獲取異步 Future對(duì)象。

第三種無(wú)需修改任何配置文件，也無(wú)需使用 RpcContext，我們需要定義一個(gè)返回值是 CompletableFuture方法，然后服務(wù)端與消費(fèi)端正常開(kāi)發(fā)即可。

這三種方式，第三種對(duì)于消費(fèi)者使用起來(lái)最方便，不過(guò)個(gè)人覺(jué)得服務(wù)提供者開(kāi)發(fā)起來(lái)比較麻煩。

第二種相當(dāng)于第一種，無(wú)需修改配置文件，個(gè)人覺(jué)得還是比較方便的，所以小黑哥還是傾向于使用第二種方式。

好了，今天的文章就到這里了，下次我們?cè)敿?xì)聊聊 Dubbo 異步調(diào)用的原理。


分享名稱(chēng)：Dubbo同步調(diào)用太慢，也許你可以試試異步處理
轉(zhuǎn)載源于：http://www.dlmjj.cn/article/ccssdce.html