Envoi d'un événement à plusieurs sujets dans le bus de service

Question

Je souhaite envoyer un événement que je reçois du concentrateur d'événements à plusieurs sujets dans le bus de service. J'utilise le code suivant pour envoyer des événements à plusieurs sujets en utilisant foreach pour obtenir topicname. Puisqu'il s'agit d'une boucle foreach, je reçois de la latence. Y a-t-il une meilleure façon de le faire?

foreach (var topicname in GetTopics_ActiveList(payload).Result) 
        { 
         TopicClient Client = TopicClient.CreateFromConnectionString(connectionstring, topicname); 
         var payloadStream = new MemoryStream(Encoding.UTF8.GetBytes(payload)); 
         //var msg = JsonConvert.SerializeObject(payloadStream); 

         //BrokeredMessage message = new BrokeredMessage(payloadStream, true); 
         BrokeredMessage message = new BrokeredMessage(payloadStream); 
         Client.Send(message); 
        } 

Answer 1

Y at-il une meilleure façon de le faire.

Toujours. Pour un démarreur, vous pouvez mettre en cache vos clients plutôt que de créer à chaque fois. Deuxièmement, utilisez la version d'envoi asynchrone de la méthode Send (SendAsync), mais plutôt que d'en envoyer une à la fois, rassemblez les tâches et attendez avec Task.WhenAll. Et construisez votre message négocié une fois et clone it dans la boucle. Quelque chose entre les lignes de

var msg = BuildYourMessage(); 
var sendTasks = new List<Task>(); 
foreach (var topic in topicsCache) 
{ 
    sendTasks.Add(client.SendAsync(msg.Clone())); 
} 
Tasks.WhenAll(sendTasks).ConfigureAwait(false); 

La question que je vous est de savoir pourquoi l'envoyer aux sujets multiples plutôt qu'un seul sujet avec plusieurs abonnements? Peut-être que vous pourriez vous en sortir avec un seul envoi à ce sujet, en déléguant à Azure Service Bus pour effectuer la diffusion à tous les abonnements.