RocketMQ 延時級別配置
阿新 • • 發佈:2019-02-07
RocketMQ 支援定時訊息,但是不支援任意時間精度,僅支援特定的 level,例如定時 5s, 10s, 1m 等。其中,level=0 級表示不延時,level=1 表示 1 級延時,level=2 表示 2 級延時,以此類推。
如何配置:
在伺服器端(rocketmq-broker端)的屬性配置檔案中加入以下行:
messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
描述了各級別與延時時間的對應對映關係。
這個配置項配置了從1級開始各級延時的時間,如1表示延時1s,2表示延時5s,14表示延時10m,可以修改這個指定級別的延時時間;
時間單位支援:s、m、h、d,分別表示秒、分、時、天;
預設值就是上面宣告的,可手工調整;
預設值已經夠用,不建議調整【僅供參考,還是根據實際需要調整。調整預設值時注意同時要修改時間對應的level級別的值】
如何傳送延時訊息:
傳送延時訊息只需要在客戶端(rocketmq-client端)待發送的訊息( com.alibaba.rocketmq.common.message.Message )中設定延時級別delayLevel即可。
Message msg = new Message(topicName,"",keys,message.getBytes());
msg.setDelayTimeLevel(delayLevel);
SendResult sendResult = getMQProducer.send(msg);