V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
bthulu
V2EX  ›  问与答

老板要求写一个公用的 rabbitmq 客户端给其他人用, 要求至少一次投递, 而且只能依赖 rabbitmq 自身, 想来想去这根本不可能实现啊

  •  
  •   bthulu · 2021-03-24 22:09:30 +08:00 · 1245 次点击
    这是一个创建于 1099 天前的主题,其中的信息可能已经有所发展或是发生改变。

    除非一次 basicPublish 一次 waitForConfirmsOrDie, 这样性能又不行.

    异步 confirm 呢, 每个 channel 都要保存自身发出去的数据, 然后在 ack 的时候清除掉, 在 nack 的时候咋办呢? 无限重发吗? 还有, 对于长时间既不 nack 又不 ack 的数据怎么处理, 还是重发么? 重发么, 发过去如果还是又不 ack 也不 nack 呢, 最后越积越多就 OOM 了. 而且这样必须有一个线程检测既不 nack 又不 ack 的数据进行处理, 否则这个保存数据的容器迟早把内存撑爆.

    批量 confirm 这个看起来似乎可行, 但 waitForConfirmsOrDie 怎么处理呢, 一个连接一个定时线程处理所有 channel 的 waitForConfirmsOrDie, 还是一个 channel 一个定时线程处理 waitForConfirmsOrDie?

    好烦躁, 感觉 rabbitmq 对于消息队列来说就是个半成品, 要求低延迟, 非可靠的应用还能用用, 可靠性要求高一点简直难用到爆

    2 条回复    2021-03-25 09:09:11 +08:00
    petercui
        1
    petercui  
       2021-03-25 00:08:21 +08:00
    spring cloud stream 如何?
    CodeCodeStudy
        2
    CodeCodeStudy  
       2021-03-25 09:09:11 +08:00
    我看成了 “老公要求写一个 rabbitmq 客户端”
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   3246 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 27ms · UTC 11:43 · PVG 19:43 · LAX 04:43 · JFK 07:43
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.