關于Endpoint如何處理消息的,我一直找不到初始調用點
請問這個圖中消息接受這個點在哪裡?我想從這裡看,但是找不到最初的起點
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指令做相關的額外啟動工作,三端啟動後