Apache-Camel-MQTT组件ClientState实例增长引发内存泄漏咨询

问题根源 #

默认情况下，Camel的Paho MQTT5生产者如果未指定固定client-id，每次发送消息时会自动生成随机clientId并创建新的MQTT客户端连接，这些连接未被复用或及时关闭，导致ClientState实例持续堆积引发内存泄漏。

最优解决方案 #

1. 复用MQTT生产者连接（核心方案） #

通过指定固定client-id并启用连接复用，让Camel重复使用同一个客户端实例，避免频繁创建新连接：

• 在发送的Endpoint URI中直接配置：

  // 发送时指定固定client-id，确保连接复用
  producerTemplate.sendBody("paho-mqtt5:your-topic?client-id=fixed-producer-id", message);
  

• Spring Boot全局配置（推荐，统一管理所有生产者连接）：
  在application.yml或application.properties中添加组件配置：

  camel:
    component:
      paho-mqtt5:
        client-id: shared-producer-client
        reuse-client: true # 开启客户端复用
        max-connections: 5 # 根据业务并发量调整最大连接数
        keep-alive-interval: 60 # 保持连接心跳，单位秒
        connection-timeout: 30 # 连接超时时间，单位秒
  

  reuse-client=true是关键参数，开启后Camel会复用已创建的客户端实例，不再每次生成新连接。

2. 确保ProducerTemplate单例复用 #

避免在业务方法中重复创建ProducerTemplate实例，Spring Boot默认注入的ProducerTemplate为单例，直接注入使用即可：

@Autowired
private ProducerTemplate producerTemplate;

// 业务方法中直接复用该实例发送消息
public void sendToMqtt(String topic, Object payload) {
    producerTemplate.sendBody("paho-mqtt5:" + topic, payload);
}

3. 手动清理闲置连接（备选方案） #

如果必须手动管理连接，可通过PahoMqtt5Component获取所有客户端实例并断开，但需注意避免影响正在使用的连接：

@Autowired
private PahoMqtt5Component pahoMqtt5Component;

// 定期或在特定时机清理闲置连接
public void cleanIdleMqttClients() {
    pahoMqtt5Component.getClients().forEach((clientId, client) -> {
        try {
            if (!client.isConnected()) {
                client.disconnect();
            }
        } catch (MqttException e) {
            // 处理断开连接异常
        }
    });
}

注意：此方案仅作为补充，优先使用连接复用从根源解决问题。

关键配置说明 #

• client-id：生产者使用固定ID，避免随机生成导致的大量临时连接
• reuse-client：强制复用已创建的客户端实例
• keep-alive-interval：设置心跳间隔，让MQTT服务器及时清理闲置连接
• max-connections：限制最大连接数，避免并发过高导致的连接溢出

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