Step 4: Connect to a RocketMQ Instance to Create and Retrieve Messages

Prerequisites

• A RocketMQ instance has been created following the instructions in Step 2: Create a RocketMQ Instance, and the instance addresses have been recorded.
• Security group rules have been configured.
• A topic has been created and you have obtained the topic name.
• An ECS has been created. For intra-VPC access, ensure that its VPC, subnet, and security group configurations are the same as those of the RocketMQ instance.
• You have installed the JDK and configured the environment variables. For details, see Step 1: Prepare the Environment.

Accessing the Instance with CLI

1. Download the rocketmq-tutorial software package.

   wget https://dms-demo.obs.ru-moscow-1.hc.sbercloud.ru/rocketmq-tutorial.zip
   
   

2. Decompress the rocketmq-tutorial package.

   unzip rocketmq-tutorial.zip
   
   

3. Go to the rocketmq-tutorial/bin directory.

   cd rocketmq-tutorial/bin
   
   

4. Create normal messages using the sample project.

   JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq"
   
   

   Parameter description:

   • Connection addresses: the RocketMQ instance address.
   • Topic name: name of the topic created for the RocketMQ instance

   In the following example, 100.xxx.xxx.89:8200;100.xxx.xxx.144:8200 are the connection addresses to the RocketMQ instance, and topic-test is the topic name.

   JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "100.xxx.xxx.89:8200;100.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq"
   
   

   Press Ctrl+C to exit.

5. Retrieve normal messages using the sample project.

   JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name}
   
   

   Parameter description:

   • Connection addresses: the RocketMQ instance address.
   • Topic name: name of the topic created for the RocketMQ instance

   In the following example, 100.xxx.xxx.89:8200;100.xxx.xxx.144:8200 are the connection addresses to the RocketMQ instance, and topic-test is the topic name.

   JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "100.xxx.xxx.89:8200;100.xxx.xxx.144:8200" -t topic-test
   
   

   To stop consuming messages, press Ctrl+C to exit.

6. Create messages with traces using the sample project.

   JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "${Connection addresses}" -t ${Topic name} -p "hello rocketmq" -m true
   
   

   Parameter description:

   • Connection addresses: the RocketMQ instance address.
   • Topic name: name of the topic created for the RocketMQ instance

   In the following example, 100.xxx.xxx.89:8200;100.xxx.xxx.144:8200 are the connection addresses to the RocketMQ instance, and topic-test is the topic name.

   JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "100.xxx.xxx.89:8200;100.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq" -m true
   
   

   Press Ctrl+C to exit.

7. Retrieve messages and send the message traces using the sample project.

   JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "${Connection addresses}" -t ${Topic name} -m true
   
   

   Parameter description:

   • Connection addresses: the RocketMQ instance address.
   • Topic name: name of the topic created for the RocketMQ instance

   In the following example, 100.xxx.xxx.89:8200;100.xxx.xxx.144:8200 are the connection addresses to the RocketMQ instance, and topic-test is the topic name.

   JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "100.xxx.xxx.89:8200;100.xxx.xxx.144:8200" -t topic-test -m true
   
   

   Press Ctrl+C to exit.