摘要：?手把手教你使用Thrift訪問ApsaraDB for HBase

Thrift 多語言接入

Thrift 提供多語言訪問HBase的能力,支持的語言包從Thrift官網(wǎng)看括:?C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, OCaml , Delphi 以及別的語言.主要流程是用戶thrift Client 通過Thrift協(xié)議訪問HBase的thriftserver,thriftserver做請求轉(zhuǎn)發(fā)給HBase的存儲服務來做數(shù)據(jù)的讀以及寫操作.大概架構(gòu)圖如下：

?

要通過thrift 多語言訪問HBase需要以下幾步：

一、開通HBase thriftserver服務：

在用戶自己管控頁面點擊這里參考開通thriftserver服務化（高可用版本thriftserver），會得到一個host:port的訪問入口；或者自己可以選擇ECS自建thriftserver方法，參考這里，最終自建ECS的ip (host)以及默認的話9090端口作為訪問入口。

二、用戶Thrift client訪問：

一般客戶常見的訪問方式是python的訪問方式以及php的訪問方式 ，這里我們先一步步給出php的訪問方式；

2.1 . 以php走thrift訪問HBase：

2.1.1 . 安裝thrift 編譯環(huán)境；

我們云HBase的thrift環(huán)境是0.9.0，所以建議客戶自己建立自己的thrift環(huán)境也是0.9.0，這里可以從這里下載thrift的0.9.0 版本，下載的源碼包我們后面會用到，這里需要先安裝thrift編譯環(huán)境，對于源碼安裝可以參考thrift官網(wǎng)；

通過如下命令可以看出安裝thrift的版本信息；

thrift?--version

2.1.2. 生成thrift訪問client的訪問文件；

我們從這里下載出我們云HBase的Hbase.thrift文件，這里我們云HBase使用的是thrift1協(xié)議，具體可以參考文件看出使用格式，下載完成以后執(zhí)行thrift命令進行編譯；

編譯命令如下：

?thrift?--gen??Hbase.thrift

上述是語言的縮寫，那么常見的有如下：

thrift?--gen?php?Hbase.thriftthrift?--gen?cpp?Hbase.thriftthrift?--gen?py?Hbase.thrift

執(zhí)行thrift --gen php Hbase.thrift 以后會在目錄下得到gen-php 這個就是我們需要的函數(shù)包文件；

thrift?git:(last_dev)??lltotal?56-rw-r--r--??1?xuanling.gc??staff????24K??3??5?15:06?Hbase.thriftdrwxr-xr-x??3?xuanling.gc??staff????96B??8??1?16:03?gen-php

此外我們在2.1.1得到thrift的源碼包文件將下載到的Thrift源碼文件夾下的/lib/php/lib下面的Thrift文件夾以及gen-php一起丟在我們的業(yè)務邏輯代碼一個src目錄下面，加上我們自己的client.php的代碼，目錄結(jié)果如下所示：

[root@xxxxxxxxxxx?thrift_client]#?lltotal?12-rw-r--r--??1?zookeeper?games?2743?Aug??2?11:16?client.phpdrwxr-xr-x??3?zookeeper?games?4096?Aug??2?01:22?gen-phpdrwxr-xr-x?12?zookeeper?games?4096?Aug??2?01:22?Thrift

2.1.3. php訪問代碼編寫；

這個時候，我們來編寫我們的client.php代碼邏輯，上述的Thrift文件夾以及gen-php文件夾，可以隨自己項目以及個人風格命名，這里方便大家搞清目錄結(jié)構(gòu)，就保留原來風格；下面貼出php的代碼，我們下面的所有程序都是在HBase 建了一張表"new"：

setSendTimeout(10000);?//?發(fā)送超時，單位毫秒$socket->setRecvTimeout(20000);?//?接收超時，單位毫秒$transport?=?new?TBufferedTransport($socket);
$protocol?=?new?TBinaryProtocol($transport);
$client?=?new?HbaseClient($protocol);

$transport->open();####列出表####echo?"----list?tables----\n";
$tables?=?$client->getTableNames();foreach?($tables?as?$name)?{
????var_dump($tables);
}

