Filas, tópicos e assinaturas do Barramento de Serviço

  • Artigo

O Barramento de Serviço do Azure dá suporte ao serviço de enfileiramento de mensagens confiável e ao sistema de mensagens de publicação/assinatura durável. As entidades de mensagens que formam o núcleo dos recursos do sistema de mensagens agenciado no Barramento de Serviço são filas, tópicos e assinaturas.

Importante

Se você é novo no Barramento de Serviço do Azure, leia O que é o Barramento de Serviço do Azure? antes de ler este artigo.

Filas

As filas oferecem entrega de mensagem do tipo FIFO (primeiro a entrar, primeiro a sair) para um ou mais consumidores concorrentes. Ou seja, os receptores geralmente recebem e processam mensagens na ordem em que foram adicionados à fila. E, somente um consumidor de mensagem recebe e processa cada mensagem.

Image showing how Service Queues work.

Um dos principais benefícios do uso de filas é obter o desacoplamento temporal de componentes do aplicativo. Em outras palavras, os produtores (remetentes) e os consumidores (receptores) não precisam enviar e receber mensagens ao mesmo tempo, pois as mensagens são armazenadas de forma durável na fila. Além disso, o produtor não precisa esperar por uma resposta do consumidor para continuar processando e enviando mensagens.

Um benefício relacionado é o nivelamento de carga, que permite que produtores e consumidores enviem e recebam mensagens em taxas diferentes. Em muitos aplicativos, a carga do sistema varia ao longo do tempo. No entanto, o tempo de processamento necessário para cada unidade de trabalho é normalmente constante. A intermediação de produtores e de consumidores de mensagem com uma fila significa que o aplicativo que está consumindo só precisa ser provisionado para poder lidar com a carga média em vez da carga de pico. A profundidade da fila aumentará e diminuirá conforme a carga de entrada variar. Essa capacidade economiza dinheiro diretamente com relação à quantidade de infraestrutura necessária para atender à carga do aplicativo. À medida que a carga aumenta, mais processos de trabalho poderão ser adicionados à leitura da fila. Cada mensagem é processada por apenas umdos processos de trabalho. Além disso, esse balanceamento de carga baseado em pull permite o uso ideal dos computadores de trabalho, mesmo se os computadores de trabalho com poder de processamento receberem mensagens em sua própria taxa máxima. Esse padrão é geralmente denominado de consumidor concorrente.

A utilização de filas para intermediar entre produtores e consumidores oferece um acoplamento flexível inerente entre os componentes. Como produtores e consumidores não têm conhecimento uns dos outros, um consumidor poderá ser atualizado sem afetar o produtor.

Criar filas

Você pode criar filas usando uma das seguintes opções:

Em seguida, envie e receba mensagens usando clientes gravados em linguagens de programação, incluindo as seguintes:

Modos de recepção

Você pode especificar dois modos diferentes nos quais os consumidores podem receber mensagens do Barramento de Serviço.

  • Receber e excluir. Nesse modo, quando o Barramento de Serviço recebe a solicitação do consumidor, ele marca a mensagem como sendo consumida e a retorna ao aplicativo do consumidor. Esse modo é o modelo mais simples. Funciona melhor em cenários em que o aplicativo pode tolerar o não processamento de uma mensagem em caso de falha. Para reconhecer esse cenário, considere um cenário no qual o consumidor emite a solicitação de recebimento e, em seguida, ocorre falha antes de processá-la. Como o Barramento de Serviço marca a mensagem como consumida, o aplicativo começa a consumir mensagens após a reinicialização. Ele perderá a mensagem consumida antes da falha. Esse processo geralmente é chamado de processamento de no máximo uma vez.
  • Bloqueio de inspeção. Nesse modo, a operação de recebimento torna-se uma operação de duas etapas, possibilitando o suporte a aplicativos que não podem tolerar mensagens ausentes.

    1. Ele localiza a próxima mensagem a ser consumida, bloqueia-a para evitar que outros consumidores a recebam e a retornem para o aplicativo.

    2. Depois que o aplicativo termina de processar a mensagem, ele solicita que o serviço do Barramento de Serviço conclua o segundo estágio do processo de recebimento. Em seguida, o serviço marca a mensagem como consumida.

      Se o aplicativo não puder processar a mensagem por algum motivo, ele poderá solicitar que o serviço do Barramento de Serviço abandone a mensagem. O Barramento de Serviço desbloqueia a mensagem e a disponibiliza para que ela possa ser recebida novamente pelo mesmo consumidor ou por outro consumidor concorrente. Em segundo lugar, há um tempo limite associado ao bloqueio. Se o aplicativo não conseguir processar a mensagem antes que o tempo limite de bloqueio expire, o Barramento de Serviço desbloqueia a mensagem e a disponibiliza para ser recebida novamente.

      Se o aplicativo falhar depois de processar a mensagem, mas antes de solicitar que o serviço do Barramento de Serviço conclua a mensagem, o Barramento de Serviço entregará a mensagem novamente ao aplicativo quando ele for reiniciado. Esse processo geralmente é chamado de processamento de pelo menos uma vez. Ou seja, cada mensagem é processada pelo menos uma vez. No entanto, em determinadas situações, a mesma mensagem pode ser revivido novamente. Se o cenário não puder tolerar o processamento duplicado, adicione lógica extra ao aplicativo para detectar duplicatas. Para obter mais informações, consulte a Detecção de duplicidade, que é conhecida como processamento exatamente uma vez.

      Observação

      Para obter mais informações sobre esses dois modos, veja Liquidar operações de recebimento.

