Compensation azure service bus de la file d'attente d'un seul coup

Nous sommes à l'aide d'un bus de service de la file d'attente dans notre projet. Nous avons besoin d'une fonction pour supprimer tous les messages de la file d'attente lorsque l'administrateur choisit pour effacer la file d'attente. J'ai cherché sur le net mais impossible de trouver une fonction qui le fait à l'intérieur de la QueueClient classe.

Dois-je faire éclater tous les messages un par un, puis marquant leur complète pour effacer la file d'attente ou est-il un meilleur moyen?

QueueClient queueClient = _messagingFactory.CreateQueueClient(
                              queueName, ReceiveMode.PeekLock);

BrokeredMessage brokeredMessage = queueClient.Receive();

while (brokeredMessage != null )
{
    brokeredMessage.Complete();
    brokeredMessage = queueClient.Receive();
}
  • J'ai récemment fait face à la même question, et de supprimer et de recréer n'était pas une option, boucle fonctionne, mais c'est lent, cependant, l'utilisation de la PrefetchCount membre de la QueueClient vous pouvez facilement le lot de quelques milliers de messages en un seul voyage aller-retour, pour accélérer les choses énormément: msdn.microsoft.com/en-us/library/...
InformationsquelleAutor bhavesh lad | 2012-03-29
  1. 8

    À l'aide de la Receive() méthode à l'intérieur de la boucle while comme vous à cause de votre code à exécuter indéfiniment une fois la file d'attente est vide, comme le Receive() méthode sera en attente pour un autre message sur la file d'attente.

    Si vous voulez que cela s'exécuter automatiquement, essayez d'utiliser le Peek() méthode.

    Par exemple:

    while (queueClient.Peek() != null)
{
    var brokeredMessage = queueClient.Receive();
    brokeredMessage.Complete();
}

    Vous pouvez rendre cela plus simple de nouveau avec le ReceiveMode.ReceiveAndDelete comme cela a été mentionné par hocho.

    • Quelques questions: 1) Peek obtiendrez prévu, les futurs messages qui ne changera pas qui sera la cause de votre application pour se bloquer en attente pour les messages programmés. (2) Chaque Œil se déplace vers le prochain message, quel que soit son statut donc, si vous Abandonnez le premier message au lieu de le Remplir, le 2ème coup d'oeil obtiendrez le 2ème message, mais le 2ème Recevoir retraiter le 1er. Cela provoque coup d'oeil à décalage à partir de la Recevoir par un message et laisser un message non transformés, à la fin de votre file d'attente pour chaque abandonné message.
    • +1 @JustinJStark en testant ce code (comme il l'est, pas de traitement, juste de recevoir et complet) contre une file d'attente qui n'était pas de la réception de nouveaux messages, il a toujours pas réussi à complètement effacer la file d'attente. C'est seulement de compensation de 50 à 75% des messages. Je ne voudrais pas utiliser cette approche pour effacer une file d'attente.
    • Ce n'est pas le QueueClient de Microsoft.Azure.ServiceBus, est-il? Je vais avoir de la difficulté à trouver de Microsoft.ServiceBus.Messagerie qui a le QueueClient avec le CreateReceiver méthode...
    InformationsquelleAutor Scott Brady
  2. 5

    À l'aide de :

    • À la fois de l'approche (de @ScottBrady et @participant)
    • Et la MessageReceiver abstraction

    vous pouvez écrire une méthode qui vide un service de bus de la file d'attente ou un sujet/abonnement:

    MessageReceiver messageReceiver = ...
while (messageReceiver.Peek() != null)
{
    //Batch the receive operation
    var brokeredMessages = messageReceiver.ReceiveBatch(300);

    //Complete the messages
    var completeTasks = brokeredMessages.Select(m => Task.Run(() => m.Complete())).ToArray();

    //Wait for the tasks to complete. 
    Task.WaitAll(completeTasks);
}
    InformationsquelleAutor Thomas
  3. 3

    Je vais avoir de bons résultats en utilisant une combinaison de ReceiveAndDelete, PrefetchCount, ReceiveBatchAsync, et une vérité simple boucle plutôt qu'à l'aide de Peek. Exemple avec MessagingFactory ci-dessous:

    var receiverFactory = MessagingFactory.CreateFromConnectionString("ConnString");
var receiver = receiverFactory.CreateMessageReceiver("QName", ReceiveMode.ReceiveAndDelete);
receiver.PrefetchCount = 300;

bool loop = true;
while (loop)
{
    var messages = await receiver.ReceiveBatchAsync(300, TimeSpan.FromSeconds(1));
    loop = messages.Any();
}

    Ne requiert que la WindowsAzure.ServiceBus package Nuget.

    InformationsquelleAutor ElliotSchmelliot
  4. 2

    Pour Azure-ServiceBus des Files d'attente il y a un ReceiveBatch-méthode qui vous permet de recevoir un lot de n-les messages à la fois. Combiné avec ReceiveMode.ReceiveAndDelete vous pouvez effacer la file d'attente de manière plus efficace.

    Mise en garde Le nombre n de messages peuvent être retournés, mais il n'est pas garanti. Il y a aussi une limite pour le message-la taille des lots de 256K.

    InformationsquelleAutor participant
  5. 2

    Le moyen le plus rapide pour nettoyer un Azure ServiceBus de la File d'attente est d'un très court DefaultMessageTimeToLive, attendre quelques secondes, essayez de recevoir de la file d'attente de forcer la mise à jour, puis restaurer la première DefaultMessageTimeToLive.

    Vous pouvez le faire à partir du portail ou de code :

    var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
var queueDescription = _namespaceManager.GetQueue(queueName);
var queueClient = QueueClient.CreateFromConnectionString(connectionString, queueName, ReceiveMode.ReceiveAndDelete);

var dl = queueDescription.EnableDeadLetteringOnMessageExpiration;
var ttl = queueDescription.DefaultMessageTimeToLive;

queueDescription.EnableDeadLetteringOnMessageExpiration = false;
queueDescription.DefaultMessageTimeToLive = TimeSpan.FromSeconds(1);

Thread.Sleep(5000);
var dumy = queueClient.ReceiveBatch(200, TimeSpan.FromSeconds(1)).ToArray();

queueDescription.EnableDeadLetteringOnMessageExpiration = dl;
queueDescription.DefaultMessageTimeToLive = ttl;
    • Salut Florent, vous ne savez Pas si l'api a changé, mais j'ai juste essayé sur ma file d'attente et il y avait zéro changements. Même les messages en file d'attente avant et après.
    InformationsquelleAutor Florent Quienne
  6. 1

    Il y a une simple Clear() méthode pour effacer la totalité de la file d'attente si vous utilisez le WindowsAzure.De stockage de la bibliothèque de nuget. J'utilise le Microsoft.Windows.Azure.Queue classe à partir de la bibliothèque pour gérer la file d'attente. Sinon, vous pouvez accéder via leur API par leur documentation. Je ne sais pas combien de temps la méthode a été, dans l'Azur de la bibliothèque, et probablement il n'existait pas lorsque la question était à l'origine posée, mais le RESTE de l'API de tiges à partir de 2014 par cette Azure commentaires post

    Le plein .NET code pour effacer la file d'attente avec l'Azur de la bibliothèque est: 

    string connectionString = "YourAzureConnectionStringHere";
string queueName = "YourWebJobQueueName";
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(connectionString);

//Create the queue client, then get a reference to queue
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
queue = queueClient.GetQueueReference(GetQueueName(queueName));

//Clear the entire queue
queue.Clear();
    • La question d'origine était sur l'effacement d'une Azure Service Bus de la File d'attente, pas un simple Azure File d'attente.
    • Selon Microsoft, les deux Azure Service Bus de la File d'attente et d'Azur de la File d'attente de soutenir le .désactivez la fonction: feedback.azure.com/forums/217298-storage/suggestions/...
    • Pas dans le .NET de Base version du client (c'est à dire Microsoft.Azure.ServiceBus). Qui ne contient pas la méthode Clear ().
    InformationsquelleAutor jozolo