Me gustaría echar un vistazo a todos los mensajes de varias colas de Azure Service Bus. Después de eso, quiero filtrarlos después de queueName, insertDate y dar la oportunidad de realizar una búsqueda de texto completo en el cuerpo.
Actualmente, estoy usando el paquete Microsoft.Azure.ServiceBus para crear un ManagementClient para recopilar información de la cola y luego uso un MessageReceiver para ver los mensajes.
var managementClient = new ManagementClient(connectionString); var queue = await managementClient.GetQueueRuntimeInfoAsync(queueName); var count = queue.MessageCount; var receiver = new MessageReceiver(connectionString, queueName); var messagesOfQueue = new List<Message>(); for (var i = 1; i <= count; i++) { messagesOfQueue.Add(await receiver.PeekAsync()); }¿Hay una mejor manera de obtener todos los mensajes? ¿O incluso hay una manera de mirar solo los mensajes que se aplican a un filtro?
También intenté usar el método QueueClient.PeekBatch del paquete WindowsAzure.ServiceBus . Pero ese método no devolvió todos los mensajes aunque configuré el parámetro messageCount correcto.
Y luego también está el paquete Azure.Messaging.ServiceBus ... ¿Qué pasa con todos estos paquetes?
Entonces, ¿cuál de los paquetes debo usar y cuál es la mejor manera de ver los mensajes de las colas en función de algunos filtros?
La solución que estoy usando actualmente y que funciona como se esperaba se ve así:
var receiver = serviceBusClient.CreateReceiver(queueName); var messagesOfQueue = new List<ServiceBusReceivedMessage>(); var previousSequenceNumber = -1L; var sequenceNumber = 0L; do { var messageBatch = await receiver.PeekMessagesAsync(int.MaxValue, sequenceNumber); if (messageBatch.Count > 0) { sequenceNumber = messageBatch[^1].SequenceNumber; if (sequenceNumber == previousSequenceNumber) break; messagesOfQueue.AddRange(messageBatch); previousSequenceNumber = sequenceNumber; } else { break; } } while (true); Utiliza el paquete Azure.Messaging.ServiceBus .
Actualmente estás recibiendo un solo mensaje del receptor. Una mejor opción sería recibir mensajes por lotes usando PeekBatchAsync(Int64, Int32) de MessageReceiver .
Aquí está el código de muestra para hacerlo (aunque no probado):
var messagesOfQueue = new List<Message>(); var sequenceNumber = 0; var batchSize = 100;//number of messages to receive in a single call do { var messages = await receiver.PeekBatchAsync(sequenceNumber, batchSize); messagesOfQueue.AddRange(messages); if (messages.Count > 0) { sequenceNumber = messages[messages.Count-1].SequenceNumber; } else { break; } } while (true);La solución evita recibir el mensaje con el mismo SequenceNumber dos veces.
Los números de secuencia aumentan monótonamente. Y probé la mayoría de los casos, excepto pasar el número de secuencia a 0 cuando alcanza el valor máximo (Long.MaxValue).
using Azure.Messaging.ServiceBus; private static async Task<List<ServiceBusReceivedMessage>> PeekAllMessages(string serviceBusConnectionString, string queueName) { var client = new ServiceBusClient(serviceBusConnectionString); var receiver = client.CreateReceiver(queueName); var messages = new List<ServiceBusReceivedMessage>(); var batchSize = 20; var sequenceNumber = 0L; do { var messageBatch = await receiver.PeekMessagesAsync(batchSize, sequenceNumber); if (messageBatch.Count <= 0) { break; } // Increasing the SequenceNumber by 1 to avoid getting the message with the same SequenceNumber twice sequenceNumber = messageBatch[^1].SequenceNumber + 1; messages.AddRange(messageBatch); } while (true); return messages; }