http://note.youdao.com/share/?id=d2163a7ba8ec1ec58e64683a961c5121&type=note

RPC是OB一個比較重要的各個元件間進行通訊的實現機制。最近在看clog的程式碼，就順著ObCLogRpc這個類，簡單總結下OB進行RPC的幾種寫法，主要偏重於寫程式碼和理解已有程式碼，不涉及到底層的RPC實現機制。 曲山的OB程式碼導讀 5.3.2節客戶端部分介紹了ObRpcStub，建議先行閱讀。 後邊是當前OB實現RPC的幾種典型寫法： 客戶端 ObCLogRpc、ObUpsRpcStub和ObRootRpcStub都繼承自common::ObCommonRpcStub，common::ObCommonRpcStub提供一些基礎的RPC實現，其繼承自ObGeneralRpcStub，ObGeneralRpcStub繼承自ObRpcStub，後者封裝了RPC的底層實現，包括ObClientManager的一個指標型別成員rpc_frame_。 客戶端實現rpc的幾種典型寫法如下： 1）rpc_frame_ -> send_request 典型實現參考ObCommonRpcStub :: send_log，是一個同步呼叫方式。 2）rpc_frame_ -> post_request 典型實現參考ObCLogRpc::post_log，此實現是一個非同步呼叫方式，需要在post_request中指明接收到響應後回撥使用的handler； 3）呼叫send_*_return_*函式，是個同步呼叫方式，具體可參見OB程式碼導讀相關章節，舉例如下：

1
 
 int ObCommonRpcStub :: renew_lease(const common::ObServer& master, const common::ObServer& slave_addr, const in t64_t timeout_us)
2 {
3 　　return send_1_return_0(master, timeout_us, OB_RENEW_LEASE_REQUEST, DEFAULT_VERSION, slave_addr);
4 }

4）呼叫send_param_*/deserialize_result_*兩個配對的巨集，具體實現可參考ObGeneralRpcStub::register_server，也是一個同步呼叫方式。 其實後兩者就是呼叫1）來完成的，這些巨集會進行展開，直接傳遞基礎資料型別或是呼叫輸出輸出引數的serialize/deserialize方法進行序列化、反序列化後傳遞。 服務端 服務端的呼叫方式都是統一的。每個RPC呼叫都對應一個packet_code，在server的init_func_array函式中，使用巨集REGISTER_HANDLE_FUNC註冊特定型別的包（也即特定型別的RPC介面）的處理函式，如上文列出的ObCommonRpcStub :: renew_lease巨集，其註冊方式即為在ObRootWorker類的init_func_array函式中呼叫： REGISTER_HANDLE_FUNC(OB_RENEW_LEASE_REQUEST, &ObRootWorker::rt_renew_lease); 然後在server的handler_packet中寫上此型別包是由IO執行緒直接處理還是交給特定的worker執行緒處理。 所有註冊的處理函式介面都是一致的，接受的都是ObRequestContext& context型別的引數，表示網路包。 收到包後如何處理可以參見ObRootWorker::rt_renew_lease，無非就是從網路包中反序列化輸入引數，根據引數呼叫業務邏輯進行處理，然後將結果打包使用send_response方法返回給客戶端。