RocketMQ–生产者之延迟消息

MessageStoreConfig

固定精度消息延迟时间

private String messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";

setDelayTimeLevel

// 1. 创建消息 Message message = new Message("test_quick_topic", // 主题 "TagA", // 标签 "key" + i, // 用户自定义的key ,唯一的标识 ("Hello RocketMQ" + i).getBytes()); // 消息内容实体（byte[]） message.setDelayTimeLevel(3);