ApsaraMQ for RocketMQ:Instructions

Étape 1 : Créer une tâche

1. Connectez-vous à la console ApsaraMQ for RocketMQ.

2. Dans le volet de navigation de gauche, cliquez sur Global Message Replication, puis sur Create Task.

3. Sur la page Create Task, saisissez les informations suivantes. Les principales configurations sont décrites ci-dessous. Configurez les autres paramètres selon vos besoins. Ensuite, cliquez sur Create.

   En haut de la page, définissez Task Name sur rocket-test, sélectionnez One-way Backup: synchronizes data from the source cluster to the destination cluster pour Task Type, et saisissez une Task Description si nécessaire. Configurez le cluster source et le cluster cible dans les volets gauche et droit. Une flèche entre les volets indique la direction de la synchronisation.

   Pour les configurations des différents types de clusters du cluster source et du cluster cible, consultez les tableaux suivants :

   ApsaraMQ for RocketMQ

   Paramètre	Description	Exemple
   Version	Sélectionnez la version de l'instance ApsaraMQ for RocketMQ. Instance de la série 4.0 Instance de la série 5,0	Instance de la série 5,0
   Region	Sélectionnez la région de l'instance ApsaraMQ for RocketMQ.	Chine (Hangzhou)
   Instance	Sélectionnez l'instance ApsaraMQ for RocketMQ.	rmq-cn-778***
   Mode d'authentification	Aucune configuration requise Authentification basée sur les ACL	Authentification basée sur les ACL
   Nom d'utilisateur	Sélectionnez un nom d'utilisateur.	yS8x01****
   ID du groupe de sécurité	Groupe de sécurité de l'instance ECS qui héberge l'instance ApsaraMQ for RocketMQ. Ce paramètre est requis lorsque Version est défini sur une instance de la série 5.0. Règle entrante : Aucune exigence. Règle sortante : Politique : Autoriser Protocole : TCP personnalisé Destination : Le bloc CIDR doit inclure tous les blocs CIDR des vSwitch du cluster. La plage de ports doit inclure 8080 et 8081.	sg-2ze4jlbqy2s40pc4****
   Configuration système des conditions de filtrage	(Facultatif) Vous pouvez ajouter des attributs personnalisés (propriétés utilisateur) aux messages. Les consommateurs peuvent ensuite filtrer les messages en fonction d'une politique d'abonnement utilisant la syntaxe SQL-92. Key : Clé de la propriété utilisateur. Source cluster value : Valeur de la propriété utilisateur ajoutée aux messages provenant du cluster source. Target cluster value : Valeur de la propriété utilisateur ajoutée aux messages provenant du cluster cible. Le code suivant fournit un exemple de filtrage d'abonnement SQL-92 : String sqlStr = "{Key} IS NOT NULL AND {Key} = {Source/Target Cluster Value}"; consumer.subscribe(MqConfig.TOPIC, MessageSelector.bySql(sqlStr));	Aucun

   Apache RocketMQ

   Paramètre	Description	Exemple
   Point d'accès	Le format d'un point d'accès est {nom de domaine/IP}:{numéro de port}.	XX.XX.XX.XX:8080
   Mode d'authentification	Aucune configuration requise Authentification basée sur les ACL	Authentification basée sur les ACL
   Nom d'utilisateur	Saisissez un nom d'utilisateur en fonction de vos besoins métier.	yS8x01****
   Mot de passe	Saisissez un mot de passe en fonction de vos besoins métier.	F17R4to****
   Type de réseau	Réseau public VPC	Réseau public
   Region	Ce paramètre est requis si vous définissez Network type sur VPC. Sélectionnez la région des instances ECS sur lesquelles Apache RocketMQ est déployé.	Chine (Hangzhou)
   VPC	Ce paramètre est requis si vous définissez Network type sur VPC. Sélectionnez le VPC des instances ECS sur lesquelles Apache RocketMQ est déployé.	vpc-bp17fapfdj0dwzjkd****
   vSwitch	Ce paramètre est requis si vous définissez Network type sur VPC. Sélectionnez le vSwitch des instances ECS sur lesquelles Apache RocketMQ est déployé.	vsw-bp1gbjhj53hdjdkg****
   ID du groupe de sécurité	Ce paramètre est requis si vous définissez Network type sur VPC. Sélectionnez le groupe de sécurité des instances ECS sur lesquelles Apache RocketMQ est déployé. Règle entrante : Aucune exigence. Règle sortante : Politique : Autoriser Protocole : TCP personnalisé Destination : Le bloc CIDR doit inclure les blocs CIDR de tous les nœuds Apache RocketMQ. La plage de ports doit inclure les ports de service de tous les nœuds Apache RocketMQ. Les ports par défaut sont 9876, 10911 et 10909. Si vous avez modifié les ports NameServer ou broker, vous devez spécifier les ports mis à jour.	sg-2ze4jlbqy2s40pc4****
   Configuration système des conditions de filtrage	(Facultatif) Vous pouvez ajouter des attributs personnalisés (propriétés utilisateur) aux messages. Les consommateurs peuvent ensuite filtrer les messages en fonction d'une politique d'abonnement utilisant la syntaxe SQL-92. Key : Clé de la propriété utilisateur. Source cluster value : Valeur de la propriété utilisateur ajoutée aux messages provenant du cluster source. Target cluster value : Valeur de la propriété utilisateur ajoutée aux messages provenant du cluster cible. Le code suivant fournit un exemple de filtrage d'abonnement SQL-92 : String sqlStr = "{Key} IS NOT NULL AND {Key} = {Source/Target Cluster Value}"; consumer.subscribe(MqConfig.TOPIC, MessageSelector.bySql(sqlStr));	Aucun

Étape 2 : Configurer les mappages de rubriques

1. Sur la page Task Basic Information, cliquez sur Message Synchronization Tasks dans le volet de navigation de gauche.

2. Cliquez sur Batch Mapping ou Add Mapping pour configurer les mappages de rubriques pour la synchronisation dans la boîte de dialogue.

   • Batch Mapping : Configurez et sélectionnez les mappages de rubriques requis, puis cliquez sur OK.

   • Add Mapping : Configurez le mappage de rubrique requis, puis cliquez sur OK.

   Remarque

   • Si le cluster source est un cluster Apache RocketMQ, vous devez spécifier un groupe pour la synchronisation des messages. N'utilisez pas un groupe déjà utilisé pour les opérations métier.

   • La synchronisation des messages ne démarre qu'après la configuration des mappages de rubriques.

Étape 3 : (Facultatif) Activer la synchronisation de la progression des consommateurs

Après avoir activé la synchronisation de la progression des consommateurs, la progression actuelle de la consommation d'un groupe consommant une rubrique peut être synchronisée avec le cluster cible. Pour plus d'informations, consultez la section Synchronisation de la progression des consommateurs.

String topic = "topic";
// Subscribe only to the messages of the local region.
FilterExpression filterExpression = new FilterExpression("Region IS NOT NULL", FilterExpressionType.SQL92);
// The Region key in the user property is NULL for locally produced messages because the local producer application does not set this key.
simpleConsumer.subscribe(topic, filterExpression);

String topic = "topic";
// Subscribe to all messages.
FilterExpression filterExpression = new FilterExpression("True", FilterExpressionType.SQL92);
simpleConsumer.subscribe(topic, filterExpression);