Ich bin ein Neuling, der versucht, Header-Austausch in Java-Client zu implementieren. Ich bin mir bewusst, dass dies das "x-match" -Bindungsargument ist. Wenn das Argument "x-match" auf "any" gesetzt ist, ist nur ein übereinstimmender Header-Wert ausreichend. Wenn Sie "x-match" auf "all" setzen, müssen Sie alle Werte miteinander vergleichen. aber kann mir jemand einen Skelett-Code zum besseren Verständnis liefern.Wie implementiere ich Header Exchange in RabbitMQ mit Java?
Antwort
für die Verwendung eines Header austauschen Sie müssen nur Ihre Austausch erklären als Header Typ:
channel.exchangeDeclare("myExchange", "headers", true);
Dann müssen Sie eine Warteschlange erklären, dass das endgültige Ziel der Nachrichten sein wird, bevor der Verbraucher sie verbraucht:
Jetzt müssen wir den Austausch an die Warteschlange binden, die eine Bindung deklariert. In dieser Deklaration legen Sie fest, welche Header Sie für das Weiterleiten von Nachrichten von Ihrem Exchange an Ihre Warteschlange verwenden möchten. Ein Beispiel könnte sein:
Dies wird die Bindung mit HeaderName # 1 und HeaderName # 2 erstellen Ich hoffe das hilft!
Erste declare Austausch mit Header-Typ: -
channel.exchangeDeclare("Exchange_Header", "headers", true);
Dann Queue erklären: -
channel.queueDeclare("Queue", true, false, false, null);
Jetzt Header definieren und binden Sie es mit Queue: -
Map<String,Object> map = new HashMap<String,Object>();
map.put("x-match","any");
map.put("First","A");
map.put("Fourth","D");
channel.queueBind("Queue", "Exchange_Header", ROUTING_KEY ,map);
prüfen diese : - http://codedestine.com/rabbitmq-headers-exchange/
- 1. Rabbitmq Exchange Fanout Probleme
- 2. Wie implementiere ich einen Comparator mit Generics?
- 3. Wie implementiere ich eine doppelt verknüpfte Liste in Java?
- 4. Wie implementiere ich IEnumerable?
- 5. Wie implementiere ich Kafka Consumer in Scala?
- 6. Wie implementiere ich `prepareForReuse`?
- 7. Wie implementiere ich Request-Throttling in einer Java EE-Umgebung?
- 8. Wie implementiere ich JDatePicker
- 9. Wie implementiere ich jquery.sound.js?
- 10. Wie implementiere ich ein gutes Spielmenü in Java?
- 11. Wie implementiere ich Strg + Z/Befehl + Z in Java/Swing?
- 12. Wie implementiere ich meinen Code in MVC Java?
- 13. Wie implementiere ich OpenID in meiner Webanwendung?
- 14. Wie implementiere ich IValidatableObject?
- 15. Wie implementiere ich virtuelle Methoden in Implementierungsdateien?
- 16. RabbitMQ: Exchange, Warteschlangen und Bindungen - wer macht was?
- 17. Wie verwendet man Nachrichten Header in RabbitMQ Erlang Client?
- 18. RabbitMQ Queues HA und Dead Letter Exchange funktioniert nicht
- 19. RabbitMQ: Nachrichten bleiben "Unbestätigt"
- 20. Tut RabbitMq Round-Robin vom Exchange zu den Warteschlangen
- 21. Wie implementiere ich Polymorphie mit std :: shared_ptr?
- 22. Wie implementiere ich Reader mit freien Monaden?
- 23. Wie implementiere ich Revisionen mit neo4j?
- 24. Wie funktioniert rabbitmq Herzschlag Arbeit
- 25. Java: Wie implementiere ich ein Warteschlangensystem, um Audioclips abzuspielen?
- 26. Mit Exchange 2003 von Java aus sprechen
- 27. Wie konfiguriere ich rabbitmq mit mongo?
- 28. Wie implementiere ich Zip-Funktionalität in VBA?
- 29. Wie implementiere ich bedingtes CSS?
- 30. Wie implementiere ich Voice-Chat in Kakao?
danke! :), es ist jetzt klar. – user2857129
Gute Erklärung der Exchange/Queue-Beziehung. Vielen Dank! – user1828780