$tablename='new';####寫數(shù)據(jù)####echo?"----write?data----\n";
$row?=?'key';
$value?=?'value';
$atrribute?=?array();
$mutations?=?array(????new?Mutation(array(????????'column'?=>?'info:cn1',????????'value'?=>?$value
????)),
);try?{
????$client->mutateRow($tablename,?$row,?$mutations,?$atrribute);
}?catch?(Exception?$e)?{
????var_dump($e);//這里自己打log}###讀數(shù)據(jù)####echo?"---read?data---\n";
$result?=?$client->getRow($tablename,?$row,?$atrribute);
var_dump($result);###刪數(shù)據(jù)####echo?"---delete?data---\n";
$client->deleteAllRow($tablename,?$row,?$atrribute);echo?"---get?data---\n";
$result?=?$client->getRow($tablename,?$row,?$atrribute);
var_dump($result);?>

代碼執(zhí)行結(jié)果如下：

[root@xxxxxxxxxxx?thrift_client]#?php?client.php----list?tables----array(1)?{
??[0]=>
??string(3)?"new"}
----write?data----
---read?data---array(1)?{
??[0]=>
??object(Hbase\TRowResult)#8?(3)?{
????["row"]=>
????string(3)?"key"
????["columns"]=>????array(1)?{
??????["info:cn1"]=>
??????object(Hbase\TCell)#10?(2)?{
????????["value"]=>
????????string(5)?"value"
????????["timestamp"]=>
????????int(1533179795969)
??????}
????}
????["sortedColumns"]=>????NULL
??}
}
---delete?data---
---get?data---array(0)?{
}

2.2.python訪問流程；

此外還有常見的python的客戶，對于python的話，有happybase這種python的第三方包含thrift的庫去做，我們見過一些客戶使用Happybase進行訪問HBase thrift，參見文章；此外，python 有豐富的庫，我們通過pip可以安裝thrift，以及訪問HBase的thrift庫；執(zhí)行流程如下,假設(shè)用戶已經(jīng)安裝python以及pip：

pip?install?thrift?//安裝thrift默認最新版本pip?install?hbase-thrift?//安裝hbase?thrift接口庫

上面2步執(zhí)行完成以后，既可以編寫訪問HBase的代碼：

import?sysimport?timeimport?osfrom?thrift?import?Thriftfrom?thrift.transport?import?TSocket,?TTransportfrom?thrift.protocol?import?TBinaryProtocolfrom?hbase?import?ttypesfrom?hbase.Hbase?import?Client,?ColumnDescriptor,?Mutationdef?printRow(entry):
??print?"row:?"?+?entry.row?+?",?cols:",??for?k?in?sorted(entry.columns):????print?k?+?"?=>?"?+?entry.columns[k].value,??printtransport?=?TSocket.TSocket('hb-bp12pt6alr1788y35-001.hbase.rds.aliyuncs.com',?9099)
transport?=?TTransport.TBufferedTransport(transport)
protocol?=?TBinaryProtocol.TBinaryProtocol(transport)
client?=?Client(protocol)
transport.open()print?"---list?table--"print?client.getTableNames()

table="new"row="key"print?"---write?data---"mutations?=?[Mutation(column="info:cn1",?value="value")]
client.mutateRow(table,?row,?mutations)print?"---get?data----"printRow(client.getRow(table,?row)[0])print?"---delete?data---"client.deleteAllRow(table,?row)print?"---end----"transport.close()

對應上述的程序執(zhí)行的結(jié)果如下：

[root@Test?~]#?python?Hbase_client.py---list?table--['new']---write?data------get?data----row:?key,?cols:?info:cn1?=>?value---delete?data------end----

三、訪問HBase thriftserver

3.1、訪問機器開通白名單

將訪問的機器的ip加入HBase集群的白名單，然后就可以正常執(zhí)行代碼；

原文鏈接

本文為云棲社區(qū)原創(chuàng)內(nèi)容，未經(jīng)允許不得轉(zhuǎn)載。