rabbitmq mehrere Verbraucher und mehrere publisher

Wissen wollen, das Verhalten von rabbitmq mehrere publisher und Verbraucher.
Tut rabbitmq-server gibt eine Nachricht an einen der Verbraucher zu einer Zeit, und andere Verbraucher sind ideal in dieser Zeit?

ODER

Verbraucher wählen Sie eine unbeaufsichtigte Nachricht aus der Warteschlange aus, so dass zu einem Zeitpunkt mehr als ein Verbraucher konsumieren die Nachricht aus der Warteschlange?

Im Grunde entwerfe ich eine Datenbank queue und wollen nicht mehr, als man fügt zu einer Zeit.

InformationsquelleAutor Rahul | 2010-12-05
  1. 0

    Einer Nachricht aus der Warteschlange werden an einen Verbraucher nur. Sprich: sobald die Nachricht macht sich auf den Weg, um die Warteschlange - es wird nicht kopiert (übertragen), um mehrere Verbraucher.

    Wenn Sie wollen broadcast - Sie haben die Verwendung mehrerer queues.

    In dieser Anleitung finden Sie weitere details:
    http://www.rabbitmq.com/tutorial-two-python.html

    InformationsquelleAutor Marek
  2. -1

    ja , RabitMQ unterstützt mehrere publisher und Verbraucher.

    1. Mehrere Publisher

      Für die Veröffentlichung einer messsge zu rabbitmqyou deklarieren müssen, eine Fabrik und eine Verbindung zum rabbitmq-server.
      dann Dekar ein chennel zu rabbitmq 

      ConnectionFactory FACTORY = new ConnectionFactory

      FABRIK.setUsername ("Gast")

      FABRIK.setPassword ("Gast")

      FABRIK.setVirtualHost ("\")

      FABRIK.setPort (5572)

      FABRIK.setHost ("localhost")

      Connection connection=FACTORY.newConnection
      Channel Channel = connection.createChannel

    die basic-Taste zum weiterleiten einer Nachricht ist ein routing-key 

    channel.basicPublish(EXCHANGE_NAME, "Queue1", MessageProperties.PERSISTENT_TEXT_PLAIN, "msg1".getBytes)

channel.basicPublish(EXCHANGE_NAME, "Queue2", MessageProperties.PERSISTENT_TEXT_PLAIN, "msg2".getBytes)

    diese beiden Nachrichten werden veröffentlicht, um eine separate Warteschlange gemäß der routing-key-wie erwähnt queue1 und queue2

    2.Mehrere Verbraucher

    für mehrere Verbraucher erklären wir, einer Warteschlange und die Bindung an ein bestimmtes routing-Taste
    die Nachricht, dass die routing-Taste wird publishe respektiert Warteschlange.

      channel.exchangeDeclare(EXCHANGE_NAME, "direct", durable)
  channel.queueDeclare("q1", durable, false, false, null)
  channel queueBind ("q1", EXCHANGE_NAME,"queue1")//routing key = "queue1"
  val q1Consumer = new QueueingConsumer(channel)
  channel basicConsume ("q1", false, q1Consumer)

    wie dieses u kann konsumieren Nachrichten aus der ersten Warteschlange
    und das gleiche gilt für die zweite Warteschlange, aber geben Sie die routing-Taste als "queue2"

      channel.exchangeDeclare(EXCHANGE_NAME, "direct", durable)
      channel.queueDeclare("q2", durable, false, false, null)
      channel queueBind ("q2", EXCHANGE_NAME,"queue2") //routing key = "queue2"
      val q2Consumer = new QueueingConsumer(channel)
      channel basicConsume ("q2", false, q2Consumer)
    InformationsquelleAutor Sagar Varpe
Schreibe einen Kommentar