tencent cloud

<!-- in your <dependencies> block -->
  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-client</artifactId>
      <version>4.9.4</version>
  </dependency>
  
  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-acl</artifactId>
      <version>4.9.4</version>
  </dependency>

// Instantiate the message producer
   DefaultMQProducer producer = new DefaultMQProducer(
       groupName,
       new AclClientRPCHook(new SessionCredentials(accessKey, secretKey)) // ACL permission
   );
   // Set the Nameserver address
   producer.setNamesrvAddr(nameserver);
   // Start the producer instance
   producer.start();


for (int i = 0; i < 3; i++) {    
    int orderId = i % 3;    
    // Construct message instance    
    Message msg = new Message(TOPIC_NAME, "your tag", "KEY" + i,("Hello RocketMQ " + i).getBytes(StandardCharsets.UTF_8));    
    SendResult sendResult = producer.send(msg, new MessageQueueSelector() {        
      @Override        
      public MessageQueue select(List<MessageQueue> mqs, Message msg1, Object arg) {            
          Integer id = (Integer) arg;            
          int index = id % mqs.size();            
          return mqs.get(index);        
      }    
     }, orderId);    
     System.out.printf("%s%n", sendResult);
}

// Instantiate the consumer
        DefaultMQPushConsumer pushConsumer = new DefaultMQPushConsumer(
            groupName,                                              
            new AclClientRPCHook(new SessionCredentials(accessKey, secretKey))); //ACL permission
        // 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 the consumption status
          return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
      });
      // Start the consumer instance
      pushConsumer.start();