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

关于监听 MQ 队列消息的判定问题

  •  
  •   lchqfnu · 357 天前 · 1345 次点击
    这是一个创建于 357 天前的主题,其中的信息可能已经有所发展或是发生改变。

    A 通过 Q1 发送一个请求,然后通过 Q2 监听反馈结果。 如果同时有 A1,A2...多个实例通过 Q1 发送请求,是没有问题的。 但是 A,A1,A2...同时通过 Q2 监听反馈结果,就会存在有人拿了本不属于他的反馈。 如 A 拿了 A1 的反馈,这样 A1 就拿不到反馈了。

    --------- 背景如上 ----------

    目前监听使用的 org.springframework.jms 的 JmsListener 以及用的 DefaultJmsListenerContainerFacotry,CachingConnectionFactory,MQQueueConnectionFactory 等常规配置。

    ---------- 问题-----------

    如何多实例同时监听 Q2 的反馈结果,且只读取属于自己的请求反馈呢?

    9 条回复    2023-04-07 20:16:28 +08:00
    wtfedc
        1
    wtfedc  
       357 天前
    可以只 peek ,不消费其他实例的消息。或者消费之后,发现不匹配,再丢回去
    lchqfnu
        2
    lchqfnu  
    OP
       357 天前
    @wtfedc IBM MQ ,好像没有 peek 的操作方式。消费之后发现不匹配再丢回去,有概率还会被错取。
    fkname
        3
    fkname  
       357 天前
    不是有 topic 区分吗
    billly
        4
    billly  
       357 天前
    消息能广播吗?可以的话发现不是自己的,直接丢掉
    lchqfnu
        5
    lchqfnu  
    OP
       357 天前
    @billly 有考虑改 topic ,但是 topic 与 queue 是有一点区别的,topic 是非持久的,如果没有监听,topic 中的消息会丢失。
    superychen
        6
    superychen  
       357 天前
    A,A1,A2 不在一个 group 里就可以了吧,每个都能消费到
    Azzsanjin
        7
    Azzsanjin  
       357 天前
    集群消费和广播消费问题?
    lchqfnu
        8
    lchqfnu  
    OP
       357 天前
    目前想到的除了 q 改 topic 以外,就是使用 mq 的 consumer 的 selector 做消息选择,暂时没有实现。
    lchqfnu
        9
    lchqfnu  
    OP
       356 天前 via iPhone
    @Azzsanjin 是的。试过 mq messageconsumer 的 selector 不行,那个只能通过消息头的属性判定。关于 topic ,好像跟 queue 差异很大啊? topic 有名称还有字符串,搞不清楚怎么用 jms 来监听
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   5406 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 28ms · UTC 08:41 · PVG 16:41 · LAX 01:41 · JFK 04:41
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.