文件名称：rocketmq:RocketMq支持任意延迟时间的延时消息
文件大小：3.19MB
文件格式：ZIP
更新时间：2024-06-15 08:59:31
Java
RocketMq支持任意延迟的延时消息方案 主要特性 支持任意延迟的延时消息，精确到秒，最长延迟时间为1年。 使用方法 配置broker.conf segmentScale=60 ##每个时间桶的时间范围，单位分钟，默认60，可选值0-60之间，延迟消息并发数越高，配置的值应该越小，如：10 dispatchLogKeepTime=72 ##dispatchLog过期后保存的小时数，默认72 producer DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); producer.setNamesrvAddr("127.0.0.1:9876"); producer.start(); for (int i = 0; i <