Spring Boot启动时仅一次监听Azure IoT Hub消息的合适实现方案

一、先解决「仅启动时执行一次」的问题 #

如果你暂时不想用专用消息订阅注解，把当前监听的事件换成ApplicationReadyEvent就能解决多次触发的问题——这个事件只会在Spring Boot应用完全启动、所有Bean初始化完成后触发一次，比ContextRefreshedEvent更适配启动时一次性执行的场景：

@EventListener
public void subscribeEventMessages(ApplicationReadyEvent event)  {
    client
            .receive(false) // set this to false to read only the newly available events
            .subscribe(this::hubAllEventsCallback);
}

另外你提到的CommandLineRunner/ApplicationRunner也是靠谱选择，它们同样保证启动后仅执行一次，写法简洁：

@Component
public class IotHubSubscriber implements CommandLineRunner {

    private final IotHubClient client;

    // 构造注入客户端
    public IotHubSubscriber(IotHubClient client) {
        this.client = client;
    }

    @Override
    public void run(String... args) throws Exception {
        client
                .receive(false)
                .subscribe(this::hubAllEventsCallback);
    }

    private void hubAllEventsCallback(Message message) {
        // 消息处理逻辑
    }
}

二、用类似@JmsListener的专用注解实现 #

Azure针对Spring Boot提供了Spring Cloud Azure IoT模块，其中的@IotHubEvent注解和JMS的@JmsListener用法逻辑一致，框架会自动管理消息监听的生命周期，不需要手动在启动时初始化订阅，天然保证只执行一次初始化。

步骤1：添加依赖 #

在Maven的pom.xml中引入对应starter：

<dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-starter-iot-hub</artifactId>
    <!-- 建议使用与你的Spring Boot版本匹配的最新稳定版 -->
</dependency>

步骤2：配置IoT Hub连接信息 #

在application.properties中配置核心参数：

spring.cloud.azure.iot-hub.connection-string=你的IoT Hub连接字符串
spring.cloud.azure.iot-hub.consumer-group=你的消费组（默认值为$Default）

步骤3：编写监听方法 #

直接在方法上添加@IotHubEvent注解，框架会自动在应用启动时初始化监听，方法参数可直接接收消息对象：

@Component
public class IotHubMessageListener {

    @IotHubEvent(consumerGroup = "$Default")
    public void handleDeviceMessage(Message message) {
        String payload = new String(message.getBody(), StandardCharsets.UTF_8);
        // 处理IoT Hub消息的业务逻辑
        System.out.println("收到IoT Hub消息：" + payload);
    }
}

这种方式完全贴合Spring的注解驱动风格，无需手动管理客户端的启动、订阅逻辑，和你熟悉的@JmsListener体验一致。

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