Hadoop YARN架构设计要点（2）

look_w

YARN协议
YARN是一个分布式资源管理系统，它包含了分布的多个组件，我们可以通过这些组件之间设计的交互协议来说明，如图所示：



下面我们来详细看看各个协议实现的功能：

• ApplicationClientProtocol（Client -> RM）

协议方法	功能描述
getNewApplication	获取一个新的ApplicationId，例如返回的ApplicationId为application_1418024756741
submitApplication	提交一个Application到RM
forceKillApplication	终止一个已经提交的Application
getApplicationReport	获取一个Application的状态报告信息ApplicationReport，包括用户、队列、名称、AM所在节点、AM的RPC端口、跟踪URL、AM状态、诊断信息（如果出错的话）、启动时间、提交Application的Client（如果启用安全策略）
getClusterMetrics	获取YARN集群信息，如节点数量
getApplications	获取Application状态报告信息，和getApplicationReport类似，只不过增加了过滤器功能
getClusterNodes	获取集群内所有节点的状态报告信息
getQueueInfo	获取队列信息
getQueueUserAcls	获取当前用户的队列ACL信息
getDelegationToken	获取访问令牌信息，用于Container与RM端服务交互
renewDelegationToken	更新已存在的访问令牌信息
cancelDelegationToken	取消访问令牌
moveApplicationAcrossQueues	将Application移动到另一个队列中
getApplicationAttemptReport	获取Application Attempt状态报告信息ApplicationAttemptReport
getApplicationAttemptReport	获取Application Attempt状态报告信息，和getApplicationAttemptReport类似，只不过增加了过滤器功能
getContainerReport	根据ContainerId获取Container状态报告信息ContainerReport，例如Container名称为container_e17_1410901177871_0001_01_000005，各个段的含义：container_e<epoch>_<clusterTimestamp>_<appId>_<attemptId>_<containerId>
getContainers	根据ApplicationAttemptId获取一个Application Attempt所使用的Container的状态报告信息，例如Container名称为container_1410901177871_0001_01_000005
submitReservation	预定资源，以备在特殊情况下能够从集群获取到资源来运行程序，例如预留出资源供AM启动
updateReservation	更新预定资源
deleteReservation	删除预定
getNodeToLabels	获取节点对应的Label集合
getClusterNodeLabels	获取集群中所有节点的Label

• ResourceTracker（NM -> RM）

协议方法	功能描述
registerNodeManager	NM向RM注册
nodeHeartbeat	NM向RM发送心跳状态报告

• ApplicationMasterProtocol（AM -> RM）

协议方法	功能描述
registerApplicationMaster	AM向RM注册
finishApplicationMaster	AM通知RM已经完成（成功/失败）
allocate	AM向RM申请资源

• ContainerManagementProtocol（AM -> NM）

协议方法	功能描述
startContainers	AM向NM请求启动Container
stopContainers	AM向NM请求停止Container
getContainerStatuses	AM向NM请求查询当前Container的状态

• ResourceManagerAdministrationProtocol（RM Admin -> RM）

协议方法	功能描述
getGroupsForUser	获取用户所在用户组，该协议继承自GetUserMappingsProtocol
refreshQueues	刷新队列配置
refreshNodes	刷新节点配置
refreshSuperUserGroupsConfiguration	刷新超级用户组配置
refreshUserToGroupsMappings	刷新用户->用户组映射信息
refreshAdminAcls	刷新Admin的ACL信息
refreshServiceAcls	刷新服务级别信息（SLA）
updateNodeResource	更新在RM端维护的RMNode资源信息
addToClusterNodeLabels	向集群中节点添加Label
removeFromClusterNodeLabels	移除集群中节点Label
replaceLabelsOnNode	替换集群中节点Label

• HAServiceProtocol（Active RM HA Framework Standby RM）

协议方法	功能描述
monitorHealth	HA Framework监控服务的健康状态
transitionToActive	使RM转移到Active状态
transitionToStandby	使RM转移到Standby状态
getServiceStatus	获取服务状态信息