Azure存储Blob触发队列消息时Spring Boot如何实现非轮询式监听

Azure存储队列服务本身没有服务端主动推送机制，但现有Java Spring Boot生态有成熟的封装方案，你不需要自己编写持续轮询的业务代码，即可实现新消息到达时自动触发处理逻辑，具体方案如下：

推荐方案：使用Spring Cloud Azure Storage Queue Starter #

该方案是Spring官方适配Azure服务的组件，对Spring Boot项目适配度最高，最少代码即可实现类监听器效果：

• 第一步：引入Maven依赖

<dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-starter-storage-queue</artifactId>
</dependency>

• 第二步：在application配置文件中添加存储队列连接信息

spring:
  cloud:
    azure:
      storage:
        queue:
          connection-string: 你的Azure存储账户连接字符串

• 第三步：编写消息监听处理逻辑，仅需添加@QueueListener注解即可完成自动监听配置

import com.azure.spring.messaging.storage.queue.annotation.QueueListener;
import org.springframework.stereotype.Component;

@Component
public class BlobQueueMessageHandler {

    @QueueListener("你配置的存储队列名称")
    public void handleBlobCreateMessage(String messageContent) {
        // 此处编写业务处理逻辑，比如解析Blob路径、读取Blob内容等
        System.out.println("收到新增Blob通知: " + messageContent);
    }
}

注：该组件底层封装了优化后的长轮询逻辑，会自动管理连接、拉取消息、异常重试，业务侧完全不需要关心轮询相关代码，新消息到达时会自动触发处理方法执行，非常符合你当前低消息量的场景，空闲时长轮询不会产生多余的费用和资源消耗。

备选方案：基于Azure SDK for Java异步API轻量封装 #

如果不想引入Spring Cloud Azure相关依赖，也可以基于Azure原生SDK做轻量封装：
调用QueueAsyncClient.receiveMessages()方法设置长轮询超时时间（最长可设为30秒），异步等待消息返回，处理完消息后再次调用该方法等待下一批消息，仅需少量代码即可实现自动监听效果，不需要自行编写死循环轮询逻辑。

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