在php的yii2框架中整合hbase库的方法

Hbase通过thrift这个跨语言的RPC框架提供多语言的调用。

Hbase有两套thrift接口（thrift1和thrift2）,但是它们并不兼容。根据官方文档，thrift1很可能被抛弃，本文以thrift2整合为例。

1、访问官网

，下载

thrift-0.11.0.exe   （生成接口rpc工具，thrift-0.11.0.exe改名thrift.exe,保存在D:projectthriftthrift.exe）

thrift-0.11.0.tar.gz（thrift相关库，保存在D:projectthriftthrift-0.11.0）

2、访问hbase官网(

/rc.tar.gz

解压保存在D:projectthrifthbase-1.2.6

3、生成php接口代码

解压hbase-1.2.6-src.tar.gz，hbase-1.2.6hbase-thriftsrcmainresourcesorgapachehadoophbase文件夹同时存在thrift和thrift2接口描述文件，本文只使用thrift2

在D:projectthrift目录中输入cmd命令，生成对应php的sdk文件。

thrift -gen php hbase-1.2.6hbase-thriftsrcmainresourcesorgapachehadoophbasethrift2hbase.thrift

生成的D:projectthriftgen-php目录包含文件：

THBaseService.php

Types.php

4、要通过thrifc调用hbase，需要先启动hbase的接口服务

$HBASE_HOME/bin/hbase-daemon.sh start thrift2 //启动

$HBASE_HOME/bin/hbase-daemon.sh stop thrift2 //停止

5、与yii2整合

在vendor文件夹中新建hbase目录

vendorhbas/

/egen-php //复制D:projectthriftgen-php

vendorhbasephp //复制D:projectthriftthrift-0.11.0libphp

由于thrift2的php不使用Composer，类库命名方式也不完全符合PSR-4标准， 所以本文使用include_path方式来定位并导入类文件。

commonmodelsHArticle.php

<?php

namespace commonmodels;

require_once dirname(dirname(__DIR__)).'/vendor/hbase/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';

use ThriftClassLoaderThriftClassLoader;

$loader = new ThriftClassLoader();

$loader->registerNamespace('Thrift', dirname(dirname(__DIR__)) . '/vendor/hbase/php/lib');

$loader->register();

require_once dirname(dirname(__DIR__)) . '/vendor/hbase/gen-php/Types.php';

require_once dirname(dirname(__DIR__)) . '/vendor/hbase/gen-php/THBaseService.php';

use ThriftProtocolTBinaryProtocol;

use ThriftTransportTSocket;

use ThriftTransportTBufferedTransport;

use THBaseServiceClient;

use TGet;

class HArticle

{

private $host = '192.168.1.108';

private $port = 9090;

public function get($rowKey){

$socket = new TSocket($this->host, $this->port);

$transport = new TBufferedTransport($socket);

$protocol = new TBinaryProtocol($transport);

$client = new THBaseServiceClient($protocol);

$transport->open();

$tableName = "article_2018";

$get = new TGet();

$get-&gt;row = $rowKey;

$arr = $client->get($tableName, $get);

$data = array();

$results = $arr->columnValues;

foreach($results as $result)

{

$qualifier = (string)$result->qualifier;

$value = $result->value;

$data[$qualifier] = $value;

}

$transport->close();

return $data;

}

}

frontendcontrollersTestController.php

<?php

namespace frontendcontrollers;

use yiiwebController;

use commonmodelsHArticle;

class TestController extends Controlle

{

public function actionIndex()

{

$hArticle = new HArticle();

$data = $hbaseNews->get('20180908_1f1be3cd26a36e351175015f450fa3f6');

var_dump($data);

exit();

}

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。