[请教]RocketMQ 支持任意时间的延迟队列有哪些实现

[Kevinyy]

最近在写告警压缩，需要实现在指定时间内，将告警压缩成一条。目前考虑的是使用 rocketmq 来实现这个功能，但是 rocketmq(开源)仅支持 18 级别的延迟。各位老哥有没有什么好的建议吗？

[huang119412]

https://developer.aliyun.com/article/660438

[dddd1919]

延迟消息发到 rabbitMQ 😂

[fireyao]

那就换 redis 做延迟队列🤣

[yazinnnn]

用代码实现一下?

https://www.reactive-streams.org/

reactive-streams 的实现都应该提供类似功能了吧,比如 rx 之类的

[lry]

指定时间内的消息压缩成一条为啥要用消息队列的任意时间延迟来做？
感觉这个像是一个限流问题。

[neilyoone]

告警压缩??

Prometheus 的告警模块 Alertmanager 有告警抑制功能

[monstervivi]

RocketMQ 5.0 支持

https://rocketmq.apache.org/zh/docs/featureBehavior/02delaymessage/

[BQsummer]

这是调度问题啊，我们告警聚合就是 quartz 做的。公司提供的秒级调度因为 quartz 压力较高，用 RocketMQ 实现的，云服务支持更高精度的延时。

[rrfeng]

这个完全没必要引入 MQ ，凭添复杂度和不稳定性。
你报警原始信息存哪里？定时去获取就行了。

[lry]

@BQsummer 如果只是调度，完全可以自己写个时间轮调度。

[ch2]

发到 pulsar 里

[unnamedhao]

rabbitmq 有死信队列
rocketmq 不清楚

[Kevinyy]

@neilyoone 对的，AlertManager 配置不太人性化，我们还作了衍生的功能。

[Kevinyy]

@monstervivi 我也看到了最新的定时特性，准备让我运维同事升级一下，试试水，谢谢老哥

[daimazha]

https://github.com/didi/DDMQ

[daimazha]

https://github.com/qunarcorp/qmq