Giraph源碼分析（二）—啟動Master/Worker服務

作者 | 白松

注：本文為原創，引用轉載需與數瀾聯系。

1、org.apache.giraph.bsp.CentralizedService 接口

功能：Basic service interface shared by both CentralizedServiceMaster and CentralizedServiceWorker.

cdn.xitu.io/2019/7/19/16c08d3d927c9e2a?w=640&h=291&f=png&s=61631">

2、org.apache.giraph.bsp.CentralizedServiceMaster接口

功能：At most, there will be one active master at a time, but many threads can be trying to be the active master.

3、org.apache.giraph.bsp.CentralizedServiceWorker接口

功能：All workers should have access to this centralized service to execute the following methods.

4、org.apache.giraph.bsp.BspService抽象類

功能：Zookeeper-based implementation of CentralizedService.

5、org.apache.giraph.master.BspServiceMaster類

功能：ZooKeeper-based implementation of CentralizedServiceMaster.

6、org.apache.giraph.worker.BspServiceWorker類

功能：ZooKeeper-based implementation of CentralizedServiceWorker.

BspServiceWorker類有WorkerClient和WorkerServer實例，分別作為IPC通信的客戶端和服務器端，通過Netty來發送數據。WorkerClient實例實際為NettyWorkerClient對象，WorkerServert實例實際為NettyWorkerServer對象。

NettyWorkerClient implements WorkerClient接口，NettyWorkerServer implements WorkerServer接口。

NettyWorkerServer類的構造方法中創建一個NettyServer對象，用于底層的IPC的通信，還有一個ServerData對象，作為數據實體。ServerData中包含該Worker的partitionStore、edgeStore、incomingMessageStore、currentMessageStore、聚集值等。

NettyWorkerClient類的構造方法中創建一個NettyClient對象，用于底層的IPC的通信，作為客戶端。

7、org.apache.giraph.worker.InputSplitsCallable 抽象類，繼承 Callable接口。

功能：用于加載頂點或邊 輸入splits，每個線程都有一個WorkerClientRequestProcessor實例（實為 NettyWorkerClientRequestProcessor對象），負責向遠端的worker發送數據。

NettyWorkerClientRequestProcessor對象用于發送的WorkerClient對象就是BspServiceWorker里面的WorkerClient對象。

VertexInputSplitsCallable類中的readInputSplit()方法用來從split中讀取頂點的信息，然后調用NettyWorkerClientRequestProcessor對象的sendVertexRequest()方法把頂點發送到它所屬的Partition上。

8、org.apache.giraph.graph.ComputeCallable 類，繼承Callable接口。

在該對象中完成“計算-通信-同步”的過程。每個線程都有一個WorkerClientRequestProcessor實例（實為 NettyWorkerClientRequestProcessor對象），負責向遠端的worker發送數據。