Camel JMS消费者仅特定队列抛出RejectedExecutionException问题排查

一、核心问题现象 #

• 基于ActiveMQ + Camel搭建的JMS-MQTT消息转发服务稳定运行多年，新增bmetry-command JMS队列后，无法将消息转发至对应MQTT主题，持续抛出RejectedExecutionException，其余数十个队列运行正常
• MQTT主题本身无问题：直接通过MQTT客户端发布消息到目标主题可正常接收
• 低吞吐量场景下问题依旧，且开发环境同配置服务无异常
• 升级至Java8兼容的Camel 3.14版本后，异常变为NoClassDefFoundError，但部署Jar仅包含Camel 3.14依赖，异常栈却显示camel-core-2.22.0

二、排查方向 #

1. 线程池资源瓶颈或配置限制 #

RejectedExecutionException通常关联线程池任务拒绝，需重点检查：

• Camel JMS组件线程池配置：查看jmsConfiguration中的maxConcurrentConsumers、threadPoolMaxSize等参数，确认新增队列后总线程数是否超出系统/容器的线程上限
• ActiveMQ Broker线程池配置：检查Broker的systemUsage、threadPool相关配置，是否存在线程资源配额不足的情况
• 运行容器线程限制：确认Docker、Tomcat等容器的进程线程数上限是否被触发

2. Camel JMS生产者服务状态异常（ServiceSupport.isRunAllowed()=false） #

异常栈指向该方法返回false，说明对应JMS生产者处于不可运行状态，需排查：

• 新增队列的Camel路由配置：检查路由的autoStartup属性是否被误设为false，或路由启动阶段是否有未捕获异常导致启动失败
• JMS连接与权限：验证bmetry-command队列的JMS连接是否正常，是否存在权限不足（如队列读写权限未配置）、连接超时等问题
• Camel上下文完整性：确认Camel上下文是否完整启动，是否有组件初始化失败影响特定路由

3. 依赖冲突与类加载异常（升级Camel后出现NoClassDefFoundError） #

部署Jar仅包含Camel 3.14但栈显示旧版本，说明存在类加载冲突：

• 运行环境类路径检查：是否存在容器级别的Camel 2.22.0依赖（如应用服务器lib目录），导致类加载优先级高于Jar内的3.14版本
• 间接依赖排查：用Maven dependency:tree或Gradle dependencies命令检查是否有第三方依赖引入了camel-core-2.22.0
• 类加载器隔离问题：若使用Spring Boot，检查是否开启类加载器隔离，或自定义类加载器导致旧版本类被优先加载

4. 生产与开发环境差异 #

开发环境正常但生产异常，需核对：

• 配置差异：ActiveMQ Broker版本、网络策略（防火墙/代理）、队列权限配置是否与开发环境不一致
• 消息特性差异：生产环境bmetry-command队列是否存在特殊消息（如超大消息、非法格式）导致路由处理失败
• 系统资源差异：生产环境CPU、内存、磁盘IO是否存在瓶颈，影响Camel路由的正常运行

三、解决方案 #

针对RejectedExecutionException #

1. 调整线程池配置：
   • 增加Camel JMS组件的maxConcurrentConsumers或threadPoolMaxSize参数，临时可将线程池拒绝策略改为CallerRunsPolicy缓解问题
   • 调整ActiveMQ Broker的systemUsage配置，适当增加线程资源配额
2. 修复JMS生产者状态：
   • 检查路由配置确保autoStartup=true，查看路由启动日志并修复启动时的异常
   • 验证bmetry-command队列的读写权限，确保Camel服务拥有对应权限
3. 环境一致性校验：
   • 同步生产与开发环境的ActiveMQ配置、网络策略，确保权限和资源配置一致
   • 捕获并记录bmetry-command队列的消息内容，排查是否存在特殊消息导致处理失败

针对升级Camel后的NoClassDefFoundError #

1. 强制依赖版本：
   • 在Maven/Gradle中通过dependencyManagement强制指定所有Camel组件版本为3.14，避免间接依赖引入旧版本
2. 清理运行环境：
   • 重启应用服务器/容器清除类加载器缓存；若使用Docker，确保镜像仅包含指定的Camel依赖
3. 打包验证：
   • 用jar tf命令查看部署Jar内容，确认仅包含Camel 3.14的类文件，无旧版本残留

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