DefaultMQPullConsumer循环拉取数据demo

DefaultMQPullConsumer是阿里云消息中间件MaxCompute（原OSS Message Queue）提供的一个用于从队列消费数据的客户端组件。下面是一个简单的循环拉取数据的Demo示例，假设我们已经有一个初始化好的Consumer实例：

import com.alipay.cloud.mq.consumer.DefaultMQPullConsumer;
import com.alipay.cloud.mq.message.Message;

public class PullDataDemo {
    private static final String GROUP_ID = "your_group_id";
    private static final String QUEUE_NAME = "your_queue_name";
    private static DefaultMQPullConsumer consumer;

    public static void main(String[] args) {
        // 初始化消费者
        consumer = new DefaultMQPullConsumer(GROUP_ID);
        consumer.subscribe(QUEUE_NAME, "*", false); // 订阅queue，*表示接收所有topic

        try {
            while (true) { // 循环拉取消息
                // 设置拉取策略，如设置超时时间、最大尝试次数等
                consumer.setConsumeMessageWaitTime(5000); // 每次拉取消息等待5秒
                consumer.setMaxConsumeMessageNums(10); // 每次最多拉取10条消息

                // 开始拉取
                PullResult pullResult = consumer.pull(); // 获取拉取结果

                if (pullResult == null || pullResult.getMsgs().size() == 0) {
                    System.out.println("No message available at the moment.");
                    continue; // 如果没消息就继续下一轮
                }

                for (Message msg : pullResult.getMsgs()) {
                    processMessage(msg); // 处理收到的消息
                }

                // 提交消费确认，告知服务端已成功消费
                consumer.commitOffset(pullResult); 
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭消费者
            consumer.shutdown();
        }
    }

    private static void processMessage(Message msg) {
        // 这里处理接收到的具体消息内容
        System.out.println("Received message: " + msg.getBody());
    }
}