php yii2系统集成hbase库方法：通过语言节省的RPC管理系统进行多语言调用

Hbase通过“语言兼容的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.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目录

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

由于PHP thrift2没有使用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();
  }
}