AWS SQS多队列订阅疑问：是否需多连接/会话或单会话多消费者？

多队列订阅的正确方案 #

直接给出结论并逐个解释：

• 不需要创建2个连接：SQS的JMS连接属于重量级资源，包含底层网络连接池、认证上下文等，创建多个连接会无端增加资源消耗，完全没必要。单个连接足以支撑多个会话和消费者。
• 可选创建2个会话，但非必须：会话是轻量级组件，主要用于隔离事务上下文和消息确认模式。如果两个队列的消息处理需要不同的配置（比如一个用事务模式，另一个用自动确认；或者一个需要CLIENT_ACKNOWLEDGE，另一个用AUTO_ACKNOWLEDGE），分开创建会话是合理的。但如果两个队列的处理规则一致，额外创建会话属于冗余操作。
• 1个连接+1个会话+2个消费者是最资源高效的推荐方案：这是常规场景下的最优做法，只需确保每个消费者的消息处理逻辑独立，且运行在各自的线程中（避免单线程阻塞影响两个队列的消息接收）。

代码示例（基于原有逻辑扩展） #

// 1) 创建单个连接
val connection = factory.createConnection()

// 2) 创建单个会话（确认模式统一时使用）
val session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)

// 3) 初始化两个队列对象
val queue1 = session.createQueue("my-q-1")
val queue2 = session.createQueue("my-q-2")

// 4) 为每个队列创建独立消费者，并绑定消息处理逻辑
val consumer1 = session.createConsumer(queue1)
consumer1.setMessageListener { message ->
    // 处理队列1的消息，建议避免长时间阻塞
    println("Received from queue1: ${message.body}")
}

val consumer2 = session.createConsumer(queue2)
consumer2.setMessageListener { message ->
    // 处理队列2的消息
    println("Received from queue2: ${message.body}")
}

// 5) 启动连接开始监听
connection.start()

补充：如果需要更严格的隔离（比如某个队列的处理异常不影响另一个），可以给每个消费者分配独立的线程池或使用异步处理逻辑。

JMS是否为该场景的最优选择？ #

分两种场景判断：

• 若需跨消息中间件兼容：JMS是Java EE标准API，如果你未来可能切换到RabbitMQ、ActiveMQ等其他消息系统，使用JMS可以大幅减少代码重构成本，此时JMS是合适的选择。
• 若仅绑定AWS生态：更推荐使用AWS SDK for Java原生SQS客户端，原因如下：
  • 原生SDK提供更贴近SQS特有功能的API，比如长轮询精细配置、消息延迟发送、批量收发高级参数、死信队列直接操作等，这些功能在JMS客户端中可能被抽象或支持有限。
  • 原生SDK开销更低，没有JMS抽象层带来的额外复杂度，性能表现更优。
  • 官方对原生SDK的更新更快，SQS的新功能会第一时间在原生SDK中落地。

内容的提问来源于stack exchange，提问作者Whizzil