Multithread-JMS-Empfang im Frühjahr

Ich versuche eine Multithread-Implementierung für die JMS-Nachrichtenverarbeitung aus einer Warteschlange zu schreiben.Multithread-JMS-Empfang im Frühjahr

Ich habe versucht mit DefaultMessageListenerContainer und SimpleMessageListenerContainer Klassen.

Das Problem, das ich habe, ist, dass es scheint, dass nur eine einzige Instanz der MessageListener-Klasse jemals instanziiert wird, egal wie ich es konfiguriere. Dies zwingt mich unnötigerweise statusfreie oder threadsichere MessageListener-Implementierungen zu schreiben, da ich den ListenerContainer so konfiguriert habe, dass er mehrere Threads verwendet (concurrentConsumers = 8).

Gibt es eine offensichtliche Lösung, die ich übersehe?

Quelle

2010-10-29 Iker Jimenez

Dies ist von Entwurf. Die MessageListener ist eine Abhängigkeit, die Sie in Spring injizieren - es hat keine Möglichkeit neue zu instantiieren.

Dies zwingt mich staatenlos oder Thread-sichere Message Implementierungen

Sie diesen Sound machen wie eine schlechte Sache unnötig zu schreiben. Machen Sie Ihre MessageListener ist eine sehr gute Idee, entfernt Frühling einfach die Versuchung, anders zu machen.

Quelle

2010-10-29 11:27:29 skaffman

Ich verstehe nicht. Ich mache meinen MessageListener. Ich will nur, dass es die Multi-Cores meiner Maschine nutzt, um Dinge parallel zu verarbeiten. –

@Iker: Ja, und der MessageListenerContainer erzeugt mehrere Threads, wobei alle Threads dieselbe Instanz Ihres 'MessageListener' verwenden. Das Erzeugen mehrerer Listener ist ineffizient und unnötig. – skaffman

Ok, das verstehe ich. Aber sagen wir, dass Sie für jede JMS-Nachricht einen Job verarbeiten müssen, der ein paar Sekunden dauert. Ich möchte in der Lage sein, eine vollständig separate Reihe von Instanzen zu verwenden, um jede der Nachrichten zu verarbeiten. Sollte ich dann Threads vom MessageListener spawnen? –

Vielleicht ist diese Antwort zu spät, aber es kann anderen helfen, die danach suchen. Kurz gesagt, die Antwort lautet CommonsPoolTargetSource und ProxyFactoryBean.

Schauen Sie sich diese Verbindung für Details: http://forum.springsource.org/showthread.php?34595-MDB-vs-MDP-concurrency

Wenn Sie etwas wollen, ähnlich für Thema tun, dies überprüfen: https://stackoverflow.com/a/12668538/266103

Quelle

2012-09-25 08:44:08 shrini1000

„concurrentConsumers“ Konfiguration ist gerade genug, um Nachrichten gleichzeitig zu verarbeiten. Dies bedeutet nicht, dass Sie "n" Instanzen von MessageListenerContainer haben. Der MessageListenerContainer kann intern "Aufgaben" umfassen, um die Nachrichten zu verarbeiten. Optional müssen Sie möglicherweise Ihre Protokollierung entsprechend konfigurieren, um die Informationen zu den zugrunde liegenden Tasks/Threads anzuzeigen. Weitere Informationen finden Sie unter "Tuning JMS message consumption in Spring".

Quelle

2014-01-20 04:06:26

Antwort

Verwandte Themen