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

 更新时间:2018年09月20日 10:54:08   作者:penngo  
这篇文章主要介绍了在php的yii2框架中整合hbase库的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

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.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

由于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();
  }
}

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

相关文章

  • ThinkPHP3.2.3框架邮件发送功能图文实例详解

    ThinkPHP3.2.3框架邮件发送功能图文实例详解

    这篇文章主要介绍了ThinkPHP3.2.3框架邮件发送功能,结合图文与实例形式详细分析了基于thinkPHP框架进行邮件发送的相关原理、配置及操作技巧,需要的朋友可以参考下
    2019-04-04
  • ThinkPHP基于PHPExcel导入Excel文件的方法

    ThinkPHP基于PHPExcel导入Excel文件的方法

    这篇文章主要介绍了ThinkPHP基于PHPExcel导入Excel文件的方法,对于Excel文件的上传、读取操作以及写入数据库等都做了较为详尽的讲述,在进行项目开发的过程中非常具有实用价值,需要的朋友可以参考下
    2014-10-10
  • php开发留言板的CRUD(增,删,改,查)操作

    php开发留言板的CRUD(增,删,改,查)操作

    php学习中,以开放一个留言本作为php的入门资料还是不错的。
    2012-04-04
  • CentOS下PHP7的编译安装及MySQL的支持和一些常见问题的解决办法

    CentOS下PHP7的编译安装及MySQL的支持和一些常见问题的解决办法

    这篇文章主要介绍了CentOS下PHP7的编译安装及MySQL的支持和一些问题的解决 的相关资料,需要的朋友可以参考下
    2015-12-12
  • 微信公众平台开发之配置与请求

    微信公众平台开发之配置与请求

    微信公众平台是腾讯公司在微信的基础上新增的功能模块,通过这一平台,个人和企业都可以打造一个微信的公众号,并实现和特定群体的文字、图片、语音的全方位沟通、互动。本文给大家介绍微信公众平台开发之配置与请求,需要的朋友可以参考下
    2015-08-08
  • php使用curl访问https示例分享

    php使用curl访问https示例分享

    curl是利用URL语法在命令行方式下工作的开源文件传输工具,下面介绍一下php使用curl访问https的示例,大家参考使用吧
    2014-01-01
  • thinkphp5redis缓存新增方法实例讲解

    thinkphp5redis缓存新增方法实例讲解

    这篇文章主要介绍了thinkphp5redis缓存新增方法实例讲解,redis是项目中最常用的缓存,有正在使用的同学可以看下
    2021-03-03
  • ecshop 批量上传(加入自定义属性)

    ecshop 批量上传(加入自定义属性)

    ECSHOP的批量上传功能没有像shopex一下可以根据商品类型导出相应的csv也就是说批量上传只能上传一般的商品属性,对于我们自己定义的特殊属性我们还是要自己一个一个填过去
    2012-03-03
  • Laravel 5 学习笔记

    Laravel 5 学习笔记

    本文记录的是个人在学习实用laravel5的过程中遇到的几个重点的地方,也是最容易犯错的地方,这里记录下来,分享给大家。
    2015-03-03
  • 注释PHP和html混合代码的小技巧(分享)

    注释PHP和html混合代码的小技巧(分享)

    下面小编就为大家带来一篇注释PHP和html混合代码的小技巧(分享)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-11-11

最新评论