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

[lchqfnu]

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

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

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

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

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

[wtfedc]

可以只 peek ，不消费其他实例的消息。或者消费之后，发现不匹配，再丢回去

[lchqfnu]

@wtfedc IBM MQ ，好像没有 peek 的操作方式。消费之后发现不匹配再丢回去，有概率还会被错取。

[fkname]

不是有 topic 区分吗

[billly]

消息能广播吗？可以的话发现不是自己的，直接丢掉

[lchqfnu]

@billly 有考虑改 topic ，但是 topic 与 queue 是有一点区别的，topic 是非持久的，如果没有监听，topic 中的消息会丢失。

[superychen]

A,A1,A2 不在一个 group 里就可以了吧，每个都能消费到

[Azzsanjin]

集群消费和广播消费问题？

[lchqfnu]

目前想到的除了 q 改 topic 以外，就是使用 mq 的 consumer 的 selector 做消息选择，暂时没有实现。

[lchqfnu]

@Azzsanjin 是的。试过 mq messageconsumer 的 selector 不行，那个只能通过消息头的属性判定。关于 topic ，好像跟 queue 差异很大啊？ topic 有名称还有字符串，搞不清楚怎么用 jms 来监听