1. 程式人生 > >RocketMQ 延時級別配置

RocketMQ 延時級別配置

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);