二話不說，先上圖

dubbo底層使用socket建立長連線，傳送、接收資料的形式進行通訊，結合使用apache mina框架，使用IoSession.write()方法，這個方法是一個非同步的呼叫。
即對於當前執行緒來說，只需要將請求傳送出去。就可以繼續向後執行了。

基本原理

1、客戶端一個執行緒呼叫遠端介面，生成一個唯一的ID。dubbo使用AtomicLong從0開始計數。
2、將打包的方法呼叫資訊（呼叫介面的介面名稱、方法名稱、引數值列表）以及處理結構的回撥物件callback，全部封裝在一起，組成一個物件Object
3、向專門存放呼叫資訊的全域性ConCurrentHashMap中put(ID,Obejct)
4、將ID和打包的方法呼叫資訊封裝成一物件connRequest，使用IoSession.write(connRequest)非同步傳送出去
5、**當前執行緒再使用callback的get()方法試圖獲取遠端返回的結果。在get()內部使用synchronized獲取回撥物件的callback鎖，再檢測是否已經獲得結果。如果沒有，然後呼叫callback的wait()方法。
釋放callback上的鎖。讓當前執行緒處於等待狀態。**
6、服務端接收到請求並處理後。將結果傳送給客戶端。客戶端上socket連線上專門監聽訊息的執行緒監聽到訊息。分析結果，取得ID,用ConCurrentHashMap.get(ID)。從而找到callback。將呼叫結果設定到callback物件中
7、監聽執行緒接著使用synchronized獲取回撥物件的鎖（callback的鎖已經被釋放掉了），再notifyAll(),喚醒前面處於等待狀態的執行緒繼續執行。

Q:當前執行緒如何”暫停”執行，等待結果回來後，再向後執行？

A:先生成一個物件Object，在全域性的ConCurrentHashMap中存放起來，再用synchronized鎖住這個物件，再呼叫wait()方法讓當前執行緒處於等待狀態。
另一訊息監聽執行緒等到服務端結果到來之後，再map.get(ID)找到Object.再用synchronized獲取Object鎖，再呼叫notifyAll()喚醒前面處於等待狀態的執行緒。