Introduction à PubNub Events & Actions

PubNub Events & Actions est un service PubNub qui vous permet de capturer des événements PubNub spécifiques, tels que la publication d'un message, et d'envoyer ces événements à des écosystèmes tiers. Nous supportons l'envoi d'événements PubNub vers ces écosystèmes, que nous définissons comme une action PubNub, comme la connexion d'un webhook ou la connexion directe à vos services cloud, comme AWS, et bien d'autres encore à venir. Tout est configuré dès maintenant dans le portail d'administration, sans aucun codage.

Veuillez vous référer à notre documentation pour plus d'informations sur la façon de démarrer avec PubNub Events & Actions. Vous pouvez également consulter notre guide pratique sur la la configuration des événements et des actionsqui couvre les bases de la création d'écouteurs d'événements et d'actions. Consultez également le how-to sur filtrer les messages à l'aide de JSONPath pour plus de détails sur le filtrage des événements.

Qu'est-ce que l'AMQP ?

Le protocole avancé de mise en file d'attente des messages (AMQP) est un protocole de messagerie qui permet aux applications clientes de communiquer avec des courtiers intermédiaires de messagerie par le biais d'une API évolutive et sécurisée. Créé en 2003 par John O'Hara chez JPMorgan Chase à Londres, AMQP facilite les solutions de messagerie complexes, y compris le streaming de données IoT et l'intégration de services dorsaux. À la mi-2005, les efforts visant à former un groupe d'utilisateurs AMQP ont vu la participation de géants de l'informatique tels que Cisco, Red Hatet IONA Technologiesen mettant l'accent sur l'importance des modèles de messagerie de type publication/abonnement.

Les courtiers et leur rôle

Les courtiers en messagerie reçoivent les messages des éditeurs (applications qui les publient, également appelées producteurs) et les acheminent vers les consommateurs (applications qui les traitent).

Comme il s'agit d'un protocole réseau, les éditeurs, les consommateurs et le courtier peuvent tous résider sur des machines différentes.

Qu'est-ce que RabbitMQ ?

RabbitMQ est un logiciel libre de mise en file d'attente de messages connu sous le nom de courtier de messages ou gestionnaire de file d'attente. RabbitMQ implémente AMQP 0.9.1 comme base d'un ensemble de normes contrôlant l'ensemble du processus de mise en file d'attente de messages. AMQP 0.9.1 a été publié en novembre 2008, et c'est également la version utilisée dans ce tutoriel. En termes simples, il s'agit d'un logiciel dans lequel sont définies des files d'attente auxquelles les applications se connectent pour transférer un ou plusieurs messages.

Un message peut contenir n'importe quel type d'information. Il peut, par exemple, contenir des informations sur un processus ou une tâche qui doit démarrer sur une autre application (qui peut même se trouver sur un autre serveur), ou il peut s'agir d'un simple message texte. Le logiciel de gestion des files d'attente stocke les messages jusqu'à ce qu'une application réceptrice se connecte et retire un message de la file d'attente. L'application réceptrice traite alors le message.

Un courtier de messages agit comme un intermédiaire pour divers services (par exemple, une application web). Il peut réduire la charge de travail et les délais de livraison des serveurs d'applications web en déléguant des tâches qui prendraient normalement beaucoup de temps ou de ressources.

Créer une action PubNub RabbitMQ (AMQP)

La connexion des événements PubNub à RabbitMQ combine la messagerie en temps réel avec une mise en file d'attente efficace des messages. Cette connexion permet un traitement évolutif des messages et la création de données propriétaires, garantissant une propriété et un contrôle complets sur votre flux d'informations.

Pré-requis

Assurez-vous d'avoir un compte PubNub et consultez le site Web de PubNub. Prix des événements et actions pour en savoir plus sur les coûts. Vous pouvez également naviguer vers Events & Actions dans le portail d'administration de Pubnub et sélectionner "Upgrade" pour voir les plans de prix pour Events & Actions. Pour ce how-to, nous allons utiliser la console PubNub Debug pour publier des messages et vérifier le traitement de ces messages à l'intérieur d'une instance RabbitMQ.

