Les concepts avancés de JMS incluent des groupes de messages, des sélecteurs de messages, des modes de transaction et de confirmation et des files d'attente de lettres mortes. Le groupe de messages garantit que le même groupe de messages est traité par le même consommateur via JMSXGroupID pour assurer la séquence; Le sélecteur de messages filtre les messages basés sur des attributs, tels que MessageConsumer Consumer = Session.CreateConsumer (Topic, "EventType = 'Login'"); La transaction prend en charge le mode session.Session_Transacted, réalisant l'atomicité des opérations d'envoi et de réception; La file d'attente de lettres morte capture plusieurs messages échoués, ce qui facilite l'analyse et la réessayer ultérieurs, et améliore les capacités de tolérance aux défauts du système.

En travaillant avec Java Messaging Service (JMS), il est facile de faire baisser les bases: les files d'attente, les producteurs et les consommateurs. Mais une fois que vous avez dépassé les principes fondamentaux, il existe plusieurs concepts avancés qui peuvent rendre votre système de messagerie plus robuste, évolutif et fiable.

Voici quelques domaines clés qui méritent de plonger si vous construisez ou maintenez des applications graves basées sur JMS.

Groupes de messages

Les groupes de messages résolvent un problème commun dans les systèmes distribués: comment assurer la commande de messages lors de l'utilisation de plusieurs consommateurs.

Normalement, les messages envoyés à une file d'attente peuvent être traités par n'importe quel nombre de consommateurs. C'est génial pour l'évolutivité mais mauvais si l'ordre des messages compte. Par exemple, si vous traitez les échanges d'actions pour un compte particulier, vous ne voulez pas que le commerce B soit traité avant le commerce juste parce que deux consommateurs différents les ont récupérés de la commande.

Comment ?a marche:

• Chaque message se voit attribuer un ID de groupe ( JMSXGroupID ) qui identifie un groupe logique.
• Le fournisseur JMS garantit que tous les messages du même groupe sont traités par le même consommateur à la fois.
• Une fois qu'un consommateur reprend un groupe, aucun autre consommateur ne traitera les messages de ce groupe jusqu'à ce qu'il soit libéré.

Cela vous donne la commande par groupe tout en permettant le parallélisme entre les groupes.

Astuce: veillez à ne pas attribuer trop de messages à un seul groupe. Si vous le faites, vous perdrez les avantages du traitement parallèle.

Sélections de messages

Parfois, vous ne voulez pas que chaque consommateur re?oive chaque message. C'est là que les sélecteurs de messages sont utiles.

Les sélecteurs permettent aux consommateurs de filtrer les messages qu'ils re?oivent en fonction des propriétés d'en-tête de message ou des propriétés personnalisées définies par le producteur.

Exemple:

Supposons que vous ayez un sujet qui diffuse des événements utilisateur comme la connexion, la déconnexion, la mise à jour de profil, etc. Vous pourriez avoir des consommateurs distincts intéressés uniquement par des types d'événements spécifiques.

 MessageConsumer Consumer = Session.CreateConsumer (Topic, "EventType = 'Login'");

Dans ce cas, le consommateur ne re?oit que des événements de connexion.

Les cas d'utilisation incluent:

• Les messages de routage vers différents services en fonction du type de contenu
• Envoi de messages de test aux consommateurs de test spéciaux sans affecter ceux en direct
• Implémentation de filtres Pub / sous-sous-poids légers sans gérer plusieurs sujets

Remarque: Tous les fournisseurs JMS implémentent les sélecteurs avec les mêmes performances. Dans les environnements à haut débit, testez comment les sélecteurs affectent la vitesse de livraison.

Transactions et modes de reconnaissance

Obtenir la bonne livraison des messages signifie comprendre les transactions et les modes de reconnaissance.

Lorsque vous recevez un message, vous devez dire au courtier si vous l'avez géré avec succès. Si quelque chose ne va pas, vous voulez probablement que le message soit redémarré.

Il existe quelques modes de reconnaissance principaux:

• Session.AUTO_ACKNOWLEDGE - reconna?t automatiquement recevoir une fois le message re?u
• Session.CLIENT_ACKNOWLEDGE - oblige le client à appeler explicitement message.acknowledge()
• Session.DUPS_OK_ACKNOWLEDGE - Remerciements paresseux qui peuvent entra?ner des doublons mais améliorent les performances
• Session.SESSION_TRANSACTED - Active les transactions locales (plus à ce sujet ci-dessous)

Les transactions vous permettent de regrouper le message envoie et re?oivent ensemble afin que tous réussissent ou que aucun ne le fasse. Ceci est utile lorsque vous devez coordonner entre la consommation de messages et les mises à jour de la base de données.

 Session Session = Connection.CreateSession (true, 0);
MessageProducer producteur = session.CreateProducer (file d'attente);
TextMessage message = session.CreateTextMessage ("Hello");
producteur.send (message);

session.Commit (); // Toutes les opérations de cette session sont engagées

Si une exception se produit avant d'appeler commit , vous pouvez revenir en arrière et réessayer.

IMPORTANT: Les transactions sont locales à une session et n'étendent pas plusieurs ressources à moins que vous n'utilisiez des transactions XA et un gestionnaire de transactions.

Files d'attente de lettres mortes (DLQ)

Peu importe la solidité de votre système, certains messages ne seront pas traités correctement. Que cela soit d? à des données mal formées, à une logique commerciale échouée ou à des problèmes de service externes, vous finissez par rencontrer des messages qui continuent d'échouer.

Les files d'attente de lettres mortes agissent comme un filet de sécurité. Lorsqu'un message ne parvient pas à être livré après un certain nombre de tentatives, elle est déplacée vers le DLQ au lieu de faire un peu à travers votre système.

Comment le configurer dépend du fournisseur JMS , mais la plupart des courtiers proposent des paramètres comme:

• Tentatives de redevance maximale
• Retard entre les tentatives
• Nom de la file d'attente de lettres mortes cibler

Une fois que les messages se retrouvent dans le DLQ, vous pouvez les inspecter manuellement ou créer un outil pour les retraiter plus tard.

Conseil de pro: surveillez régulièrement votre DLQ. C'est souvent le premier endroit où regarder lorsque les choses commencent à mal en aval.

Ce ne sont pas les seules fonctionnalités avancées de JMS, mais elles couvrent certains des plus percutants lors de la mise à l'échelle ou du dépannage des systèmes de messagerie.

Chaque concept aborde les problèmes du monde réel - l'ordre, le filtrage, la fiabilité et la gestion des erreurs - et savoir comment et quand les appliquer font une grande différence dans le comportement du système.

Fondamentalement, c'est tout.

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!