Apache Camel空闲时间计算规则咨询及SQS路由闲置终止异常排查

核心逻辑 #

• Camel的durationMaxIdleSeconds是根据路由的活动状态计算空闲时间的，只要路由有任何“活动动作”，就会重置空闲计数器。
• 像AWS SQS这类轮询组件，哪怕轮询后没拿到消息，发起轮询请求这个动作本身也算路由活动，会直接重置空闲计时器。这就是你配置后没达到预期的原因。

官方文档的明确说明 #

Camel官方文档对durationMaxIdleSeconds的触发逻辑有清晰定义：

当Camel上下文在指定空闲秒数内未处理任何消息（且无任何路由活动）时，自动终止上下文。注意：轮询组件的定期轮询动作属于路由活动，即便未获取到消息，也会重置空闲计数器。

满足需求的替代方案 #

如果要实现“SQS无消息达到一定时长后终止应用”，可以试试这两种方式：

• 自定义计时器：在处理消息的逻辑里重置计时器，当计时器达到设定时长且期间没有消息处理时，调用camelMain.stop()终止应用。
• 利用IdleChannelConsumer特性：给SQS端点配置idleConsumerTimeout参数，让消费者连续指定时长没拿到消息就停止，再监听消费者停止事件来终止整个应用。

示例代码（配置SQS端点）：

from("sqs://myQueue?idleConsumerTimeout=300") // 连续5分钟无消息后停止消费者
    .process(exchange -> {
        // 消息处理逻辑
    })
    .routeId("sqsPollingRoute");

监听消费者停止事件的代码：

camelMain.addRouteStartupListener((context, route) -> {
    if ("sqsPollingRoute".equals(route.getId())) {
        route.getConsumer().addListener(new ConsumerListener() {
            @Override
            public void onStopped(Consumer consumer) {
                camelMain.stop();
            }
        });
    }
});

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