Workerman でのデータ ストレージとクエリに HBase を使用する方法

Workerman は、高性能の PHP ソケット フレームワークであり、多数の同時接続を実行できることが特徴です。従来の PHP フレームワークとは異なり、Workerman は Apache や Nginx などの Web サーバーに依存せず、PHP プロセスを開始することでアプリケーション全体を単独で実行します。 Workerman は非常に高い作業効率と優れた耐荷重性を備えています。

同時に、HBase はビッグ データ処理の分野で広く使用されている分散型 NoSQL データベース システムです。 HBase の利点は、強力な水平拡張性と、大量のデータを処理するための無制限の拡張性です。 HBase はその非常に高いスケーラビリティにより、Hadoop エコシステムの不可欠な部分となり、徐々に大規模なデータのストレージと処理の最初の選択肢となりました。

この記事では、Workerman でのデータ ストレージとクエリに HBase を使用する方法を紹介します。

1. HBase のインストールと構成

HBase の使用を開始する前に、まず HBase をインストールして構成する必要があります。ここでは、HBase の公式ドキュメントに記載されている手順を使用してインストールと構成を行います。

1. HBase のダウンロード

HBase の公式 Web サイトから HBase の最新バージョンをダウンロードし、ここで hbase-2.2.4 バージョンを選択します。

2. HBase の解凍

ダウンロードした HBase パッケージを解凍し、指定したディレクトリに移動します。

tar -zxf hbase-2.2.4-bin.tar.gz
mv hbase-2.2.4 /usr/local/hbase

3. 設定ファイルを変更します

HBase 設定ファイルを変更します。設定ファイルは「/usr/local/hbase/conf」ディレクトリにあります。主に「hbase-env.sh」「hbase-site.xml」「regionservers」などが含まれます。

(1) hbase-env.sh ファイルを変更します。

ファイルの最後に次の内容を追加します:

export JAVA_HOME=/usr/local/jdk1。 8.0_211
export HBASE_MANAGES_ZK=false
export HBASE_HEAPSIZE=1024

最初の行は Java インストール ディレクトリを指定し、2 行目は HBase に組み込まれた ZooKeeper を使用しないことを示し、3 行目は最大値を設定します。 HBase プロセス メモリのヒープ。

(2) hbase-site.xml ファイルを変更します

ファイルの末尾に次の内容を追加します:

<name>hbase.rootdir</name>
<value>file:///usr/local/hbase/data</value>

> ;

ここで、「file:///usr/local/hbase/data」は、指定された HBase データ ストレージのルート ディレクトリを示します。

(3)regionservers ファイルの変更

ファイル「/usr/local/hbase/conf/regionservers」を編集し、ローカル IP アドレスをファイルに追加して保存します。

4. HBase の起動

次のコマンドを実行して HBase を起動します:

cd /usr/local/hbase
./bin/start-hbase.sh

5. HBase が正常に起動したかどうかを確認する

次のコマンドを実行して、HBase が正常に起動したかどうかを確認します:

./bin/status.sh

出力「HMaster」は、HBase が正常に開始されたことを意味します。

2. PHP HBase クライアントのインストール

PHP HBase クライアントには、HBase-thrift、HBase-rest など、選択できるオープン ソース パッケージが多数あります。この記事では、純粋な PHP で実装された HBase1.0.0 プロトコル互換クライアントである HBase-PHP ライブラリを使用することを選択します。

1. HBase-PHP ライブラリをインストールする

HBase-PHP ライブラリは Composer を通じてインストールできます。次のコマンドを実行してインストールします:

composer require rwgrier/HBase-PHP

2. HBase 接続を作成します

HBaseClient クラスのコンストラクターを呼び出して接続を確立します。

require_once 'vendor/autoload.php';
use HBaseClientHBaseClient;
$client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);

接続を確立するには、HBase アドレスとポート番号を指定する必要があります。

3. Workerman での HBase の使用

Workerman での HBase の使用も非常に簡単で、上記の手順で HBase 接続を作成するためのコードを独自のコードに追加するだけです。簡単な例を次に示します:

use WorkermanWorker;
require_once DIR . '/vendor/autoload.php';
use HBaseClientHBaseClient;
// Workerman インスタンスの作成
$worker = new Worker();
// HBase 接続の確立
$client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);
$worker->onMessage = function ($connection, $data) use ($client) {
// データを取得
$ result = $client->get('mytable', 'row-key');
$row = current($result);
// データを処理中
$value = $row-> ; getColumnValue('cf1:col1');
// データを返す
$connection->send($value);
};
// ワーカー プロセスを開始します
Worker:: runAll();

上記の例では、HBase 接続を使用してテーブル "mytable" 内のデータを取得し、取得したデータをクライアント接続に返します。 HBase の API の使用方法の詳細については、HBase-PHP 公式ドキュメントを参照してください。

概要

Workerman と HBase を使用すると、高性能と大容量のデータ ストレージを簡単に実現し、リアルタイムのデータ クエリと処理を実現できます。 Workerman と HBase はどちらもオープンソース ソフトウェアであり、その優れたパフォーマンスと安定性は多くのユーザーに認められており、大規模なアプリケーションのニーズに応えます。この記事ではWorkermanとHBaseを併用してデータの保存やクエリを行う方法を紹介しましたが、実際の開発では実情に合わせて調整、最適化する必要があります。

以上がWorkerman でのデータ ストレージとクエリに HBase を使用する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。