java rocketmq 自动提交和手动提交代码示例

在Java中使用RocketMQ，消息的提交行为（确认消费）可以通过自动提交和手动提交两种方式来控制。以下是这两种提交方式的基本代码示例：

### 自动提交 (AutoCommit)
自动提交模式下，消费者在接收到一条消息并处理完毕后，会自动将该消息从队列中移除并确认。这是默认的行为，如果你没有显式关闭自动提交或者设置为`false`，则会是自动的。

// 创建ConsumerGroup
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("消费组名称");
// 开启自动提交
consumer.setConsumeMessageAutoCommitEnable(true);

// 消费消息
consumer.start();
Message msg = consumer.fetchMessage(new TopicQueue("主题名", "队列名"), 1);
if (msg != null) {
    // 处理消息
    processMessage(msg);
    // 默认自动提交，这里不需要额外的操作
}

### 手动提交 (Manual Commit)
如果需要更精细的控制，你可以关闭自动提交，然后在处理完消息后手动调用`commitMessage()`来确认消费。

// 设置自动提交为关闭状态
consumer.setConsumeMessageAutoCommitEnable(false);

// 消费消息
Message msg = consumer.fetchMessage(new TopicQueue("主题名", "队列名"), 1);
if (msg != null) {
    // 处理消息
    processMessage(msg);
    // 手动提交消息
    msg.setRequeue(false); // 如果不需要重新排队（例如消费失败），设为false
    consumer.commitMessage(msg); // 提交消费确认
}

### 相关问题--
1. 在什么情况下会选择手动提交而非自动提交？
2. 如何在Java RocketMQ中关闭自动提交功能？
3. 如果消息处理过程中出现异常，如何优雅地处理手动提交？