天天看點

spark學習-75-源代碼:Endpoint模型介紹(6)-Endpoint的消息的接收(2)

spark學習-75-源代碼:Endpoint模型介紹(6)-Endpoint的消息的接收(2)

關于Endpoint如何處理消息的,我一直找不到初始調用點

spark學習-75-源代碼:Endpoint模型介紹(6)-Endpoint的消息的接收(2)

請問這個圖中消息接受這個點在哪裡?我想從這裡看,但是找不到最初的起點

1。消息的産生點

沒找到,消息是怎麼産生的還不清楚,知道的底下評論一下,謝謝

2。消息的分發

Endpoint Inbox處理流程

Spark在Endpoint的設計上核心設計即為Inbox與Outbox,其中Inbox核心要點為

内部的處理流程拆分為多個消息指令(InboxMessage)存放入Inbox

當Dispatcher啟動最後,會啟動一個名為【dispatcher-event-loop】的線程掃描Inbox待處理InboxMessage,并調用Endpoint根據InboxMessage類型做相應處理

當Dispatcher啟動最後,預設會向Inbox存入OnStart類型的InboxMessage,Endpoint在根據OnStart指令做相關的額外啟動工作,三端啟動後

繼續閱讀