Configurez le SDK Apache RocketMQ pour Java afin d'envoyer et de recevoir des messages via ApsaraMQ for RocketMQ 5.x.
Étape 1 : Installer le SDK
Importez les dépendances avec Maven ou téléchargez le package JAR. Pour la dernière version du SDK, consultez la section Versions recommandées.
Étape 2 : Créer des ressources cloud
Créez les ressources suivantes dans la console ApsaraMQ for RocketMQ avant d'exécuter l'exemple de code :
| Ressource | Description |
|---|---|
| Endpoint de l'instance | URL utilisée par votre client pour se connecter à ApsaraMQ for RocketMQ |
| Topic | Destination vers laquelle les producteurs envoient les messages |
| Groupe de consommateurs | Regroupement de consommateurs abonnés à des topics |
Pour des instructions détaillées, consultez la section Étape 2 : Créer des ressources.
Étape 3 : Exécuter le projet de démonstration
Clonez le projet de démonstration depuis GitHub.
Mettez à jour les paramètres de connexion dans l'exemple de code avec les ressources créées à l'étape 2.
Compilez et exécutez le projet.
Si votre projet utilise le SDK rocketmq-client au lieu de rocketmq-client-java, vous n'avez pas besoin de télécharger le projet de démonstration. Consultez la section Exemples de code pour des exemples d'intégration.