RabbitMQ— selektiv abrufen von Nachrichten aus einer Warteschlange

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 erfüllen; zum Beispiel, wenn ein bestimmter Betreff in der Nachricht.

Ich bin immer noch lernen über RabbitMQ, und war auf der Suche nach Tipps auf, wie man diesen Ansatz. Meine Fragen sind: wie kann der Verbraucher ziehen, die nur bestimmten Nachrichten aus der Warteschlange? Wie können die Hersteller setzen einen Betreff in die Nachricht (wenn das überhaupt der richtige Begriff?)

  • Wenn das wirklich dein Verbraucher hat abonnieren Sie (nicht daran interessiert, Nachrichten, veröffentlicht werden, bevor das Abonnement), das Abo (und verbindlich mit der Auswahl der Regel) nicht zu einer vorhandenen Warteschlange aber zu einer bestehenden exchange (als beantwortet, unten).. Dann ist die Frage, der Wortlaut sollte geändert werden.
InformationsquelleAutor larryq | 2012-06-21
  1. 24

    RabbitMQ ist perfekt für diese situation. Sie haben eine Reihe von Optionen, zu tun, was Sie wollen. Ich schlage vor, Lesen Sie in der Dokumentation zum besseren Verständnis. Ich würde vorschlagen, dass Sie ein Thema oder den direkten Austausch. Thema ist flexibler. Es geht so.

    Erzeuger-code Verbindung zum RabbitMQ-Broker und schafft und den Austausch mit einem bestimmten Namen.

    Produzent veröffentlicht zu tauschen. Jede Nachricht veröffentlicht werden veröffentlicht, mit einem routing-Taste.

    Verbraucher Verbindung zu RabbitMQ-broker.

    Verbraucher schafft Warteschlange

    Verbraucher bindet Queue an den exchange, exchange definiert der Hersteller. Die Bindung schließt auch die routing-keys für jede Nachricht benötigen Sie für diesen bestimmten Verbraucher.

    Können sagen, Sie waren die Veröffentlichung von log-Meldungen. Die routing-Taste könnte etwas sein wie "log.info", "log.warnen", "log.error". Jede Nachricht veröffentlicht, indem der Produzent die entsprechenden routing-Taste angebracht. Sie haben dann einen Verbraucher sendet und E-Mail für alle Fehlermeldungen und einen anderen, der schreibt alle Fehlermeldungen in einer Datei. Also der emailer definieren Sie die Bindung aus der Warteschlange, um den Austausch mit der routing-Taste "anmelden.error". Diese Weise, obwohl der exchange empfängt alle Nachrichten, die der Warteschlange definiert für die emailer enthält nur die Fehlermeldungen. Der filelogger definieren Sie eine neue separate Warteschlange an das gleiche exchange-und ein anderes routing-Taste. Man könnte drei separate Bindungen für die drei verschiedenen routing-keys benötigen, oder nur den Platzhalter verwenden "anmelden.*" auf Wunsch werden alle Nachrichten aus der exchange-beginnend mit log.

    Dies ist ein einfaches Beispiel, das zeigt, wie Sie erreichen, was Sie wollen zu tun.

    Aussehen hier für code-Beispiele, die speziell Anzahl tutorial Nummer 5.

    • Meinst du, können Verbraucher abrufen, die Nachricht mit bestimmten routing-Taste in einer Warteschleife? Es sieht aus wie Verbraucher haben keine Wahl, Sie einfach erhalten Sie alle Nachrichten aus der Warteschlange.
    • Verbraucher erhalten alle Nachrichten aus der Warteschlange. Ich denke, das ist per definition. Der Punkt hier ist, dass Sie gefiltert werden an der Börse level. Mit einem Thema, Austausch der Warteschlange erhalten nur bestimmte Nachrichten. So ein Verbraucher auf die Nachrichten Lesen, die Sie wollen, weil die Warteschlange erhält nur die Nachrichten, die der Verbraucher will.
    InformationsquelleAutor robthewolf
  2. 1
      1. To Retrive Message from RabbitMQ we need to first connect with RabbitMQ server 

    public WebClient GetRabbitMqConnection(string userName, string password)
    {
        var client = new WebClient(); 
        client.Credentials = new NetworkCredential(userName, password);
        return client;
    }

 2. Now retrieve message from RabbitMQ using below code.

      public string GetRabbitMQMessages(string domainName, string port, string 
                    queueName, string virtualHost, WebClient client, string 
                    methodType)
      {
                  string messageResult = string.Empty;
                  string strUri = "http://" + domainName + ":" + port + 
                                  "/api/queues/" + virtualHost + "/";
                  var data = client.DownloadString(strUri + queueName + "/");
                  var queueInfo = JsonConvert.DeserializeObject<QueueInfo>(data);
                  if (queueInfo == null || queueInfo.messages == 0)
                             return string.Empty;
                  if (methodType == "POST")
                  {
                      string postbody = "  
                      {\"ackmode\":\"ack_requeue_true\",\"count\":
                       \"$totalMessageCount\",\"name\":\"${DomainName}\",
                       \"requeue\":\"false\",\"encoding\":\"auto\",\"vhost\" :
                       \"${QueueName}\"}";
                       postbody = postbody.Replace("$totalMessageCount", 
                       queueInfo.messages.ToString()).Replace("${DomainName}", 
                       domainName).Replace("${QueueName}", queueName);
                       messageResult = client.UploadString(strUri + queueName + 
                       "/get", "POST", postbody);
                }
                return messageResult;
    } 


   I think this will help you to implement RabbitMQ.
    • Hallo Punit. Herzlich willkommen auf StackOverflow. Es scheint, dass Ihre Antwort nicht die Frage beantworten. Er wurde gefragt, "wie kann der Verbraucher ziehen nur bestimmte Nachrichten aus der Warteschlange" und "wie kann der Produzent legen Sie eine Betreff-Zeile der Nachricht". Ihre Antwort scheint zu sein, über die Verbindung zu den RabbitMQ - server und das abrufen von Daten im Allgemeinen. Er möchte, ziehen bestimmte Nachrichten, die möglicherweise Kopfzeilen in der Nachricht. Bitte überarbeiten Sie Ihre Antwort. Darüber hinaus nehmen Sie sich bitte die Zeit, um zu formatieren, wie es scheint, gibt es Abschnitte, die nicht code, sondern sind formatiert als code.
    • Hey bro Ishaan, das ist rabbitmq müssen Sie zum abrufen von Nachrichten aus besonders Warteschlange, um Benutzer zu definieren, Liste und wenden Sie dann linq zu filtern, besonders Nachricht .... Sie müssen, um Ihre eigene Logik .... Alle die besten!!!
    InformationsquelleAutor Punit Pandya
Schreibe einen Kommentar