Tag: rabbitmq
RabbitMQ ist eine open-source-message-broker, die ursprünglich Implementierung des AMQP-Protokoll mit zusätzlichen messaging-Protokolle unterstützt, die über eine plug-in-Architektur. Dieser tag sollte verwendet werden, mit Fragen, die die RabbitMQ-server message broker Produkt oder Fragen bezüglich des Quellcodes und die Implementierung der RabbitMQ-Produkt. Eine bestimmte Protokoll-tag wie amqp oder mqtt können ebenfalls geeignet sein, sowie das Betriebssystem und die Programmiersprache, die verwendet wird.
1
Antworten
Wir bauen für Sie unser message-queue-system. Zwar werde über die RabbitMQ-exchange-Typen, die ich bemerkte, gibt es zwei mögliche Lösungen zur Umsetzung der multi-cast-Art der Weiterleitung von Nachrichten. Thema Exchange. Durch die Einrichtung ein Thema exchange-und eine routing-Schlüssel
1
Antworten
Ich nach Abschluss der Installation von RabbitMQ mit dem folgenden RPM - http://www.rabbitmq.com/releases/rabbitmq-server/v2.7.1/rabbitmq-server-2.7.1-1.noarch.rpm installierte ich es so : $ wget \ http://www.rabbitmq.com/releases/rabbitmq-server/v2.7.1/rabbitmq-server-2.7.1-1.noarch.rpm $ rpm --nodeps -Uvh rabbitmq-server-2.7.1-1.noarch.rpm der Grund, warum ich verwendet --nodeps war, weil ich installiert
2
Antworten
Grundsätzlich meine Konsumenten werden Produzenten. Wir bekommen einen ersten Datensatz und es wird an die Warteschlange gesendet. Ein Verbraucher nimmt ein Element und Prozesse, die Sie von diesem Punkt aus gibt es 3 Möglichkeiten: Daten ist gut
2
Antworten
Ich habe eine web-Anwendung, die verwendet das jquery autocomplete-plugin, das im wesentlichen sendet per ajax eine Anfrage mit text, der eingegeben wurde, in ein Textfeld auf unseren web-server, sobald der web-server empfängt diese Anfrage, es reichte dann
2
Antworten
Ich versuche, RabbitMQ mit Sellerie und Django geht auf eine EC2-Instanz zu tun, ein paar ziemlich grundlegende hintergrund-Verarbeitung. Ich bin mit rabbitmq-server 2.5.0 auf einem großen EC2-Instanz. Ich heruntergeladen und installiert die test-client nach der Anleitung hier
2
Antworten
Bekomme ich eine string durch ein rabbitmq-message-system. Vor dem senden, Benutze ich json.Marshal konvertieren, das Ergebnis zu string und senden durch rabbitmq. Den Strukturen, die ich konvertieren und senden kann: (die Namen geändert und die Größe der
1
Antworten
Möchte ich wissen, wie funktioniert RabbitMQ speichern die Nachrichten, die physikalisch an RAM und Festplatte? Ich weiß, dass RabbitMQ versucht die Nachrichten in Erinnerung (Aber ich weiß nicht, wie die Nachrichten in den Ram). Aber die Nachrichten
2
Antworten
Wir haben ein windows-Dienst, das hören auf einzelne RabbitMQ Warteschlange und verarbeiten der Nachricht. Wir möchten Sie herzlich derselben windows-Dienste, so dass Sie hören können mehrere Warteschlangen von RabbitMQ und verarbeiten der Nachricht. Nicht sicher, ob das
3
Antworten
Ich so konfiguriert haben, dass die RabbitMQ rabbitmq.config - Datei mit der neuen port-Nummer, D. H. 5671 mit SSL. Nun möchte ich deaktivieren Sie die Standard-port-d.h. 5672. Config-Datei wie folgt :- [ {rabbit, [ {ssl_listeners, [5671]}, {ssl_options,
2
Antworten
Sende ich JAXB-Objekt Rabbit MQ via Java. JAXBContext jaxbContext = JAXBContext.newInstance(MyDTO.class); Marshaller jaxbMarshaller = jaxbContext.createMarshaller(); //output pretty printed jaxbMarshaller.setProperty(Marshaller.JAXB_FRAGMENT, true); java.io.StringWriter sw = new StringWriter(); jaxbMarshaller.marshal(deliveryrequest, sw); ConnectionFactory factory = new ConnectionFactory() ; //TODO change the hardcoding
2
Antworten
Ich versuche, führen Sie den folgenden Befehl rabbitmq-plugins.bat enable rabbitmq_management und sein gibt mir eine Fehlermeldung Fehler beim erstellen des cookie-Datei h:/. Ich bin mit windows 7, Erlang Version R16B01 und RabbitMQ-Server version 3.1.5 Ich bin mit
3
Antworten
Ich bin neu in Spring AMQP /Rabbit MQ. Bin mit einem Spring AMQP /Rabbit MQ in meinem Projekt. Ich bin mit folgenden Fehler nach der Ausführung einer tomcat: org.springframework.amqp.Kaninchen.listener.SimpleMessageListenerContainer - Verbraucher ausnahmeereignis, kann die Verarbeitung neu starten,
2
Antworten
Ich habe eine RabbitMQ 3.4.2 Beispiel mit einem web-management-plugin installiert. Wenn ich push-to-die Nachricht {'operationId': 194} an die Warteschlange über Python ' s kombu queue-Paket, wird die Nachricht Lesen, die am anderen Ende als ein Wörterbuch. Allerdings,
1
Antworten
QueueingConsumer consumer = new QueueingConsumer(channel); System.out.println(consumer.getConsumerTag()); channel.basicConsume("queue1", consumer); channel.basicConsume("queue3", consumer); Ist es möglich, aufzuhören die Nachrichten aus der Warteschlange "queue3" allein dynamisch? InformationsquelleAutor user1182253 | 2014-04-28
2
Antworten
Ich habe eine Anwendung, die einige bugs hat. Für einige Grund 2 die Verbraucher werden erstellt, wenn nur eine da sein sollte - und einer von Ihnen ist nicht geprüft für Nachrichten mehr. Kann ich erkennen, dass
4
Antworten
Welche diese Technologie-suite für Multi-user-online-Spiel-Projekt.. Anforderungen an ein Projekt: 1. In der Lage zu handhaben 2k-5k user zu einem bestimmten Zeitpunkt. 2. client-Bibliothek für iphone und android (native, kein javascript). 3. client-Bibliothek für Microsoft Windows (die wichtigsten),
1
Antworten
Ich habe 100 Kunden. Jeder Kunde hat eine eindeutige Benutzername, Passwort und die zwei Kanäle (Benutzer können keine Verbindung zu anderen Kanälen, abgesehen von Ihrer eigenen). Sollte ich VirtualHost-Eintrag für jeden Benutzer? Wie schreibt man richtige Benutzer
1
Antworten
Ich bin neu RabbitMQ, so bitte ich um Entschuldigung für die trivialen Fragen: 1) Im Falle von clustering in RabbitMQ, wenn ein Knoten fehlschlägt, laden Sie die Umschalttaste auf einen anderen Knoten (ohne dass die anderen Knoten).
4
Antworten
Ich bin versucht, setup-rabbitmq es von extern erreichbar ist (nicht localhost) durch nginx. nginx-rabbitmq.conf: server { listen 5672; server_name x.x.x.x; location /{ proxy_pass http://localhost:55672/; } } rabbitmq.conf: [ {rabbit, [ {tcp_listeners, [{"127.0.0.1", 55672}]} ] } ] Standardmäßig
2
Antworten
Ich habe Zugang zu einem RabbitMQ-server zu tun, eine Last test auf Sie zu. Ich bin ganz neu auf Server und AMQ Protokoll. Ich habe schon online recherchieren, um zu sehen, was sind einige verschiedene Methoden. Bisher
3
Antworten
Habe ich gebaut, dieses Beispiel: Erste Schritte Mit RabbitMQ in .net, aber aus 2 Programmen: eine-Verlag one-Abonnenten Ich bin mit BasicPublish zu veröffentlichen und zu BasicAck zu hören, wie im Beispiel. Wenn ich einen Verleger und mehrere
2
Antworten
Habe ich installiert RabbidMQ aber wenn ich versuche, mit rabbitmqctl status im cmd habe ich nächste Ergebnis : D:\RabbitMQ\rabbitmq_server-3.6.2\sbin>rabbitmqctl status Error: Failed to initialize erlang distribution: {{shutdown, {failed_to_start_child, net_kernel, {'EXIT',nodistribution}}}, {child,undefined, net_sup_dynamic, {erl_distribution, start_link, [['rabbitmq-cli-70', shortnames]]}, permanent,1000,supervisor,
4
Antworten
Ich erstelle vhost: rabbitmqctl add_vhost test Dann Benutzer: rabbitmqctl add_user user 123456 Dann nehme ich die Berechtigungen, die dem Benutzer: rabbitmqctl set_permissions -p test user "test" "test" "test" Ich verwende Sellerie, in tasks.py: app = Celery('tasks', broker='amqp://user:123456@localhost/test',
2
Antworten
Ich bin neu RabbitMQ und Frage mich, für einen guten Ansatz, um dieses problem bin ich grübelte über. Ich möchte einen Dienst erstellen, der bekennt sich zu einer queue und zieht nur Nachrichten, die eine bestimmte Kriterien
1
Antworten
Die native rabbitmq-client für java ermöglicht das setup von heartbeat auf Verbindungs-Einstellungen, wie zum Beispiel diese: import com.rabbitmq.client.ConnectionFactory; ... ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setAutomaticRecoveryEnabled(true); connectionFactory.setHost("some://host"); connectionFactory.setConnectionTimeout(5000); connectionFactory.setRequestedHeartbeat(5); //keeps an idle connection alive Was ist das rabbitmq-client
4
Antworten
Sieht es aus wie Sellerie Speicher nicht freigegeben werden, nachdem Aufgabe beendet. Jedes mal, wenn eine Aufgabe abgeschlossen ist, es wäre 5m-10m-memory-Leck. So mit tausenden von Aufgaben, bald wird es zu verwenden, bis alle Speicher. BROKER_URL =
3
Antworten
Ich bin immer der folgenden Ausnahme wiederholt, wenn ich mein spring-boot-Anwendung mit rabbitmq. Der gesamte Durchfluss ist in Ordnung, die sogar von den unten genannten Ausnahmen. hat es zu tun mit der auto-delete durch ? 08 Jul
2
Antworten
Ich bin versucht, zu erstellen eine einfache spring-boot-Anwendung mit spring-boot, die "produzieren" - Nachrichten an einen rabbitmq exchange/queue und ein weiteres Beispiel spring-boot-app, die sich "verbrauchen" diese Nachrichten. Also ich habe zwei apps (oder microservices, wenn Sie
1
Antworten
Konnte ich nicht finden im RabbitMQ-Dokumentation die Standard-x-message-ttl-Wert kommt mit der installation. Ich wissen, wie es auf einen gewünschten Wert, aber ich bin neugierig zu wissen, den default-Wert. InformationsquelleAutor Martin Chen | 2014-07-25
3
Antworten
Ich versuche, RabbitMq in einer eher unkonventionellen Weg (obwohl an dieser Stelle kann ich wählen Sie eine andere message-queue-Implementierung, wenn nötig). Anstatt Kaninchen push-Nachrichten an meine Verbraucher, der Verbraucher eine Verbindung zu einem queue und holt einen
2
Antworten
Mein Sellerie Aufgaben aufhört, ausgeführt zwischen. Meine rabbitmq Haltestellen dazwischen und dann muss ich manuell neu starten. Beim letzten mal(15-16 Stunden zurück), ähnliches problem aufgetreten ist, habe ich Folgendes (manuell), und es begann wieder zu arbeiten. Ich
1
Antworten
Ich Frage mich, ob dies möglich ist. Ich möchten, ziehen Sie eine Aufgabe aus einer Warteschlange und haben einige arbeiten, die potenziell überall von 3 Sekunden oder länger (möglicherweise) Minuten, bevor ein ack gesendet wird, zurück zum
3
Antworten
code import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; public class Send { private final static String QUEUE_NAME = "test"; public static void main(String argv) throws java.io.IOException { try { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Connection connection =
5
Antworten
Ich verwendet habe, docker zu Beginn meines rabbitmqserver. Wie kann ich rabbitmqctl zu verbinden, um die rabbitmqserver in den docker-container? Port 5672 wurde ausgesetzt und map 5672-port von meinem host. Aber ich bekomme immer noch folgende Fehlermeldung:
2
Antworten
Habe ich Eine box und es hat ein Verbraucher, der es hört, die auf ein Kaninchen MQ server Ich habe Feld B, das veröffentlichen einer Nachricht an den listener So lange, wie all dies auf der box
4
Antworten
Fand ich dieses Kleinod: In der Ausfall der Verbindung, der client zum herstellen einer neuen Verbindung zum broker. Alle Kanäle geöffnet, die auf der vorherigen Verbindung wird automatisch geschlossen, und diese wird wieder der öffnung zu. So,
2
Antworten
Ich gefunden habe, dieses Bild ist sehr ähnlich wie meine bussiness-Modell. Ich brauche split-message, um einige der Warteschlange. für einige schwere Arbeit. Ich kann hinzufügen, mehr worker-thread für Sie. Aber für einige nicht viel schwere Arbeit. Ich
3
Antworten
Ich versuche, verwenden Sie SSL-Zertifikate mit RabbitMQ aber ich bekomme den handshake Fehler mit dem Makler. Zertifikate, die ich generiert haben, funktionieren gut bei der Verwendung der openssl 's_client' und 's_server" - Befehle in separaten terminal-Fenster und
2
Antworten
Ich habe nicht gefunden, einen vorhandenen Beitrag gefragt, aber entschuldige mich, wenn ich es verpasst. Ich versuche, meinen Kopf Runde microservices und haben über Artikel, in denen RabbitMQ verwendet. Ich bin verwirrt, warum RabbitMQ ist erforderlich. Ist
3
Antworten
Hallo, ich bin versucht, senden Sie einen einfachen Gegenstand, wie durch RabbitMQ über EasyNetQ. Habe ich Probleme, zu Deserialisieren das Objekt auf der Abo-Seite. Jemand in der Lage mir zu zeigen, ein Beispiel, wie dies funktioniert. Halten
3
Antworten
Wie zu erkennen die Nachrichten manuell, ohne die Verwendung der automatischen Anerkennung. Gibt es eine Möglichkeit, verwenden Sie diese zusammen mit der @RabbitListener und @EnableRabbit - Stil der Konfiguration. Der größte Teil der Dokumentation erzählt uns SimpleMessageListenerContainer
3
Antworten
Bin ich spec ' Ing eine design jetzt verwendet RabbitMQ als message queue. Die Botschaft gehen, um eine JSON-Körper, und für eine Nachricht im besonderen möchte ich hinzufügen, eine kleine binäre Datei. Was ich wissen möchte ist,
2
Antworten
Gibt es eine Möglichkeit zu zählen wie viel Zeit ein Auftrag requeued (über Ablehnung oder Nak), ohne manuell requeu den job? Ich muss versuchen einen job für 'n" - Zeit und dann legen Sie es nach -
10
Antworten
Den RabbitMQ-windows-Dienst wird nicht gestartet: C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.0.4\sbin>rabbitmq-service.bat start C:\Program Files (x86)\erl5.10.1\erts-5.10.1\bin\erlsrv: Failed to start service RabbitMQ. Error: The process terminated unexpectedly. Ich kann laufen, rabbitmq-server.bat ohne Probleme. Werden keine log-Einträge aus %appdata%\RabbitMQ\log\ - Verzeichnis, wenn
2
Antworten
Ich versuche, Weg von SQS zu RabbitMQ für den messaging-Dienst. Ich bin auf der Suche nach Aufbau eine stabile, hohe Verfügbarkeit queuing-Dienst. Jetzt werde ich mit cluster. Aktuellen Implementierung , Ich habe drei EC2-Maschinen mit RabbitMQ mit
2
Antworten
Wenn Sie versuchen zu installieren rabbitmq-server auf dem RHEL: [ec2-user@ip-172-31-34-1XX ~]$ sudo rpm -i rabbitmq-server-3.3.5-1.noarch.rpm error: Failed dependencies: erlang >= R13B-03 is needed by rabbitmq-server-3.3.5-1.noarch [ec2-user@ip-172-31-34-1XX ~]$ rpm -i rabbitmq-server-3.3.5-1.noarch.rpm error: Failed dependencies: erlang >= R13B-03 is
2
Antworten
Ich habe eine SpringBoot Anwendung macht die Verwendung von Spring AMQP. Im moment bin ich der Umsetzung der Empfängerseite mit JavaConfig Klassen unter der Leitung der offizielle Frühling docs Beispiele. Aber, ich erhalte eine MessageConversionException und die
3
Antworten
Habe ich zwei Systeme integriert sind, mit RabbitMQ. Hintergrund Client-senden Sie multiple-request-Nachrichten von Spring-AMQP outbound-Gateway zu RabbitMQExchange, die rabbitmq-DirectExchange verwenden round-robin - Versand dieser Nachrichten an Mehrere Arbeitnehmer(die Arbeiter sind unabhängige, die sich auf verschiedenen desktops die
1
Antworten
Ich würde gerne ein Message-Oriented-Middleware (MOM) mit Microsoft Azure cloud-Plattform. Ich habe ein wenig den Vergleich zwischen dem RabbitMQ und MSMQ. Die erste scheint besser zu sein für meinen Fall. Es ist einfacher, mit zu arbeiten und
2
Antworten
Habe ich setted rabbitMQ und seine Verwaltung plubin in windows, Fand ich rabbitmq.config-Datei mit "BEISPIEL-DATEI" den Pfad eingeben, in der " ...AppData\Roaming\RabbitMQ " und " C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.3.1\etc " Füge ich die Zeile {loopback_users, } in