ApsaraMQ for RocketMQ:Intégration avec Spring

ApsaraMQ for RocketMQ fournit des projets de démonstration qui intègrent le SDK ons-client en tant que beans gérés par Spring, vous offrant ainsi des composants producteur et consommateur prêts pour l'injection de dépendances. Ce guide présente la démonstration Spring Boot. La démonstration Spring standard suit le même modèle.

Types de messages pris en charge

L'intégration Spring prend en charge les producteurs et les consommateurs pour les types de messages suivants :

• Messages normaux

• Messages ordonnés

• Messages transactionnels

Prérequis

Avant de commencer, assurez-vous de disposer des éléments suivants :

• JDK 1.8 ou version ultérieure

• Maven 2.5 ou version ultérieure

• IntelliJ IDEA ou un autre IDE Java

• Une instance ApsaraMQ for RocketMQ avec un endpoint TCP

• Une paire AccessKey (ID AccessKey et secret AccessKey)

Étape 1 : Télécharger le projet de démonstration

Clonez ou téléchargez l'un des projets de démonstration depuis GitHub :

Étape 2 : Créer les ressources

Créez les ressources suivantes dans la console ApsaraMQ for RocketMQ :

1. Créer une instance.

2. Créer un topic. Définissez le type de message pour qu'il corresponde aux messages que vous prévoyez d'envoyer. Par exemple, sélectionnez Normal pour les messages normaux ou Ordered pour les messages ordonnés.

3. Créer un groupe. Sélectionnez TCP comme type de protocole, car le SDK ons-client communique via TCP.

4. Obtenir l'endpoint TCP de votre instance.

Étape 3 : Configurer le projet de démonstration

Ouvrez le projet de démonstration dans IntelliJ IDEA, puis mettez à jour la dépendance Maven et les propriétés de l'application.

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>com.aliyun.openservices</groupId>
        <artifactId>ons-client</artifactId>
        <!-- Replace with the latest version -->
        <version>1.8.8.8.Final</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

Étape 4 : Exécuter la démonstration

Assurez-vous que les classes situées sous java-springboot-demo/src/main/java/com/aliyun/openservices/springboot/example sont importées dans votre projet, puis exécutez la méthode main().

Étapes suivantes

• Filtrage des messages — Filtrez les messages par tag ou par expression SQL.

• Notes de version — Vérifiez la dernière version du SDK ons-client.