JBoss Fuse - Apache AMQ

Dans ce chapitre, nous découvrirons ActiveMQ et comment il agit en tant que courtier de messages pour permettre aux applications de communiquer entre elles.

Qu'est-ce que l'AMQ?

ActiveMQ est un courtier de messages open source écrit en Java. Il est entièrement conforme aux normes JMS 1.1.

JMS est une spécification qui permet le développement d'un système basé sur les messages. ActiveMQ agit comme un courtier de messages qui se situe entre les applications et leur permet de communiquer de manière asynchrone et fiable.

Types de messagerie

Il existe deux types d'options de messagerie expliquées ci-dessous pour une meilleure compréhension.

Point à point

Dans ce type de communication, le courtier n'envoie des messages qu'à un seul consommateur, tandis que les autres consommateurs attendront de recevoir les messages du courtier. Aucun consommateur ne recevra le même message.

S'il n'y a pas de consommateurs, le courtier conservera les messages jusqu'à ce qu'il obtienne un consommateur. Ce type de communication est également appeléQueue based communicationoù le producteur envoie des messages à une file d'attente et un seul consommateur reçoit un message de la file d'attente. S'il y a plus d'un consommateur, ils peuvent recevoir le message suivant mais ils ne recevront pas le même message que l'autre consommateur.

Publier / S'abonner

Dans ce type de communication, le Broker envoie la même copie des messages à tous les consommateurs actifs. Ce type de communication est également appeléTopic based communicationoù le courtier envoie le même message à tous les consommateurs actifs qui se sont abonnés à un sujet particulier. Ce modèle prend en charge la communication unidirectionnelle où aucune vérification des messages transmis n'est attendue.

Création d'une file d'attente et de sujets

Fuse est livré avec ActiveMQ. Nous pouvons accéder à ActiveMQ à l'aide de la console FMC (l'interface basée sur le navigateur pour travailler avec AMQ).

Connectez-vous à FMC en utilisant localhost:8181 et sélectionnez ActiveMQ languette.

  • Cliquez sur + Créer
  • Entrez le nom de la file d'attente / du sujet
  • Sélectionnez File d'attente / Sujet dans le bouton radio
  • Cliquez sur Créer une file d'attente / Créer un sujet

Vous devriez maintenant pouvoir voir le TestQ créé sous root → File d'attente →

Pour vérifier le sujet créé, suivez root → Sujet.

Parcourir / supprimer le contenu de la file d'attente

  • Connectez-vous à FMC en utilisant localhost:8181

  • Sélectionnez l'onglet ActiveMQ

  • Racine → File d'attente → TestQ <sélectionnez la file d'attente que vous souhaitez parcourir> → Parcourir

  • Pour vérifier le contenu de ce message, cliquez sur ce message particulier.

  • Vous pouvez supprimer un message particulier en cliquant sur le bouton Supprimer affiché dans le coin supérieur droit