如何用Node.js监听Azure存储队列？Azure Service Bus能否解决该问题？

架构老林

2026-8-8

Azure Service Bus 能否解决存储队列自动监听缺失的问题？

答案是肯定的。Azure Service Bus 原生支持消息推送式的自动监听，完全可以替代存储队列需要手动编写轮询逻辑的方式。

核心差异

Azure 存储队列仅支持拉取模式，必须主动调用 receiveMessages 这类方法轮询获取消息；而 Service Bus 提供了推送式的监听能力，SDK 内置了消息到达时的自动触发机制，无需手动轮询。

示例实现（JavaScript）

使用 @azure/service-bus SDK 实现自动监听：

import { ServiceBusClient } from "@azure/service-bus";

// 替换为你的Service Bus连接字符串
const connectionString = "Endpoint=sb://xxx.servicebus.windows.net/;SharedAccessKeyName=xxx;SharedAccessKey=xxx";
const queueName = "test-servicebus-queue";

async function startListening() {
  const serviceBusClient = new ServiceBusClient(connectionString);
  // 创建队列接收器
  const receiver = serviceBusClient.createReceiver(queueName);

  // 定义消息处理逻辑
  const handleMessage = async (message) => {
    console.log(`收到消息内容: ${message.body}`);
    // 处理完成后标记消息为已完成，避免重复消费
    await message.complete();
  };

  // 定义错误处理逻辑
  const handleError = async (error) => {
    console.error(`消息处理出错: ${error}`);
  };

  // 注册自动消息处理器，开启监听
  receiver.registerMessageHandler(handleMessage, {
    autoComplete: false, // 手动控制消息完成状态，更灵活
    maxConcurrentCalls: 3, // 设置并发处理的消息数量
  });

  console.log("Service Bus 队列自动监听已启动，等待新消息...");
}

startListening().catch(err => {
  console.error("启动监听失败:", err);
});