日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > php >内容正文

php

在php的yii2框架中整合hbase库

發布時間:2025/3/21 php 37 豆豆
生活随笔 收集整理的這篇文章主要介紹了 在php的yii2框架中整合hbase库 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

為什么80%的碼農都做不了架構師?>>> ??

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

?

轉載于:https://my.oschina.net/penngo/blog/2049652

總結

以上是生活随笔為你收集整理的在php的yii2框架中整合hbase库的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。