org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently的consumeMessage方法怎么使用

`org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently` 是 Apache RocketMQ 消费者框架中的一个并发监听器接口，它提供了一个 `consumeMessage` 方法，用于处理接收到的消息。这个方法的主要目的是异步消费消息，并支持同时处理多个消息。

当你创建一个消费者实例并设置 `MessageListenerConcurrently` 作为监听器时，`consumeMessage` 的基本使用步骤如下：

1. **创建消费者实例**:

   Consumer consumer = new DefaultMQPushConsumer("consumerGroup");
   consumer.setMessageListener(new MessageListenerConcurrently() {
       // 实现 consumeMessage 方法
   });

2. **配置消费者属性**:
设置需要订阅的主题、队列组等信息。

3. **启动消费者**:

   consumer.start();

4. **消费消息**:
当有消息到达时，`consumeMessage` 方法会被调用，它接收一个 `MessageExt` 对象作为参数，你可以从中获取消息的内容和其他元数据。示例：

   @Override
   public void consumeMessage(MessageExt msg) {
       try {
           // 解析消息内容
           String messageBody = new String(msg.getBody(), "UTF-8");
           // 处理消息逻辑...
       } catch (UnsupportedEncodingException e) {
           log.error("Failed to decode message body", e);
       }
   }

5. **关闭消费者**:
完成消费任务后，记得调用 `consumer.shutdown()` 关闭消费者。