Comment utiliser HBase pour le stockage de données et les requêtes dans Workerman

Workerman est un framework de socket PHP hautes performances, qui se caractérise par sa capacité à supporter un grand nombre de connexions simultanées. Contrairement aux frameworks PHP traditionnels, Workerman ne s'appuie pas sur des serveurs Web tels qu'Apache ou Nginx, mais exécute lui-même l'intégralité de l'application en démarrant un processus PHP. Workerman a une efficacité opérationnelle extrêmement élevée et une meilleure capacité de charge.

En même temps, HBase est un système de base de données NoSQL distribué largement utilisé dans le domaine du traitement du Big Data. L'avantage de HBase est sa forte évolutivité horizontale et son expansion illimitée pour gérer des données massives. En raison de son évolutivité extrêmement élevée, HBase est devenu partie intégrante de l'écosystème Hadoop et est progressivement devenu le premier choix pour le stockage et le traitement de données à grande échelle.

Cet article expliquera comment utiliser HBase pour le stockage de données et les requêtes dans Workerman.

1. Installation et configuration de HBase

Avant de commencer à utiliser HBase, vous devez d'abord installer et configurer HBase. Ici, nous utilisons les étapes de la documentation officielle de HBase pour l'installation et la configuration.

1. Téléchargez HBase

Téléchargez la dernière version de HBase depuis le site officiel de HBase, sélectionnez la version hbase-2.2.4 ici.

2. Décompressez HBase

Décompressez le package HBase téléchargé et déplacez-le vers le répertoire spécifié.

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

3 Modifier le fichier de configuration

Modifiez le fichier de configuration de HBase, le fichier de configuration est situé dans le répertoire "/usr /local/hbase/conf". Incluant principalement "hbase-env.sh", "hbase-site.xml", "regionservers", etc.

(1) Modifiez le fichier hbase-env.sh

Ajoutez le contenu suivant à la fin du fichier :

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

La première La première ligne spécifie le répertoire d'installation Java, la deuxième ligne indique de ne pas utiliser le ZooKeeper intégré à HBase et la troisième ligne définit la mémoire maximale du processus HBase.

(2) Modifiez le fichier hbase-site.xml

Ajoutez le contenu suivant à la fin du fichier :

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

where "file:///usr /local/hbase/ data" indique le répertoire racine du stockage de données HBase spécifié.

(3) Modifiez le fichier régionsservers

Modifiez le fichier "/usr/local/hbase/conf/regionservers", ajoutez l'adresse IP locale au fichier et enregistrez-le.

4. Démarrez HBase

Exécutez la commande suivante pour démarrer HBase :

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

5 Vérifiez si HBase démarre correctement

Exécutez la commande suivante. pour vérifier si HBase a été démarré avec succès :

./bin/status.sh

La sortie de "HMaster" indique que HBase a été démarré avec succès.

2. Installation du client PHP HBase

Le client HBase de PHP propose de nombreux packages open source, tels que HBase-thrift, HBase-rest, etc. Cet article choisit d'utiliser la bibliothèque HBase-PHP, qui est un client compatible avec le protocole HBase1.0.0 implémenté en PHP pur.

1. Installez la bibliothèque HBase-PHP

Vous pouvez installer la bibliothèque HBase-PHP via Composer. Exécutez la commande suivante pour installer :

composer require rwgrier/HBase-PHP

2. Créez une connexion HBase

Appelez la méthode constructeur de la classe HBaseClient pour établir une connexion :

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

Vous devez spécifier l'adresse HBase et le numéro de port pour établir un connexion.

3. Utiliser HBase dans Workerman

Utiliser HBase dans Workerman est également très simple. Il vous suffit d'ajouter le code pour créer la connexion HBase dans les étapes ci-dessus à votre propre code. Voici un exemple simple :

use WorkermanWorker;
require_once DIR '/vendor/autoload.php';
use HBaseClientHBaseClient;
// Créer une instance Workerman
$worker = new Worker() ;
// Établir une connexion HBase
$client = new HBaseClient([
'host' => 'localhost',
'port' => 9090
]);
$worker->onMessage = function ($connection , $data) use ($client) {
// Obtenir les données
$result = $client->get('mytable', 'row-key');
$row = current($result);
// Processus data
$value = $row->getColumnValue('cf1:col1');
// Renvoie les données
$connection->send($value);
};
// Démarre le processus de travail
Worker:: runAll();

Dans l'exemple ci-dessus, nous obtenons les données d'une table "mytable" en utilisant la connexion HBase et renvoyons les données obtenues à la connexion client. Pour plus d'informations sur l'utilisation de l'API de HBase, veuillez consulter la documentation officielle de HBase-PHP.

Résumé

L'utilisation de Workerman et HBase peut facilement atteindre des performances élevées et un stockage de données massif, ainsi que réaliser des requêtes et des traitements de données en temps réel. Workerman et HBase sont tous deux des logiciels open source. Leurs excellentes performances et stabilité ont été reconnues par un grand nombre d'utilisateurs et peuvent répondre aux besoins d'applications à grande échelle. Cet article présente la méthode d'utilisation de Workerman avec HBase pour le stockage et les requêtes de données. Dans le développement réel, il doit être ajusté et optimisé en fonction de la situation réelle.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!