Maison développement back-end tutoriel php Comment utiliser Google Cloud Pub/Sub pour implémenter l'abonnement et la publication de messages dans le développement PHP

Comment utiliser Google Cloud Pub/Sub pour implémenter l'abonnement et la publication de messages dans le développement PHP

Jun 25, 2023 am 09:15 AM
php开发 google cloud pub/sub 消息订阅

Google Cloud Pub/Sub est un service de messagerie entièrement géré qui vous permet de transférer de manière fiable des données en temps réel et asynchrones entre plusieurs applications. Il s'agit d'une solution largement utilisée qui répond à de nombreux cas d'utilisation tels que l'équilibrage de charge, l'informatique basée sur les événements, la journalisation, les notifications et les analyses, etc.

Dans le développement PHP, il est également possible d'utiliser Google Cloud Pub/Sub pour mettre en œuvre l'abonnement et la publication des messages. Cet article explique comment utiliser Google Cloud Pub/Sub pour la messagerie à partir d'une application PHP.

  1. Créer un service Google Cloud Pub/Sub

Avant d'utiliser Google Cloud Pub/Sub, vous devez activer l'API Google Cloud Pub/Sub sur Google Cloud Console et créer un compte de service Google Cloud Pub/Sub.

Activer l'API Google Cloud Pub/Sub :

  1. Ouvrez Google Cloud Console
  2. Sélectionnez les API et les services dans le menu -> Tableau de bord
  3. Entrez "API Google Cloud Pub/Sub" dans le champ de recherche et sélectionnez Service correspondant
  4. Cliquez sur le bouton d'activation

Créez un compte de service Google Cloud Pub/Sub :

  1. Ouvrez la console Google Cloud
  2. Sélectionnez IAM et gestion-> Compte de service dans le menu de gauche
  3. Cliquez sur le bouton Créer un compte de service
  4. Saisissez le nom et la description du compte de service dans la fenêtre contextuelle
  5. Sélectionnez Pub/Sub dans la liste déroulante des rôles -> Récepteur Pub/Sub ou Éditeur Pub/Sub
  6. Cliquez sur le bouton Enregistrer
  7. Dans le champ In généré. sur la page de détails du compte de service, cliquez sur le bouton "Créer une clé" et sélectionnez le format JSON
  8. Installez le SDK Google Cloud Pub/Sub pour PHP

Le SDK Google Cloud Pub/Sub pour PHP est la version officielle de Google Cloud Pub/Sub Bibliothèque PHP pouvant être utilisée pour implémenter la messagerie dans les applications PHP.

Installez facilement le SDK Google Cloud Pub/Sub pour PHP à l'aide de Composer :

composer require google/cloud-pubsub
Copier après la connexion
  1. Publication de messages

La publication de messages à l'aide de Google Cloud Pub/Sub est très simple. Le code suivant peut publier un message dans un sujet nommé "exemple-sujet" :

require_once 'vendor/autoload.php';

use GoogleCloudPubSubPubSubClient;

$pubsub = new PubSubClient();

$topic = $pubsub->topic('example-topic');

$topic->publish(['data' => 'Hello, World!']);
Copier après la connexion

Dans le code ci-dessus, l'autochargeur du fichier "vendor/autoload.php" est d'abord utilisé. Ensuite, instanciez un objet client PubSub à l'aide de la classe "GoogleCloudPubSubPubSubClient".

Ensuite, autorisez l'objet client Pub/Sub à l'aide des informations d'identification du compte de service créées à l'étape précédente. Une fois l'objet client autorisé, vous pouvez l'utiliser pour opérer sur vos rubriques et abonnements.

Ensuite, vous devez utiliser la méthode $pubsub->topic() pour obtenir un pointeur vers le sujet nommé "exemple-sujet". Ensuite, utilisez la méthode $topic->publish() pour publier des messages dans le sujet. La méthode

publish() accepte un paramètre de tableau, où la clé "data" est utilisée pour spécifier le contenu du message à publier.

  1. S'abonner aux messages

Pour vous abonner aux messages, vous devez créer un abonnement qui se connectera à un sujet et recevra tous les messages publiés par le sujet.

Le code suivant crée un abonnement nommé "exemple-abonnement" et s'abonne à un sujet nommé "exemple-sujet" :

require_once 'vendor/autoload.php';

use GoogleCloudPubSubPubSubClient;

$pubsub = new PubSubClient();

$topic = $pubsub->topic('example-topic');

$subscription = $topic->subscription('example-subscription');

if (!$subscription->exists()) {
    $subscription->create();
}

$messages = $subscription->pull();

foreach ($messages as $message) {
    echo $message->data() . PHP_EOL;
    $subscription->acknowledge($message);
}
Copier après la connexion

