Partager via

Sessions de message

  • Article

Les sessions Azure Service Bus permettent un traitement conjoint et chronologique de séquences illimitées de messages associés. Vous pouvez utiliser des sessions dans des modèles premier entré, premier sorti (FIFO) et requête-réponse. Cet article explique comment utiliser des sessions pour implémenter ces modèles lors de l’utilisation de Service Bus.

Notes

Le niveau de base de Service Bus ne prend pas en charge les sessions. Les niveaux standard et premium prennent en charge les sessions. Pour connaître les différences entre ces niveaux, voir Tarification de Service Bus.

Modèle premier entré, premier sorti (FIFO)

Pour garantir l’application de la méthode FIFO dans le traitement des messages dans les files d’attente ou les abonnements Service Bus, utilisez des sessions. Service Bus n’est pas normatif concernant la nature de la relation entre les messages, et ne définit aucun modèle spécifique pour déterminer le début et la fin d’une séquence de messages.

Lors de l’envoi de messages dans une rubrique ou dans une file d’attente, tout expéditeur peut créer une session en définissant la propriété d’ID de session sur un identificateur défini par l’application qui est unique à la session. Au niveau du protocole AMQP 1.0, cette valeur est mappée sur la propriété group-id.

Dans les files d’attente ou abonnements prenant en compte la session, les sessions entrent en action quand au moins un message existe avec l’ID de session. Une fois qu’une session existe, aucune heure ou API ne définissent son expiration ou sa disparition. Il est théoriquement possible de recevoir un message pour une session le jour même, puis le message suivant un an après et, si l’ID de session correspond, Service Bus considère alors qu’il s’agit de la même session.

Toutefois, en général, une application détermine précisément le début et la fin d’un ensemble de messages associés. Service Bus ne définit pas de règles spécifiques. Par exemple, votre application pourrait définir la propriété Label du premier message sur start, celle des messages intermédiaires sur content et celle du dernier message sur end. La position relative des messages de contenu peut être calculée comme étant égale à la différence entre la valeur SequenceNumber du message actuel et la valeur SequenceNumber du message présentant la valeur start.

Important

Lorsque les sessions sont activées sur une file d’attente ou un abonnement, les applications clientes ne peuvent plus envoyer/recevoir de messages normaux. Tous les messages doivent être envoyés dans le cadre d’une session (en définissant l’ID de session) et reçus en acceptant la session. Les clients peuvent toujours examiner une file d’attente ou un abonnement ayant des sessions activées. Consultez Navigation dans les messages.

Les API relatives aux sessions existent sur les clients de file d’attente et d’abonnement. Il existe un modèle impératif qui contrôle le moment où les sessions et les messages sont reçus, ainsi qu’un modèle basé sur un gestionnaire qui simplifie la gestion de la boucle de réception.

Pour obtenir des exemples, utilisez les liens de la section Étapes suivantes.

Fonctionnalités de session

Les sessions assurent un démultiplexage simultané de flux de messages entrelacés tout en préservant et en garantissant la remise chronologique des messages.

Diagram that shows how the Sessions feature preserves an ordered delivery.

Un destinataire de session est créé par un client qui accepte une session. Lorsque la session est acceptée et détenue par un client, ce dernier détient un verrou exclusif sur tous les messages portant l’ID de session de cette session dans la file d’attente ou l’abonnement. Il détient des verrous exclusifs sur tous les messages dont l’ID de session arrive plus tard.

Le verrou est libéré lorsque vous appelez les méthodes connexes de fermeture sur le récepteur ou lorsque le verrou expire. Il existe également des méthodes sur le récepteur pour renouveler les verrous. Au lieu de cela, vous pouvez utiliser la fonctionnalité de renouvellement automatique du verrouillage, dans laquelle vous pouvez spécifier la durée pendant laquelle vous souhaitez que le verrou soit renouvelé. Le verrouillage de session doit être traité de la même façon qu’un verrouillage exclusif sur un fichier, ce qui signifie que l’application doit fermer la session dès qu’elle n’en a plus besoin ou qu’elle n’attend plus aucun message.

Lorsque plusieurs destinataires simultanés extraient des données de la file d’attente, les messages appartenant à une session spécifique sont envoyés au destinataire concerné qui détient actuellement le verrouillage pour cette session. Grâce à cette opération, un flux de messages entrelacé dans une file d’attente ou un abonnement est correctement démultiplexé vers différents récepteurs qui peuvent également résider sur des machines clientes distinctes, parce que la gestion des verrous se produit côté service, au sein de Service Bus.

L’illustration précédente montre trois récepteurs de session simultanée. Une Session avec SessionId = 4 ne contenant aucun client actif, propriétaire, aucun message n’est remis à partir de cette session. Une session se comporte à maints égards comme une sous-file d’attente.

Le verrouillage de session détenu par le destinataire de session constitue une protection pour les verrouillages de message utilisés par le mode de règlement peek-lock. Un seul destinataire peut avoir un verrou sur une session. Un destinataire peut avoir de nombreux messages en vol, mais les messages seront reçus dans l’ordre. L’abandon d’un message entraîne un nouveau traitement de ce message lors de l’opération de réception suivante.

État d’une session de messagerie

Lorsque les workflows sont traités dans des systèmes de cloud à grande échelle et à haute disponibilité, le gestionnaire de workflows associé à une session spécifique doit pouvoir redevenir opérationnel en cas de défaillance inattendue, et peut reprendre un travail incomplet sur un processus ou une machine différents de que ceux sur lesquels le travail a commencé.

La fonction d’état de session active une annotation définie par l’application d’une session de messagerie dans le répartiteur, de sorte que l’état de traitement enregistré concernant cette session devient immédiatement disponible lorsque la session est acquise par un nouveau processeur.

