来源：https://www.codeleading.com/article/19661999901/

目录

hbase环境配置

thrift环境配置

api接口生成

操作案例

最近要进行用户行为分析，数据存储决定采用hbase。并且为了便于和当前系统契合，采用php进行存取。

hbase环境配置

1. 进入hbase官网，进入下载页面，下载对应版本的可执行文件和源文件。

2. 直接将可执行文件进行解压缩，并且进行配置。

conf/hbase-env.sh中的 export JAVA_HOME=/***/jdk 设定为自己系统的jdk路径

conf/hbase-site.xml 中配置数据存储路径和端口

3. <name>hbase.rootdir</name>

4. <value>file:///opt/bigdata/hbase/data</value>

8. <name>hbase.master.info.port</name>

另外，要把机器名字配置到hosts当。 执行hostname，并且将机器名称结果在hosts写入 127.0.0.1  devname

3.进入bin目录，启动hbase

start-hbase.sh

至此，hbase环境就搭建好了

thrift环境配置

1.进入thrift官网下载页面，并且进行下载

2.解压缩，并且进行安装

./configure -prefix=/安装目录  -with-php=/usr/bin

make

make install

3.启动hbase的thrift服务

./hbase-daemon.sh start thrift

api接口生成

1. 记得第一步中下载的hbase源码，在这里可以用的上了，解压缩hbase的源码，并且找到文件Hbase.thrift

hbase-2.1.0/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift/Hbase.thrift

进入thrift可执行文件目录bin中，生成php版本的接口。

./thrift --gen php hbase-2.1.0/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift/Hbase.thrift

2.拷贝thrift中php的库文件 hrift-0.11.0/lib/php ， 

1. cp -r thrift-0.11.0/lib/php ./thrift_lib

2. cp -r gen-php/* ./thrift_lib

操作案例

1.在hbase中插入表，并且插入数据，具体详细命令可以参考这里。

2. create 'test',{NAME=>'cf1',VERSIONS=>1000},{NAME=>'cf2',VERSIONS=>1000}

3. put 'test','20180814','cf1:column1','test_cf1_column1'

4. put 'test','20180814','cf2:column1','test_cf2_column1'

2.依赖于上一步中的thrift_lib，我们开始创建php代码

2. $GLOBALS['THRIFT_ROOT'] = '/opt/bigdata/test/test_thrift/thrift_lib';

3. require_once($GLOBALS['THRIFT_ROOT'].'/Hbase/Hbase.php');

4. require_once($GLOBALS['THRIFT_ROOT'].'/Hbase/Types.php');

6. require_once( $GLOBALS['THRIFT_ROOT'].'/lib/Thrift/ClassLoader/ThriftClassLoader.php' );

7. use Thrift\ClassLoader\ThriftClassLoader;

8. $loader = new ThriftClassLoader();

9. $loader->registerNamespace('Thrift',$GLOBALS['THRIFT_ROOT'].'/lib/');

10. $loader->registerDefinition('shared',$GLOBALS['THRIFT_ROOT']);

11. $loader->registerDefinition('tutorial',$GLOBALS['THRIFT_ROOT']);

14. use Thrift\Protocol\TBinaryProtocol;

15. use Thrift\Transport\TSocket;

16. use Thrift\Transport\THttpClient;

17. use Thrift\Transport\TBufferedTransport;

18. use Thrift\Exception\TException;

21. use Hbase\ColumnDescriptor;

24. $socket = new TSocket( 'localhost', 9090 );

25. $socket->setSendTimeout( 10000 );

26. $socket->setRecvTimeout( 20000 );

28. $transport = new TBufferedTransport( $socket );

30. $protocol = new TBinaryProtocol( $transport );

32. $client = new HBase\HbaseClient( $protocol );

37. $tables = $client->getTableNames();

41. $rows = $client->getRows($table,['20180814'],['cf1']);

42. $rows = $client->getRow($table,'20180814',['cf1']);

43. $rows = $client->getRowsWithColumns($table,['20180814',],['cf1:column1'],[]);

44. $rows = $client->getRowTs($table,'20180814',1544214539999,[]);

45. $rows = $client->getVerTs($table,'20180814','cf1:column1',1544214539933,2,[]);

46. $rows = $client->getVer($table,'20180814','cf1:column1',20,[]);

51. new Mutation(['column'=>'cf1:column1','value'=>'101505033']),

52. new Mutation(['column'=>'cf1:column2','value'=>'3']),

53. new Mutation(['column'=>'cf1:column3','value'=>'12']),

54. new Mutation(['column'=>'cf2:column1','value'=>'101505033']),

55. new Mutation(['column'=>'cf2:column2','value'=>'3']),

56. new Mutation(['column'=>'cf2:column3','value'=>'12']),

58. $client->mutateRow($table,'20180814',$dataArr,[]);