Tópicos e assinaturas

Uma fila permite o processamento de uma mensagem por um único consumidor. Diferente das filas, os tópicos e as assinaturas fornecem uma forma de comunicação de um para muitos, em um padrão de publicação e assinatura. É útil para dimensionar para um grande número de destinatários. Cada mensagem publicada é disponibilizada para cada assinatura registrada no tópico. O editor envia uma mensagem para um tópico e um ou mais assinantes recebem uma cópia da mensagem.

Image showing a Service Bus topic with three subscriptions.

As assinaturas podem usar mais filtros para restringir as mensagens que desejam receber. Os editores enviam mensagens para um tópico da mesma forma que enviam mensagens para uma fila. No entanto, os consumidores não recebem mensagens diretamente do tópico. Em vez disso, os consumidores recebem mensagens de assinaturas do tópico. Uma assinatura de tópico é semelhante a uma fila virtual que recebe cópias das mensagens enviadas para o tópico. Os consumidores recebem mensagens de uma assinatura de forma idêntica à maneira como recebem mensagens de uma fila.

A funcionalidade de envio de mensagens de uma fila é diretamente mapeada para um tópico e sua funcionalidade de recebimento de mensagens é mapeada para uma assinatura. Entre outras coisas, esse recurso significa que as assinaturas dão suporte aos mesmos padrões descritos anteriormente nesta seção no que diz respeito a filas: consumidor concorrente, desacoplamento temporal, nivelamento de carga e balanceamento de carga.

Criar tópicos e assinaturas

A criação de um tópico é semelhante à criação de uma fila, conforme descrito na seção anterior. Você pode criar tópicos e assinaturas usando uma das seguintes opções:

Em seguida, envie mensagens para um tópico e receba mensagens de assinaturas usando clientes gravados em linguagens de programação, incluindo as seguintes:

Regras e ações

Em muitos cenários, as mensagens com características específicas precisam ser processadas de maneiras diferentes. Para habilitar esse processamento, você pode configurar assinaturas para localizar as mensagens com as propriedades desejáveis e, em seguida, realizar determinadas modificações nessas propriedades. Embora as assinaturas do Barramento de Serviço vejam todas as mensagens enviadas ao tópico, só é possível copiar um subconjunto dessas mensagens para a fila de assinatura virtual. Essa filtragem é realizada usando filtros de assinatura. Tais modificações são chamadas de ações de filtro. Quando uma assinatura é criada, você pode fornecer uma expressão de filtro que opere nas propriedades da mensagem. As propriedades podem ser ambas as propriedades do sistema (por exemplo, Rótulo) e propriedades de aplicativo personalizadas (por exemplo, StoreName). A expressão de filtro SQL é opcional nesse caso. Sem uma expressão de filtro SQL, qualquer ação de filtro definida em uma assinatura é feita em todas as mensagens dessa assinatura.

Para ver um exemplo em pleno funcionamento, confira a amostra de filtros de tópicos no GitHub. Para saber mais sobre filtros, consulte Filtros e ações de tópico.

Entidades do JMS (Serviço de Mensagens Java) 2.0

As entidades a seguir podem ser acessadas por meio da API do Java Message Service (JMS) 2.0.

  • Filas temporárias
  • Tópicos temporários
  • Assinaturas duráveis compartilhadas
  • Assinaturas duráveis não compartilhadas
  • Assinaturas não duráveis compartilhadas
  • Assinaturas não duráveis não compartilhadas

Saiba mais sobre as Entidades JMS 2.0 e sobre como usá-las.

Próximas etapas

Experimente os exemplos no idioma de sua escolha:

Para exemplos que usam as bibliotecas de clientes .NET e Java mais antigas, use os seguintes links:

Em 30 de setembro de 2026, desativaremos as bibliotecas do SDK do Barramento de Serviço do Azure WindowsAzure.ServiceBus, Microsoft.Azure.ServiceBus e com.microsoft.azure.servicebus, que não estão em conformidade com as diretrizes do SDK do Azure. Também encerraremos o suporte ao protocolo SBMP, portanto, ele não poderá mais ser usado após 30 de setembro de 2026. Antes dessa data, migre para as bibliotecas mais recentes do SDK do Azure, que oferecem atualizações de segurança críticas e funcionalidades aprimoradas.

Embora as bibliotecas mais antigas ainda poderão ser usadas após 30 de setembro de 2026, elas não receberão mais suporte e atualizações oficiais da Microsoft. Para obter mais informações, confira o anúncio de desativação do suporte.