Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Didacticiels RabbitMQ

Les didacticiels suivants vous montrent comment configurer et utiliser RabbitMQ sur Amazon MQ. Pour en savoir plus sur l'utilisation des bibliothèques client prises en charge dans une variété de langages de programmation tels que Node.js, Python, .NET, etc., consultez Didacticiels RabbitMQ du Guide de démarrage RabbitMQ.

Étape 2 : Connectez une application basée sur JVM à votre courtier

Après avoir créé un agent RabbitMQ, vous pouvez y connecter votre application. Les exemples suivants montrent comment utiliser la bibliothèque client Java RabbitMQ pour créer une connexion à votre agent, créer une file d'attente et envoyer un message. Vous pouvez vous connecter à des agents RabbitMQ à l'aide des bibliothèques client RabbitMQ prises en charge pour une variété de langages. Pour de plus amples informations sur les bibliothèques client RabbitMQ prises en charge, consultez Bibliothèques client et outils de développement RabbitMQ.

Prérequis

Activer les attributs du VPC

Pour vous assurer que votre agent est accessible dans votre VPC, vous devez activer les attributs enableDnsHostnames et enableDnsSupport du VPC. Pour plus d'informations, consultez Prise en charge du DNS dans votre VPC dans le Guide de l'utilisateur Amazon VPC.

Activer les connexions entrantes

Ajout de dépendances Java

Si vous utilisez Apache Maven pour automatiser les builds, ajoutez la dépendance suivante à votre fichier pom.xml. Pour plus d'informations sur les fichiers Project Object Model dans Apache Maven, consultez Introduction to the POM (Présentation de POM).

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.9.0</version>
</dependency>

Si vous utilisez Gradle pour automatiser les builds, déclarez la dépendance suivante.

dependencies {
    compile 'com.rabbitmq:amqp-client:5.9.0'
}

Importer les classe Connection et Channel

Le client Java RabbitMQ utilise com.rabbitmq.client comme paquet de premier niveau, avec les classes d'API Connection et Channel représentant une connexion et un canal AMQP 0-9-1, respectivement. Importez les classe Connection et Channel avant de les utiliser, comme illustré dans l'exemple suivant.

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

Créer un ConnectionFactory et se connecter à votre agent

Utilisez l'exemple suivant pour créer une instance de la classe ConnectionFactory avec les paramètres donnés. Utilisation de la méthode setHost pour configurer le point de terminaison de l'agent noté précédemment. Pour les connexions au niveau filaire AMQPS, utilisez le port 5671.

ConnectionFactory factory = new ConnectionFactory();

factory.setUsername(username);
factory.setPassword(password);

//Replace the URL with your information
factory.setHost("b-c8352341-ec91-4a78-ad9c-a43f23d325bb.mq.us-west-2.amazonaws.com");
factory.setPort(5671);

// Allows client to establish a connection over TLS
factory.useSslProtocol();

// Create a connection
Connection conn = factory.newConnection();

// Create a channel
Channel channel = conn.createChannel();

Publier un message dans un échange

Vous pouvez utiliser Channel.basicPublish pour publier des messages dans un échange. L'exemple suivant utilise la classe Builder AMQP pour créer un objet de propriétés de message avec le type de contenu plain/text.

byte[] messageBodyBytes = "Hello, world!".getBytes();
channel.basicPublish(exchangeName, routingKey,
             new AMQP.BasicProperties.Builder()
               .contentType("text/plain")
               .userId("userId")
               .build(),
               messageBodyBytes);

S'abonner à une file d'attente et recevoir un message

Vous pouvez recevoir un message en vous abonnant à une file d'attente à l'aide de l'interface Consumer. Une fois abonné, les messages seront alors remis automatiquement dès leur arrivée.

La façon la plus simple d'implémenter un objet Consumer est d'utiliser la sous-classe DefaultConsumer. Un objet DefaultConsumer peut être transmis comme faisant partie d'un appel basicConsume pour configurer l'abonnement comme illustré dans l'exemple suivant.

boolean autoAck = false;
channel.basicConsume(queueName, autoAck, "myConsumerTag",
     new DefaultConsumer(channel) {
         @Override
         public void handleDelivery(String consumerTag,
                                    Envelope envelope,
                                    AMQP.BasicProperties properties,
                                    byte[] body)
             throws IOException
         {
             String routingKey = envelope.getRoutingKey();
             String contentType = properties.getContentType();
             long deliveryTag = envelope.getDeliveryTag();
             // (process the message components here ...)
             channel.basicAck(deliveryTag, false);
         }
     });

Fermer votre connexion et se déconnecter de l'agent

Afin de vous déconnecter de votre agent RabbitMQ, fermez à la fois le canal et la connexion comme indiqué ci-dessous.

channel.close();
conn.close();

Étape 3 : (Facultatif) Se connecter à une AWS Lambda fonction

AWS Lambda peut se connecter à votre courtier Amazon MQ et en consommer les messages. Lorsque vous connectez un agent à Lambda, vous créez un mappage de la source d'événement qui lit les messages d'une file d'attente et appelle la fonction de manière synchrone. Le mappage de la source d'événements que vous créez lit les messages de votre agent par lots et les convertit en une charge utile Lambda sous la forme d'un objet JSON.

Pour plus d'informations sur la connexion d'Amazon MQ à Lambda, les options prises en charge par Lambda pour une source d'événement Amazon MQ et les erreurs de mappage de la source d'événement, consultez Utilisation de Lambda avec Amazon MQ dans le Guide du développeur AWS Lambda .