在php的yii2框架中整合hbase库的方法_php实例_

 THBaseService.php Types.php

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

 vendor\hbase\gen-php //复制D:\project\thrift\gen-php vendor\hbase\php //复制D:\project\thrift\thrift-0.11.0\lib\php

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 Thrift\Protocol\TBinaryProtocol; use Thrift\Transport\TSocket; use Thrift\Transport\TBufferedTransport; 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->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; } } 

get('20180908_1f1be3cd26a36e351175015f450fa3f6'); var_dump($data); exit(); } }