Téléchargement des produits


Version anglaise


 

L'AMBSS est un gestionnaire de souscripteurs (subscribers) de courtiers de message (message brokers). Il permet à la plateforme Adélia Studio de consommer des messages dans un programme Adélia.

De plus, il offre la possibilité de gérer le cycle de vie d'un souscripteur à travers les opérations CRUD suivantes :

  • Créer un souscripteur
  • Lire un souscripteur
  • Mettre à jour un souscripteur
  • Supprimer un souscripteur


Cet outil s'exécute dans un environnement Java.

Prérequis

L'AMBSS fonctionne avec un JDK ou JRE Java version 1.8 minimum.

De plus, il est nécessaire d'avoir des connaissances sur les principes de fonctionnement des courtiers de message à utiliser et sur les principes et mécanismes de consommation de messages associés à ceux-ci.

Enfin, il est nécessaire d'avoir des connaissances sur l'installation et la configuration des courtiers ciblés, car cette partie n'est pas abordée dans cette aide.

Courtier de message

Un courtier de message (ou agent de message) est une application qui permet l'échange de messages en s'appuyant sur un protocole de communication donné (certains courtiers supportent plusieurs protocoles).

Ces principales fonctions sont :

  • Transport de messages : Les messages comportent deux parties : l'en-tête technique, utilisée par le courtier et les données (ou payload), qui peuvent être dans n'importe quel format.
  • Communication asynchrone : L'application émettrice d'un message et l'application réceptrice du message n'ont pas besoin d'être actives en même temps. La file d'attente reçoit le message de l'application émettrice et le stocke jusqu'à ce que l'application réceptrice vienne lire le message.
  • Routage : Les messages peuvent être routés entre courtiers. Par exemple, pour router un message entre deux sites distants disposant chacun d'un courtier installé localement.
  • Transformation des données : La plupart des courtiers permettent de changer le format des données contenues dans les messages pour les adapter à l'application réceptrice.
  • Persistance des messages : Les messages présents dans les files d'attente peuvent être sauvegardés sur un support physique pour en assurer la conservation en cas de panne.
  • Fiabilité : Chaque message envoyé par une application fait l'objet d'un accusé de réception par le courtier. Chaque application qui consomme un message envoie un accusé de réception au courtier. Couplé avec la persistance, ce mécanisme permet de garantir qu'aucun message ne sera perdu dans son transfert entre les applications.


Les courtiers ont deux modes de fonctionnement principaux :

  • Point à point : Une application produit des messages et une application les consomme. Les messages ne sont lus que par un seul consommateur. Une fois qu'un message est lu, il est retiré de la file d'attente.
  • Publish - Subscribe (Publier - S'abonner) : Les applications consommatrices des messages s'abonnent à un topic (sujet, catégorie de messages). Les messages envoyés à ce topic restent dans la file d'attente jusqu'à ce que toutes les applications abonnées aient lu le message.


L'AMBSS supporte les courtiers (ou protocoles) suivants :

↑ Haut de page

Souscripteur

Dans le cadre du paradigme Publish - Subscribe, un souscripteur (ou subscriber) est un destinataire de messages. Un destinataire s'abonne aux catégories de messages (ou sujets) l'intéressant et ne reçoit que les messages correspondant, sans savoir s'il y a des diffuseurs.

Les principales étapes de fonctionnement d'un souscripteur sont :

  • La connexion au courtier et l'abonnement aux catégories de messages à traiter.
  • La réception d'un message (soit initiée par la demande du souscripteur (modèle Pull), soit déclenchée par le courtier (modèle Push) et son traitement. Suivant le protocole de communication utilisé, le souscripteur peut avoir un temps de traitement de message limité et défini lors de la connexion au courtier,
  • Suivant le protocole de communication utilisé, le souscripteur peut acquitter le message traité : 
    • un acquittement positif indique au courtier que le message a été correctement traité et qu'il peut envoyer le message suivant ;
    • un acquittement négatif (en cas d'erreur lors du traitement du message) permet d'indiquer au courtier de renvoyer ultérieurement ce message.
  • La déconnection au courtier.


L'AMBSS ne gère que des souscripteurs. Cependant, il est possible avec Adélia Studio de créer des producteurs de messages compatibles avec les courtiers Kakfa et RABBITMQ (AMQP 0.9.1), grâce à l'utilisation de fonctions de la VaToolBx -Voir les Fonctions sur les agents de messages (message broker).

↑ Haut de page



  • Aucune étiquette