首页 > 语言 > PHP > 正文

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

2024-05-05 00:05:25
字体:
来源:转载
供稿:网友

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 -gen php hbase-1.2.6/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift2/hbase.thrift

生成的D:/project/thrift/gen-php目录包含文件:

THBaseService.phpTypes.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目录

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

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

common/models/HArticle.php

<?phpnamespace 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

<?phpnamespace 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();  }}

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


注:相关教程知识阅读请移步到PHP教程频道。
发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表

图片精选