OceanBase處理網路包的邏輯還是蠻繞的，這裡以UPS為例，作為給自己的備忘。

UPS程式碼的main.cpp中呼叫ObUpdateServerMain的start啟動server。start函式會呼叫ObUpdateServerMain的do_work函式，此函式呼叫ObUpdateServer類的start啟動UPS。

ObUpdateServer繼承自如下幾個類：

1）common::ObBaseServer，基礎的server類，要求派生類實現handlePacket和handleBatchPacket方法（後一個UPS不會使用），這兩個是純虛擬函式，同時有個虛擬函式start_service，派生類可以實現此方法用於初始化時做些server相關的邏輯；

2）ObPacketQueueHandler，  要求派生類實現handlePacketQueue介面；

3）common::IBatchPacketQueueHandler，要求派生類實現handleBatchPacketQueue介面；

ObUpdateServer類的start函式實際上呼叫的ObBaseServer的start函式，此函式做如下幾件事：

1）初始化libeasy相關的一系列資料結構, 在特定的網路埠上監聽等；

2）呼叫initialize函式（需要派生類實現）；

3）呼叫start_service函式（派生類可自己實現）；

ObUpdateServer的initialize函式，做一系列啟動UPS內部所需的引數的初始化，除了必要的引數外，有幾個需要特別注意下：

1）server_handler_，此變數的型別是easy_io_handler_pt，此處註冊一系列回撥，包括收包時的編解碼（server_handler_.encode/server_handler_.decode），收包時的處理邏輯（server_handler_.process），斷開連線時的處理等（server_handler_.on_disconnect）等；編解碼相關等都是使用的所有OB server共用的ObTbnetCallback類的方法，版本升級時包的格式變化只需要統一改此common類的方法即可；包的處理邏輯呼叫的UPS自己的ObUpdateCallback::process方法；

2）client_manager_的初始化，後續server發包都需要用到client_manager_;

3）rpc相關的初始化；

4）一系列worker執行緒的初始化（如read_thread_queue_/write_thread_queue_/lease_thread_queue_等，具體看程式碼，指定不同型別執行緒的執行緒數，將this傳給各個執行緒用作handler回撥等）；

ObUpdateServer的start_service函式，呼叫start_threads（此函式呼叫上述一系列worker執行緒的start方法，等候收到任務處理），start_timer_schedule設定一系列ObTimer設定一些定時器相關的處理邏輯。

如上和網路包處理相關的一系列函式說清楚了，然後具體說說網路包收到後是怎麼處理的。

libeasy收到包會呼叫註冊的回撥方法ObUpdateCallback::process，此函式會呼叫ObUpdateServer的handlePacket方法，此函式由各server自己實現，如UPS，會根據packet_code不同，或者進行本地處理（因為libeasy有多個IO poll thread，所以本地可以處理一些耗時少的操作包），或是扔給不同的worker類處理。這裡分別舉個例子：

1）packet_code為OB_SET_OBI_ROLE型別的包，呼叫read_thread_queue_的push方法，交由read_thread_queue_執行緒處理；

2）packet_code為OB_UPS_CLEAR_FATAL_STATUS型別的包，呼叫lease_thread_queue_的push方法，交由lease_thread_queue_執行緒處理；

3）OB_WRITE/OB_MS_MUTATE/OB_FAKE_WRITE_FOR_KEEP_ALIVE/OB_UPS_PHY_PLAN_EXECUTE/OB_START_TRANSACTION/OB_END_TRANSACTION/OB_WRITE_DUMMY_LOG型別的包，直接在IO執行緒中呼叫trans_executor_的handle_packet函式處理；這裡注意下，trans_executor_的handle_packet也會進一步判斷包的型別，確定是直接在此函式中處理（transe_executor_類對不同型別的包實現了一系列的handle函式），還是通過呼叫push_task_交由trans_executor自己的一系列worker執行緒處理。

read_thread_queue_等worker執行緒是common::ObPacketQueueThread型別的（或者其他類似型別）例項，此類型別都是tbsys::CDefaultRunnable的派生類，其內部含有一個阻塞佇列等訊息到來，同時有一個用於回撥的ObPacketQueueHandler型別的handler（注意ObUpdateServer就繼承自ObPacketQueueHandler，實際上此處註冊的handler就是ObUpdateServer類的物件）。此類worker執行緒start後真正呼叫的是ObPacketQueueThread::run函式，此函式即從內部佇列中取訊息，然後呼叫ObUpdateServer的handlePacketQueue函式，handlePacketQueue函式再根據包的型別呼叫ObUpdateServer類實現的各類方法對包進行處理。此處由於是worker執行緒，所有包都是執行緒本地處理的。

至此，整個處理包的邏輯應該被串起來了。其實主要是初看程式碼時handlePacket/handlePacketQueue/handleBatchPacket/handleBatchPacketQueue各由誰呼叫，以及在哪個執行緒空間中被呼叫不太好理解。