sql >> Database >  >> NoSQL >> Redis

Redisson, werkwachtrij / dequeu. Strategieën voor het verwerken van berichten / elementen voor het afhandelen van onvolledige berichten bij het afsluiten van het systeem / de pod

Dus ik takeHead en dan begin ik met verwerken. Probleem als dit moet worden geschaald en met behulp van een 8-threads executor-service per pod/instantie, bij plotseling afsluiten van het systeem, zouden de "berichten" al als ontvangen / verbruikt zijn beschouwd.

U moet in plaats daarvan het RStream-object gebruiken om niet-geconsumeerde elementen per consument te volgen.




  1. Kan lokale mongo db . niet starten/starten

  2. Hoe gebruik ik Node.js-clusters met mijn eenvoudige Express-app?

  3. MongoDB $toInt

  4. MongoDB NOW Aggregatievariabele