With SSL
If SSL is enabled, data will be encrypted before transmission for enhanced security. This section describes how to use TCP to connect to a RocketMQ instance with SSL in CLI mode.
Intra-VPC access and public access differ only in the connection IP addresses and ports. For intra-VPC access, use port 8100. For public access, use port 8200.
The following describes only the procedure for public access. For intra-VPC access, replace the IP addresses with the actual ones.
Prerequisites
- A RocketMQ instance has been created (see Step 2: Create a RocketMQ Instance) and you have obtained the metadata connection addresses for intra-VPC access or public network access.
- 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
- Download the rocketmq-tutorial software package.
wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip
- Decompress the rocketmq-tutorial package.
unzip rocketmq-tutorial.zip
- Go to the rocketmq-tutorial/bin directory.
cd rocketmq-tutorial/bin
- 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 metadata connection addresses for intra-VPC access or public network access to the RocketMQ instance
- Topic name: name of the topic created for the RocketMQ instance
In the following example, 100.85.125.89:8200;100.85.119.144:8200 are the metadata connection addresses for public network access to the RocketMQ instance, and topic-test is the topic name.
JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "100.85.125.89:8200;100.85.119.144:8200" -t topic-test -p "hello rocketmq"
Press Ctrl+C to exit.
- 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 metadata connection addresses for intra-VPC access or public network access to the RocketMQ instance
- Topic name: name of the topic created for the RocketMQ instance
In the following example, 100.85.125.89:8200;100.85.119.144:8200 are the metadata connection addresses for public network access to the RocketMQ instance, and topic-test is the topic name.
JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "100.85.125.89:8200;100.85.119.144:8200" -t topic-test
To stop consuming messages, press Ctrl+C to exit.
- 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 metadata connection addresses for intra-VPC access or public network access to the RocketMQ instance
- Topic name: name of the topic created for the RocketMQ instance
In the following example, 100.85.125.89:8200;100.85.119.144:8200 are the metadata connection addresses for public network access to the RocketMQ instance, and topic-test is the topic name.
JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "100.85.125.89:8200;100.85.119.144:8200" -t topic-test -p "hello rocketmq" -m true
Press Ctrl+C to exit.
- 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 metadata connection addresses for intra-VPC access or public network access to the RocketMQ instance
- Topic name: name of the topic created for the RocketMQ instance
In the following example, 100.85.125.89:8200;100.85.119.144:8200 are the metadata connection addresses for public network access to the RocketMQ instance, and topic-test is the topic name.
JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "100.85.125.89:8200;100.85.119.144:8200" -t topic-test -m true
Press Ctrl+C to exit.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.