Limitations du mode de livraison non persistante d'ActiveMQ?

Question

J'utilise ActiveMQ où je dois les exigences suivantes

• Pour avoir très consommateurs rapides que mes producteurs sont déjà très rapide
• besoin de traitement à des messages de location 2K par seconde
• Pas besoin de traiter/consommer des messages à nouveau en cas de panne du serveur ou d'autres défaillances. Je peux encore déclencher tout le processus.
• a besoin pour exécuter le serveur de configuration très normale - 4GiB RAM

J'ai configuré ActiveMQ comme donné ci-dessous

• aide non-persistent delivery mode (vm://localhost) (http://activemq.apache.org/what-is-the-difference-between-persistent-and-non-persistent-delivery.html)
• Grâce à l'intégration de printemps pour mettre/fetch messages dans/de la file d'attente/canal.
• En utilisant max-concurrent-consumers avec 10 fils
• On suppose tous les autres configs sont par défaut avec ActiveMQ et Sprig-intégration.

Problèmes/Questions

• Je ne sais pas comment ActiveMQ stocke les messages en cas de non-persistent delivery mode, est-il possible que mon processus échouera avec des erreurs de mémoire une fois ma taille de file d'attente dépasse une certaine limite ? Je pose cette question parce qu'il est très difficile de tester tout le processus pour moi. Donc, je dois être conscient de la limitation avant de déclencher le processus.
• Si non-persistent delivery mode ne suffit pas avec mes exigences ci-dessus, y at-il des conseils de réglage des performances avec lequel je peux atteindre mes exigences avec persistent delivery mode (tcp://). J'ai déjà testé avec ce mode, mais il semble que les consommateurs sont très lents ici. De plus, je l'ai déjà essayé d'utiliser DUPS_OK_ACKNOWLEDGE pour faire mon consommation rapide avec persistent delivery mode mais pas de chance.

NOTE: J'utilise dernière version ActiveMQ 5.14

Answer 1

Je ne sais pas comment ActiveMQ stocker les messages dans le cas du mode de livraison non persistant

ActiveMQ enregistrer des messages dans la mémoire à en premier lieu, et il échangera également sur le disque (il y a un dossier tmp_storage dans le chemin de données ActiveMQ).

est-il possible que mon processus échouera avec des erreurs de mémoire une fois ma taille de file d'attente dépasse une certaine limite

Je ne l'ai jamais rencontré de mémoire dans ActiveMQ, même avec environ un million de messages.

Vous pouvez également vous assurer le contrôle de flux de production (http://activemq.apache.org/producer-flow-control.html). Vous pouvez bloquer le producteur en cas de trop nombreux messages non utilisés.

Et sur les performances de la livraison persistante, je n'ai pas non plus de bonnes méthodes.