Avant d'utiliser le SDK pour envoyer et recevoir des messages, créez les ressources ApsaraMQ for RocketMQ requises : une instance, un topic et un groupe de consommateurs. Vous avez également besoin du endpoint de l'instance. Spécifiez ces ressources dans votre code SDK.
Prérequis
Informations générales
Vous pouvez créer des ressources via la console ou en appelant des API. La procédure suivante utilise la console.
Pour créer des ressources à l'aide d'OpenAPI, consultez les rubriques suivantes :
Limites
-
Restrictions régionales
Assurez-vous que l'instance créée se trouve dans la même région que le VPC et le vSwitch définis dans les prérequis.
-
Conventions de nommage
Pour connaître les conventions de nommage des instances, des topics et des groupes de consommateurs, consultez la rubrique Quotas et limites.
-
Restrictions liées au type de topic
Le type de message d'un topic doit correspondre au type de messages envoyés et reçus. Par exemple, si vous créez un topic pour des messages normaux, vous ne pouvez l'utiliser que pour envoyer et recevoir des messages normaux, et non des messages ordonnés. Pour plus d'informations, consultez la section Recommandations d'utilisation des topics.
Créer une instance
Connectez-vous à la console ApsaraMQ for RocketMQ. Dans le volet de navigation de gauche, cliquez sur Instances.
Dans la barre de navigation supérieure, sélectionnez une région, par exemple China (Hangzhou).
-
Sur la page Instances, cliquez sur Create Instance. Dans le panneau Create Message Queue for Apache RocketMQ Instance, définissez Instance Version sur V5.0, sélectionnez un Product Type, puis cliquez sur OK.
ApsaraMQ for RocketMQ prend en charge les types de produits suivants :
Abonnement : modèle prépayé où la facturation est mensuelle, basée sur la spécification de calcul de l'instance.
Paiement à l'utilisation : modèle postpayé où la facturation est horaire, basée sur la spécification de calcul de l'instance.
-
Serverless : modèle de paiement à l'utilisation où la facturation est basée sur le nombre total de requêtes de messages.
Remarque
Pour plus de détails sur les éléments facturables et les scénarios applicables, consultez la rubrique Présentation de la facturation.
-
Sur la page d'achat, sélectionnez les spécifications de l'instance, cliquez sur Buy Now et effectuez le paiement.
Reportez-vous aux tableaux suivants lors de la création d'une instance. Pour plus de détails sur chaque paramètre, consultez la rubrique Sélectionner l'édition de l'instance.
Serverless
Paramètre
Valeur d'exemple
Primary Edition
Standard
Mode de facturation
La valeur par défaut est Pay-by-request.
Spécification de stockage des messages
Aucune sélection de capacité de stockage n'est requise. La facturation est basée sur l'espace de stockage réel utilisé.
ID VPC
vpc-bp1cg09dua6sgh0
ID du VPC créé lors des prérequis.
ImportantUne fois l'instance créée, il est impossible de modifier le VPC sélectionné. Pour changer le VPC associé, vous devez libérer l'instance achetée, puis en acheter une nouvelle.
vSwitch ID
vsw-bp1vqb0p9nz3irz
ID du vSwitch créé lors des prérequis.
Vous devez sélectionner deux vSwitch ID pour une instance Serverless.
ImportantUne fois l'instance créée, il est impossible de modifier le vSwitch sélectionné. Pour changer le vSwitch associé, vous devez libérer l'instance achetée, puis en acheter une nouvelle.
Internet Access
Désactivé
Remarque-
Cette procédure utilise l'accès VPC comme exemple ; l'accès Internet est donc désactivé par défaut. Pour accéder au service via Internet, définissez le Type d'accès Internet sur Activé.
Type d'accès intranet
La valeur par défaut est Pay-By-Data-Transfer.
Les instances Serverless prennent en charge uniquement l'accès VPC et ne prennent pas en charge l'accès Internet.
Resource Group
Sélectionnez le groupe de ressources par défaut.
Security Group
Sélectionnez le groupe de sécurité créé lors des prérequis.
Subscription or pay-as-you-go
Paramètre
Valeur d'exemple
Primary Edition
Standard
Édition de sous-catégorie
Cluster High-availability Edition (Recommandé pour les environnements de production)
Spécification de calcul pour l'envoi et la réception de messages
rmq.s2,2xlarge
ID VPC
vpc-bp1cg09dua6sgh0
ID du VPC créé lors des prérequis.
ImportantUne fois l'instance créée, il est impossible de modifier le VPC sélectionné. Pour changer le VPC associé, vous devez libérer l'instance achetée, puis en acheter une nouvelle.
vSwitch ID
vsw-bp1vqb0p9nz3irz
ID du vSwitch créé lors des prérequis.
ImportantUne fois l'instance créée, il est impossible de modifier le vSwitch sélectionné. Pour changer le vSwitch associé, vous devez libérer l'instance achetée, puis en acheter une nouvelle.
Type d'accès public
Désactivé
RemarqueCette procédure utilise l'accès VPC comme exemple ; l'accès Internet est donc désactivé par défaut. Pour accéder au service via Internet, définissez le Type d'accès Internet sur Activé.
Resource Group
Sélectionnez le groupe de ressources par défaut.
Disk Encryption
Désactivé
RemarqueLe chiffrement de disque est pris en charge uniquement pour les instances Platinum Edition.
Disk Encryption Key
key-hzz66c8207****
RemarqueID de la clé utilisée pour le chiffrement de disque dans la même région. Ce paramètre est requis uniquement lorsque Disk Encryption est défini sur Enable.
-
Obtenir le endpoint de l'instance
Sur la page Instances, cliquez sur le nom de l'instance cible.
-
Sur la page Instance Details, consultez les informations du endpoint dans la section TCP Endpoint.
Endpoint VPC : utilisez cet endpoint pour accéder à ApsaraMQ for RocketMQ depuis un VPC. Cet endpoint est fourni par défaut.
Endpoint public : utilisez cet endpoint pour accéder au service via Internet. Cet endpoint s'affiche uniquement si l'accès public est activé.
Obtenir le nom d'utilisateur et le mot de passe de l'instance
Les étapes suivantes indiquent comment obtenir le nom d'utilisateur et le mot de passe système en utilisant la méthode de contrôle d'accès par défaut : l'authentification intelligente.
Pour utiliser l'authentification par liste de contrôle d'accès (ACL) à la place, créez un utilisateur ACL, configurez les autorisations, puis utilisez le nom d'utilisateur et le mot de passe ACL. Pour plus d'informations, consultez la rubrique Authentification des utilisateurs.
Lorsqu'un client se connecte au serveur ApsaraMQ for RocketMQ, configurez un nom d'utilisateur et un mot de passe en fonction de la méthode d'accès.
Pour accéder au serveur via Internet : vous devez configurer le nom d'utilisateur et le mot de passe de l'instance.
Pour accéder au serveur depuis un VPC : pour les instances Serverless, les identifiants ne sont pas requis si l'accès sans authentification est activé. Pour les autres types d'instances, l'authentification est automatique et ne nécessite pas d'identifiants.
Sur la page Instances, cliquez sur le nom de l'instance cible.
Dans le volet de navigation de gauche, cliquez sur Access Control.
Cliquez sur l'onglet Intelligent Authentication pour afficher le Username et le Password de l'instance.
Créer un topic
Sur la page Instances, cliquez sur le nom de l'instance cible.
Dans le volet de navigation de gauche, cliquez sur Topics. Ensuite, sur la page Topics, cliquez sur Create Topic.
Dans le panneau Create Topic, saisissez un nom de topic et une description, définissez Message Type sur Normal Message, puis cliquez sur OK.
Créer un groupe de consommateurs
Sur la page Instances, cliquez sur le nom de l'instance cible.
Dans le volet de navigation de gauche, cliquez sur Groups. Ensuite, sur la page Groups, cliquez sur Create Group.
Dans le panneau Create Group, saisissez un Group ID, laissez les autres paramètres avec leurs valeurs par défaut, puis cliquez sur OK.
Étapes suivantes
Étape 3 : Utiliser un SDK pour envoyer et recevoir des messages