Mise en place d'une instance RabbitMQ

Nous allons configurer une instance RabbitMQ au sein d'AWS en utilisant Amazon MQce qui permet de mettre en place des courtiers. Il existe de nombreuses façons d'héberger un courtier de messages ou, plus précisément, un courtier RabbitMQ, par exemple en exécutant une image RabbitMQ dans un conteneur Docker et en l'hébergeant à l'aide d'une instance EC2. Cependant, pour ce guide pratique, nous utiliserons Amazon MQ.

Pour créer une instance RabbitMQ dans Amazon MQ, suivez les étapes ci-dessous :

1. Connectez-vous à Amazon Web Services (AWS)

2. Dans la barre de recherche, recherchez "Amazon MQ" et cliquez sur le service Amazon MQ.

3. Cliquez sur le bouton "Create brokers" pour configurer votre courtier.

4. Sous "Broker engine types", sélectionnez "Rabbit MQ".

5. Sélectionnez votre mode de déploiement (en fonction du cas d'utilisation de votre application)

6. Sélectionnez "Single-instance broker" car vous n'avez pas besoin de plusieurs zones de disponibilité.

7. Saisissez un nom de courtier tel que "rabbit-1".

8. Sous Accès RabbitMQ, entrez un nom d'utilisateur et un mot de passe pour la console de gestion RabbitMQ. Vous les utiliserez plus tard pour vous connecter à votre instance RabbitMQ.

9. Souvenez-vous de votre nom d'utilisateur et de votre mot de passe, car vous ne pourrez pas les consulter à nouveau.

10. Sélectionnez "Create Broker" (Créer un courtier). La création du courtier prendra environ 20 minutes.

Après avoir suivi ces étapes, votre portail Web Amazon devrait ressembler à ce qui suit :

Votre courtier de messages est maintenant configuré pour commencer à traiter les événements PubNub. Il ne nous reste plus qu'à connecter votre instance RabbitMQ aux événements et actions PubNub.

Mise en place d'un écouteur d'événements PubNub

Nous allons configurer un écouteur d'événements PubNub pour écouter des événements PubNub spécifiques et même filtrer les événements PubNub si nécessaire. Les écouteurs d'événements attendent un ensemble particulier de conditions pour déclencher une action prédéfinie, comme l'envoi de messages PubNub à votre instance RabbitMQ. Pour plus d'informations sur le filtrage des événements PubNub, consultez notre documentation.

Pour créer un écouteur d'événements, suivez les étapes ci-dessous :

1. Connectez-vous au Portail d'administration.

2. Cliquez sur l'onglet Événements et actions dans la partie gauche du portail.

3. Suivez la boîte de dialogue et sélectionnez l'une de vos applications.

4. Suivez la boîte de dialogue et choisissez un jeu de clés.

5. Cliquez sur le bouton "+ Event Listener".

6. Choisissez votre source d'événement. Pour ce guide, nous choisirons "Messages".

7. Sous "Event Producer", sélectionnez "Pub/Sub".

8. Sous "Event Type", sélectionnez "Message sent".

9. Sélectionnez votre type de filtre pour ce guide pratique, "Pas de filtre".

10. Par exemple, cliquez sur l'icône du crayon pour nommer votre auditeur d'événement : "Rabbit-1 Listener".

11. Cliquez sur "Enregistrer les modifications" en bas à droite de l'écran.

Après avoir suivi ces étapes, l'événement sur le portail PubNub devrait ressembler à ce qui suit :

Configuration d'une action PubNub vers Rabbit MQ

Maintenant, nous allons configurer une action Rabbit MQ sur le portail PubNub :

1. Retournez sur l'onglet "Events & Actions" et sélectionnez "+ Add Action"

2. Sous "Action Type", sélectionnez "AMQP".

3. Sélectionnez le menu déroulant "Add event listener" et sélectionnez l'écouteur d'événement créé ci-dessus. Dans ce cas, sélectionnez "Rabbit-1 Listener".

Nous devons obtenir l'URL AMQP de notre instance RabbitMQ. Tout d'abord, les URL AMQP sont formatées de la manière suivante :

a*mqps://*username:password@host.name:port

Le nom d'utilisateur et le mot de passe que vous avez attribué à l'instance RabbitMQ seront utilisés ici pour que PubNub puisse envoyer des messages à votre instance. Dans mon cas, l'URL serait définie comme suit :

a*mqps://*username:password@b-d7d2f067-c7be-45a9-8c20-de79a3c309d0.mq.us-west-2.amazonaws.com:5671

Vous pouvez trouver le nom d'hôte en naviguant vers l'instance Rabbit MQ dans Amazon MQ.

1. Sélectionnez votre instance ; si vous avez suivi, sélectionnez l'instance "rabbit-1".

2. Faites défiler vers le bas. Sous "Connections" et "Endpoints", copiez le nom d'hôte et le port.

Dans ce cas, mon nom d'hôte était :

b-d7d2f067-c7be-45a9-8c20-de79a3c309d0.mq.us-west-2.amazonaws.com:5671

Jusqu'à présent, notre action devrait ressembler à ceci. Cependant, nous devons créer et échanger une clé de routage. Pour ce faire, suivez les étapes ci-dessous :

1. Retournez à l'instance Amazon MQ "rabbit-1".

2. Faites défiler vers le bas jusqu'à Connections et cliquez sur le lien RabbitMQ web console. Vous serez alors dirigé vers la console de gestion RabbitMQ.

3. Vous devriez voir une page web qui ressemble à ceci :

Saisissez le nom d'utilisateur et le mot de passe définis précédemment lors de la création de l'instance RabbitMQ. Après vous être connecté à la console de gestion RabbitMQ, nous allons créer une file d'attente. Suivez les étapes ci-dessous pour obtenir votre clé de routage :

1. Après vous être connecté à la console de gestion, naviguez jusqu'à l'onglet "Queues".

2. Sélectionnez le menu déroulant "Add a new queue" (Ajouter une nouvelle file d'attente).

3. Donnez un nom à la file d'attente ; ce sera votre clé de routage.

4. Sélectionnez "Ajouter une file d'attente".

Votre console de gestion devrait maintenant ressembler à ceci :

Nous allons maintenant créer un échange pour votre file d'attente. Un échange est l'endroit où les messages sont envoyés. Les échanges prennent les messages et les acheminent vers 0 ou plusieurs files d'attente. L'algorithme de routage dépend du type d'échange et des règles appelées "bindings". Créons un échange.

1. Naviguez vers l'onglet "Echanges".

2. Sélectionnez l'échange "amqp.direct".

3. Sélectionnez le menu déroulant "Bindings". C'est ici que nous allons lier l'échange à votre file d'attente.

4. Dans l'onglet "To queue", nous voulons écrire "Publisher" car c'est le nom de notre file d'attente.

5. La clé de routage peut être celle que vous préférez. J'ai utilisé "amqp.publisher" pour la mienne.

La configuration de votre console RabbitMQ devrait maintenant refléter la configuration de l'échange et de la clé de routage, adaptée à la gestion de données et de notifications en temps réel dans une architecture microservices.

Copiez le nom de votre clé de routage et de votre terrain d'échange dans les champs requis de l'action PubNub :

Tester votre intégration RabbitMQ avec PubNub E&A

Nous pouvons utiliser la PubNub Debug Console pour tester notre intégration. Naviguez vers le portail d'administration de PubNub, et sur le côté gauche, sélectionnez "Debug Console". Puisque nous n'avons pas de filtres dans notre Event Listener, chaque fois que nous publions un message sur n'importe quel canal, notre action doit se déclencher et le message PubNub doit être envoyé pour être traité par notre instance RabbitMQ. Il suffit de taper un message et de cliquer sur "Send" sur l'un ou l'autre des clients. Nous allons maintenant vérifier si notre instance RabbitMQ a reçu ce message.

Une fois que nous avons publié un message, nous devrions pouvoir le voir apparaître dans la file d'attente "Publisher" dans la RabbitMQ Management Console, ce qui démontre l'efficacité du débit des messages et la robustesse de notre système de messagerie en temps réel. Vous devriez voir votre message dans la console RabbitMQ comme ceci.

Dans ce cas, j'ai publié 7 messages, qui sont tous dans la file d'attente, prêts à être traités.

Ce qui suit

Ce how-to a décrit les étapes pour configurer PubNub Events & Actions et une instance RabbitMQ hébergée pour développer des systèmes de messagerie réactifs garantissant un débit élevé de livraison de messages. Il existe de nombreux cas d'utilisation pour lesquels quelqu'un voudrait traiter ses propres messages PubNub, tels que la définition d'une opération avec l'interactivité en temps réel que PubNub fournit avec vos données connectées à vos serveurs web. Par exemple, en utilisant le PubNub Unity SDKle traitement en temps réel des actions de l'utilisateur dans les jeux multijoueurs peut être utilisé pour le matchmaking, les mises à jour en direct de l'état du jeu, les classements et le chat dans le jeu, offrant ainsi une expérience de jeu plus interactive. Il existe de nombreux autres cas d'utilisation pour les applications web. Javascript ou Java SDK.

Bien que cet article ait discuté d'une des actions PubNub que vous pouvez mettre en place avec PubNub E&A, il y en a beaucoup d'autres, qui incluent :

• Faire un appel Webhook (c'est-à-dire appeler votre serveur pour chaque événement filtré)

• Sauvegarder dans SQS (c.-à-d. enregistrer chaque événement dans la file d'attente SQS d'Amazon) le service de mise en file d'attente SQS d'Amazon)

• Envoyer à Kinesis (c.-à-d. envoyer au service d'ingestion d'événements service d'ingestion d'événements d'Amazon)

• Envoi vers S3 (c'est-à-dire stocker les données dans un panier Amazon S3)

• Envoyer à Kafka (c'est-à-dire envoyer les données à Apache Kafka)

• Créer une action IFTTT (c'est-à-dire envoyer à Si Ceci Alors Cela)

N'hésitez pas à contacter l'équipe chargée des relations avec les développeurs à l'adresse devrel@pubnub.com si vous avez des questions ou des préoccupations.

Sommaire

Introduction aux événements et actions PubNubQu'est-ce queAMQPLes courtierset leur rôleQu'est-ce queRabbitMQCréation d'une action PubNub RabbitMQ (AMQP)PrérequisConfigurationd'une instance RabbitMQConfiguration d'un écouteur d'événements PubNubConfiguration d'uneaction PubNub vers Rabbit MQTestervotre intégration RabbitMQ avec PubNub E&AQu'est-ce qu'il y a deplus important ?

Comment PubNub peut-il vous aider ?

Cet article a été publié à l'origine sur PubNub.com

Notre plateforme aide les développeurs à construire, livrer et gérer l'interactivité en temps réel pour les applications web, les applications mobiles et les appareils IoT.

La base de notre plateforme est le réseau de messagerie en temps réel le plus grand et le plus évolutif de l'industrie. Avec plus de 15 points de présence dans le monde, 800 millions d'utilisateurs actifs mensuels et une fiabilité de 99,999 %, vous n'aurez jamais à vous soucier des pannes, des limites de concurrence ou des problèmes de latence causés par les pics de trafic.

Découvrez PubNub

Découvrez le Live Tour pour comprendre les concepts essentiels de chaque application alimentée par PubNub en moins de 5 minutes.

S'installer

Créez un compte PubNub pour un accès immédiat et gratuit aux clés PubNub.

Commencer

La documentation PubNub vous permettra de démarrer, quel que soit votre cas d'utilisation ou votre SDK.