HBase-IPC基本流程

2017-03-16 14:00:01   0  举报





仅支持查看

HBase-IPC基本流程是：客户端通过RPC协议与HMaster通信，获取RegionServer的地址信息；然后客户端通过RPC协议与RegionServer通信，执行数据的读写操作。其中，RPC协议是基于TCP/IP协议实现的，客户端和服务器之间通过Socket进行通信。在HBase中，ZooKeeper用于维护集群中各个节点的状态信息，包括HMaster和RegionServer的地址信息、Region的分布情况等。当HMaster发生故障时，ZooKeeper会选举出新的HMaster来接管整个集群的管理。希望这个回答能够帮到您！如果您有其他问题，请随时问我。

作者其他创作

大纲/内容

read

...

CallExecutor

handlers

process

Get Queue

......

call对象

1. RpcServer监听在特定端口，等待客户端连接；连接进来之后扔进Request队列2. RpcServer开启了多个Reader线程，负责从Request队列fetch任务，进行处理。主要解析请求头以及body体，封装成call对象（最核心的元素包括service、method、param等）3. RPCScheduler负责将RPC请求根据一定规则扔进不同的RPC队列，每套规则对应一种CallExecutor。比如RWQueueRPCExecutor会将RPC请求按照请求类型（Get、Write或Scan）分发到对应的RPC队列4. RpcServer会启动一定handler线程，负责从RPC队列中fetch Call对象进行处理，并将结果返回给客户端

Listener

Request

RPCScheduler

Client

HRegionServer

Reader2

ReaderN

Scan Queue

Write Queue

Reader1

Response