Spring集成MQTT时MBean注册失败：JMX对象名含非法冒号

问题分析 #

报错核心是JMX的ObjectName包含非法字符:，从错误栈可见自动生成的MBean名称为mqttInFlowTopic1.mqtt:inbound-channel-adapter#0，其中的冒号违反了JMX ObjectName规范（冒号是ObjectName中键值对的分隔符，不能出现在值字段里）。这是Spring Integration自动为MQTT入站适配器生成组件名称时引入的问题。

解决方案 #

方案1：手动指定MQTT适配器的Bean名称（推荐） #

直接给Mqttv5PahoMessageDrivenChannelAdapter设置不含非法字符的自定义Bean名称，覆盖自动生成的名称：

@Bean
public IntegrationFlow mqttInFlowTopic1(ClientManager<IMqttAsyncClient, MqttConnectionOptions> clientManager) {
    Mqttv5PahoMessageDrivenChannelAdapter messageProducer = new Mqttv5PahoMessageDrivenChannelAdapter(clientManager, "topic1");
    // 设置自定义Bean名称，避免包含冒号
    messageProducer.setBeanName("mqttInboundAdapterTopic1");
    return IntegrationFlow.from(messageProducer)
        .channel(c -> c.executor(Executors.newCachedThreadPool()))
        .handle(message -> {
            MessageHeaders messageHeaders = message.getHeaders();
            String rs = new String((byte[]) message.getPayload());
            log.info("{}", messageHeaders);
            log.info("{}", rs);
        })
        .get();
}

JMX注册时会使用指定的名称，不会再出现非法字符。

方案2：禁用JMX（无需监控场景） #

如果项目不需要JMX功能，直接关闭即可从根源避免问题：
在application.properties中添加配置：

spring.jmx.enabled=false

或者在启动类上排除JMX自动配置：

@SpringBootApplication(exclude = JmxAutoConfiguration.class)
public class DemoEmqxApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoEmqxApplication.class, args);
    }
}

方案3：自定义JMX命名策略替换非法字符 #

若需要保留JMX且统一处理所有非法字符，可以自定义命名策略，将冒号替换为下划线等合法字符：

@Bean
public MetadataNamingStrategy customJmxNamingStrategy() {
    MetadataNamingStrategy strategy = new MetadataNamingStrategy();
    strategy.setObjectNameGenerator((beanDef, beanName) -> {
        // 将所有冒号替换为下划线
        String cleanedBeanName = beanName.replaceAll(":", "_");
        try {
            return new ObjectName("com.uncloud.demoemqx:name=" + cleanedBeanName);
        } catch (MalformedObjectNameException e) {
            throw new RuntimeException("生成JMX ObjectName失败", e);
        }
    });
    return strategy;
}

该方案会全局处理所有Bean的JMX名称，适合存在大量类似问题的场景。

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