RocketMQ的消息没消费如何扔回消息队列，请给出java代码实例

当RocketMQ消息没有被消费者成功消费时，可以使用消息重试机制来进行重试。如果重试多次仍然失败，则可以将该消息重新投递到消息队列中，等待后续的消费者重新消费。

以下是Java代码示例，用于将未消费的消息重新投递到消息队列中：

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.common.message.MessageConst;

public class RetryMessageUtil {

    // 将消息重新投递到消息队列中
    public static void retryMessage(DefaultMQProducer producer, Message message) throws Exception {
        // 获取消息的重试次数
        int retryTimes = message.getReconsumeTimes();

        if (retryTimes >= 3) {
            // 如果消息已经重试了3次，则放弃重试，直接将消息标记为已经消费
            message.putUserProperty(MessageConst.PROPERTY_RECONSUME_TIME, String.valueOf(retryTimes));
            producer.send(message);
        } else {
            // 如果消息还未重试3次，则将消息重新发送到消息队列中，并设置消息的延迟时间
            message.setDelayTimeLevel(3); // 设置延迟时间为10秒
            producer.send(message);
        }
    }
}

使用该工具类，您可以在消费者消费消息失败时，调用`retryMessage`方法将消息重新投递到消息队列中。如果消息已经重试了3次，则将消息标记为已经消费。如果消息还未重试3次，则将消息重新发送到消息队列中，并设置消息的延迟时间。