RabbitMQ la création de files d'attente et des liaisons à partir d'une ligne de commande

Résumé:

Autres réponses sont bonnes alternatives à ce qui a été demandé. Ci-dessous sont des commandes que vous pouvez utiliser à partir de la ligne de commande.

Tout d'abord, faire tout le nécessaire travail de préparation, par exemple, installez le lapin, rabbitmqadmin, et rabbitctl. L'idée est d'utiliser les commandes de rabbitmqctl et rabbitmqadmin. Vous pouvez voir quelques exemples de commande: https://www.rabbitmq.com/management-cli.html

Exemple Des Commandes/Réglages:

Les commandes suivantes devraient vous donner la majorité sinon la totalité de ce que vous avez besoin de:

# Get the cli and make it available to use.
wget http://127.0.0.1:15672/cli/rabbitmqadmin
chmod +x rabbitmqadmin
mv rabbitmqadmin /etc/rabbitmq

Ajouter un utilisateur et les autorisations

rabbitmqctl add_user testuser testpassword
rabbitmqctl set_user_tags testuser administrator
rabbitmqctl set_permissions -p /testuser ".*" ".*" ".*"

Faire un hôte virtuel et de Définir des Autorisations

rabbitmqctl add_vhost Some_Virtual_Host
rabbitmqctl set_permissions -p Some_Virtual_Host guest ".*" ".*" ".*"

Faire un Échange

./rabbitmqadmin declare exchange --vhost=Some_Virtual_Host name=some_exchange type=direct

Faire une File d'attente

./rabbitmqadmin declare queue --vhost=Some_Virtual_Host name=some_outgoing_queue durable=true

Faire une Liaison

./rabbitmqadmin --vhost="Some_Virtual_Host" declare binding source="some_exchange" destination_type="queue" destination="some_incoming_queue" routing_key="some_routing_key"

Autre Façon de se Lier avec Python

Ce qui suit est une alternative à la ligne de commande de liaison, comme j'ai eu des problèmes avec elle parfois, et trouvé le code python suivant, pour être plus fiable.

#!/usr/bin/env python
import pika

rabbitmq_host = "127.0.0.1"
rabbitmq_port = 5672
rabbitmq_virtual_host = "Some_Virtual_Host"
rabbitmq_send_exchange = "some_exchange" 
rabbitmq_rcv_exchange = "some_exchange"
rabbitmq_rcv_queue = "some_incoming_queue"
rabbitmq_rcv_key = "some_routing_key"

outgoingRoutingKeys = ["outgoing_routing_key"]
outgoingQueues = ["some_outgoing_queue "]

# The binding area
credentials = pika.PlainCredentials(rabbitmq_user, rabbitmq_password)
connection = pika.BlockingConnection(pika.ConnectionParameters(rabbitmq_host, rabbitmq_port, rabbitmq_virtual_host, credentials))
channel = connection.channel()
channel.queue_bind(exchange=rabbitmq_rcv_exchange, queue=rabbitmq_rcv_queue, routing_key=rabbitmq_rcv_key)

for index in range(len(outgoingRoutingKeys)):
    channel.queue_bind(exchange=rabbitmq_send_exchange, queue=outgoingQueues[index], routing_key=outgoingRoutingKeys[index])

Ci-dessus peuvent être exécutés dans le cadre d'un script à l'aide de python. Notez que j'ai mis le sortant des trucs dans des tableaux, ce qui vous permettra d'itérer à travers eux. Cela devrait rendre les choses faciles pour déploie.

Dernières Pensées

Je pense que le ci-dessus devrait vous faire bouger dans la bonne direction, l'utilisation de google si des commandes ne font pas de sens ou de lire en plus avec rabbitmqadmin help subcommands. J'ai essayé d'utiliser des variables qui expliquent eux-mêmes. Bonne chance 🙂

Si vous utilisez Linux Debian, il y a un paquet appelé "amqp-outils". L'installer avec

apt-get install amqp-tools

Vous pouvez ensuite utiliser la ligne de commande comme amqp-publier pour envoyer des messages à votre file d'attente

amqp-publish -e exchange_name -b "your message"

Puis vous pouvez recueillir message(s) à partir de la file d'attente à l'aide de

amqp-get -q queue_name

ou

amqp-consume -q queue_name

Il y a aussi (ligne de commande) exemples de rabbitmq-c package /bibliothèque. Après vous construisez, vous pouvez envoyer des messages via la ligne de commande comme

amqp_sendstring localhost 5672 amq.direct test "hello world"

Avoir du plaisir ...

Créer RabbitMq Échange, la File d'attente et de Liaisons dynamique à partir de la CLI sur Windows

J'ai déjà eu une RabbitMQ Server est installé et en cours d'exécution avec plusieurs de la file d'attente et d'échange et voulait maintenant de le créer à la volée à partir de la ligne de commande. Je sais que c'est une vieille question, mais j'ai pensé donner cette information sera utile.

Qui suit est ce que j'ai fait:

Installation

1. Téléchargé et installé Python 2.6.6-201008-24 Windows x86-64 programme d'installation MSI , n'importe quelle version de python de plus de 2.X, mais pas 3.X
2. Télécharger RabbitMqAdmin: RabbitMq de l'Interface Utilisateur Web a un lien en Ligne de Commande qui permet de naviguer à http://server-name:15672/cli/ (nom de serveur: serveur sur lequel rabbitmq est installé) sinon,utilisez l'url ci-dessus et enregistrez le fichier en tant que rabbitmqadmin.exe dans le python exe emplacement

par exemple: C:\Python26\
C:\Python26\python
C:\Python26\rabbitmqadmin.exe

Code:dans un lot de fichier utilisé les commandes ci-dessous

1. Créer de l'échange:

   c:\python26\python.exe rabbitmqadmin.exe déclarer change name=ExchangeName1 type=sujet durable=true

2. Créer une file d'attente:

   c:\python26\python.exe rabbitmqadmin.exe déclarer nom de file d'attente=NameofQueue1 durable=true

3. Créer de liaison:

   c:\python26\python.exe rabbitmqadmin.exe déclarer la source de liaison=ExchangeName1 destination_type=file d'attente de destination=NameofQueue1 routing_key=RoutingKey1

par l'exécution de rabbitmqadmin.exe -aider -les sous-commandes, il répertorie toutes les commandes disponibles

par exemple: c:\python26\python.exe rabbitmqadmin.exe -aider -les sous-commandes

Procédure pas à pas pour Créer et supprimer une file d'attente dans RabbitMQ:

Je ne pouvais pas trouver une ligne de commande de commande de le faire. Voici comment je l'ai fait dans le code java.

Rabbitmq-server version 3.3.5 sur Ubuntu.

Liste les files d'attente, pas de files d'attente encore:

sudo rabbitmqctl list_queues
[sudo] password for eric:
Listing queues ...
...done.

Mettre cela en CreateQueue.java

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.util.*;
public class CreateQueue {
  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-message-ttl", 60000);
    channel.queueDeclare("kowalski", false, false, false, args);
    channel.close();
    connection.close();
  }
}

Fournir le fichier jar qui est venu avec votre rabbitmq installation:

Je suis en utilisant rabbitmq-client.jar la version 0.9.1, utilisez celui qui est livré avec votre version de rabbitmq.

Compiler et exécuter:

javac -cp .:rabbitmq-client.jar CreateQueue.java
java -cp .:rabbitmq-client.jar CreateQueue

Il devrait terminer sans erreur, vérifiez vos files d'attente maintenant:

sudo rabbitmqctl list_queues
Listing queues ...
kowalski        0
...done.

l'kowalski file d'attente existe.