如何配置Apache Camel从AWS SQS一次仅处理一条消息？

问题本质拆解 #

你碰到的核心误区是把路由处理线程池和SQS消费者线程池搞混了，而且CamelContext的默认线程是框架内部用于管理、监控、生命周期事件的，和消息消费完全无关，没法也没必要禁用。thread(1,1)只是控制路由处理器环节的线程数，管不到SQS消费者拉取消息的行为——这才是你看到同时处理两条消息的根源。

关键配置步骤（实现一次只处理一条消息） #

要达成目标，直接针对AWS SQS组件的专属参数配置即可，不用绕线程池的弯：

• 限制单次拉取消息数：在SQS端点URL中添加maxMessagesPerPoll=1，强制消费者每次从队列仅拉取1条消息。
• 强制单消费线程：再追加concurrentConsumers=1，让SQS消费者仅用一个线程运行，彻底避免并发拉取。
• 移除多余的thread()配置：既然要串行处理，没必要给路由加thread(1,1)，反而会造成混淆——直接让消费和处理在同一个线程执行即可。

Java DSL 示例配置 #

from("aws-sqs://your-target-queue?maxMessagesPerPoll=1&concurrentConsumers=1")
    .process(exchange -> {
        // 这里编写你的业务处理逻辑
    });

XML 路由示例配置 #

<route>
    <from uri="aws-sqs://your-target-queue?maxMessagesPerPoll=1&concurrentConsumers=1"/>
    <process ref="yourBusinessProcessorBean"/>
</route>

为什么之前的配置未生效？ #

• 修改CamelContext默认线程池无效：该线程池是给框架内部任务使用的，和消息消费线程完全不相关。
• thread(1,1)管错了环节：它仅控制处理器的线程数，但SQS消费者已经提前把两条消息拉到本地，处理器再单线程处理也无法改变“已拉取多条”的事实，你看到的“同时处理”其实是消费者先拉取多条，再依次交给处理线程执行。

额外注意事项 #

• 确认SQS队列的可见性超时：必须大于单条消息的处理时间，否则消息还未处理完成，SQS就会将其重新放回队列，导致重复消费。
• 验证线程状态：如果开启了Camel的管理功能，可以查看aws-sqs相关线程池，确认线程数确实为1，参数已生效。

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