在php的yii2框架中整合hbase库的方法
Hbase通过thrift这个跨语言的RPC框架提供多语言的调用。
Hbase有两套thrift接口（thrift1和thrift2）,但是它们并不兼容。根据官方文档，thrift1很可能被抛弃，本文以thrift2整合为例。
1、访问官网http://thrift.apache.org/download，下载
thrift-0.11.0.exe （生成接口rpc工具，thrift-0.11.0.exe改名thrift.exe,保存在D:\project\thrift\thrift.exe）
thrift-0.11.0.tar.gz（thrift相关库，保存在D:\project\thrift\thrift-0.11.0）
2、访问hbase官网(http://archive.apache.org/dist/hbase/),下载hbase-1.2.6-src.tar.gz
解压保存在D:\project\thrift\hbase-1.2.6
3、生成php接口代码
解压hbase-1.2.6-src.tar.gz，hbase-1.2.6\hbase-thrift\src\main\resources\org\apache\hadoop\hbase文件夹同时存在thrift和thrift2接口描述文件，本文只使用thrift2
在D:\project\thrift目录中输入cmd命令，生成对应php的sdk文件。
thrift-genphphbase-1.2.6\hbase-thrift\src\main\resources\org\apache\hadoop\hbase\thrift2\hbase.thrift
生成的D:\project\thrift\gen-php目录包含文件：
THBaseService.php Types.php
4、要通过thrifc调用hbase，需要先启动hbase的接口服务
$HBASE_HOME/bin/hbase-daemon.shstartthrift2//启动 $HBASE_HOME/bin/hbase-daemon.shstopthrift2//停止
5、与yii2整合
在vendor文件夹中新建hbase目录
vendor\hbase\gen-php//复制D:\project\thrift\gen-php vendor\hbase\php//复制D:\project\thrift\thrift-0.11.0\lib\php
由于thrift2的php不使用Composer，类库命名方式也不完全符合PSR-4标准，所以本文使用include_path方式来定位并导入类文件。
common\models\HArticle.php
registerNamespace('Thrift',dirname(dirname(__DIR__)).'/vendor/hbase/php/lib');
$loader->register();
require_oncedirname(dirname(__DIR__)).'/vendor/hbase/gen-php/Types.php';
require_oncedirname(dirname(__DIR__)).'/vendor/hbase/gen-php/THBaseService.php';
useThrift\Protocol\TBinaryProtocol;
useThrift\Transport\TSocket;
useThrift\Transport\TBufferedTransport;
useTHBaseServiceClient;
useTGet;
classHArticle
{
private$host='192.168.1.108';
private$port=9090;
publicfunctionget($rowKey){
$socket=newTSocket($this->host,$this->port);
$transport=newTBufferedTransport($socket);
$protocol=newTBinaryProtocol($transport);
$client=newTHBaseServiceClient($protocol);
$transport->open();
$tableName="article_2018";
$get=newTGet();
$get->row=$rowKey;
$arr=$client->get($tableName,$get);
$data=array();
$results=$arr->columnValues;
foreach($resultsas$result)
{
$qualifier=(string)$result->qualifier;
$value=$result->value;
$data[$qualifier]=$value;
}
$transport->close();
return$data;
}
}
frontend\controllers\TestController.php
get('20180908_1f1be3cd26a36e351175015f450fa3f6');
var_dump($data);
exit();
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。