Rabbitmq Abonnieren Sie mehrere Dienste, aber verbrauchen Sie es in einer Round-Robin-Mode

Question

Ich habe eine funktionierende Lösung für mein Problem, aber frage mich, ob es eine sauberere Möglichkeit, dies zu tun ist.

Meine Architektur besteht aus mehreren Diensten, die Nachrichten über einen Rabbitmq-Broker ausgeben.

Einige Arbeiter konsumieren diese Nachrichten und führen Hintergrundjobs aus.

Die Sache ist, dass ich in der Lage sein wollte, verschiedene Arten von Arbeitern zu schaffen, alle die gleichen Dienste konsumierend und in der Lage zu haben, mehrere Arbeiter des gleichen Typs den Job durch Round Robin zu bekommen.

Dazu werden die Nachrichten vom Dienst in einer Pub/Sub-Art veröffentlicht und von einem Prozess verarbeitet, der die Nachrichten in einer Arbeitswarteschlange neu verteilt, die einer Gruppe von Arbeitern gewidmet ist.

Gibt es eine elegantere Art, dies zu tun?

Sorry, wenn die Erklärung nicht klar ist, werde ich es bearbeiten.

Danke!

(I eine Warteschlange pro Arbeiter in den Diensten erstellt haben könnte, aber mit meiner Lösung kann ich so viel abonnieren, wie ich will, ohne Code zu berühren)

Answer 1

Klingt wie eine perfekte Passform für topic exchange.

Answer 2

Bitte suchen: https://www.rabbitmq.com/tutorials/tutorial-two-java.html

Abschnitt "Round-Robin-Dispatching"

Sie haben die Parameter einzustellen channel.basicQos(X):

channel.basicQos(1); 

final Consumer consumer = new DefaultConsumer(channel) { 
    @Override 
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { 
    String message = new String(body, "UTF-8"); 

    System.out.println(" [x] Received '" + message + "'"); 
    try { 
     doWork(message); 
    } finally { 
     System.out.println(" [x] Done"); 
     channel.basicAck(envelope.getDeliveryTag(), false); 
    } 
    } 
};