–hbase 刪除表

HBaseAdmin admin = new HBaseAdmin(conf);

可以檢視原始碼，其實低層也是呼叫建立 HConnectionImplementation 物件進行連線管理的

admin.disableTable(tableName);

然後失效一個表，
裡面類似於delete操作一下，建立一個回撥臨時物件

DisableTableResponse response = executeCallable(
  new MasterCallable<DisableTableResponse>(getConnection()) {
    @Override
    public DisableTableResponse call(int callTimeout) throws ServiceException {
      PayloadCarryingRpcController controller = rpcControllerFactory.newController();
      controller.setCallTimeout(callTimeout);
      controller.setPriority(tableName);

      LOG.info("Started disable of " + tableName);
      DisableTableRequest req =
          RequestConverter.buildDisableTableRequest(
            tableName, ng.getNonceGroup(), ng.newNonce());
      return master.disableTable(controller, req);
    }
  });
 

在MasterCallable 中的 prepare 方法中

 this.master = this.connection.getKeepAliveMasterService();

拿到hmaster的地址 ，建立如下物件，建立到hmaster的查詢過程

 MasterServiceStubMaker stubMaker = new MasterServiceStubMaker();
  try {
this.masterServiceState.stub = stubMaker.makeStub();

在makeStub方法中呼叫makeStubNoRetries() 方法
建立連線到 zk的物件

 keepAliveZookeeper = new ZooKeeperKeepAliveConnection(conf, this.toString(), this);

然後通過 下面方法進行連線到zk當中

this.recoverableZooKeeper = ZKUtil.connect(conf, quorum, this, identifier);

然後去請請求hmaster的地址
ServerName sn = MasterAddressTracker.getMasterAddress(zkw);

在hmaster拿到hmaster的地址

data = ZKUtil.getData(zkw, zkw.getMasterAddressZNode())

最好就可以建立rpc的channel物件了

   BlockingRpcChannel channel = rpcClient.createBlockingRpcChannel(sn, user, rpcTimeout);
  stub = makeStub(channel);

其實是建立了 BlockingRpcChannelImplementation，物件，裡面又呼叫了 rpcClient物件
然後每次建立 連線時，都會進行了 isMasterRunning(); 方法的呼叫進行測試master是否在運行當中
在hmaster的rpc服務中 MasterRpcServices.isMasterRunning 就可以接到請求的方法呼叫。

現在回到最開始的業務，就是 傳送 DisableTableRequest 請求到hmaster中。
接著

admin.deleteTable(tableName);

過程和上面的過程一樣，只是現在請求的物件是DeleteTableRequest 而已

  private Future<Void> deleteTableAsyncV2(final TableName tableName) throws IOException {
DeleteTableResponse response = executeCallable(
  new MasterCallable<DeleteTableResponse>(getConnection()) {
@Override
public DeleteTableResponse call(int callTimeout) throws ServiceException {
  PayloadCarryingRpcController controller = rpcControllerFactory.newController();
  controller.setCallTimeout(callTimeout);
  controller.setPriority(tableName);
  DeleteTableRequest req =
  RequestConverter.buildDeleteTableRequest(tableName, ng.getNonceGroup(),ng.newNonce());
  return master.deleteTable(controller,req);
}
  });
return new DeleteTableFuture(this, tableName, response);
  }

其中 deleteTable是 client 和hmaster的rpc介面方法

大家可能也注意到，像上面也用到了 rpcClient

this.rpcClient = RpcClientFactory.createClient(this.conf, this.clusterId);

這個類是對服務端呼叫的公共rpc類。
所以在之前曾經說到的在傳送RpcClientImpl.call之時，會建立到遠端的連線

  final Call call = new Call(this.callIdCnt.getAndIncrement(), md, param, cells, returnType,
pcrc.getCallTimeout());
   final Connection connection = getConnection(ticket, call, addr);

在這裡建立連線，在連線裡會建立 ConnectionHeader header 類，在發起連線建立時，會上傳客戶端的使用者資訊的

connection.tracedWriteRequest(call, pcrc.getPriority(), Trace.currentSpan());