V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
Kevinyy
V2EX  ›  Java

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

  •  
  •   Kevinyy · 2023-02-02 16:35:01 +08:00 · 2029 次点击
    这是一个创建于 678 天前的主题,其中的信息可能已经有所发展或是发生改变。

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

    16 条回复    2023-02-03 10:52:32 +08:00
    huang119412
        1
    huang119412  
       2023-02-02 16:37:47 +08:00   ❤️ 1
    dddd1919
        2
    dddd1919  
       2023-02-02 16:47:52 +08:00
    延迟消息发到 rabbitMQ 😂
    fireyao
        3
    fireyao  
       2023-02-02 17:04:14 +08:00
    那就换 redis 做延迟队列🤣
    yazinnnn
        4
    yazinnnn  
       2023-02-02 17:21:43 +08:00
    用代码实现一下?

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

    reactive-streams 的实现都应该提供类似功能了吧,比如 rx 之类的
    lry
        5
    lry  
       2023-02-02 17:23:45 +08:00
    指定时间内的消息压缩成一条为啥要用消息队列的任意时间延迟来做?
    感觉这个像是一个限流问题。
    neilyoone
        6
    neilyoone  
       2023-02-02 17:44:39 +08:00
    告警压缩??

    Prometheus 的告警模块 Alertmanager 有告警抑制功能
    monstervivi
        7
    monstervivi  
       2023-02-02 17:51:31 +08:00
    BQsummer
        8
    BQsummer  
       2023-02-02 17:59:41 +08:00
    这是调度问题啊,我们告警聚合就是 quartz 做的。公司提供的秒级调度因为 quartz 压力较高,用 RocketMQ 实现的,云服务支持更高精度的延时。
    rrfeng
        9
    rrfeng  
       2023-02-02 18:20:48 +08:00
    这个完全没必要引入 MQ ,凭添复杂度和不稳定性。
    你报警原始信息存哪里?定时去获取就行了。
    lry
        10
    lry  
       2023-02-02 18:25:30 +08:00
    @BQsummer 如果只是调度,完全可以自己写个时间轮调度。
    ch2
        11
    ch2  
       2023-02-02 18:36:52 +08:00 via iPhone
    发到 pulsar 里
    unnamedhao
        12
    unnamedhao  
       2023-02-02 18:39:15 +08:00
    rabbitmq 有死信队列
    rocketmq 不清楚
    Kevinyy
        13
    Kevinyy  
    OP
       2023-02-02 22:49:58 +08:00
    @neilyoone 对的,AlertManager 配置不太人性化,我们还作了衍生的功能。
    Kevinyy
        14
    Kevinyy  
    OP
       2023-02-02 22:51:14 +08:00
    @monstervivi 我也看到了最新的定时特性,准备让我运维同事升级一下,试试水,谢谢老哥
    daimazha
        15
    daimazha  
       2023-02-03 10:52:01 +08:00
    daimazha
        16
    daimazha  
       2023-02-03 10:52:32 +08:00
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2669 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 30ms · UTC 14:40 · PVG 22:40 · LAX 06:40 · JFK 09:40
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.