tencent cloud

All product documents
TDMQ for RocketMQ
DocumentationTDMQ for RocketMQRocketMQ 5.xGetting StartedUse SDK for TDMQ 4.x to Send/Receive General Messages
Use SDK for TDMQ 4.x to Send/Receive General Messages
Download PDF
Last updated: 2024-01-17 17:45:31
Use SDK for TDMQ 4.x to Send/Receive General Messages
Last updated: 2024-01-17 17:45:31
Download PDF

Operation Scenarios

In calling 4.0 Java SDK for example, this article introduces the process of using an open-source SDK to send and receive messages, thus enhancing your comprehension of the complete procedure in messaging.
Note:
Take the Java client as an exemple. For clients employing other languages, please refer to the SDK Documentation.

Prerequisites

Resources Creation and Preparation already completed
Install JDK 1.8 or the later
Install Maven 2.5 or the later
Download the demo

Steps

Step 1: Install the Java dependency

Incorporate the relevant dependencies in the Java project. Take a Maven project as an example, add the following dependency to pom.xml:
<!-- in your <dependencies> block -->
  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-client</artifactId>
      <version>4.9.7</version>
  </dependency>
  
  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-acl</artifactId>
      <version>4.9.7</version>
  </dependency>

Step 2: Generate a Message

// Instantiate the message producer.
   DefaultMQProducer producer = new DefaultMQProducer(
       groupName,
       new AclClientRPCHook(new SessionCredentials(accessKey, secretKey)) // ACL Permission
   );
   // Set the NameServer address. The address should be in the form of xxx.tencenttdmq.com:8080.
   producer.setNamesrvAddr(nameserver);
   // Start the Producer instance.
   producer.start();
   
   for (int i = 0; i < 10; i++) {
          // Create a message instance and establish the topic and content.
          Message msg = new Message(topic_name, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));
          // Send the message.
          SendResult sendResult = producer.send(msg);
          System.out.printf("%s%n", sendResult);
   }

Step 3: Consume the message

The following code example illustrates the use of Push Consumer. For further details, please refer to the more detailed 4.x documentation.
// Instantiate the consumer
DefaultMQPushConsumer pushConsumer = new DefaultMQPushConsumer(
            groupName,                                              
            new AclClientRPCHook(new SessionCredentials(accessKey, secretKey))); //ACL permissions
        // Set the NameServer address.
pushConsumer.setNamesrvAddr(nameserver);
        // Subscribe to a topic.
pushConsumer.subscribe(topic_name, "*");
      // Register a callback implementation class to process messages pulled from the broker.
pushConsumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
          // Message processing logic.
          System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
          // Mark the message as being successfully consumed, and return to the processing status based on the consumption condition.
          return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
      });
      // Start the consumer instance.
pushConsumer.start();

Step 4: View message details

After sending the message, a message ID (messageID) is generated. Developers can then verify this recently sent message on the "Message Query" page as shown below. Additionally, it allows viewing specific details and track information of the message. For more information, please refer to Message Query.



Was this page helpful?
You can also Contact Sales or Submit a Ticket for help.
Yes
No

Feedback

Contact Us

Contact our sales team or business advisors to help your business.

Contact Us
Technical Support

Open a ticket if you're looking for further assistance. Our Ticket is 7x24 available.

Submit a Ticket
7x24 Phone Support
Hong Kong, China
+852 800 906 020 (Toll Free)
United States
+1 844 606 0804 (Toll Free)
United Kingdom
+44 808 196 4551 (Toll Free)
Canada
+1 888 605 7930 (Toll Free)
Australia
+61 1300 986 386 (Toll Free)
EdgeOne hotline
+852 300 80699
More local hotlines coming soon