MqttDemo报错：无法找到MqttGateway Bean，求解决方案

错误原因 #

com.mqtt.ecmqtt.controller.MqttController的构造函数第0个参数需要一个类型为'com.mqtt.ecmqtt.mqtt.gateway.MqttGateway'的bean，但未找到。

出现这个错误的核心原因：

1. @MessagingGateway接口未被Spring扫描生成代理Bean：Spring Integration会为标注@MessagingGateway的接口自动生成代理实现，但如果接口不在Spring扫描范围内，或者@IntegrationComponentScan未覆盖该包，就无法生成对应的Bean。
2. 自定义实现类逻辑错误：手动编写MqttGateway实现类时，要么没给实现类加@Component等Spring Bean注解，要么没正确绑定mqttOutputChannel消息通道，导致注入时实例为null；删除自定义实现后，又回到原问题——Spring未自动生成代理Bean。

具体解决步骤 #

1. 确保MqttGateway被Spring扫描到 #

检查MqttGateway所在包路径，确保它在Spring Boot主启动类的默认扫描范围内（主启动类所在包的子包会自动扫描）。如果不在，修改MqttConfig的@IntegrationComponentScan，明确指定网关所在包：

@Configuration
@IntegrationComponentScan(basePackages = "com.mqtt.ecmqtt.mqtt.gateway") // 替换为你的MqttGateway实际包路径
public class MqttConfig {
    // 原有代码不变
}

2. 删除自定义的MqttGateway实现类 #

@MessagingGateway是Spring Integration专属注解，Spring会自动为接口生成代理实现，手动编写实现类会破坏自动代理逻辑，导致Bean异常。

3. 修复ReceiveMessageHandler的Bean注册 #

当前ReceiveMessageHandler未被Spring管理，导致无法注入SensorMapper，需要添加@Component注解：

@Slf4j
@Component // 添加该注解，让Spring管理这个类
public class ReceiveMessageHandler implements MessageHandler {
    @Resource
    private SensorMapper sensorMapper;

    // 原有handleMessage逻辑不变
}

同时修改MqttConfig中的mqttInputHandler方法，改为注入已注册的Bean：

@Bean
@ServiceActivator(inputChannel = "mqttInputChannel")
public MessageHandler mqttInputHandler(ReceiveMessageHandler receiveMessageHandler) {
    return receiveMessageHandler;
}

4. 检查依赖完整性 #

确保项目依赖中包含Spring Integration MQTT的完整包（以Maven为例）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
</dependency>

验证 #

完成上述修改后重启应用，检查控制台是否还有Bean缺失错误，调用/mqtt/send或/mqtt/topic/send接口测试MQTT消息发送功能。

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