fatcheung
V2EX  ›  Java

想问下各位大佬这个面试题

  •  
  •   fatcheung · Apr 10, 2021 via Android · 4318 views
    This topic created in 2042 days ago, the information mentioned may be changed or developed.
    就是我们发送消息可能会用到消息中间件,如果失败了,我们会记录到表里面,然后会用定时调度去扫。但是这个操作可能会有一定的延时,有没有更快的方法?🤔
    14 replies  •  2021-04-13 00:49:24 +08:00
    xuanbg
    xuanbg
    Apr 10, 2021
    1
    快是什么快?要消除的是定时任务的延时效果?这个没意义,现在发不出去的消息,马上重发大概率也是发不出去的。
    fatcheung
    fatcheung
    OP
    Apr 10, 2021 via Android
    2
    @xuanbg 对啊,面试官问我有没有更加即时的方法,我答不上来,有点困惑,想问问各位老哥😂
    noreplay
    noreplay
    Apr 10, 2021 via Android
    3
    跟面试官说,记录完之后,发个通知给面试官,让面试官马上打电话通知调用方。🌚🌚
    mseasons
    mseasons
    Apr 10, 2021
    4
    将失败了的信息写进一个优先级队列,然后每次执行任务之前都检查队列,有就发送。

    实际上把轮询写进了代码逻辑,就像程序响应系统中断一样
    skymei
    skymei
    Apr 10, 2021
    5
    没有 ACK 机制吗,失败的没有 ACK 确认会自动进入延时队列,延时结束之后会自动进入原队列。
    leafre
    leafre
    Apr 10, 2021
    6
    callback 持久化到 db 同时开个线程重试消息
    ch2
    ch2
    Apr 10, 2021 via iPhone
    7
    把定时任务改成循环监听,就是看门狗机制
    RRL
    RRL
    Apr 10, 2021 via iPhone
    8
    Binlog listener
    young1lin
    young1lin
    Apr 10, 2021
    9
    用 Binglog 机制不行么,或者 MySQL 的插件 mysql-udf-http 。或者像 Kafka 一样,用带有回调的方法发送消息,阻塞直到发送成功,外加 ACK = -1
    qianxiaobang
    qianxiaobang
    Apr 10, 2021
    10
    加个发送结果,发送过去如果没有响应,就起几个定时任务( 10s,30s,60s,5min )来重试;长期没有结果再走定时跑批
    jacksparrow414
    jacksparrow414
    Apr 10, 2021
    11
    redis 的 list 结构? LPUSHRPOP 试一下
    securityCoding
    securityCoding
    Apr 10, 2021 via Android
    12
    他想要的应该是 binlog
    DoctorCat
    DoctorCat
    Apr 10, 2021
    13
    写到 kafka/RabbitMQ/RocketMQ 理论上应该更快一些。
    cubecube
    cubecube
    Apr 13, 2021
    14
    应该是想让你说延时队列处理,然后 balabala 队列的一些问题
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Privacy   ·   Solana   ·   1928 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 45ms · UTC 15:39 · PVG 23:39 · LAX 07:39 · JFK 10:39
    ♥ Do have faith in what you're doing.