Dans le code ci-dessus, utilisez d'abord le chargement automatique dans le périphérique de fichier "vendor/autoload.php".

Ensuite, instanciez un objet client PubSub à l'aide de la classe "GoogleCloudPubSubPubSubClient".

Ensuite, utilisez la méthode $pubsub->topic() pour obtenir un pointeur vers le sujet nommé "exemple-sujet". Ensuite, utilisez la méthode $topic->subscription() pour obtenir un pointeur vers l’abonnement nommé « exemple-abonnement ».

Si l'abonnement n'existe pas, utilisez la méthode $subscription->create() pour créer l'abonnement.

Utilisez la méthode $subscription->pull() pour extraire les messages de l'abonnement. La méthode $subscription->pull() renverra un tableau contenant les objets de message renvoyés.

Si un message est reçu, parcourez le tableau de messages, affichez le contenu du message et utilisez la méthode $subscription->acknowledge() pour confirmer que le message a été consommé.

Remarque : La méthode pull() se bloque jusqu'à ce qu'un message soit reçu ou que le délai d'attente soit atteint. Si vous souhaitez attendre de nouveaux messages, vous pouvez utiliser la méthode accusé de réception() pour accuser réception des messages reçus.

  1. Conclusion

Dans le développement PHP, il est très simple d'utiliser Google Cloud Pub/Sub pour mettre en œuvre l'abonnement et la publication de messages. Utilisez simplement la bibliothèque Google Cloud Pub/Sub SDK pour PHP et suivez les étapes ci-dessus pour intégrer Google Cloud Pub/Sub dans votre application.

De plus, Google Cloud Pub/Sub propose de nombreuses fonctions avancées, telles que l'utilisation de filtres d'abonnement pour filtrer les messages, la définition du délai d'expiration et du temps de conservation des tâches de messagerie, etc., qui peuvent être utilisées en fonction des conditions réelles.

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!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

AI Hentai Generator

AI Hentai Generator

Générez AI Hentai gratuitement.

Article chaud

R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
1 Il y a quelques mois By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Meilleurs paramètres graphiques
1 Il y a quelques mois By 尊渡假赌尊渡假赌尊渡假赌
Will R.E.P.O. Vous avez un jeu croisé?
1 Il y a quelques mois By 尊渡假赌尊渡假赌尊渡假赌

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Comment utiliser Memcache dans le développement PHP ? Comment utiliser Memcache dans le développement PHP ? Nov 07, 2023 pm 12:49 PM

Dans le développement Web, nous devons souvent utiliser une technologie de mise en cache pour améliorer les performances du site Web et la vitesse de réponse. Memcache est une technologie de mise en cache populaire qui peut mettre en cache n'importe quel type de données et prend en charge une simultanéité élevée et une haute disponibilité. Cet article explique comment utiliser Memcache dans le développement PHP et fournit des exemples de code spécifiques. 1. Installer Memcache Pour utiliser Memcache, nous devons d'abord installer l'extension Memcache sur le serveur. Dans le système d'exploitation CentOS, vous pouvez utiliser la commande suivante

Apprenez étape par étape à développer votre propre site Web de forum en utilisant PHP Apprenez étape par étape à développer votre propre site Web de forum en utilisant PHP Oct 28, 2023 am 08:23 AM

Avec le développement rapide d'Internet et la demande croissante d'échange d'informations, les sites de forum sont devenus une plate-forme sociale en ligne courante. Développer votre propre site Web de forum peut non seulement répondre à vos propres besoins personnalisés, mais également fournir une plate-forme de communication et de partage, bénéficiant à un plus grand nombre de personnes. Cet article vous apprendra étape par étape comment utiliser PHP pour développer votre propre site Web de forum. J'espère qu'il sera utile aux débutants. Tout d’abord, nous devons clarifier certains concepts et préparatifs de base. PHP (HypertextPreproces

Décrivez les principes solides et comment ils s'appliquent au développement de PHP. Décrivez les principes solides et comment ils s'appliquent au développement de PHP. Apr 03, 2025 am 12:04 AM

L'application du principe solide dans le développement de PHP comprend: 1. Principe de responsabilité unique (SRP): Chaque classe n'est responsable d'une seule fonction. 2. Principe ouvert et ferme (OCP): les changements sont réalisés par extension plutôt que par modification. 3. Principe de substitution de Lisch (LSP): les sous-classes peuvent remplacer les classes de base sans affecter la précision du programme. 4. Principe d'isolement d'interface (ISP): utilisez des interfaces à grain fin pour éviter les dépendances et les méthodes inutilisées. 5. Principe d'inversion de dépendance (DIP): les modules élevés et de bas niveau reposent sur l'abstraction et sont mis en œuvre par injection de dépendance.

