Comment utiliser Cassandra pour le stockage de données dans Workerman

Comment utiliser Cassandra pour le stockage de données dans Workerman

Dans le développement logiciel actuel, différentes méthodes et moteurs de stockage de données sont largement utilisés. Cassandra, en tant que base de données NoSQL distribuée à haute disponibilité, joue un rôle important dans le domaine du Big Data. Cet article explique comment utiliser Cassandra pour le stockage de données dans Workerman et fournit des exemples de code pertinents.

1. Installer l'extension PHP Cassandra

Avant de commencer à utiliser Cassandra, nous devons installer l'extension PHP de Cassandra. Exécutez la commande suivante dans le terminal pour installer :

sudo apt-get install libuv-dev libssl-dev libcurl4-openssl-dev libsasl2-dev pecl install cassandra

Une fois l'installation terminée, vous devez également ajouter la ligne suivante au fichier php.ini :

extension=cassandra.so

Redémarrez le serveur Web PHP pour que les modifications prennent effet.

2. Configurer la connexion Cassandra

Ensuite, nous devons configurer les informations de connexion Cassandra à utiliser dans Workerman. Créez un nouveau fichier PHP nommé cassandra.php et ajoutez le contenu suivant :

withContactPoints('127.0.0.1') // Cassandra节点IP地址 ->withPort(9042) // Cassandra端口号 ->withDefaultConsistency(1) ->build(); $session = $cluster->connect('mykeyspace'); // 替换为你自己的keyspace名称 function execute_query($query) { global $session; $result = $session->execute(new SimpleStatement($query)); return $result; }

Dans ce code, nous utilisons le pilote PHP Cassandra pour établir une connexion à la base de données Cassandra et définir une fonction execute_query pour l'exécution de l'instruction de requête CQL.

3. Utilisation de Cassandra dans Workerman

Ensuite, nous montrerons comment utiliser Cassandra dans Workerman pour le stockage de données. Tout d'abord, nous devons introduire la configuration de la connexion Cassandra dans le projet Workerman. Créez un nouveau fichier PHP, nommez-le travailleur.php et ajoutez le contenu suivant :

onMessage = function ($connection, $request) { $path = $request->path(); $result = ''; if ($path == '/save') { $name = $_POST['name']; $email = $_POST['email']; $query = "INSERT INTO users (name, email) VALUES ('$name', '$email')"; execute_query($query); $result = 'Data saved successfully'; } $response = new Response(200, [], $result); $connection->send($response); }; Worker::runAll();

Dans ce code, nous créons un Http Worker et définissons la fonction de rappel onMessage pour gérer les requêtes HTTP. Si le chemin demandé est /save, nous obtenons le nom et l'e-mail des paramètres POST et les insérons dans la base de données Cassandra.

4. Démarrez le serveur Workerman

Maintenant que nous avons terminé la configuration de la connexion Cassandra et de Workerman, nous pouvons démarrer le serveur Workerman. Exécutez la commande suivante dans le terminal :

php worker.php start

Le serveur démarrera à ce moment-là et écoutera sur le port 8000.

5. Test

Entrez l'URL suivante dans le navigateur pour tester :

http://localhost:8000/save

Ajoutez le nom et l'e-mail aux paramètres POST et cliquez pour envoyer la demande. Si tout se passe bien, vous recevrez une réponse indiquant que les données ont été enregistrées avec succès.

Résumé

Cet article explique comment utiliser Cassandra pour le stockage de données dans Workerman. En installant l'extension PHP Cassandra, en configurant les informations de connexion Cassandra et en écrivant le code correspondant dans Workerman, nous pouvons facilement interagir avec la base de données Cassandra et implémenter la fonction de stockage de données. J'espère que cet article pourra vous fournir de l'aide lors de l'utilisation de Workerman et Cassandra.

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!