Avant d'utiliser un SDK client TCP pour envoyer et recevoir des messages, créez les ressources requises dans la console ApsaraMQ for RocketMQ. Configurez ensuite les paramètres des ressources en fonction des informations obtenues.
Avant de commencer
Activer ApsaraMQ for RocketMQ et accorder des autorisations à un utilisateur RAM
Contexte
ApsaraMQ for RocketMQ propose des SDK pour plusieurs langages de programmation afin d'envoyer et de recevoir des messages via les protocoles TCP et HTTP. Nous vous recommandons de créer des groupes distincts pour chaque protocole. Pour connaître les limites d'utilisation des groupes selon le protocole, consultez la rubrique Gérer les groupes.
Limites d'accès réseau
Avant d'utiliser ApsaraMQ for RocketMQ, tenez compte des limitations suivantes concernant l'accès au réseau :
Un topic n'est accessible aux producteurs ou aux consommateurs d'un groupe que si ce groupe a été créé sur la même instance et dans la même région que le topic. Par exemple, si vous créez un topic sur l'instance A dans la région China (Hangzhou), seuls les producteurs ou consommateurs d'un groupe créé sur l'instance A dans la région China (Hangzhou) peuvent accéder à ce topic.
Des endpoints publics et privés pour les clients TCP et HTTP sont disponibles dans toutes les régions. Dans les environnements de production, nous vous recommandons d'accéder à ApsaraMQ for RocketMQ via des réseaux privés virtuels (VPC). Si vous souhaitez accéder à ApsaraMQ for RocketMQ depuis d'autres régions, depuis des centres de données locaux ou via Internet alors que Cloud Enterprise Network (CEN) n'est pas disponible, utilisez des endpoints publics. L'utilisation d'endpoints publics entraîne des frais pour le trafic sortant vers Internet. Pour plus d'informations, consultez la rubrique Facturation du trafic Internet.
ApsaraMQ for RocketMQ fournit des endpoints HTTP et TCP. Chaque type d'endpoint ne peut être utilisé que par des clients du même protocole. Par exemple, si vous utilisez un SDK client TCP, spécifiez uniquement un endpoint TCP dans votre code.
Créer une instance
Dans ApsaraMQ for RocketMQ, une instance est une machine virtuelle utilisée pour stocker les informations relatives aux topics et aux groupes. Pour créer une instance ApsaraMQ for RocketMQ, procédez comme suit :
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, telle que China (Hangzhou).
Sur la page Instances, cliquez sur Create Instance.
Dans le panneau Create Message Queue for Apache RocketMQ Instance, configurez les paramètres Instance Type, Name et Description. Cliquez ensuite sur OK.
Créer un topic
Dans ApsaraMQ for RocketMQ, un topic est un identifiant de premier niveau utilisé pour classer les messages. Par exemple, vous pouvez créer un topic nommé Topic_Trade pour identifier les messages transactionnels. Les producteurs de messages peuvent alors publier des messages dans Topic_Trade et les consommateurs peuvent s'y abonner pour les consommer. Les topics doivent respecter les exigences suivantes :
Un topic ne peut pas être partagé entre plusieurs instances. Par exemple, le topic A créé sur l'instance A n'est pas disponible sur l'instance B.
Chaque nom de topic doit être unique au sein d'une instance.
Nous vous recommandons de créer des topics distincts pour envoyer différents types de messages. Par exemple, vous pouvez créer le topic A pour les messages normaux, le topic B pour les messages transactionnels et le topic C pour les messages planifiés et différés.
Dans le volet de navigation de gauche de la page Instance Details, cliquez sur Topics.
Sur la page Topics, cliquez sur Create Topic.
-
Dans le panneau Create Topic, configurez les paramètres Name et Description, définissez le paramètre Message Type sur Normal Message, puis cliquez sur OK.
RemarqueDans l'exemple suivant, des messages normaux sont utilisés. Le topic créé en suivant les étapes décrites dans cette rubrique ne peut pas être utilisé pour envoyer ou recevoir d'autres types de messages. Chaque topic permet uniquement d'envoyer et de recevoir un type spécifique de message. Pour plus d'informations sur les types de messages, consultez la rubrique Types de messages.
Créer un groupe
Dans ApsaraMQ for RocketMQ, un groupe sert à identifier les producteurs ou les consommateurs d'un même type. Les groupes doivent respecter les exigences suivantes :
Limite de 1 000 groupes par instance. Réutilisez ou supprimez les groupes inutilisés pour rester dans cette limite. Pour augmenter ce quota, contactez le support technique ApsaraMQ for RocketMQ.
Un groupe ne peut pas être partagé entre plusieurs instances.
-
ApsaraMQ for RocketMQ prend en charge les protocoles HTTP et TCP pour la consommation de messages. Différents groupes peuvent utiliser des protocoles différents, mais tous les consommateurs au sein d'un même groupe doivent utiliser le même protocole.
L'utilisation de protocoles mixtes au sein d'un groupe peut entraîner des échecs de consommation, une duplication ou une perte de messages.
Les modifications de protocole pour un groupe prennent environ 1 à 2 heures pour être effectives.
Si les consommateurs d'un groupe consomment des messages via un protocole différent de celui affiché dans la console ApsaraMQ for RocketMQ, les données affichées dans la console seront inexactes et des problèmes tels que la perte de messages ou des messages non consommés peuvent survenir. Assurez-vous que le protocole déclaré pour un groupe dans la console correspond au protocole effectivement utilisé par les consommateurs. Si vous devez corriger le type de protocole déclaré pour un groupe dans la console, contactez le support technique ApsaraMQ for RocketMQ.
Un ID de groupe est requis pour chaque consommateur, mais facultatif pour les producteurs.
Dans le volet de navigation de gauche de la page Instance Details, cliquez sur Groups.
Sur la page Groups, choisissez .
Dans le panneau Create Group for TCP Protocol, configurez les paramètres Group ID et Description. Cliquez ensuite sur OK.
Obtenir un endpoint
Après avoir créé les ressources dans la console ApsaraMQ for RocketMQ, obtenez l'endpoint permettant d'accéder à l'instance. Avant d'envoyer et de recevoir des messages, spécifiez l'endpoint sur les clients producteurs et consommateurs afin de permettre à ces derniers d'accéder à l'instance dans la région spécifiée.
Dans le volet de navigation de gauche de la page Instance Details, cliquez sur Instance Details.
Dans la section TCP Endpoint de la page Instance Details, placez le pointeur sur l'endpoint et cliquez dessus pour le copier.
Avant d'utiliser les endpoints, tenez compte des points suivants :
Chaque type d'endpoint ne peut être utilisé que par des clients du même protocole. Par exemple, si vous souhaitez utiliser un SDK client TCP pour envoyer et recevoir des messages, utilisez l'endpoint TCP de votre instance ApsaraMQ for RocketMQ pour accéder au broker ApsaraMQ for RocketMQ.
Des endpoints publics et privés pour les clients TCP et HTTP sont disponibles dans toutes les régions. Dans les environnements de production, nous vous recommandons d'accéder à ApsaraMQ for RocketMQ via des réseaux privés virtuels (VPC). Si vous souhaitez accéder à ApsaraMQ for RocketMQ depuis d'autres régions, depuis des centres de données locaux ou via Internet alors que Cloud Enterprise Network (CEN) n'est pas disponible, utilisez des endpoints publics. L'utilisation d'endpoints publics entraîne des frais pour le trafic sortant vers Internet. Pour plus d'informations, consultez la rubrique Facturation du trafic Internet.
Une fois ces opérations effectuées, exécutez l'exemple de code et utilisez ApsaraMQ for RocketMQ pour envoyer et recevoir des messages.
Étapes suivantes
Utiliser les SDK clients TCP pour envoyer et s'abonner à des messages normaux