『壹』 rocketmq messagedelaylevel 能定義多少延時級別
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級開始,各級延時的時間,可以修改這個指定級別的延時時間;
時間單位支持:s、m、h、d,分別表示秒、分、時、天;
默認值就是上面聲明的,可手工調整;
默認值已夠用,不建議修改這個值。
如何發送延時消息
發送延時消息只需要在客戶端(rocketmq-client端)待發送的消息( com.alibaba.rocketmq.common.message.Message )中設置延時級別即可。
「設置消息延時 10s 消費」的 Procer 端代碼如下:
1
2
3
4
5
Message msg = new Message(topic, tags, keys, body);
msg.setDelayTimeLevel(3);
...
SendResult sendResult = getMQProcer().send(msg);
...