Camel S3组件禁用内置调度器后无法执行对象列表查询的问题

我来帮你梳理这个问题的核心，并给出可行的解决方案——你遇到的情况其实是Camel S3组件的消费者模式与生产者模式差异导致的。

问题根源 #

在你的原路由中，第二个from("aws-s3://...")是把S3组件当作轮询消费者来使用的：Camel的S3消费者默认依赖内置调度器定期轮询存储桶，这也是为什么你会遇到重复处理的问题。当你添加startScheduler=false后，这个消费者端点直接被禁用了——它不会主动启动，自然也不会响应direct:my-route的触发信号，导致${header.CamelAwsS3Key}为空。

解决方案：切换为生产者模式调用 #

要实现外部调度触发+禁用内置调度器的需求，你需要把S3组件当作生产者来使用，也就是用to()代替from()来调用listObjects操作。这样一来，每当direct:my-route被外部调度触发时，Camel就会主动执行一次S3的列表查询，完全不需要依赖内置调度器。

修改后的路由代码如下：

from("direct:my-route")
    // 将S3端点作为生产者调用，执行listObjects操作
    .to("aws-s3://my.bucket?useIAMCredentials=true&useAwsKMS=true&awsKMSKeyId=my-key-id&deleteAfterRead=false&operation=listObjects&prefix=test1/test.xml")
    // listObjects返回的是List<S3ObjectSummary>集合，拆分每个对象单独处理
    .split(body())
        // 从S3ObjectSummary对象中获取文件Key（如果组件自动设置了CamelAwsS3Key头，也可以用${header.CamelAwsS3Key}）
        .log(" File detected: ${body.key}")
.end();

关键说明 #

• 不需要设置startScheduler=false：生产者模式下的S3端点本来就没有内置调度器，完全由外部触发控制执行时机，天然避免了重复处理。
• 关于includeBody参数：原路由中的includeBody=false是针对消费者模式（获取文件内容）的配置，在生产者执行listObjects时可以移除——因为我们需要获取的是对象元数据列表，默认就会返回S3ObjectSummary集合。
• 拆分集合：listObjects操作返回的是一个对象列表，所以需要用split(body())来遍历每个文件，才能逐个输出Key。

这样调整后，你的外部调度每分钟触发direct:my-route时，就会执行一次S3文件列表查询，且不会出现重复处理的问题。

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