接收异步任务完成通知

{
  "datacontenttype": "application/json;charset=utf-8",
  "aliyunaccountid": "xxxxx",
  "aliyunpublishtime": "2023-10-25T01:45:16.993Z",
  "data": {
    "start_time": "2023-10-25 09:45:09",
    "user_api_unique_key": "apikey:v1:audio:asr:transcription:paraformer-8k-v1",
    "task_status": "SUCCEEDED",
    "contain_result": false,
    "end_time": "2023-10-25 09:45:16",
    "task_id": "a154c328-xxxx-xxxx-xxxx-e52a9a7e9a35",
    "region": "cn-beijing",
    "request_id": "108f38f5-xxxx-xxxx-xxxx-6504db9080b3",
    "api_key_id": "1250"
  },
  "aliyunoriginalaccountid": "xxxxxxxx",
  "specversion": "1.0",
  "aliyuneventbusname": "default",
  "id": "81765e5b-xxxx-xxxx-xxxx-bbad8dde2bd9",
  "source": "acs.dashscope",
  "time": "2023-1-25T01:45:16.969Z",
  "aliyunregionid": "cn-beijing",
  "type": "dashscope:System:AsyncTaskFinish"
}

{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"]
}

{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"],
  "data": {
    "user_api_unique_key": [
      {"suffix": ":paraformer-8k-v1"}
    ]
  }
}

{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"]
}

{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"],
  "data": {
    "user_api_unique_key": [
      {"suffix": ":paraformer-8k-v1"}
    ]
  }
}

<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-client-java</artifactId>
  <version>5.0.4</version>
</dependency>

import com.alibaba.fastjson2.JSON;
import org.apache.rocketmq.client.apis.*;
import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
import org.apache.rocketmq.client.apis.consumer.FilterExpression;
import org.apache.rocketmq.client.apis.consumer.FilterExpressionType;
import org.apache.rocketmq.client.apis.consumer.PushConsumer;
import org.apache.rocketmq.shaded.org.slf4j.Logger;
import org.apache.rocketmq.shaded.org.slf4j.LoggerFactory;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Collections;

public class ConsumerExample {
    private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerExample.class);

    private ConsumerExample() {
    }

    public static void main(String[] args) throws ClientException, IOException, InterruptedException {
        /*
          实例接入点，从控制台实例详情页的接入点页签中获取。
          如果是在阿里云ECS内网访问，建议填写VPC接入点。
          如果是在本地公网访问，或者是线下IDC环境访问，可以使用公网接入点。使用公网接入点访问，必须开启实例的公网访问功能。
         */
        String endpoints = "xxxx";
        // 指定需要订阅哪个目标Topic，Topic需要提前在控制台创建，如果不创建直接使用会返回报错。
        String topic = "xxxx";
        // 为消费者指定所属的消费者分组，Group需要提前在控制台创建，如果不创建直接使用会返回报错。
        String consumerGroup = "xxxx";
        final ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoints);
        /*
          如果是使用公网接入点访问，configuration还需要设置实例的用户名和密码。用户名和密码在控制台实例详情页获取。
          如果是在阿里云ECS内网访问，无需填写该配置，服务端会根据内网VPC信息智能获取。
         */
        builder.setCredentialProvider(new StaticSessionCredentialsProvider("xxxx", "xxxx"));
        ClientConfiguration clientConfiguration = builder.build();
        // 订阅消息的过滤规则，表示订阅所有Tag的消息。
        String tag = "*";
        FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG);
        // 初始化SimpleConsumer，需要绑定消费者分组ConsumerGroup、通信参数以及订阅关系。
        PushConsumer pushConsumer = provider.newPushConsumerBuilder()
            .setClientConfiguration(clientConfiguration)
            // 设置消费者分组。
            .setConsumerGroup(consumerGroup)
            // 设置预绑定的订阅关系。
            .setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression))
            // 设置消费监听器。
            .setMessageListener(messageView -> {
                try {
                    // 处理消息并返回消费结果。
                    ByteBuffer buffer = messageView.getBody();
                    ByteBuffer newBuffer = ByteBuffer.allocate(buffer.capacity());
                    for (int i = 0; i < buffer.capacity(); i++) {
                        newBuffer.put(buffer.get(i));
                    }
                    String result = new String(newBuffer.array());
                    LOGGER.info("Consume message={}", JSON.toJSONString(result));
                    System.out.println(result);
                    return ConsumeResult.SUCCESS;
                } catch (Exception e) {
                    LOGGER.error("deal message has error", e);
                    return ConsumeResult.FAILURE;
                }
            })
            .build();
        Thread.sleep(Long.MAX_VALUE);

        // 如果不需要再使用PushConsumer，可关闭该进程。
        pushConsumer.close();
    }
}