控制多个 JMS 队列的消耗

Question

我在任何地方都找不到此信息。我有两个队列，@JmsListener(destination = "p1")，@JmsListener(destination = "p2")。如何确保我一次只处理 1 条消息，即使我正在监听 2 个队列，以及如何配置轮询我首先从哪个队列获取消息，即在处理我想要轮询的消息之后p1 首先。或者进行加权轮询：p1:90%、p2:10%。等等。

基本上我在问如何为Spring 实现消息的优先处理。我正在使用不支持优先级的SQS。

Answer 1

使用JmsTemplate receive() 或receiveAndConvert() 方法之一，而不是消息驱动模型。

如果您想确保没有消息丢失，请使用事务。