Comment utiliser PHP pour développer une plateforme de services de tutorat en ligne Comment utiliser PHP pour développer une plateforme de services de tutorat en ligne Oct 28, 2023 am 09:01 AM

Comment utiliser PHP pour développer une plateforme de services de tutorat en ligne Avec le développement rapide d'Internet, les plateformes de services de tutorat en ligne ont attiré de plus en plus l'attention et la demande. Les parents et les étudiants peuvent facilement trouver des tuteurs appropriés grâce à une telle plateforme, et les tuteurs peuvent également mieux démontrer leurs capacités et avantages pédagogiques. Cet article explique comment utiliser PHP pour développer une plateforme de services de tutorat en ligne. Tout d’abord, nous devons clarifier les exigences fonctionnelles de la plateforme. Une plateforme de services de tutorat en ligne doit avoir les fonctions de base suivantes : Système d'inscription et de connexion : les utilisateurs peuvent

Partage d'expériences de développement Java à partir de zéro : création d'un système d'abonnement aux messages Partage d'expériences de développement Java à partir de zéro : création d'un système d'abonnement aux messages Nov 20, 2023 pm 04:02 PM

En tant que langage de programmation très populaire, Java a toujours été privilégié par tous. Lorsque j'ai commencé à apprendre le développement Java, j'ai rencontré un jour un problème : comment créer un système d'abonnement aux messages. Dans cet article, je partagerai mon expérience dans la création d'un système d'abonnement aux messages à partir de zéro, dans l'espoir d'être utile à d'autres débutants Java. Étape 1 : Choisissez une file d'attente de messages appropriée Pour créer un système d'abonnement aux messages, vous devez d'abord choisir une file d'attente de messages appropriée. Les files d'attente de messages les plus populaires actuellement sur le marché incluent ActiveMQ,

Comment implémenter le contrôle de version et la collaboration de code dans le développement PHP ? Comment implémenter le contrôle de version et la collaboration de code dans le développement PHP ? Nov 02, 2023 pm 01:35 PM

Comment implémenter le contrôle de version et la collaboration de code dans le développement PHP ? Avec le développement rapide d'Internet et de l'industrie du logiciel, le contrôle de version et la collaboration en matière de code dans le développement de logiciels sont devenus de plus en plus importants. Que vous soyez un développeur indépendant ou une équipe de développement, vous avez besoin d'un système de contrôle de version efficace pour gérer les modifications de code et collaborer. Dans le développement PHP, il existe plusieurs systèmes de contrôle de version couramment utilisés, tels que Git et SVN. Cet article expliquera comment utiliser ces outils pour le contrôle de version et la collaboration de code dans le développement PHP. La première étape est de choisir celui qui vous convient

Comment utiliser PHP pour développer la fonction coupon du système de commande ? Comment utiliser PHP pour développer la fonction coupon du système de commande ? Nov 01, 2023 pm 04:41 PM

Comment utiliser PHP pour développer la fonction coupon du système de commande ? Avec le développement rapide de la société moderne, le rythme de vie des gens s'accélère de plus en plus et de plus en plus de gens choisissent de manger au restaurant. L'émergence du système de commande a considérablement amélioré l'efficacité et la commodité des commandes des clients. En tant qu'outil marketing pour attirer les clients, la fonction coupon est également largement utilisée dans divers systèmes de commande. Alors comment utiliser PHP pour développer la fonction coupon du système de commande ? 1. Conception de la base de données Tout d'abord, nous devons concevoir une base de données pour stocker les données relatives aux coupons. Il est recommandé de créer deux tables : une

Comment utiliser PHP pour développer la fonction de points membres du système d'épicerie ? Comment utiliser PHP pour développer la fonction de points membres du système d'épicerie ? Nov 01, 2023 am 10:30 AM

Comment utiliser PHP pour développer la fonction de points membres du système d'épicerie ? Avec l’essor du commerce électronique, de plus en plus de personnes choisissent d’acheter des produits de première nécessité en ligne, y compris leurs courses alimentaires. Le système d'épicerie est devenu le premier choix pour de nombreuses personnes, et l'une de ses caractéristiques importantes est le système de points d'adhésion. Le système de points d'adhésion peut attirer les utilisateurs et accroître leur fidélité, tout en offrant aux utilisateurs une expérience d'achat supplémentaire. Dans cet article, nous verrons comment utiliser PHP pour développer la fonction de points d'adhésion du système d'épicerie. Tout d'abord, nous devons créer une table d'adhésion pour stocker les utilisateurs

See all articles