2019-09-17 10:31:26 5018瀏覽
Hbase通過(guò)thrift這個(gè)跨語(yǔ)言的RPC框架提供多語(yǔ)言的調(diào)用。Hbase有兩套thrift接口(thrift1和thrift2),但是它們并不兼容。根據(jù)官方文檔,thrift1很可能被拋棄,本篇文章扣丁學(xué)堂php培訓(xùn)小編給小伙伴們分享一下在php的yii2框架中整合hbase庫(kù)的方法,感興趣的小伙伴一起跟隨小編過(guò)來(lái)看看吧。
1、訪問(wèn)官網(wǎng)下載
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相關(guān)庫(kù),保存在D:\project\thrift\thrift-0.11.0)
2、訪問(wèn)hbase官網(wǎng)下載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文件夾同時(shí)存在thrift和thrift2接口描述文件,本文只使用thrift2
在D:\project\thrift目錄中輸入cmd命令,生成對(duì)應(yīng)php的sdk文件。
thrift -gen php hbase-1.2.6\hbase-thrift\src\main\resources\org\apache\hadoop\hbase\thrift2\hbase.thrift
生成的D:\project\thrift\gen-php目錄包含文件:
4、要通過(guò)thrifc調(diào)用hbase,需要先啟動(dòng)hbase的接口服務(wù)
5、與yii2整合
在vendor文件夾中新建hbase目錄
由于thrift2的php不使用Composer,類庫(kù)命名方式也不完全符合PSR-4標(biāo)準(zhǔn), 所以本文使用include_path方式來(lái)定位并導(dǎo)入類文件。
common\models\HArticle.php
frontend\controllers\TestController.php
THBaseService.php
Types.php
$HBASE_HOME/bin/hbase-daemon.sh start thrift2 //啟動(dòng)
$HBASE_HOME/bin/hbase-daemon.sh stop thrift2 //停止
vendor\hbase\gen-php //復(fù)制D:\project\thrift\gen-php
vendor\hbase\php //復(fù)制D:\project\thrift\thrift-0.11.0\lib\php
<?php
namespace common\models;
require_once dirname(dirname(__DIR__)).'/vendor/hbase/php/lib/Thrift/ClassLoader/ThriftClassLoader.php';
use Thrift\ClassLoader\ThriftClassLoader;
$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 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;
}
}
<?php
namespace frontend\controllers;
use yii\web\Controller;
use common\models\HArticle;
class TestController extends Controller
{
public function actionIndex()
{
$hArticle = new HArticle();
$data = $hbaseNews->get('20180908_1f1be3cd26a36e351175015f450fa3f6');
var_dump($data);
exit();
}
}
想要了解更多關(guān)于PHP開(kāi)發(fā)方面內(nèi)容的小伙伴,請(qǐng)關(guān)注扣丁學(xué)堂PHP培訓(xùn)官網(wǎng)、微信等平臺(tái),扣丁學(xué)堂IT職業(yè)在線學(xué)習(xí)教育有專業(yè)的PHP講師為您指導(dǎo),此外扣丁學(xué)堂老師精心推出的PHP視頻教程定能讓你快速掌握PHP從入門(mén)到精通開(kāi)發(fā)實(shí)戰(zhàn)技能??鄱W(xué)堂PHP技術(shù)交流群:374332265。
【關(guān)注微信公眾號(hào)獲取更多學(xué)習(xí)資料】 【掃碼進(jìn)入JavaEE/微服務(wù)VIP免費(fèi)公開(kāi)課】