Du point de vue de Service Bus, l’état d’une session de messagerie est un objet binaire opaque qui peut contenir une taille de données équivalant à un message, autrement dit 256 Ko pour Service Bus Standard et 100 Mo dans le cas de Service Bus Premium. L’état de traitement relatif à une session peut être stocké dans l’état de session, ou l’état de session peut pointer vers un emplacement de stockage ou un enregistrement de base de données contenant cette information.

Les méthodes de gestion de l’état de session, SetState et GetState, se trouvent sur l’objet récepteur de la session. Une session sans état de session précédent renvoie une référence null pour GetState. L’état de session précédemment défini peut être effacé en passant la valeur Null à la méthode SetState sur le récepteur.

L’état de session persiste tant qu’il n’est pas effacé (retour de la valeur Null), même si tous les messages dans une session donnée sont consommés.

L’état de session stocké dans une file d’attente ou dans un abonnement est pris en compte dans le quota de stockage de cette entité. Quand l’application a terminé avec une session, il est donc recommandé de faire en sorte que l’application supprime l’état de session conservé afin d’éviter un coût de gestion externe.

Impact du nombre de livraisons

La définition du nombre de livraisons par message dans le contexte de sessions diffère légèrement de la définition en l’absence de sessions. Voici un tableau résumant le moment où le nombre de livraisons est incrémenté.

Scénario Le nombre de livraisons du message est-il incrémenté
La session est acceptée, mais le verrouillage de session expire (en raison du délai d’expiration) Oui
La session est acceptée, les messages de la session ne sont pas terminés (même s’ils sont verrouillés) et la session est fermée Non
La session est acceptée, les messages sont terminés, puis la session est explicitement fermée S.O. (il s’agit du flux standard. Ici, les messages sont supprimés de la session)

Modèle requête-réponse

Le modèle requête-réponse est un modèle d’intégration bien établi qui permet à l’application de l’expéditeur d’envoyer une demande et fournit au destinataire un moyen de renvoyer correctement une réponse à l’application de l’expéditeur. Ce modèle a généralement besoin d’une file d’attente ou d’une rubrique de courte durée de vie à laquelle l’application puisse envoyer des réponses. Dans ce scénario, les sessions fournissent une solution alternative simple avec une sémantique comparable.

Plusieurs applications peuvent envoyer leurs requêtes à une seule file d’attente de requêtes, avec un paramètre d’en-tête spécifique défini pour identifier de manière unique l’application de l’expéditeur. L’application du destinataire peut traiter les requêtes arrivant dans la file d’attente et envoyer des réponses sur une file d’attente activée par la session, en définissant l’ID de session sur l’identificateur unique que l’expéditeur a envoyé sur le message de requête. L’application qui a envoyé la requête peut alors recevoir des messages sur l’ID de session spécifique et traiter correctement les réponses.

Notes

L’application qui envoie les requêtes initiales doit connaître l’ID de session et l’utiliser pour accepter la session afin que la session sur laquelle elle attend la réponse soit verrouillée. Il est judicieux d’utiliser un GUID qui identifie de façon unique l’instance de l’application comme ID de session. Il ne doit y avoir aucun gestionnaire de session ni de délai d’attente spécifié sur le destinataire de session pour la file d’attente afin de garantir que les réponses sont disponibles pour verrouillage et traitement par des destinataires spécifiques.

Séquencement et sessions

Le numéro de séquence garantit lui-même l’ordre de mise en file d’attente et l’ordre d’extraction des messages, mais pas l’ordre de traitement, qui nécessite des sessions.

Par exemple, il y a trois messages dans la file d’attente et deux consommateurs.

  1. Le consommateur 1 récupère le message 1.
  2. Le consommateur 2 récupère le message 2.
  3. Le consommateur 2 termine le traitement du message 2 et récupère le message 3, tandis que le consommateur 1 n’a pas encore terminé le traitement du message 1.
  4. Le consommateur 2 termine le traitement du message 3, mais le consommateur 1 n’a pas encore terminé le traitement du message 1.
  5. Enfin, le consommateur 1 termine le traitement du message 1.

Ainsi, les messages sont traités dans cet ordre : message 2, message 3 et message 1. Si vous avez besoin que les messages 1, 2 et 3 soient traités dans l’ordre, vous devez utiliser des sessions.

Si les messages doivent simplement être récupérés dans l’ordre, vous n’avez pas besoin d’utiliser de sessions. Si les messages doivent être traités dans l’ordre, utilisez des sessions. Le même ID de session doit être défini sur les messages qui sont associés, qui peuvent être les messages 1, 4 et 8 dans un ensemble, et 2, 3 et 6 dans un autre ensemble.

Expiration des messages

Pour les files d’attente ou les abonnements aux rubriques activés pour la session, les messages sont verrouillés au niveau de la session. Si la durée de vie (TTL) d’un des messages expire, tous les messages liés à cette session sont supprimés ou mis en file d’attente de lettres mortes en fonction du paramètre de mise en file d’attente de lettres mortes à l’expiration des messages sur l’entité. En d’autres termes, s’il existe un seul message dans la session qui a passé la durée de vie, tous les messages de la session sont expirés. Les messages expirent uniquement s’il existe un écouteur actif. Pour plus d’informations, consultez Expiration des messages.

Étapes suivantes

Vous pouvez activer les sessions de message lors de la création d’une file d’attente à l’aide du portail Azure, de PowerShell, de l’interface de ligne de commande, d’un modèle Resource Manager, de .NET, Java, de Python et de JavaScript. Pour plus d’informations, consultez Activer les sessions de messages.

Essayez les exemples dans le langage de votre choix pour explorer les fonctionnalités d’Azure Service Bus.