<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId>
</dependency>

rocketmq:name-server: 172.31.0.44:9876producer:group: delay-group

@Component
@Slf4j
public class DelayProduce {@Autowiredprivate RocketMQTemplate rocketMQTemplatet;public void sendDelayMessage(String topic,String message,int delayLevel){SendResult sendResult = rocketMQTemplatet.syncSend(topic, MessageBuilder.withPayload(message).build(), 2000, delayLevel);log.info("sendtime is {}", DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss").format(LocalDateTime.now()));log.info("sendResult is{}",sendResult);}
}

@Slf4j
@Component
@RocketMQMessageListener(topic = "delay-topic",consumerGroup = "delay-group"
)
public class DelayConsumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {log.info("received message time is {}", DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss").format(LocalDateTime.now()));log.info("received message is {}",message);}
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class DelayProduceTest {@Autowiredprivate DelayProduce delayProduce;@Testpublic void sendDelayMessage() {delayProduce.sendDelayMessage("delay-topic","Hello,JAVA日知录",5);}
}

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir = /app/rocketmq/data
messageDelayLevel=90s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

public void sendDelayMessage() {delayProduce.sendDelayMessage("delay-topic","Hello,JAVA日知录",1);
}