Comment traitez-vous les messages en parallèle tout en assurant la FIFO par entité?

Disons que vous avez une entité, disons, "personne" dans votre système et que vous souhaitez traiter des événements qui modifient diverses entités de personnes. Il est important que:

• Les événements pour la même personne sont traités dans l'ordre FIFO
• Les flux d'événements multiples personnes sont traités en parallèle par différents threads / processus

  Nous avons une implémentation qui résout celle-ci en utilisant une base de données et des verrous partagés. Les threads se font concurrence pour acquérir la serrure pour une personne, puis traiter des événements dans l'ordre après avoir acquis la serrure. Nous aimerions passer à une file d'attente de message pour éviter les interrogations et le verrouillage, que nous pensons réduire la charge sur la base de données et simplifierait la mise en œuvre du code de consommation.

  J'ai fait des recherches sur Activemq, Rabbbitmq et Hornetq, mais je ne vois pas de manière évidente de mettre en œuvre cela.

  ActiveMQ soutient les caractères génériques de souscription des consommateurs, mais je ne vois pas un moyen de limiter la concurrence sur chaque file d'attente à 1. Si je pouvais le faire, la solution serait simple:

  • Dites à un courtier de permettre une concurrence de 1 pour toutes les files d'attente à partir de: / File d'attente / personne.
  • Éditeur écrit l'événement à la file d'attente à l'aide de la personne ID dans le nom de la file d'attente. E.g.: /queue/person.20
  • Les consommateurs s'abonnent à la file d'attente avec Wildcards: / File d'attente / personne.>
  • Chaque consommateur recevrait des messages pour différentes files d'attente. Si toutes les files d'attente de la personne étaient utilisées, certains consommateurs peuvent rester inactifs, ce qui est OK
  • Après le traitement d'un message, le consommateur envoie un ACK, qui indique au courtier, il est fait avec le message et permet à un autre message pour que la file d'attente de cette personne soit envoyée à un autre consommateur (éventuellement le même)

    ActiveMQ est arrivé à proximité: vous pouvez faire des abonnements génériques et activer le «consommateur exclusif», mais cette combinaison entraîne un seul consommateur recevant tous les messages envoyés à toutes les files d'attente correspondantes, réduisant ainsi votre concurrence à 1 à toutes les personnes. J'ai envie de me manquer quelque chose d'évident.

    questions:

    • Y a-t-il un moyen de mettre en œuvre l'approche ci-dessus avec une implémentation de la file d'attente de message majeure? Nous sommes assez ouverts aux options. La seule exigence est qu'elle fonctionne sur Linux.
    • Y a-t-il un moyen différent de résoudre le problème général que je ne considère pas?

      Merci!