在php的yii2框架中整合hbase库
為什么80%的碼農(nóng)都做不了架構(gòu)師?>>> ??
Hbase通過thrift這個跨語言的RPC框架提供多語言的調(diào)用。
Hbase有兩套thrift接口(thrift1和thrift2),但是它們并不兼容。根據(jù)官方文檔,thrift1很可能被拋棄,本文以thrift2整合為例。
1、訪問官網(wǎng)http://thrift.apache.org/download,下載
2、訪問hbase官網(wǎng)(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文件。
生成的D:\project\thrift\gen-php目錄包含文件:
4、要通過thrifc調(diào)用hbase,需要先啟動hbase的接口服務(wù)
$HBASE_HOME/bin/hbase-daemon.sh start thrift2 //啟動 $HBASE_HOME/bin/hbase-daemon.sh stop thrift2 //停止5、與yii2整合
在vendor文件夾中新建hbase目錄
由于thrift2的php不使用Composer,類庫命名方式也不完全符合PSR-4標準, 所以本文使用include_path方式來定位并導入類文件。
common\models\HArticle.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;} }frontend\controllers\TestController.php
<?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();} }?
轉(zhuǎn)載于:https://my.oschina.net/penngo/blog/2049652
總結(jié)
以上是生活随笔為你收集整理的在php的yii2框架中整合hbase库的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: MySql 建表、添加字段、修改字段、添
- 下一篇: “生于忧患,死于安乐”之程序员人生