rocketmq 怎么设置过期时间

在RocketMQ中，消息的过期时间可以通过配置`MessageExpireTimeInSecond`属性来设置。这个属性通常是在创建Producer时设置的，或者在生产消息时使用`Producer sendMessage()`或`sendOrderlyMessage()`方法的相应参数。

以下是一个简单的示例：

import com.alibaba.rocketmq.client.producer.DefaultMQProducer;
import com.alibaba.rocketmq.client.producer.MessageProducer;

// 创建Producer实例并设置过期时间（单位为秒）
DefaultMQProducer producer = new DefaultMQProducer("your-producer-group-name");
producer.setInstanceName("your-instance-name"); // 设置实例名称
producer.setMessageExpireTimeInSecond(60 * 60); // 过期时间为一小时

try {
    // 配置好后启动生产者
    producer.start();

    // 发送消息，这里msgExpiresSeconds参数可以用来指定单条消息的过期时间
    MessageProducer messageProducer = producer.createProducerId();
    SendResult sendResult = messageProducer.sendMessage(new TopicMessage(
        "your-topic", // 主题
        "your-tag",   // 标签
        ("key", "value".getBytes()), // 消息内容和键值对
        System.currentTimeMillis(), // 生产时间
        msgExpiresSeconds)); // 可选，单条消息的过期时间

    // 关闭生产者
    producer.shutdown();
} catch (Exception e) {
    e.printStackTrace();
}

请注意，`MessageExpireTimeInSecond`设置的是全局默认值，如果希望某条特定的消息有不同的过期时间，可以在发送消息时提供`msgExpiresSeconds`参数。另外，实际使用时请确保设置的过期时间不要超过集群的清理策略。