So verwenden Sie HBase zur Datenspeicherung und -abfrage in Workerman

Workerman ist ein leistungsstarkes PHP-Socket-Framework, das sich durch seine Fähigkeit auszeichnet, eine große Anzahl gleichzeitiger Verbindungen zu übertragen. Im Gegensatz zu herkömmlichen PHP-Frameworks ist Workerman nicht auf Webserver wie Apache oder Nginx angewiesen, sondern führt die gesamte Anwendung selbst aus, indem es einen PHP-Prozess startet. Workerman verfügt über eine extrem hohe Betriebseffizienz und eine bessere Tragfähigkeit.

Gleichzeitig ist HBase ein verteiltes NoSQL-Datenbanksystem, das im Bereich der Big-Data-Verarbeitung weit verbreitet ist. Der Vorteil von HBase ist seine starke horizontale Skalierbarkeit und unbegrenzte Erweiterung zur Verarbeitung großer Datenmengen. Aufgrund seiner extrem hohen Skalierbarkeit ist HBase zu einem integralen Bestandteil des Hadoop-Ökosystems geworden und nach und nach zur ersten Wahl für die Speicherung und Verarbeitung großer Datenmengen geworden.

In diesem Artikel wird erläutert, wie Sie HBase für die Datenspeicherung und -abfrage in Workerman verwenden.

1. Installation und Konfiguration von HBase

Bevor Sie HBase verwenden, müssen Sie zunächst HBase installieren und konfigurieren. Hier verwenden wir die Schritte in der offiziellen Dokumentation von HBase zur Installation und Konfiguration.

1. Laden Sie HBase herunter

Laden Sie die neueste Version von HBase von der offiziellen Website von HBase herunter. Wählen Sie hier die Version hbase-2.2.4 aus.

2. HBase entpacken

Entpacken Sie das heruntergeladene HBase-Paket und verschieben Sie es in das angegebene Verzeichnis.

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

3. Ändern Sie die Konfigurationsdatei

Ändern Sie die Konfigurationsdatei von HBase, die Konfigurationsdatei ist befindet sich im Verzeichnis „/usr /local/hbase/conf“. Hauptsächlich einschließlich „hbase-env.sh“, „hbase-site.xml“, „regionservers“ usw.

(1) Ändern Sie die Datei hbase-env.sh.

Fügen Sie am Ende der Datei den folgenden Inhalt hinzu:

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

Die erste Zeile gibt das Java-Installationsverzeichnis an, die zweite Zeile gibt an, den in HBase eingebetteten ZooKeeper nicht zu verwenden, und die dritte Zeile legt den maximalen Heap-Speicher des HBase-Prozesses fest.

(2) Ändern Sie die Datei hbase-site.xml.

Fügen Sie am Ende der Datei den folgenden Inhalt hinzu:

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

wobei „file:///usr /local/hbase/data“ gibt das Stammverzeichnis des angegebenen HBase-Datenspeichers an.

(3) Ändern Sie die Regionsservers-Datei

Bearbeiten Sie die Datei „/usr/local/hbase/conf/regionservers“, fügen Sie die lokale IP-Adresse zur Datei hinzu und speichern Sie sie.

4. Starten Sie HBase

Führen Sie den folgenden Befehl aus, um HBase zu starten:

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

5. Überprüfen Sie, ob HBase erfolgreich gestartet wird

Führen Sie den folgenden Befehl aus um zu prüfen, ob HBase erfolgreich gestartet wurde:

./bin/status.sh

Die Ausgabe von „HMaster“ zeigt an, dass HBase erfolgreich gestartet wurde.

2. Installation des PHP-HBase-Clients

Der HBase-Client von PHP bietet viele Open-Source-Pakete zur Auswahl, wie z. B. HBase-thrift, HBase-rest usw. In diesem Artikel wird die Verwendung der HBase-PHP-Bibliothek ausgewählt, bei der es sich um einen mit dem HBase1.0.0-Protokoll kompatiblen Client handelt, der in reinem PHP implementiert ist.

1. Installieren Sie die HBase-PHP-Bibliothek

Sie können die HBase-PHP-Bibliothek über Composer installieren. Führen Sie zur Installation den folgenden Befehl aus:

composer require rwgrier/HBase-PHP

2. Erstellen Sie eine HBase-Verbindung.

Rufen Sie die Konstruktormethode der HBaseClient-Klasse auf, um eine Verbindung herzustellen:

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

Sie müssen die HBase-Adresse und die Portnummer angeben, um einen einzurichten Verbindung.

3. Die Verwendung von HBase in Workerman ist ebenfalls sehr einfach. Sie müssen lediglich den Code zum Erstellen der HBase-Verbindung in den obigen Schritten zu Ihrem eigenen Code hinzufügen. Hier ist ein einfaches Beispiel:

use WorkermanWorker;

require_once
DIR
'/vendor/autoload.php';use HBaseClientHBaseClient;// Workerman-Instanz erstellen
$worker = new Worker() ;
// HBase-Verbindung herstellen
$client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);
$worker->onMessage = function ($connection , $data) use ($client) {
// Daten abrufen
$result = $client->get('mytable', 'row-key');
$row = current($result);
// Prozess data
$value = $row->getColumnValue('cf1:col1');
// Daten zurückgeben
$connection->send($value);
};
// Worker-Prozess starten
Worker:: runAll();

Im obigen Beispiel erhalten wir die Daten in einer Tabelle „mytable“ über eine HBase-Verbindung und geben die erhaltenen Daten an die Client-Verbindung zurück. Weitere Informationen zur API-Nutzung von HBase finden Sie in der offiziellen Dokumentation zu HBase-PHP.

Zusammenfassung

Mit Workerman und HBase können auf einfache Weise eine hohe Leistung und eine enorme Datenspeicherung erreicht sowie eine Datenabfrage und -verarbeitung in Echtzeit realisiert werden. Workerman und HBase sind beide Open-Source-Software. Ihre hervorragende Leistung und Stabilität wurden von einer großen Anzahl von Benutzern anerkannt und können die Anforderungen großer Anwendungen erfüllen. In diesem Artikel wird die Methode zur Verwendung von Workerman mit HBase zur Datenspeicherung und -abfrage vorgestellt. In der tatsächlichen Entwicklung muss sie entsprechend der tatsächlichen Situation angepasst und optimiert werden.

Das obige ist der detaillierte Inhalt vonSo verwenden Sie HBase zur Datenspeicherung und -abfrage in Workerman. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!