SuperAPI AI 工具集

azure-servicebus-rust

编程与开发

查看项目

更新于 10-16 05:54

技能介绍

用途:在 Rust 应用中通过 Azure Service Bus 这一企业级消息代理进行消息收发,支持队列的点对点竞争消费,以及主题与订阅的发布-订阅模式。

主要能力:使用 ServiceBusClient 连接命名空间;通过 create_sender 向队列或主题发送消息;通过 create_receiver 从队列接收,或用 create_receiver_for_subscription 从主题订阅接收;接收后可对消息执行 complete(处理成功、从队列移除)或 abandon(释放锁、可重试)。

安装:cargo add azure_messaging_servicebus azure_identity tokio。仅当代码直接导入 azure_core 类型时才需要显式添加 azure_core。

必要配置:设置环境变量 SERVICEBUS_NAMESPACE 为完全限定命名空间(形如 <namespace>.servicebus.windows.net)。本地开发使用 DeveloperToolsCredential,生产建议使用 ManagedIdentityCredential;使用 Entra ID 认证时需分配 Azure Service Bus Data Sender / Receiver / Owner 等 RBAC 角色。

用法要点:创建客户端后按需生成 sender 或 receiver,构造 Message 发送,接收后务必调用 complete_message 完成消息,避免重复投递;需要扇出时用主题加订阅。

限制:该 crate 处于早期开发阶段,官方明确提示不应在生产环境使用,API 可能随时变更;仅使用 azure-sdk 发布的官方 azure_messaging_servicebus crate,不要使用非官方或社区 crate。示例中的命令、依赖与凭据行为需结合本地环境和安全审查自行验证,本资料未提供价格等信息。