Est-ce une attente réaliste d'un mécanisme distribué?

Question

J'ai évalué ActiveMQ en tant que courtier de message de candidat. J'ai écrit un code de test pour essayer de comprendre les limitations de performances d'ActiveMQ.

Je peux produire un état d'échec dans le courtier en envoyant des messages aussi vite que possible comme ceci:

try { 
    while(true) { 
     byte[] payload = new byte[(int) (Math.random() * 16384)]; 
     BytesMessage message = session.createBytesMessage(); 
     message.writeBytes(payload); 
     producer.send(message); 
} catch (JMSException ex) { ... } 

J'ai été surpris que la ligne

producer.send(message); 

bloque lorsque le courtier entre dans une Failed Etat. J'espérais qu'une exception serait lancée, donc il y aurait une indication que le courtier a échoué. Je me rends compte que mon code de test est en train de spammer le courtier, et je m'attends à ce que le courtier échoue. Cependant, je préférerais que le courtier échoue "fort" au lieu de simplement bloquer.

Est-ce une attente irréaliste?

Mise à jour:

réponse Uri fait référence à un rapport de bogue ActiveMQ qui a été déposé en Mars. La description du bug inclut une proposition qui ressemble à ce que je cherche: "si la requête sur le transport avait un timeout (ceci est pour attraper des scénarios d'échecs, donc quelque chose qui ne devrait raisonnablement pas arriver), les choses auraient plutôt que de construire des fils d'attente. "

Cependant, après 8 mois, le bug est actuellement non attribué avec un seul vote. Donc je suppose que la question est toujours là, est-ce quelque chose qu'ActiveMQ devrait mettre en œuvre?

Answer 1

Vous n'êtes pas sûr de la configuration d'ActiveMQ, mais les autres fournisseurs JMS disposent de diverses options de configuration. Vous pouvez donc faire en sorte qu'ActiveMQ fasse ce que vous souhaitez dans cette situation.

Je sais que Fiorano a des options pour spécifier si les fournisseurs bloquent ou non dans cette situation.

Answer 2

Vous testez le problème 'slow consumer' and producer flowcontrol que tous les courtiers de messagerie doivent traiter. Voulez-vous échouer les producteurs, les bloquer ou les mettre sur disque?

Fondamentalement, le défaut par défaut dans ActiveMQ est de bloquer les producteurs. Mais vous pouvez configure message cursors to spool to disk.

BTW vous n'avez pas dit si vous utilisez des files d'attente/sujets ou persistant/non persistant; si vous utilisez des sujets non persistants, il existe d'autres stratégies que vous pouvez utiliser pour jeter des messages, etc.

Answer 3

apprently il y a un problème connu, pas sûr si elle a été fixée:

https://issues.apache.org/activemq/browse/AMQ-1625