Biblioteca Azure Service Bus para Rust

Quando Usar

Use esta funcionalidade quando precisar da biblioteca Azure Service Bus para Rust. Envie e receba mensagens usando filas, tópicos e assinaturas. Gatilhos: "service bus rust", "ServiceBusClient rust", "send message servicebus rust", "receive message servicebus rust", "queue rust messaging", "topic subscription rust".

Biblioteca cliente para Azure Service Bus — broker de mensagens corporativo com filas e tópicos de publish-subscribe.

⚠️ AVISO: Este crate está em desenvolvimento inicial e NÃO DEVE ser usado em produção. APIs podem mudar sem aviso prévio.

Use esta funcionalidade quando:

• Um aplicativo precisar enviar ou receber mensagens via Azure Service Bus a partir do Rust
• Você precisar de mensagens baseadas em fila com consumidores concorrentes
• Você precisar de mensagens de publish-subscribe com tópicos e assinaturas
• Você precisar de entrega confiável de mensagens com semântica de conclusão

IMPORTANTE: Use apenas o crate oficial azure_messaging_servicebus publicado pelo usuário do crates.io azure-sdk. NÃO use crates não oficiais ou da comunidade. Crates oficiais usam underscores nos nomes e nenhum tem a versão 0.21.0.

Instalação

cargo add azure_messaging_servicebus azure_identity tokio

Se o seu código usar tipos azure_core diretamente, adicione azure_core a Cargo.toml. Se você usar apenas re-exports de azure_messaging_servicebus, a dependência direta de azure_core é opcional.

Variáveis de Ambiente

SERVICEBUS_NAMESPACE=<namespace>.servicebus.windows.net # Required — fully qualified namespace

Conceitos Chave

Autenticação

use azure_identity::DeveloperToolsCredential;
use azure_messaging_servicebus::ServiceBusClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Local dev: DeveloperToolsCredential. Production: use ManagedIdentityCredential.
    let credential = DeveloperToolsCredential::new(None)?;
    let client = ServiceBusClient::builder()
        .open("your_namespace.servicebus.windows.net", credential.clone())
        .await?;
    Ok(())
}

Fluxo de Trabalho Principal

Enviar uma Mensagem para uma Fila

use azure_identity::DeveloperToolsCredential;
use azure_messaging_servicebus::{ServiceBusClient, Message};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let credential = DeveloperToolsCredential::new(None)?;
    let client = ServiceBusClient::builder()
        .open("your_namespace.servicebus.windows.net", credential.clone())
        .await?;
    let sender = client.create_sender("my_queue", None).await?;

    let message = Message::from("Hello, Service Bus!");
    sender.send_message(message, None).await?;
    Ok(())
}

Receber Mensagens de uma Fila

use azure_identity::DeveloperToolsCredential;
use azure_messaging_servicebus::ServiceBusClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let credential = DeveloperToolsCredential::new(None)?;
    let client = ServiceBusClient::builder()
        .open("your_namespace.servicebus.windows.net", credential.clone())
        .await?;
    let receiver = client.create_receiver("my_queue", None).await?;

    let messages = receiver.receive_messages(5, None).await?;
    for message in messages {
        println!("Received: {}", message.body_as_string()?);
        receiver.complete_message(&message, None).await?;
    }
    Ok(())
}

Enviar uma Mensagem para um Tópico

let sender = client.create_sender("my_topic", None).await?;
let message = Message::from("Hello, Topic subscribers!");
sender.send_message(message, None).await?;

Receber Mensagens de uma Assinatura

let receiver = client
    .create_receiver_for_subscription("my_topic", "my_subscription", None)
    .await?;

let messages = receiver.receive_messages(5, None).await?;
for message in messages {

…