Intégration de SQS avec Spring Boot : démarrage rapide

Qu’est-ce qu’Amazon SQS ?

• Amazon SQS (Simple Queue Service) est un service de mise en file d’attente de messages entièrement géré qui nous permet de communiquer de manière asynchrone entre les différents composants de notre application.
• Nous pouvons envoyer, stocker et recevoir des messages entre les composants logiciels. Il peut gérer n’importe quelle quantité de données, évoluant dynamiquement pour correspondre au débit de notre application.
• En utilisant SQS, nous payons uniquement pour ce que vous utilisez. Il n’y a pas de frais initiaux ni de frais minimum, et nous sommes facturés en fonction du nombre de demandes et de la quantité de données transférées.

Comment fonctionne SQS ?

Simple Queue Service implique essentiellement trois composants principaux : les producteurs, les consommateurs et la file d’attente.

• Producteurs: Ce sont les composants qui envoient des messages à la file d’attente. Il peut s’agir de n’importe quelle partie de votre application qui doit communiquer avec un autre composant.
• Files d’attente: La file d’attente est le stockage temporaire des messages. Les producteurs envoient les messages à la file d’attente, où ils sont stockés jusqu’à ce qu’ils soient traités par les consommateurs.
• Consommateurs: Ce sont les composants qui reçoivent et traitent les messages de la file d’attente. Les consommateurs vérifient la file d’attente à la recherche de nouveaux messages et les traitent dès qu’ils deviennent disponibles.

Intégration du service de file d’attente simple avec Spring Boot

1. Création d’une file d’attente SQS :

Tout d’abord, nous devons créer une file d’attente en nous connectant à AWS Management Console, configurer les paramètres de file d’attente et créer la file d’attente.

2. Mise en place du projet Spring Boot :

Créez un nouveau projet Spring Boot à l’aide de l’IDE ou Spring Initializr, puis ajoutez les dépendances nécessaires au projet

Utiliser Gradle :

dependencies {
implementation 'org.springframework:spring-messaging:5.3.27'
implementation 'software.amazon.awssdk:sqs:2.26.8'
implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs'
}

3. Ajoutez la configuration de vos informations d’identification AWS :

Assurez-vous que vos informations d’identification AWS sont configurées. Ajoutez vos informations d’identification dans application.properties ou utilisez la configuration AWS CLI.

aws.access.key.id=your-access-key
aws.secret.access.key=your-secret-key
aws.region=your-region

4. Créer une classe de configuration :

Créez une classe de configuration pour configurer le client SQS et la file d’attente.

@Configuration
public class SQSConfig {

@Bean
public SqsClient createSqsClient() {
return SqsClient.builder()
.credentialsProvider(DefaultCredentialsProvider.create())
.region(Region.of("your_region"))
.build();
}
}

5. Envoyer des messages à SQS

Créez une classe de service pour envoyer des messages à la file d’attente SQS.

@Service
public class SqsService {

private final String queueUrl; (// Specify your queue URL in the config file)

public void sendMessageToQueue(String messageBody) {
log.info("Sending msg to SQS queue");
try {
SqsClient sqsClient = sqsConfig.createSqsClient();
String jsonMessage;
try {
jsonMessage = objectMapper.writeValueAsString(messageBody);
} catch (JsonProcessingException e) {
log.error("Error converting message to JSON: {}", e.getMessage());
return;
}
SendMessageRequest sendMessageRequest = SendMessageRequest.builder()
.queueUrl(queueUrl)
.messageBody(jsonMessage)
.build();
sqsClient.sendMessage(sendMessageRequest);
log.info("Message sent to SQS queue");
} catch (Exception e) {
log.error("Error sending message to SQS queue: {}", e.getMessage());
}
}
}

6. Recevez des messages de SQS :

Créez une classe de service pour recevoir les messages de la file d’attente SQS.

@Component("sqsConsumer")
@RequiredArgsConstructor
public class SQSConsumer {

@SqsListener("your_queue_name")
public void consumeQueueMessages(String message) {
log.info("Received message from SQS queue: {}", message);
processMessage(message);
}

private void processMessage(String messageBody) {
try {
log.info("Started processing queue message.");
// You can specify your logic for processing the message according to requirements
} catch (Exception e) {
log.error("Error processing message from SQS queue: {}", e.getMessage(), e);
}
}
}

7. Propriétés de l’application

Vous pouvez ajouter l’URL de la file d’attente à votre fichier application.properties ou application.yml

sqs.queue.url="your_queue_url"

Amazon SQS par rapport à d’autres systèmes de messagerie : référence rapide

• Interrogation et interrogation longue : Amazon SQS utilise un modèle d’interrogation pour récupérer les messages. Par défaut, il utilise une interrogation courte, qui renvoie immédiatement même si aucun message n’est disponible. Cela réduit le nombre de réponses vides et contribue à réduire les coûts en réduisant le nombre de requêtes adressées à SQS. D’autre part, RabbitMQ et Kafka nécessitent la gestion du courtier, du clustering et de la mise à l’échelle.
• Livraison des messages : SQS fournit une livraison au moins une fois pour les files d’attente standard et une livraison exactement une fois pour les files d’attente FIFO. tandis que Kafka prend en charge la sémantique de livraison au moins une fois et exactement une fois en fonction de la configuration.
• Évolutivité : SQS évolue automatiquement en fonction du volume de messages, tandis que RabbitMQ et Kafka nécessitent une mise à l’échelle manuelle pour ajouter des nœuds ou configurer des clusters.
• Durabilité : Dans SQS, les messages sont stockés dans plusieurs zones de disponibilité AWS, tandis que dans RabbitMQ et Kafka, les messages et les files d’attente peuvent être configurés pour être durables afin de résister aux pannes du courtier.

Conclusion

En suivant les étapes ci-dessus, vous pouvez intégrer efficacement SQS à votre application Spring Boot, permettant ainsi des fonctionnalités de messagerie fiables et évolutives. Assurez-vous également que les messages sont supprimés de la file d’attente après un traitement réussi. De plus, vous pouvez implémenter une gestion appropriée des erreurs pour le traitement des messages et les tentatives.

VOUS TROUVEZ CECI UTILE ? PARTAGEZ-LE